Profiler graph

[dragonfireclient.git] / src / client.cpp

/*
Minetest-c55
Copyright (C) 2010 celeron55, Perttu Ahola <celeron55@gmail.com>

This program is free software; you can redistribute it and/or modify
it under the terms of the GNU General Public License as published by
the Free Software Foundation; either version 2 of the License, or
(at your option) any later version.

This program is distributed in the hope that it will be useful,
but WITHOUT ANY WARRANTY; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
GNU General Public License for more details.

You should have received a copy of the GNU General Public License along
with this program; if not, write to the Free Software Foundation, Inc.,
51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
*/

#include "client.h"
#include "utility.h"
#include <iostream>
#include "clientserver.h"
#include "jmutexautolock.h"
#include "main.h"
#include <sstream>
#include "porting.h"
#include "mapsector.h"
#include "mapblock_mesh.h"
#include "mapblock.h"
#include "settings.h"
#include "profiler.h"
#include "log.h"
#include "nodemetadata.h"
#include "nodedef.h"
#include "itemdef.h"
#include <IFileSystem.h>
#include "sha1.h"
#include "base64.h"
#include "clientmap.h"

static std::string getTextureCacheDir()
{
        return porting::path_user + DIR_DELIM + "cache" + DIR_DELIM + "textures";
}

struct TextureRequest
{
        std::string name;

        TextureRequest(const std::string &name_=""):
                name(name_)
        {}
};

/*
        QueuedMeshUpdate
*/

QueuedMeshUpdate::QueuedMeshUpdate():
        p(-1337,-1337,-1337),
        data(NULL),
        ack_block_to_server(false)
{
}

QueuedMeshUpdate::~QueuedMeshUpdate()
{
        if(data)
                delete data;
}

/*
        MeshUpdateQueue
*/
        
MeshUpdateQueue::MeshUpdateQueue()
{
        m_mutex.Init();
}

MeshUpdateQueue::~MeshUpdateQueue()
{
        JMutexAutoLock lock(m_mutex);

        for(std::vector<QueuedMeshUpdate*>::iterator
                        i = m_queue.begin();
                        i != m_queue.end(); i++)
        {
                QueuedMeshUpdate *q = *i;
                delete q;
        }
}

/*
        peer_id=0 adds with nobody to send to
*/
void MeshUpdateQueue::addBlock(v3s16 p, MeshMakeData *data, bool ack_block_to_server, bool urgent)
{
        DSTACK(__FUNCTION_NAME);

        assert(data);

        JMutexAutoLock lock(m_mutex);

        if(urgent)
                m_urgents.insert(p);

        /*
                Find if block is already in queue.
                If it is, update the data and quit.
        */
        for(std::vector<QueuedMeshUpdate*>::iterator
                        i = m_queue.begin();
                        i != m_queue.end(); i++)
        {
                QueuedMeshUpdate *q = *i;
                if(q->p == p)
                {
                        if(q->data)
                                delete q->data;
                        q->data = data;
                        if(ack_block_to_server)
                                q->ack_block_to_server = true;
                        return;
                }
        }
        
        /*
                Add the block
        */
        QueuedMeshUpdate *q = new QueuedMeshUpdate;
        q->p = p;
        q->data = data;
        q->ack_block_to_server = ack_block_to_server;
        m_queue.push_back(q);
}

// Returned pointer must be deleted
// Returns NULL if queue is empty
QueuedMeshUpdate * MeshUpdateQueue::pop()
{
        JMutexAutoLock lock(m_mutex);

        bool must_be_urgent = !m_urgents.empty();
        for(std::vector<QueuedMeshUpdate*>::iterator
                        i = m_queue.begin();
                        i != m_queue.end(); i++)
        {
                QueuedMeshUpdate *q = *i;
                if(must_be_urgent && m_urgents.count(q->p) == 0)
                        continue;
                m_queue.erase(i);
                m_urgents.erase(q->p);
                return q;
        }
        return NULL;
}

/*
        MeshUpdateThread
*/

void * MeshUpdateThread::Thread()
{
        ThreadStarted();

        log_register_thread("MeshUpdateThread");

        DSTACK(__FUNCTION_NAME);
        
        BEGIN_DEBUG_EXCEPTION_HANDLER

        while(getRun())
        {
                /*// Wait for output queue to flush.
                // Allow 2 in queue, this makes less frametime jitter.
                // Umm actually, there is no much difference
                if(m_queue_out.size() >= 2)
                {
                        sleep_ms(3);
                        continue;
                }*/

                QueuedMeshUpdate *q = m_queue_in.pop();
                if(q == NULL)
                {
                        sleep_ms(3);
                        continue;
                }

                ScopeProfiler sp(g_profiler, "Client: Mesh making");

                MapBlockMesh *mesh_new = new MapBlockMesh(q->data);
                if(mesh_new->getMesh()->getMeshBufferCount() == 0)
                {
                        delete mesh_new;
                        mesh_new = NULL;
                }

                MeshUpdateResult r;
                r.p = q->p;
                r.mesh = mesh_new;
                r.ack_block_to_server = q->ack_block_to_server;

                /*infostream<<"MeshUpdateThread: Processed "
                                <<"("<<q->p.X<<","<<q->p.Y<<","<<q->p.Z<<")"
                                <<std::endl;*/

                m_queue_out.push_back(r);

                delete q;
        }

        END_DEBUG_EXCEPTION_HANDLER(errorstream)

        return NULL;
}

Client::Client(
                IrrlichtDevice *device,
                const char *playername,
                std::string password,
                MapDrawControl &control,
                IWritableTextureSource *tsrc,
                IWritableItemDefManager *itemdef,
                IWritableNodeDefManager *nodedef
):
        m_tsrc(tsrc),
        m_itemdef(itemdef),
        m_nodedef(nodedef),
        m_mesh_update_thread(this),
        m_env(
                new ClientMap(this, this, control,
                        device->getSceneManager()->getRootSceneNode(),
                        device->getSceneManager(), 666),
                device->getSceneManager(),
                tsrc, this, device
        ),
        m_con(PROTOCOL_ID, 512, CONNECTION_TIMEOUT, this),
        m_device(device),
        m_server_ser_ver(SER_FMT_VER_INVALID),
        m_playeritem(0),
        m_inventory_updated(false),
        m_inventory_from_server(NULL),
        m_inventory_from_server_age(0.0),
        m_animation_time(0),
        m_crack_level(-1),
        m_crack_pos(0,0,0),
        m_map_seed(0),
        m_password(password),
        m_access_denied(false),
        m_texture_receive_progress(0),
        m_textures_received(false),
        m_itemdef_received(false),
        m_nodedef_received(false),
        m_time_of_day_set(false),
        m_last_time_of_day_f(-1),
        m_time_of_day_update_timer(0)
{
        m_packetcounter_timer = 0.0;
        //m_delete_unused_sectors_timer = 0.0;
        m_connection_reinit_timer = 0.0;
        m_avg_rtt_timer = 0.0;
        m_playerpos_send_timer = 0.0;
        m_ignore_damage_timer = 0.0;

        // Build main texture atlas, now that the GameDef exists (that is, us)
        if(g_settings->getBool("enable_texture_atlas"))
                m_tsrc->buildMainAtlas(this);
        else
                infostream<<"Not building texture atlas."<<std::endl;
        
        /*
                Add local player
        */
        {
                Player *player = new LocalPlayer(this);

                player->updateName(playername);

                m_env.addPlayer(player);
        }
}

Client::~Client()
{
        {
                //JMutexAutoLock conlock(m_con_mutex); //bulk comment-out
                m_con.Disconnect();
        }

        m_mesh_update_thread.setRun(false);
        while(m_mesh_update_thread.IsRunning())
                sleep_ms(100);

        delete m_inventory_from_server;
}

void Client::connect(Address address)
{
        DSTACK(__FUNCTION_NAME);
        //JMutexAutoLock lock(m_con_mutex); //bulk comment-out
        m_con.SetTimeoutMs(0);
        m_con.Connect(address);
}

bool Client::connectedAndInitialized()
{
        //JMutexAutoLock lock(m_con_mutex); //bulk comment-out

        if(m_con.Connected() == false)
                return false;
        
        if(m_server_ser_ver == SER_FMT_VER_INVALID)
                return false;
        
        return true;
}

void Client::step(float dtime)
{
        DSTACK(__FUNCTION_NAME);
        
        // Limit a bit
        if(dtime > 2.0)
                dtime = 2.0;
        
        if(m_ignore_damage_timer > dtime)
                m_ignore_damage_timer -= dtime;
        else
                m_ignore_damage_timer = 0.0;
        
        m_animation_time += dtime;
        if(m_animation_time > 60.0)
                m_animation_time -= 60.0;

        m_time_of_day_update_timer += dtime;
        
        //infostream<<"Client steps "<<dtime<<std::endl;

        {
                //TimeTaker timer("ReceiveAll()", m_device);
                // 0ms
                ReceiveAll();
        }
        
        {
                //TimeTaker timer("m_con_mutex + m_con.RunTimeouts()", m_device);
                // 0ms
                //JMutexAutoLock lock(m_con_mutex); //bulk comment-out
                m_con.RunTimeouts(dtime);
        }

        /*
                Packet counter
        */
        {
                float &counter = m_packetcounter_timer;
                counter -= dtime;
                if(counter <= 0.0)
                {
                        counter = 20.0;
                        
                        infostream<<"Client packetcounter (20s):"<<std::endl;
                        m_packetcounter.print(infostream);
                        m_packetcounter.clear();
                }
        }
        
        // Get connection status
        bool connected = connectedAndInitialized();

#if 0
        {
                /*
                        Delete unused sectors

                        NOTE: This jams the game for a while because deleting sectors
                              clear caches
                */
                
                float &counter = m_delete_unused_sectors_timer;
                counter -= dtime;
                if(counter <= 0.0)
                {
                        // 3 minute interval
                        //counter = 180.0;
                        counter = 60.0;

                        //JMutexAutoLock lock(m_env_mutex); //bulk comment-out

                        core::list<v3s16> deleted_blocks;

                        float delete_unused_sectors_timeout = 
                                g_settings->getFloat("client_delete_unused_sectors_timeout");
        
                        // Delete sector blocks
                        /*u32 num = m_env.getMap().unloadUnusedData
                                        (delete_unused_sectors_timeout,
                                        true, &deleted_blocks);*/
                        
                        // Delete whole sectors
                        m_env.getMap().unloadUnusedData
                                        (delete_unused_sectors_timeout,
                                        &deleted_blocks);

                        if(deleted_blocks.size() > 0)
                        {
                                /*infostream<<"Client: Deleted blocks of "<<num
                                                <<" unused sectors"<<std::endl;*/
                                /*infostream<<"Client: Deleted "<<num
                                                <<" unused sectors"<<std::endl;*/
                                
                                /*
                                        Send info to server
                                */

                                // Env is locked so con can be locked.
                                //JMutexAutoLock lock(m_con_mutex); //bulk comment-out
                                
                                core::list<v3s16>::Iterator i = deleted_blocks.begin();
                                core::list<v3s16> sendlist;
                                for(;;)
                                {
                                        if(sendlist.size() == 255 || i == deleted_blocks.end())
                                        {
                                                if(sendlist.size() == 0)
                                                        break;
                                                /*
                                                        [0] u16 command
                                                        [2] u8 count
                                                        [3] v3s16 pos_0
                                                        [3+6] v3s16 pos_1
                                                        ...
                                                */
                                                u32 replysize = 2+1+6*sendlist.size();
                                                SharedBuffer<u8> reply(replysize);
                                                writeU16(&reply[0], TOSERVER_DELETEDBLOCKS);
                                                reply[2] = sendlist.size();
                                                u32 k = 0;
                                                for(core::list<v3s16>::Iterator
                                                                j = sendlist.begin();
                                                                j != sendlist.end(); j++)
                                                {
                                                        writeV3S16(&reply[2+1+6*k], *j);
                                                        k++;
                                                }
                                                m_con.Send(PEER_ID_SERVER, 1, reply, true);

                                                if(i == deleted_blocks.end())
                                                        break;

                                                sendlist.clear();
                                        }

                                        sendlist.push_back(*i);
                                        i++;
                                }
                        }
                }
        }
#endif

        if(connected == false)
        {
                float &counter = m_connection_reinit_timer;
                counter -= dtime;
                if(counter <= 0.0)
                {
                        counter = 2.0;

                        //JMutexAutoLock envlock(m_env_mutex); //bulk comment-out
                        
                        Player *myplayer = m_env.getLocalPlayer();
                        assert(myplayer != NULL);
        
                        // Send TOSERVER_INIT
                        // [0] u16 TOSERVER_INIT
                        // [2] u8 SER_FMT_VER_HIGHEST
                        // [3] u8[20] player_name
                        // [23] u8[28] password (new in some version)
                        // [51] u16 client network protocol version (new in some version)
                        SharedBuffer<u8> data(2+1+PLAYERNAME_SIZE+PASSWORD_SIZE+2);
                        writeU16(&data[0], TOSERVER_INIT);
                        writeU8(&data[2], SER_FMT_VER_HIGHEST);

                        memset((char*)&data[3], 0, PLAYERNAME_SIZE);
                        snprintf((char*)&data[3], PLAYERNAME_SIZE, "%s", myplayer->getName());

                        /*infostream<<"Client: sending initial password hash: \""<<m_password<<"\""
                                        <<std::endl;*/

                        memset((char*)&data[23], 0, PASSWORD_SIZE);
                        snprintf((char*)&data[23], PASSWORD_SIZE, "%s", m_password.c_str());
                        
                        // This should be incremented in each version
                        writeU16(&data[51], PROTOCOL_VERSION);

                        // Send as unreliable
                        Send(0, data, false);
                }

                // Not connected, return
                return;
        }

        /*
                Do stuff if connected
        */
        
        /*
                Run Map's timers and unload unused data
        */
        const float map_timer_and_unload_dtime = 5.25;
        if(m_map_timer_and_unload_interval.step(dtime, map_timer_and_unload_dtime))
        {
                ScopeProfiler sp(g_profiler, "Client: map timer and unload");
                core::list<v3s16> deleted_blocks;
                m_env.getMap().timerUpdate(map_timer_and_unload_dtime,
                                g_settings->getFloat("client_unload_unused_data_timeout"),
                                &deleted_blocks);
                                
                /*if(deleted_blocks.size() > 0)
                        infostream<<"Client: Unloaded "<<deleted_blocks.size()
                                        <<" unused blocks"<<std::endl;*/
                        
                /*
                        Send info to server
                        NOTE: This loop is intentionally iterated the way it is.
                */

                core::list<v3s16>::Iterator i = deleted_blocks.begin();
                core::list<v3s16> sendlist;
                for(;;)
                {
                        if(sendlist.size() == 255 || i == deleted_blocks.end())
                        {
                                if(sendlist.size() == 0)
                                        break;
                                /*
                                        [0] u16 command
                                        [2] u8 count
                                        [3] v3s16 pos_0
                                        [3+6] v3s16 pos_1
                                        ...
                                */
                                u32 replysize = 2+1+6*sendlist.size();
                                SharedBuffer<u8> reply(replysize);
                                writeU16(&reply[0], TOSERVER_DELETEDBLOCKS);
                                reply[2] = sendlist.size();
                                u32 k = 0;
                                for(core::list<v3s16>::Iterator
                                                j = sendlist.begin();
                                                j != sendlist.end(); j++)
                                {
                                        writeV3S16(&reply[2+1+6*k], *j);
                                        k++;
                                }
                                m_con.Send(PEER_ID_SERVER, 1, reply, true);

                                if(i == deleted_blocks.end())
                                        break;

                                sendlist.clear();
                        }

                        sendlist.push_back(*i);
                        i++;
                }
        }

        /*
                Handle environment
        */
        {
                // 0ms
                //JMutexAutoLock lock(m_env_mutex); //bulk comment-out

                // Control local player (0ms)
                LocalPlayer *player = m_env.getLocalPlayer();
                assert(player != NULL);
                player->applyControl(dtime);

                //TimeTaker envtimer("env step", m_device);
                // Step environment
                m_env.step(dtime);
                
                /*
                        Get events
                */
                for(;;)
                {
                        ClientEnvEvent event = m_env.getClientEvent();
                        if(event.type == CEE_NONE)
                        {
                                break;
                        }
                        else if(event.type == CEE_PLAYER_DAMAGE)
                        {
                                if(m_ignore_damage_timer <= 0)
                                {
                                        u8 damage = event.player_damage.amount;
                                        
                                        if(event.player_damage.send_to_server)
                                                sendDamage(damage);

                                        // Add to ClientEvent queue
                                        ClientEvent event;
                                        event.type = CE_PLAYER_DAMAGE;
                                        event.player_damage.amount = damage;
                                        m_client_event_queue.push_back(event);
                                }
                        }
                }
        }
        
        /*
                Print some info
        */
        {
                float &counter = m_avg_rtt_timer;
                counter += dtime;
                if(counter >= 10)
                {
                        counter = 0.0;
                        //JMutexAutoLock lock(m_con_mutex); //bulk comment-out
                        // connectedAndInitialized() is true, peer exists.
                        float avg_rtt = m_con.GetPeerAvgRTT(PEER_ID_SERVER);
                        infostream<<"Client: avg_rtt="<<avg_rtt<<std::endl;
                }
        }

        /*
                Send player position to server
        */
        {
                float &counter = m_playerpos_send_timer;
                counter += dtime;
                if(counter >= 0.2)
                {
                        counter = 0.0;
                        sendPlayerPos();
                }
        }

        /*
                Replace updated meshes
        */
        {
                //JMutexAutoLock lock(m_env_mutex); //bulk comment-out

                //TimeTaker timer("** Processing mesh update result queue");
                // 0ms
                
                /*infostream<<"Mesh update result queue size is "
                                <<m_mesh_update_thread.m_queue_out.size()
                                <<std::endl;*/
                
                int num_processed_meshes = 0;
                while(m_mesh_update_thread.m_queue_out.size() > 0)
                {
                        num_processed_meshes++;
                        MeshUpdateResult r = m_mesh_update_thread.m_queue_out.pop_front();
                        MapBlock *block = m_env.getMap().getBlockNoCreateNoEx(r.p);
                        if(block)
                        {
                                //JMutexAutoLock lock(block->mesh_mutex);

                                // Delete the old mesh
                                if(block->mesh != NULL)
                                {
                                        // TODO: Remove hardware buffers of meshbuffers of block->mesh
                                        delete block->mesh;
                                        block->mesh = NULL;
                                }

                                // Replace with the new mesh
                                block->mesh = r.mesh;
                        }
                        if(r.ack_block_to_server)
                        {
                                /*infostream<<"Client: ACK block ("<<r.p.X<<","<<r.p.Y
                                                <<","<<r.p.Z<<")"<<std::endl;*/
                                /*
                                        Acknowledge block
                                */
                                /*
                                        [0] u16 command
                                        [2] u8 count
                                        [3] v3s16 pos_0
                                        [3+6] v3s16 pos_1
                                        ...
                                */
                                u32 replysize = 2+1+6;
                                SharedBuffer<u8> reply(replysize);
                                writeU16(&reply[0], TOSERVER_GOTBLOCKS);
                                reply[2] = 1;
                                writeV3S16(&reply[3], r.p);
                                // Send as reliable
                                m_con.Send(PEER_ID_SERVER, 1, reply, true);
                        }
                }
                if(num_processed_meshes > 0)
                        g_profiler->graphAdd("num_processed_meshes", num_processed_meshes);
        }

        /*
                If the server didn't update the inventory in a while, revert
                the local inventory (so the player notices the lag problem
                and knows something is wrong).
        */
        if(m_inventory_from_server)
        {
                float interval = 10.0;
                float count_before = floor(m_inventory_from_server_age / interval);

                m_inventory_from_server_age += dtime;

                float count_after = floor(m_inventory_from_server_age / interval);

                if(count_after != count_before)
                {
                        // Do this every <interval> seconds after TOCLIENT_INVENTORY
                        // Reset the locally changed inventory to the authoritative inventory
                        Player *player = m_env.getLocalPlayer();
                        player->inventory = *m_inventory_from_server;
                        m_inventory_updated = true;
                }
        }
}

// Virtual methods from con::PeerHandler
void Client::peerAdded(con::Peer *peer)
{
        infostream<<"Client::peerAdded(): peer->id="
                        <<peer->id<<std::endl;
}
void Client::deletingPeer(con::Peer *peer, bool timeout)
{
        infostream<<"Client::deletingPeer(): "
                        "Server Peer is getting deleted "
                        <<"(timeout="<<timeout<<")"<<std::endl;
}

void Client::ReceiveAll()
{
        DSTACK(__FUNCTION_NAME);
        u32 start_ms = porting::getTimeMs();
        for(;;)
        {
                // Limit time even if there would be huge amounts of data to
                // process
                if(porting::getTimeMs() > start_ms + 100)
                        break;
                
                try{
                        Receive();
                        g_profiler->graphAdd("client_received_packets", 1);
                }
                catch(con::NoIncomingDataException &e)
                {
                        break;
                }
                catch(con::InvalidIncomingDataException &e)
                {
                        infostream<<"Client::ReceiveAll(): "
                                        "InvalidIncomingDataException: what()="
                                        <<e.what()<<std::endl;
                }
        }
}

void Client::Receive()
{
        DSTACK(__FUNCTION_NAME);
        SharedBuffer<u8> data;
        u16 sender_peer_id;
        u32 datasize;
        {
                //TimeTaker t1("con mutex and receive", m_device);
                //JMutexAutoLock lock(m_con_mutex); //bulk comment-out
                datasize = m_con.Receive(sender_peer_id, data);
        }
        //TimeTaker t1("ProcessData", m_device);
        ProcessData(*data, datasize, sender_peer_id);
}

/*
        sender_peer_id given to this shall be quaranteed to be a valid peer
*/
void Client::ProcessData(u8 *data, u32 datasize, u16 sender_peer_id)
{
        DSTACK(__FUNCTION_NAME);

        // Ignore packets that don't even fit a command
        if(datasize < 2)
        {
                m_packetcounter.add(60000);
                return;
        }

        ToClientCommand command = (ToClientCommand)readU16(&data[0]);

        //infostream<<"Client: received command="<<command<<std::endl;
        m_packetcounter.add((u16)command);
        
        /*
                If this check is removed, be sure to change the queue
                system to know the ids
        */
        if(sender_peer_id != PEER_ID_SERVER)
        {
                infostream<<"Client::ProcessData(): Discarding data not "
                                "coming from server: peer_id="<<sender_peer_id
                                <<std::endl;
                return;
        }

        u8 ser_version = m_server_ser_ver;

        //infostream<<"Client received command="<<(int)command<<std::endl;

        if(command == TOCLIENT_INIT)
        {
                if(datasize < 3)
                        return;

                u8 deployed = data[2];

                infostream<<"Client: TOCLIENT_INIT received with "
                                "deployed="<<((int)deployed&0xff)<<std::endl;

                if(deployed < SER_FMT_VER_LOWEST
                                || deployed > SER_FMT_VER_HIGHEST)
                {
                        infostream<<"Client: TOCLIENT_INIT: Server sent "
                                        <<"unsupported ser_fmt_ver"<<std::endl;
                        return;
                }
                
                m_server_ser_ver = deployed;

                // Get player position
                v3s16 playerpos_s16(0, BS*2+BS*20, 0);
                if(datasize >= 2+1+6)
                        playerpos_s16 = readV3S16(&data[2+1]);
                v3f playerpos_f = intToFloat(playerpos_s16, BS) - v3f(0, BS/2, 0);

                { //envlock
                        //JMutexAutoLock envlock(m_env_mutex); //bulk comment-out
                        
                        // Set player position
                        Player *player = m_env.getLocalPlayer();
                        assert(player != NULL);
                        player->setPosition(playerpos_f);
                }
                
                if(datasize >= 2+1+6+8)
                {
                        // Get map seed
                        m_map_seed = readU64(&data[2+1+6]);
                        infostream<<"Client: received map seed: "<<m_map_seed<<std::endl;
                }
                
                // Reply to server
                u32 replysize = 2;
                SharedBuffer<u8> reply(replysize);
                writeU16(&reply[0], TOSERVER_INIT2);
                // Send as reliable
                m_con.Send(PEER_ID_SERVER, 1, reply, true);

                return;
        }

        if(command == TOCLIENT_ACCESS_DENIED)
        {
                // The server didn't like our password. Note, this needs
                // to be processed even if the serialisation format has
                // not been agreed yet, the same as TOCLIENT_INIT.
                m_access_denied = true;
                m_access_denied_reason = L"Unknown";
                if(datasize >= 4)
                {
                        std::string datastring((char*)&data[2], datasize-2);
                        std::istringstream is(datastring, std::ios_base::binary);
                        m_access_denied_reason = deSerializeWideString(is);
                }
                return;
        }

        if(ser_version == SER_FMT_VER_INVALID)
        {
                infostream<<"Client: Server serialization"
                                " format invalid or not initialized."
                                " Skipping incoming command="<<command<<std::endl;
                return;
        }
        
        // Just here to avoid putting the two if's together when
        // making some copypasta
        {}

        if(command == TOCLIENT_REMOVENODE)
        {
                if(datasize < 8)
                        return;
                v3s16 p;
                p.X = readS16(&data[2]);
                p.Y = readS16(&data[4]);
                p.Z = readS16(&data[6]);
                
                //TimeTaker t1("TOCLIENT_REMOVENODE");
                
                removeNode(p);
        }
        else if(command == TOCLIENT_ADDNODE)
        {
                if(datasize < 8 + MapNode::serializedLength(ser_version))
                        return;

                v3s16 p;
                p.X = readS16(&data[2]);
                p.Y = readS16(&data[4]);
                p.Z = readS16(&data[6]);
                
                //TimeTaker t1("TOCLIENT_ADDNODE");

                MapNode n;
                n.deSerialize(&data[8], ser_version);
                
                addNode(p, n);
        }
        else if(command == TOCLIENT_BLOCKDATA)
        {
                // Ignore too small packet
                if(datasize < 8)
                        return;
                        
                v3s16 p;
                p.X = readS16(&data[2]);
                p.Y = readS16(&data[4]);
                p.Z = readS16(&data[6]);
                
                /*infostream<<"Client: Thread: BLOCKDATA for ("
                                <<p.X<<","<<p.Y<<","<<p.Z<<")"<<std::endl;*/
                /*infostream<<"Client: Thread: BLOCKDATA for ("
                                <<p.X<<","<<p.Y<<","<<p.Z<<")"<<std::endl;*/
                
                std::string datastring((char*)&data[8], datasize-8);
                std::istringstream istr(datastring, std::ios_base::binary);
                
                MapSector *sector;
                MapBlock *block;
                
                v2s16 p2d(p.X, p.Z);
                sector = m_env.getMap().emergeSector(p2d);
                
                assert(sector->getPos() == p2d);

                //TimeTaker timer("MapBlock deSerialize");
                // 0ms
                
                block = sector->getBlockNoCreateNoEx(p.Y);
                if(block)
                {
                        /*
                                Update an existing block
                        */
                        //infostream<<"Updating"<<std::endl;
                        block->deSerialize(istr, ser_version, false);
                }
                else
                {
                        /*
                                Create a new block
                        */
                        //infostream<<"Creating new"<<std::endl;
                        block = new MapBlock(&m_env.getMap(), p, this);
                        block->deSerialize(istr, ser_version, false);
                        sector->insertBlock(block);
                }

#if 0
                /*
                        Acknowledge block
                */
                /*
                        [0] u16 command
                        [2] u8 count
                        [3] v3s16 pos_0
                        [3+6] v3s16 pos_1
                        ...
                */
                u32 replysize = 2+1+6;
                SharedBuffer<u8> reply(replysize);
                writeU16(&reply[0], TOSERVER_GOTBLOCKS);
                reply[2] = 1;
                writeV3S16(&reply[3], p);
                // Send as reliable
                m_con.Send(PEER_ID_SERVER, 1, reply, true);
#endif

                /*
                        Add it to mesh update queue and set it to be acknowledged after update.
                */
                //infostream<<"Adding mesh update task for received block"<<std::endl;
                addUpdateMeshTaskWithEdge(p, true);
        }
        else if(command == TOCLIENT_INVENTORY)
        {
                if(datasize < 3)
                        return;

                //TimeTaker t1("Parsing TOCLIENT_INVENTORY", m_device);

                { //envlock
                        //TimeTaker t2("mutex locking", m_device);
                        //JMutexAutoLock envlock(m_env_mutex); //bulk comment-out
                        //t2.stop();
                        
                        //TimeTaker t3("istringstream init", m_device);
                        std::string datastring((char*)&data[2], datasize-2);
                        std::istringstream is(datastring, std::ios_base::binary);
                        //t3.stop();
                        
                        //m_env.printPlayers(infostream);

                        //TimeTaker t4("player get", m_device);
                        Player *player = m_env.getLocalPlayer();
                        assert(player != NULL);
                        //t4.stop();

                        //TimeTaker t1("inventory.deSerialize()", m_device);
                        player->inventory.deSerialize(is);
                        //t1.stop();

                        m_inventory_updated = true;

                        delete m_inventory_from_server;
                        m_inventory_from_server = new Inventory(player->inventory);
                        m_inventory_from_server_age = 0.0;

                        //infostream<<"Client got player inventory:"<<std::endl;
                        //player->inventory.print(infostream);
                }
        }
        else if(command == TOCLIENT_TIME_OF_DAY)
        {
                if(datasize < 4)
                        return;
                
                u16 time_of_day = readU16(&data[2]);
                time_of_day = time_of_day % 24000;
                //infostream<<"Client: time_of_day="<<time_of_day<<std::endl;
                float time_speed = 0;
                if(datasize >= 2 + 2 + 4){
                        time_speed = readF1000(&data[4]);
                } else {
                        // Old message; try to approximate speed of time by ourselves
                        float time_of_day_f = (float)time_of_day / 24000.0;
                        float tod_diff_f = 0;
                        if(time_of_day_f < 0.2 && m_last_time_of_day_f > 0.8)
                                tod_diff_f = time_of_day_f - m_last_time_of_day_f + 1.0;
                        else
                                tod_diff_f = time_of_day_f - m_last_time_of_day_f;
                        m_last_time_of_day_f = time_of_day_f;
                        float time_diff = m_time_of_day_update_timer;
                        m_time_of_day_update_timer = 0;
                        if(m_time_of_day_set){
                                time_speed = 3600.0*24.0 * tod_diff_f / time_diff;
                                infostream<<"Client: Measured time_of_day speed (old format): "
                                                <<time_speed<<" tod_diff_f="<<tod_diff_f
                                                <<" time_diff="<<time_diff<<std::endl;
                        }
                }
                
                // Update environment
                m_env.setTimeOfDay(time_of_day);
                m_env.setTimeOfDaySpeed(time_speed);
                m_time_of_day_set = true;

                u32 dr = m_env.getDayNightRatio();
                verbosestream<<"Client: time_of_day="<<time_of_day
                                <<" time_speed="<<time_speed
                                <<" dr="<<dr<<std::endl;
        }
        else if(command == TOCLIENT_CHAT_MESSAGE)
        {
                /*
                        u16 command
                        u16 length
                        wstring message
                */
                u8 buf[6];
                std::string datastring((char*)&data[2], datasize-2);
                std::istringstream is(datastring, std::ios_base::binary);
                
                // Read stuff
                is.read((char*)buf, 2);
                u16 len = readU16(buf);
                
                std::wstring message;
                for(u16 i=0; i<len; i++)
                {
                        is.read((char*)buf, 2);
                        message += (wchar_t)readU16(buf);
                }

                /*infostream<<"Client received chat message: "
                                <<wide_to_narrow(message)<<std::endl;*/
                
                m_chat_queue.push_back(message);
        }
        else if(command == TOCLIENT_ACTIVE_OBJECT_REMOVE_ADD)
        {
                //if(g_settings->getBool("enable_experimental"))
                {
                        /*
                                u16 command
                                u16 count of removed objects
                                for all removed objects {
                                        u16 id
                                }
                                u16 count of added objects
                                for all added objects {
                                        u16 id
                                        u8 type
                                        u32 initialization data length
                                        string initialization data
                                }
                        */

                        char buf[6];
                        // Get all data except the command number
                        std::string datastring((char*)&data[2], datasize-2);
                        // Throw them in an istringstream
                        std::istringstream is(datastring, std::ios_base::binary);

                        // Read stuff
                        
                        // Read removed objects
                        is.read(buf, 2);
                        u16 removed_count = readU16((u8*)buf);
                        for(u16 i=0; i<removed_count; i++)
                        {
                                is.read(buf, 2);
                                u16 id = readU16((u8*)buf);
                                // Remove it
                                {
                                        //JMutexAutoLock envlock(m_env_mutex); //bulk comment-out
                                        m_env.removeActiveObject(id);
                                }
                        }
                        
                        // Read added objects
                        is.read(buf, 2);
                        u16 added_count = readU16((u8*)buf);
                        for(u16 i=0; i<added_count; i++)
                        {
                                is.read(buf, 2);
                                u16 id = readU16((u8*)buf);
                                is.read(buf, 1);
                                u8 type = readU8((u8*)buf);
                                std::string data = deSerializeLongString(is);
                                // Add it
                                {
                                        //JMutexAutoLock envlock(m_env_mutex); //bulk comment-out
                                        m_env.addActiveObject(id, type, data);
                                }
                        }
                }
        }
        else if(command == TOCLIENT_ACTIVE_OBJECT_MESSAGES)
        {
                //if(g_settings->getBool("enable_experimental"))
                {
                        /*
                                u16 command
                                for all objects
                                {
                                        u16 id
                                        u16 message length
                                        string message
                                }
                        */
                        char buf[6];
                        // Get all data except the command number
                        std::string datastring((char*)&data[2], datasize-2);
                        // Throw them in an istringstream
                        std::istringstream is(datastring, std::ios_base::binary);
                        
                        while(is.eof() == false)
                        {
                                // Read stuff
                                is.read(buf, 2);
                                u16 id = readU16((u8*)buf);
                                if(is.eof())
                                        break;
                                is.read(buf, 2);
                                u16 message_size = readU16((u8*)buf);
                                std::string message;
                                message.reserve(message_size);
                                for(u16 i=0; i<message_size; i++)
                                {
                                        is.read(buf, 1);
                                        message.append(buf, 1);
                                }
                                // Pass on to the environment
                                {
                                        //JMutexAutoLock envlock(m_env_mutex); //bulk comment-out
                                        m_env.processActiveObjectMessage(id, message);
                                }
                        }
                }
        }
        else if(command == TOCLIENT_HP)
        {
                std::string datastring((char*)&data[2], datasize-2);
                std::istringstream is(datastring, std::ios_base::binary);
                Player *player = m_env.getLocalPlayer();
                assert(player != NULL);
                u8 oldhp = player->hp;
                u8 hp = readU8(is);
                player->hp = hp;

                if(hp < oldhp)
                {
                        // Add to ClientEvent queue
                        ClientEvent event;
                        event.type = CE_PLAYER_DAMAGE;
                        event.player_damage.amount = oldhp - hp;
                        m_client_event_queue.push_back(event);
                }
        }
        else if(command == TOCLIENT_MOVE_PLAYER)
        {
                std::string datastring((char*)&data[2], datasize-2);
                std::istringstream is(datastring, std::ios_base::binary);
                Player *player = m_env.getLocalPlayer();
                assert(player != NULL);
                v3f pos = readV3F1000(is);
                f32 pitch = readF1000(is);
                f32 yaw = readF1000(is);
                player->setPosition(pos);
                /*player->setPitch(pitch);
                player->setYaw(yaw);*/

                infostream<<"Client got TOCLIENT_MOVE_PLAYER"
                                <<" pos=("<<pos.X<<","<<pos.Y<<","<<pos.Z<<")"
                                <<" pitch="<<pitch
                                <<" yaw="<<yaw
                                <<std::endl;

                /*
                        Add to ClientEvent queue.
                        This has to be sent to the main program because otherwise
                        it would just force the pitch and yaw values to whatever
                        the camera points to.
                */
                ClientEvent event;
                event.type = CE_PLAYER_FORCE_MOVE;
                event.player_force_move.pitch = pitch;
                event.player_force_move.yaw = yaw;
                m_client_event_queue.push_back(event);

                // Ignore damage for a few seconds, so that the player doesn't
                // get damage from falling on ground
                m_ignore_damage_timer = 3.0;
        }
        else if(command == TOCLIENT_PLAYERITEM)
        {
                std::string datastring((char*)&data[2], datasize-2);
                std::istringstream is(datastring, std::ios_base::binary);

                u16 count = readU16(is);

                for (u16 i = 0; i < count; ++i) {
                        u16 peer_id = readU16(is);
                        Player *player = m_env.getPlayer(peer_id);

                        if (player == NULL)
                        {
                                infostream<<"Client: ignoring player item "
                                        << deSerializeString(is)
                                        << " for non-existing peer id " << peer_id
                                        << std::endl;
                                continue;
                        } else if (player->isLocal()) {
                                infostream<<"Client: ignoring player item "
                                        << deSerializeString(is)
                                        << " for local player" << std::endl;
                                continue;
                        } else {
                                InventoryList *inv = player->inventory.getList("main");
                                std::string itemstring(deSerializeString(is));
                                ItemStack item;
                                item.deSerialize(itemstring, m_itemdef);
                                inv->changeItem(0, item);
                                if(itemstring.empty())
                                {
                                        infostream<<"Client: empty player item for peer "
                                                <<peer_id<<std::endl;
                                }
                                else
                                {
                                        infostream<<"Client: player item for peer "
                                                <<peer_id<<": "<<itemstring<<std::endl;
                                }
                        }
                }
        }
        else if(command == TOCLIENT_DEATHSCREEN)
        {
                std::string datastring((char*)&data[2], datasize-2);
                std::istringstream is(datastring, std::ios_base::binary);
                
                bool set_camera_point_target = readU8(is);
                v3f camera_point_target = readV3F1000(is);
                
                ClientEvent event;
                event.type = CE_DEATHSCREEN;
                event.deathscreen.set_camera_point_target = set_camera_point_target;
                event.deathscreen.camera_point_target_x = camera_point_target.X;
                event.deathscreen.camera_point_target_y = camera_point_target.Y;
                event.deathscreen.camera_point_target_z = camera_point_target.Z;
                m_client_event_queue.push_back(event);
        }
        else if(command == TOCLIENT_ANNOUNCE_TEXTURES)
        {
                io::IFileSystem *irrfs = m_device->getFileSystem();
                video::IVideoDriver *vdrv = m_device->getVideoDriver();

                std::string datastring((char*)&data[2], datasize-2);
                std::istringstream is(datastring, std::ios_base::binary);

                // Mesh update thread must be stopped while
                // updating content definitions
                assert(!m_mesh_update_thread.IsRunning());

                int num_textures = readU16(is);

                core::list<TextureRequest> texture_requests;

                for(int i=0; i<num_textures; i++){

                        bool texture_found = false;

                        //read texture from cache
                        std::string name = deSerializeString(is);
                        std::string sha1_texture = deSerializeString(is);
                        
                        // if name contains illegal characters, ignore the texture
                        if(!string_allowed(name, TEXTURENAME_ALLOWED_CHARS)){
                                errorstream<<"Client: ignoring illegal texture name "
                                                <<"sent by server: \""<<name<<"\""<<std::endl;
                                continue;
                        }

                        std::string tpath = getTextureCacheDir() + DIR_DELIM + name;
                        // Read data
                        std::ifstream fis(tpath.c_str(), std::ios_base::binary);


                        if(fis.good() == false){
                                infostream<<"Client::Texture not found in cache: "
                                                <<name << " expected it at: "<<tpath<<std::endl;
                        }
                        else
                        {
                                std::ostringstream tmp_os(std::ios_base::binary);
                                bool bad = false;
                                for(;;){
                                        char buf[1024];
                                        fis.read(buf, 1024);
                                        std::streamsize len = fis.gcount();
                                        tmp_os.write(buf, len);
                                        if(fis.eof())
                                                break;
                                        if(!fis.good()){
                                                bad = true;
                                                break;
                                        }
                                }
                                if(bad){
                                        infostream<<"Client: Failed to read texture from cache\""
                                                        <<name<<"\""<<std::endl;
                                }
                                else {

                                        SHA1 sha1;
                                        sha1.addBytes(tmp_os.str().c_str(), tmp_os.str().length());

                                        unsigned char *digest = sha1.getDigest();

                                        std::string digest_string = base64_encode(digest, 20);

                                        if (digest_string == sha1_texture) {
                                                // Silly irrlicht's const-incorrectness
                                                Buffer<char> data_rw(tmp_os.str().c_str(), tmp_os.str().size());

                                                // Create an irrlicht memory file
                                                io::IReadFile *rfile = irrfs->createMemoryReadFile(
                                                                *data_rw,  tmp_os.str().size(), "_tempreadfile");
                                                assert(rfile);
                                                // Read image
                                                video::IImage *img = vdrv->createImageFromFile(rfile);
                                                if(!img){
                                                        infostream<<"Client: Cannot create image from data of "
                                                                        <<"received texture \""<<name<<"\""<<std::endl;
                                                        rfile->drop();
                                                }
                                                else {
                                                        m_tsrc->insertSourceImage(name, img);
                                                        img->drop();
                                                        rfile->drop();

                                                        texture_found = true;
                                                }
                                        }
                                        else {
                                                infostream<<"Client::Texture cached sha1 hash not matching server hash: "
                                                                <<name << ": server ->"<<sha1_texture <<" client -> "<<digest_string<<std::endl;
                                        }

                                        free(digest);
                                }
                        }

                        //add texture request
                        if (!texture_found) {
                                infostream<<"Client: Adding texture to request list: \""
                                                <<name<<"\""<<std::endl;
                                texture_requests.push_back(TextureRequest(name));
                        }

                }

                ClientEvent event;
                event.type = CE_TEXTURES_UPDATED;
                m_client_event_queue.push_back(event);


                //send Texture request
                /*
                                u16 command
                                u16 number of textures requested
                                for each texture {
                                        u16 length of name
                                        string name
                                }
                 */
                std::ostringstream os(std::ios_base::binary);
                u8 buf[12];


                // Write command
                writeU16(buf, TOSERVER_REQUEST_TEXTURES);
                os.write((char*)buf, 2);

                writeU16(buf,texture_requests.size());
                os.write((char*)buf, 2);


                for(core::list<TextureRequest>::Iterator i = texture_requests.begin();
                                i != texture_requests.end(); i++) {
                        os<<serializeString(i->name);
                }

                // Make data buffer
                std::string s = os.str();
                SharedBuffer<u8> data((u8*)s.c_str(), s.size());
                // Send as reliable
                Send(0, data, true);
                infostream<<"Client: Sending request list to server " <<std::endl;
        }
        else if(command == TOCLIENT_TEXTURES)
        {
                io::IFileSystem *irrfs = m_device->getFileSystem();
                video::IVideoDriver *vdrv = m_device->getVideoDriver();

                std::string datastring((char*)&data[2], datasize-2);
                std::istringstream is(datastring, std::ios_base::binary);

                // Mesh update thread must be stopped while
                // updating content definitions
                assert(!m_mesh_update_thread.IsRunning());

                /*
                        u16 command
                        u16 total number of texture bunches
                        u16 index of this bunch
                        u32 number of textures in this bunch
                        for each texture {
                                u16 length of name
                                string name
                                u32 length of data
                                data
                        }
                */
                int num_bunches = readU16(is);
                int bunch_i = readU16(is);
                m_texture_receive_progress = (float)bunch_i / (float)(num_bunches - 1);
                if(bunch_i == num_bunches - 1)
                        m_textures_received = true;
                int num_textures = readU32(is);
                infostream<<"Client: Received textures: bunch "<<bunch_i<<"/"
                                <<num_bunches<<" textures="<<num_textures
                                <<" size="<<datasize<<std::endl;
                for(int i=0; i<num_textures; i++){
                        std::string name = deSerializeString(is);
                        std::string data = deSerializeLongString(is);

                        // if name contains illegal characters, ignore the texture
                        if(!string_allowed(name, TEXTURENAME_ALLOWED_CHARS)){
                                errorstream<<"Client: ignoring illegal texture name "
                                                <<"sent by server: \""<<name<<"\""<<std::endl;
                                continue;
                        }

                        // Silly irrlicht's const-incorrectness
                        Buffer<char> data_rw(data.c_str(), data.size());
                        // Create an irrlicht memory file
                        io::IReadFile *rfile = irrfs->createMemoryReadFile(
                                        *data_rw, data.size(), "_tempreadfile");
                        assert(rfile);
                        // Read image
                        video::IImage *img = vdrv->createImageFromFile(rfile);
                        if(!img){
                                errorstream<<"Client: Cannot create image from data of "
                                                <<"received texture \""<<name<<"\""<<std::endl;
                                rfile->drop();
                                continue;
                        }

                        fs::CreateAllDirs(getTextureCacheDir());

                        std::string filename = getTextureCacheDir() + DIR_DELIM + name;
                        std::ofstream outfile(filename.c_str(), std::ios_base::binary | std::ios_base::trunc);

                        if (outfile.good()) {
                                outfile.write(data.c_str(),data.length());
                                outfile.close();
                        }
                        else {
                                errorstream<<"Client: Unable to open cached texture file "<< filename <<std::endl;
                        }

                        m_tsrc->insertSourceImage(name, img);
                        img->drop();
                        rfile->drop();
                }

                ClientEvent event;
                event.type = CE_TEXTURES_UPDATED;
                m_client_event_queue.push_back(event);
        }
        else if(command == TOCLIENT_TOOLDEF)
        {
                infostream<<"Client: WARNING: Ignoring TOCLIENT_TOOLDEF"<<std::endl;
        }
        else if(command == TOCLIENT_NODEDEF)
        {
                infostream<<"Client: Received node definitions: packet size: "
                                <<datasize<<std::endl;

                // Mesh update thread must be stopped while
                // updating content definitions
                assert(!m_mesh_update_thread.IsRunning());

                // Decompress node definitions
                std::string datastring((char*)&data[2], datasize-2);
                std::istringstream is(datastring, std::ios_base::binary);
                std::istringstream tmp_is(deSerializeLongString(is), std::ios::binary);
                std::ostringstream tmp_os;
                decompressZlib(tmp_is, tmp_os);

                // Deserialize node definitions
                std::istringstream tmp_is2(tmp_os.str());
                m_nodedef->deSerialize(tmp_is2);
                m_nodedef_received = true;
        }
        else if(command == TOCLIENT_CRAFTITEMDEF)
        {
                infostream<<"Client: WARNING: Ignoring TOCLIENT_CRAFTITEMDEF"<<std::endl;
        }
        else if(command == TOCLIENT_ITEMDEF)
        {
                infostream<<"Client: Received item definitions: packet size: "
                                <<datasize<<std::endl;

                // Mesh update thread must be stopped while
                // updating content definitions
                assert(!m_mesh_update_thread.IsRunning());

                // Decompress item definitions
                std::string datastring((char*)&data[2], datasize-2);
                std::istringstream is(datastring, std::ios_base::binary);
                std::istringstream tmp_is(deSerializeLongString(is), std::ios::binary);
                std::ostringstream tmp_os;
                decompressZlib(tmp_is, tmp_os);

                // Deserialize node definitions
                std::istringstream tmp_is2(tmp_os.str());
                m_itemdef->deSerialize(tmp_is2);
                m_itemdef_received = true;
        }
        else
        {
                infostream<<"Client: Ignoring unknown command "
                                <<command<<std::endl;
        }
}

void Client::Send(u16 channelnum, SharedBuffer<u8> data, bool reliable)
{
        //JMutexAutoLock lock(m_con_mutex); //bulk comment-out
        m_con.Send(PEER_ID_SERVER, channelnum, data, reliable);
}

void Client::interact(u8 action, const PointedThing& pointed)
{
        if(connectedAndInitialized() == false){
                infostream<<"Client::interact() "
                                "cancelled (not connected)"
                                <<std::endl;
                return;
        }

        std::ostringstream os(std::ios_base::binary);

        /*
                [0] u16 command
                [2] u8 action
                [3] u16 item
                [5] u32 length of the next item
                [9] serialized PointedThing
                actions:
                0: start digging (from undersurface) or use
                1: stop digging (all parameters ignored)
                2: digging completed
                3: place block or item (to abovesurface)
                4: use item
        */
        writeU16(os, TOSERVER_INTERACT);
        writeU8(os, action);
        writeU16(os, getPlayerItem());
        std::ostringstream tmp_os(std::ios::binary);
        pointed.serialize(tmp_os);
        os<<serializeLongString(tmp_os.str());

        std::string s = os.str();
        SharedBuffer<u8> data((u8*)s.c_str(), s.size());

        // Send as reliable
        Send(0, data, true);
}

void Client::sendSignNodeText(v3s16 p, std::string text)
{
        /*
                u16 command
                v3s16 p
                u16 textlen
                textdata
        */
        std::ostringstream os(std::ios_base::binary);
        u8 buf[12];
        
        // Write command
        writeU16(buf, TOSERVER_SIGNNODETEXT);
        os.write((char*)buf, 2);
        
        // Write p
        writeV3S16(buf, p);
        os.write((char*)buf, 6);

        u16 textlen = text.size();
        // Write text length
        writeS16(buf, textlen);
        os.write((char*)buf, 2);

        // Write text
        os.write((char*)text.c_str(), textlen);
        
        // Make data buffer
        std::string s = os.str();
        SharedBuffer<u8> data((u8*)s.c_str(), s.size());
        // Send as reliable
        Send(0, data, true);
}
        
void Client::sendInventoryAction(InventoryAction *a)
{
        std::ostringstream os(std::ios_base::binary);
        u8 buf[12];
        
        // Write command
        writeU16(buf, TOSERVER_INVENTORY_ACTION);
        os.write((char*)buf, 2);

        a->serialize(os);
        
        // Make data buffer
        std::string s = os.str();
        SharedBuffer<u8> data((u8*)s.c_str(), s.size());
        // Send as reliable
        Send(0, data, true);
}

void Client::sendChatMessage(const std::wstring &message)
{
        std::ostringstream os(std::ios_base::binary);
        u8 buf[12];
        
        // Write command
        writeU16(buf, TOSERVER_CHAT_MESSAGE);
        os.write((char*)buf, 2);
        
        // Write length
        writeU16(buf, message.size());
        os.write((char*)buf, 2);
        
        // Write string
        for(u32 i=0; i<message.size(); i++)
        {
                u16 w = message[i];
                writeU16(buf, w);
                os.write((char*)buf, 2);
        }
        
        // Make data buffer
        std::string s = os.str();
        SharedBuffer<u8> data((u8*)s.c_str(), s.size());
        // Send as reliable
        Send(0, data, true);
}

void Client::sendChangePassword(const std::wstring oldpassword,
                const std::wstring newpassword)
{
        Player *player = m_env.getLocalPlayer();
        if(player == NULL)
                return;

        std::string playername = player->getName();
        std::string oldpwd = translatePassword(playername, oldpassword);
        std::string newpwd = translatePassword(playername, newpassword);

        std::ostringstream os(std::ios_base::binary);
        u8 buf[2+PASSWORD_SIZE*2];
        /*
                [0] u16 TOSERVER_PASSWORD
                [2] u8[28] old password
                [30] u8[28] new password
        */

        writeU16(buf, TOSERVER_PASSWORD);
        for(u32 i=0;i<PASSWORD_SIZE-1;i++)
        {
                buf[2+i] = i<oldpwd.length()?oldpwd[i]:0;
                buf[30+i] = i<newpwd.length()?newpwd[i]:0;
        }
        buf[2+PASSWORD_SIZE-1] = 0;
        buf[30+PASSWORD_SIZE-1] = 0;
        os.write((char*)buf, 2+PASSWORD_SIZE*2);

        // Make data buffer
        std::string s = os.str();
        SharedBuffer<u8> data((u8*)s.c_str(), s.size());
        // Send as reliable
        Send(0, data, true);
}


void Client::sendDamage(u8 damage)
{
        DSTACK(__FUNCTION_NAME);
        std::ostringstream os(std::ios_base::binary);

        writeU16(os, TOSERVER_DAMAGE);
        writeU8(os, damage);

        // Make data buffer
        std::string s = os.str();
        SharedBuffer<u8> data((u8*)s.c_str(), s.size());
        // Send as reliable
        Send(0, data, true);
}

void Client::sendRespawn()
{
        DSTACK(__FUNCTION_NAME);
        std::ostringstream os(std::ios_base::binary);

        writeU16(os, TOSERVER_RESPAWN);

        // Make data buffer
        std::string s = os.str();
        SharedBuffer<u8> data((u8*)s.c_str(), s.size());
        // Send as reliable
        Send(0, data, true);
}

void Client::sendPlayerPos()
{
        //JMutexAutoLock envlock(m_env_mutex); //bulk comment-out
        
        Player *myplayer = m_env.getLocalPlayer();
        if(myplayer == NULL)
                return;
        
        u16 our_peer_id;
        {
                //JMutexAutoLock lock(m_con_mutex); //bulk comment-out
                our_peer_id = m_con.GetPeerID();
        }
        
        // Set peer id if not set already
        if(myplayer->peer_id == PEER_ID_INEXISTENT)
                myplayer->peer_id = our_peer_id;
        // Check that an existing peer_id is the same as the connection's
        assert(myplayer->peer_id == our_peer_id);
        
        v3f pf = myplayer->getPosition();
        v3s32 position(pf.X*100, pf.Y*100, pf.Z*100);
        v3f sf = myplayer->getSpeed();
        v3s32 speed(sf.X*100, sf.Y*100, sf.Z*100);
        s32 pitch = myplayer->getPitch() * 100;
        s32 yaw = myplayer->getYaw() * 100;

        /*
                Format:
                [0] u16 command
                [2] v3s32 position*100
                [2+12] v3s32 speed*100
                [2+12+12] s32 pitch*100
                [2+12+12+4] s32 yaw*100
        */

        SharedBuffer<u8> data(2+12+12+4+4);
        writeU16(&data[0], TOSERVER_PLAYERPOS);
        writeV3S32(&data[2], position);
        writeV3S32(&data[2+12], speed);
        writeS32(&data[2+12+12], pitch);
        writeS32(&data[2+12+12+4], yaw);

        // Send as unreliable
        Send(0, data, false);
}

void Client::sendPlayerItem(u16 item)
{
        Player *myplayer = m_env.getLocalPlayer();
        if(myplayer == NULL)
                return;

        u16 our_peer_id = m_con.GetPeerID();

        // Set peer id if not set already
        if(myplayer->peer_id == PEER_ID_INEXISTENT)
                myplayer->peer_id = our_peer_id;
        // Check that an existing peer_id is the same as the connection's
        assert(myplayer->peer_id == our_peer_id);

        SharedBuffer<u8> data(2+2);
        writeU16(&data[0], TOSERVER_PLAYERITEM);
        writeU16(&data[2], item);

        // Send as reliable
        Send(0, data, true);
}

void Client::removeNode(v3s16 p)
{
        core::map<v3s16, MapBlock*> modified_blocks;

        try
        {
                //TimeTaker t("removeNodeAndUpdate", m_device);
                m_env.getMap().removeNodeAndUpdate(p, modified_blocks);
        }
        catch(InvalidPositionException &e)
        {
        }
        
        // add urgent task to update the modified node
        addUpdateMeshTaskForNode(p, false, true);

        for(core::map<v3s16, MapBlock * >::Iterator
                        i = modified_blocks.getIterator();
                        i.atEnd() == false; i++)
        {
                v3s16 p = i.getNode()->getKey();
                addUpdateMeshTaskWithEdge(p);
        }
}

void Client::addNode(v3s16 p, MapNode n)
{
        TimeTaker timer1("Client::addNode()");

        core::map<v3s16, MapBlock*> modified_blocks;

        try
        {
                //TimeTaker timer3("Client::addNode(): addNodeAndUpdate");
                m_env.getMap().addNodeAndUpdate(p, n, modified_blocks);
        }
        catch(InvalidPositionException &e)
        {}
        
        for(core::map<v3s16, MapBlock * >::Iterator
                        i = modified_blocks.getIterator();
                        i.atEnd() == false; i++)
        {
                v3s16 p = i.getNode()->getKey();
                addUpdateMeshTaskWithEdge(p);
        }
}
        
void Client::setPlayerControl(PlayerControl &control)
{
        //JMutexAutoLock envlock(m_env_mutex); //bulk comment-out
        LocalPlayer *player = m_env.getLocalPlayer();
        assert(player != NULL);
        player->control = control;
}

void Client::selectPlayerItem(u16 item)
{
        //JMutexAutoLock envlock(m_env_mutex); //bulk comment-out
        m_playeritem = item;
        m_inventory_updated = true;
        sendPlayerItem(item);
}

// Returns true if the inventory of the local player has been
// updated from the server. If it is true, it is set to false.
bool Client::getLocalInventoryUpdated()
{
        // m_inventory_updated is behind envlock
        //JMutexAutoLock envlock(m_env_mutex); //bulk comment-out
        bool updated = m_inventory_updated;
        m_inventory_updated = false;
        return updated;
}

// Copies the inventory of the local player to parameter
void Client::getLocalInventory(Inventory &dst)
{
        //JMutexAutoLock envlock(m_env_mutex); //bulk comment-out
        Player *player = m_env.getLocalPlayer();
        assert(player != NULL);
        dst = player->inventory;
}

Inventory* Client::getInventory(const InventoryLocation &loc)
{
        switch(loc.type){
        case InventoryLocation::UNDEFINED:
        {}
        break;
        case InventoryLocation::CURRENT_PLAYER:
        {
                Player *player = m_env.getLocalPlayer();
                assert(player != NULL);
                return &player->inventory;
        }
        break;
        case InventoryLocation::PLAYER:
        {
                Player *player = m_env.getPlayer(loc.name.c_str());
                if(!player)
                        return NULL;
                return &player->inventory;
        }
        break;
        case InventoryLocation::NODEMETA:
        {
                NodeMetadata *meta = m_env.getMap().getNodeMetadata(loc.p);
                if(!meta)
                        return NULL;
                return meta->getInventory();
        }
        break;
        default:
                assert(0);
        }
        return NULL;
}
void Client::inventoryAction(InventoryAction *a)
{
        /*
                Send it to the server
        */
        sendInventoryAction(a);

        /*
                Predict some local inventory changes
        */
        a->clientApply(this, this);
}

ClientActiveObject * Client::getSelectedActiveObject(
                f32 max_d,
                v3f from_pos_f_on_map,
                core::line3d<f32> shootline_on_map
        )
{
        core::array<DistanceSortedActiveObject> objects;

        m_env.getActiveObjects(from_pos_f_on_map, max_d, objects);

        //infostream<<"Collected "<<objects.size()<<" nearby objects"<<std::endl;
        
        // Sort them.
        // After this, the closest object is the first in the array.
        objects.sort();

        for(u32 i=0; i<objects.size(); i++)
        {
                ClientActiveObject *obj = objects[i].obj;
                
                core::aabbox3d<f32> *selection_box = obj->getSelectionBox();
                if(selection_box == NULL)
                        continue;

                v3f pos = obj->getPosition();

                core::aabbox3d<f32> offsetted_box(
                                selection_box->MinEdge + pos,
                                selection_box->MaxEdge + pos
                );

                if(offsetted_box.intersectsWithLine(shootline_on_map))
                {
                        //infostream<<"Returning selected object"<<std::endl;
                        return obj;
                }
        }

        //infostream<<"No object selected; returning NULL."<<std::endl;
        return NULL;
}

void Client::printDebugInfo(std::ostream &os)
{
        //JMutexAutoLock lock1(m_fetchblock_mutex);
        /*JMutexAutoLock lock2(m_incoming_queue_mutex);

        os<<"m_incoming_queue.getSize()="<<m_incoming_queue.getSize()
                //<<", m_fetchblock_history.size()="<<m_fetchblock_history.size()
                //<<", m_opt_not_found_history.size()="<<m_opt_not_found_history.size()
                <<std::endl;*/
}

core::list<std::wstring> Client::getConnectedPlayerNames()
{
        core::list<Player*> players = m_env.getPlayers(true);
        core::list<std::wstring> playerNames;
        for(core::list<Player*>::Iterator
                        i = players.begin();
                        i != players.end(); i++)
        {
                Player *player = *i;
                playerNames.push_back(narrow_to_wide(player->getName()));
        }
        return playerNames;
}

float Client::getAnimationTime()
{
        return m_animation_time;
}

int Client::getCrackLevel()
{
        return m_crack_level;
}

void Client::setCrack(int level, v3s16 pos)
{
        int old_crack_level = m_crack_level;
        v3s16 old_crack_pos = m_crack_pos;

        m_crack_level = level;
        m_crack_pos = pos;

        if(old_crack_level >= 0 && (level < 0 || pos != old_crack_pos))
        {
                // remove old crack
                addUpdateMeshTaskForNode(old_crack_pos, false, true);
        }
        if(level >= 0 && (old_crack_level < 0 || pos != old_crack_pos))
        {
                // add new crack
                addUpdateMeshTaskForNode(pos, false, true);
        }
}

u16 Client::getHP()
{
        Player *player = m_env.getLocalPlayer();
        assert(player != NULL);
        return player->hp;
}

bool Client::getChatMessage(std::wstring &message)
{
        if(m_chat_queue.size() == 0)
                return false;
        message = m_chat_queue.pop_front();
        return true;
}

void Client::typeChatMessage(const std::wstring &message)
{
        // Discard empty line
        if(message == L"")
                return;

        // Send to others
        sendChatMessage(message);

        // Show locally
        if (message[0] == L'/')
        {
                m_chat_queue.push_back(
                                (std::wstring)L"issued command: "+message);
        }
        else
        {
                LocalPlayer *player = m_env.getLocalPlayer();
                assert(player != NULL);
                std::wstring name = narrow_to_wide(player->getName());
                m_chat_queue.push_back(
                                (std::wstring)L"<"+name+L"> "+message);
        }
}

void Client::addUpdateMeshTask(v3s16 p, bool ack_to_server, bool urgent)
{
        /*infostream<<"Client::addUpdateMeshTask(): "
                        <<"("<<p.X<<","<<p.Y<<","<<p.Z<<")"
                        <<" ack_to_server="<<ack_to_server
                        <<" urgent="<<urgent
                        <<std::endl;*/

        MapBlock *b = m_env.getMap().getBlockNoCreateNoEx(p);
        if(b == NULL)
                return;
        
        /*
                Create a task to update the mesh of the block
        */
        
        MeshMakeData *data = new MeshMakeData(this);
        
        {
                //TimeTaker timer("data fill");
                // Release: ~0ms
                // Debug: 1-6ms, avg=2ms
                data->fill(b);
                data->setCrack(m_crack_level, m_crack_pos);
                data->setSmoothLighting(g_settings->getBool("smooth_lighting"));
        }

        // Debug wait
        //while(m_mesh_update_thread.m_queue_in.size() > 0) sleep_ms(10);
        
        // Add task to queue
        m_mesh_update_thread.m_queue_in.addBlock(p, data, ack_to_server, urgent);

        /*infostream<<"Mesh update input queue size is "
                        <<m_mesh_update_thread.m_queue_in.size()
                        <<std::endl;*/
}

void Client::addUpdateMeshTaskWithEdge(v3s16 blockpos, bool ack_to_server, bool urgent)
{
        /*{
                v3s16 p = blockpos;
                infostream<<"Client::addUpdateMeshTaskWithEdge(): "
                                <<"("<<p.X<<","<<p.Y<<","<<p.Z<<")"
                                <<std::endl;
        }*/

        try{
                v3s16 p = blockpos + v3s16(0,0,0);
                //MapBlock *b = m_env.getMap().getBlockNoCreate(p);
                addUpdateMeshTask(p, ack_to_server, urgent);
        }
        catch(InvalidPositionException &e){}
        // Leading edge
        try{
                v3s16 p = blockpos + v3s16(-1,0,0);
                addUpdateMeshTask(p, false, urgent);
        }
        catch(InvalidPositionException &e){}
        try{
                v3s16 p = blockpos + v3s16(0,-1,0);
                addUpdateMeshTask(p, false, urgent);
        }
        catch(InvalidPositionException &e){}
        try{
                v3s16 p = blockpos + v3s16(0,0,-1);
                addUpdateMeshTask(p, false, urgent);
        }
        catch(InvalidPositionException &e){}
}

void Client::addUpdateMeshTaskForNode(v3s16 nodepos, bool ack_to_server, bool urgent)
{
        {
                v3s16 p = nodepos;
                infostream<<"Client::addUpdateMeshTaskForNode(): "
                                <<"("<<p.X<<","<<p.Y<<","<<p.Z<<")"
                                <<std::endl;
        }

        v3s16 blockpos = getNodeBlockPos(nodepos);
        v3s16 blockpos_relative = blockpos * MAP_BLOCKSIZE;

        try{
                v3s16 p = blockpos + v3s16(0,0,0);
                addUpdateMeshTask(p, ack_to_server, urgent);
        }
        catch(InvalidPositionException &e){}
        // Leading edge
        if(nodepos.X == blockpos_relative.X){
                try{
                        v3s16 p = blockpos + v3s16(-1,0,0);
                        addUpdateMeshTask(p, false, urgent);
                }
                catch(InvalidPositionException &e){}
        }
        if(nodepos.Y == blockpos_relative.Y){
                try{
                        v3s16 p = blockpos + v3s16(0,-1,0);
                        addUpdateMeshTask(p, false, urgent);
                }
                catch(InvalidPositionException &e){}
        }
        if(nodepos.Z == blockpos_relative.Z){
                try{
                        v3s16 p = blockpos + v3s16(0,0,-1);
                        addUpdateMeshTask(p, false, urgent);
                }
                catch(InvalidPositionException &e){}
        }
}

ClientEvent Client::getClientEvent()
{
        if(m_client_event_queue.size() == 0)
        {
                ClientEvent event;
                event.type = CE_NONE;
                return event;
        }
        return m_client_event_queue.pop_front();
}

void Client::afterContentReceived()
{
        assert(m_itemdef_received);
        assert(m_nodedef_received);
        assert(m_textures_received);

        // Rebuild inherited images and recreate textures
        m_tsrc->rebuildImagesAndTextures();

        // Update texture atlas
        if(g_settings->getBool("enable_texture_atlas"))
                m_tsrc->buildMainAtlas(this);

        // Update node aliases
        m_nodedef->updateAliases(m_itemdef);

        // Update node textures
        m_nodedef->updateTextures(m_tsrc);

        // Update item textures and meshes
        m_itemdef->updateTexturesAndMeshes(this);

        // Start mesh update thread after setting up content definitions
        m_mesh_update_thread.Start();
}

float Client::getRTT(void)
{
        try{
                return m_con.GetPeerAvgRTT(PEER_ID_SERVER);
        } catch(con::PeerNotFoundException &e){
                return 1337;
        }
}

// IGameDef interface
// Under envlock
IItemDefManager* Client::getItemDefManager()
{
        return m_itemdef;
}
INodeDefManager* Client::getNodeDefManager()
{
        return m_nodedef;
}
ICraftDefManager* Client::getCraftDefManager()
{
        return NULL;
        //return m_craftdef;
}
ITextureSource* Client::getTextureSource()
{
        return m_tsrc;
}
u16 Client::allocateUnknownNodeId(const std::string &name)
{
        errorstream<<"Client::allocateUnknownNodeId(): "
                        <<"Client cannot allocate node IDs"<<std::endl;
        assert(0);
        return CONTENT_IGNORE;
}