// Ryzom - MMORPG Framework <http://dev.ryzom.com/projects/ryzom/>
// Copyright (C) 2010  Winch Gate Property Limited
//
// This program is free software: you can redistribute it and/or modify
// it under the terms of the GNU Affero General Public License as
// published by the Free Software Foundation, either version 3 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 Affero General Public License for more details.
//
// You should have received a copy of the GNU Affero General Public License
// along with this program.  If not, see <http://www.gnu.org/licenses/>.



#include "stdpch.h"

#ifdef NL_OS_WINDOWS
#include <process.h>
#endif

#include "network_connection.h"
#include "client_cfg.h"

#include "game_share/action_factory.h"
#include "game_share/action.h"
#include "game_share/action_disconnection.h"
#include "game_share/action_position.h"
#include "game_share/action_sync.h"
#include "game_share/action_association.h"
#include "game_share/action_dummy.h"
#include "game_share/action_login.h"
#include "game_share/action_sint64.h"
#include "game_share/action_target_slot.h"
#include "game_share/action_generic.h"
#include "game_share/action_generic_multi_part.h"
#include "game_share/mode_and_behaviour.h"

#include "game_share/simlag.h"

#include "cdb.h"
#include "cdb_leaf.h"
#include "cdb_branch.h"
#include "cdb_synchronised.h"

#include "nel/misc/variable.h"
#include "nel/misc/algo.h"
#include "nel/3d/u_driver.h"

#include "game_share/system_message.h"

#include "game_share/entity_types.h" // required for ifdef

#include "graph.h"

#include "global.h"
#include "far_tp.h"

#ifdef DISPLAY_ENTITIES
#include "../../../test/network/sb5000/client/graph.h"
#endif

#include <set>
#include <errno.h>


// ***************************************************************************
// Smooth ServerTick setup
// The numner of Smooth Tick per Server Tick
#define SMOOTH_SERVER_TICK_PER_TICK		100
// The possible not corrected error between actual ServerTick and estimated one (NB: equal to packet sent frequency)
#define SMOOTH_SERVER_TICK_WINDOW		100
// The min Difference between the estimated and the actual one. If <=, the estimation is reseted.
#define SMOOTH_SERVER_TICK_DIFF_MIN		-1000
// The max Difference between the estimated and the actual one. If >=, clamp
#define SMOOTH_SERVER_TICK_DIFF_MAX		500
// When the estimation is late, the Max Acceleration factor
#define SMOOTH_SERVER_TICK_ACCEL		4.0f


const char * ConnectionStateCStr [9] = { "NotInitialised", "NotConnected", "Authenticate", "Login", "Synchronize", "Connected", "Probe", "Stalled", "Disconnect" };


// ***************************************************************************
using namespace std;
using namespace NLMISC;
using namespace NLNET;
using namespace CLFECOMMON;


#undef MEASURE_RECEIVE_DATES
//#define SHOW_PROPERTIES_RECEIVED

#ifdef MEASURE_RECEIVE_DATES
#include <nel/misc/config_file.h>
#include <nel/misc/displayer.h>
#include <nel/misc/log.h>
#include <nel/misc/path.h>
#include <nel/misc/time_nl.h>
#include <nel/misc/command.h>
// Stat: array of vectors of cycles when a pos is received, indexed by TCLEntityId
struct TRDateState
{
	TRDateState( TGameCycle gc, TGameCycle pdit, TTime ct ) : ServerCycle(gc), PredictedInterval(pdit), LocalTime(ct) {}

	TGameCycle	ServerCycle, PredictedInterval;
	TTicks		LocalTime;
};


extern CLFECOMMON::TCLEntityId WatchedEntitySlot;

////////////
// GLOBAL //
////////////


typedef vector<TRDateState> TReceiveDateLog;
TReceiveDateLog				ReceivePosDateLog [256];
bool						LogReceiveEnabled = false;
CConfigFile					NCConfigFile;
CFileDisplayer				*ReceiveLogDisp;
CLog						ReceiveLogger;


/*
 * initReceiveLog
 */
void			initReceiveLog()
{
	try
	{
		ReceiveLogDisp = new CFileDisplayer( "ReceiveLog.log" );
		ReceiveLogger.addDisplayer( ReceiveLogDisp );
		//ReceiveLogger.displayNL( "Searching for param LogReceive in the config file..." );
		NCConfigFile.load( string( "client.cfg" ) );
		int slot = NCConfigFile.getVar( "LogReceive" ).asInt();
		if ( slot != 0 )
		{
			LogReceiveEnabled = true;
			ReceiveLogger.displayNL( "LogReceive is on" ); // only when enabled
		}
	}
	catch ( EConfigFile& )
	{}
}

/*
 * startReceiveLog (the slots logged are all if no selection, or only the selected slots (one at a time)
 */
void			startReceiveLog()
{
	sint i;
	for ( i=0; i!=256; ++i )
	{
		ReceivePosDateLog[i].clear();
	}

	LogReceiveEnabled = true;
}

/*
 * stopReceiveLog
 */
void			stopReceiveLog()
{
	LogReceiveEnabled = false;
}

/*
 * displayReceiveLog
 */
void			displayReceiveLog()
{
	if ( ! LogReceiveEnabled )
		return;

	nlinfo( "Dumping ReceiveLog" );
	ReceiveLogger.displayNL( "ReceiveLog (ServerCycle, PredictedInterval, LocalTime(ms)):" );

	// Display receive dates for all slots for which vector is not empty
	// (allows to trace several selected slots one after one, or all slots at the same time)
	sint i;
	for ( i=0; i!=256; ++i )
	{
		if ( ! ReceivePosDateLog[i].empty() )
		{
			ReceiveLogger.displayRawNL( "Entity %d: %u updates", i, ReceivePosDateLog[i].size() );
			TReceiveDateLog::iterator idl;
			for ( idl=ReceivePosDateLog[i].begin(); idl!=ReceivePosDateLog[i].end(); ++idl )
			{
				ReceiveLogger.displayRawNL( "%u\t%u\t%"NL_I64"u", (*idl).ServerCycle, (*idl).PredictedInterval, (*idl).LocalTime );
			}
		}
	}
	ReceiveLogger.displayRawNL( "ReceiveLog completed" );
}

NLMISC_COMMAND( startReceiveLog, "Starts logging the position receives (for all or only the watched entities when selected)", "" )
{
	nlinfo( "Starting ReceiveLog" );
	startReceiveLog();
	return true;
}

NLMISC_COMMAND( stopReceiveLog, "Stops logging the position receives", "" )
{
	stopReceiveLog();
	return true;
}

NLMISC_COMMAND( displayReceiveLog, "Flush the receive log into ReceiveLog.log", "" )
{
	displayReceiveLog();
	return true;
}

#endif // MEASURE_RECEIVE_DATES

extern NL3D::UDriver		*Driver;


CVariable<bool>	CheckXMLSignature("client", "CheckXMLSignature", "enable client to check msg/database.xml signature", true, 0, true);

CSlotGraph *PosUpdateIntervalGraph = NULL;
CSlotGraph *PosUpdatePredictionGraph = NULL;

CGraph MsPerTickGraph  ("mspertick (ms)",  10.0f, 570.0f, 400.0f, 100.0f, CRGBA(0,0,128,128), 1000, 400.0f, 2);
CGraph PingGraph       ("ping (ms)",       10.0f, 460.0f, 400.0f, 100.0f, CRGBA(128,0,0,128), 100000, 1000.0f, 2);
CGraph PacketLossGraph ("PacketLoss (pc)", 10.0f, 350.0f, 200.0f, 100.0f, CRGBA(0,128,0,128), 100000, 100.0f, 2);
CGraph UploadGraph     ("upload (byps)",   10.0f, 240.0f, 200.0f, 100.0f, CRGBA(0,128,128,128), 1000, 3000.0f, 2);
CGraph DownloadGraph   ("download (byps)", 10.0f, 130.0f, 200.0f, 100.0f, CRGBA(0,0,128,128), 1000, 3000.0f, 2);


//#define A a()					!!!
//#define B b()					!!! SO DANGEROUS !!!
//#define Parent parent()		!!!


bool			CNetworkConnection::_Registered = false;


/*
 * Percentile (in fact, quantile) function
 * Freely adapted from the Goose Library (http://www.gnu.org/software/goose)
 * at http://cvs.gnome.org/lxr/source/goose/src/stats/descriptive.cpp#90
 */

// Normal quantile function (see also percentilRev below)
/*float percentile( const multiset<uint32>& dataset, float p )
{
	//nlassert( ! dataset.empty() );
	//nlassert( (p >= 0) && (p <= 1) );
	uint ds = dataset.size();
	if ( ds == 1 )
		return (float)(*dataset.begin());
	float fpIndex = p * (float)(ds-1);
	sint ipIndex = (sint)fpIndex;
	multiset<uint32>::iterator it = dataset.begin(), itnext;
	for ( sint i=0; i!=ipIndex; ++i, ++it );
	itnext = it; ++itnext;
	return ((float)(ipIndex+1)-fpIndex)*(float)(*it) + (fpIndex-(float)ipIndex)*(float)(*itnext);
}*/

// Reversed quantile function = percentile(dataset, 1-p) (optimized for p>0.5 i.e. rp<=0.5)
float percentileRev( const multiset<uint32>& dataset, float rp )
{
	//nlassert( ! dataset.empty() );
	//nlassert( (rp >= 0) && (rp <= 1) );
	uint ds = (uint)dataset.size();
	if ( ds == 1 )
		return (float)(*dataset.begin());
	float fpIndex = rp * (float)(ds-1);
	sint ipIndex = (sint)fpIndex;
	multiset<uint32>::const_reverse_iterator it = dataset.rbegin(), itnext;
	for ( sint i=0; i!=ipIndex; ++i, ++it );
	itnext = it; ++itnext;
	return ((float)(ipIndex+1)-fpIndex)*(float)(*it) + (fpIndex-(float)ipIndex)*(float)(*itnext);
}


//

const uint MAX_POSUPDATETICKQUEUE_SIZE = 25;
const float PREDICTION_REV_PERCENTILE = 0.2f; // (1 - 0.8)

//

bool CNetworkConnection::LoggingMode = false;


/*
 * Constructor
 */
#ifdef ENABLE_INCOMING_MSG_RECORDER
CNetworkConnection::CNetworkConnection() : _NextMessageToReplay(true)
#else
CNetworkConnection::CNetworkConnection()
#endif
{
	_ConnectionState = NotInitialised;
	_ImpulseCallback = NULL;
	_ImpulseArg = NULL;
	_DataBase = NULL;

	reset();

	_QuitId = 0;

	initTicks();
}


/*
 * Destructor
 */
CNetworkConnection::~CNetworkConnection()
{
#ifdef MEASURE_RECEIVE_DATES
	delete ReceiveLogDisp;
#endif
	if ( _VisualPropertyTreeRoot ) // not allocated in local mode
	{
		_VisualPropertyTreeRoot->deleteBranches();
		delete _VisualPropertyTreeRoot;
		_VisualPropertyTreeRoot = NULL;
	}

#ifdef ENABLE_INCOMING_MSG_RECORDER
	if ( _RecordIncomingMessagesOn )
		_RecordedMessagesOut.close();
	else if ( _ReplayIncomingMessagesOn )
		_RecordedMessagesIn.close();
#endif
}

NLMISC::CHashKeyMD5	getTextMD5(const std::string& filename)
{
	CIFile	fi;
	if (!fi.open(CPath::lookup(filename, false)))
		return NLMISC::CHashKeyMD5();

	std::vector<uint8>	buffer(fi.getFileSize());
	fi.serialBuffer(&(buffer[0]), (uint)buffer.size());

	std::vector<uint8>::iterator	it = buffer.begin();
	do
	{
		while (it != buffer.end() && *it != '\015')
			++it;

		if (it != buffer.end())
			it = buffer.erase(it);
	}
	while (it != buffer.end());

	return NLMISC::getMD5((&buffer[0]), (uint32)buffer.size());
}

/*
 * Init
 */
void	CNetworkConnection::init(const string &cookie, const string &addr)
{
	if (_ConnectionState != NotInitialised &&
		_ConnectionState != Disconnect)
	{
		nlwarning("Unable to init(): connection not properly closed yet.");
		return;
	}

	if (!_Registered)
	{
		CActionFactory::getInstance ()->registerAction (ACTION_POSITION_CODE, CActionPosition::create);
		CActionFactory::getInstance ()->registerAction (ACTION_SYNC_CODE, CActionSync::create);
		CActionFactory::getInstance ()->registerAction (ACTION_DISCONNECTION_CODE, CActionDisconnection::create);
		CActionFactory::getInstance ()->registerAction (ACTION_ASSOCIATION_CODE, CActionAssociation::create);
		CActionFactory::getInstance ()->registerAction (ACTION_DUMMY_CODE, CActionDummy::create);
		CActionFactory::getInstance ()->registerAction (ACTION_LOGIN_CODE, CActionLogin::create);
		CActionFactory::getInstance ()->registerAction (ACTION_TARGET_SLOT_CODE, CActionTargetSlot::create);
		CActionFactory::getInstance ()->registerAction (ACTION_GENERIC_CODE, CActionGeneric::create);
		CActionFactory::getInstance ()->registerAction (ACTION_GENERIC_MULTI_PART_CODE, CActionGenericMultiPart::create);
		CActionFactory::getInstance ()->registerAction (ACTION_SINT64, CActionSint64::create);
		_Registered = true;
	}

	initCookie(cookie, addr);

#ifdef HALF_FREQUENCY_SENDING_TO_CLIENT
	nlinfo( "Half-frequency mode" );
#else
	nlinfo( "Full-frequency mode" );
#endif

#ifdef MEASURE_RECEIVE_DATES
	initReceiveLog();
#endif

	// Register property nbbits
	CActionSint64::registerNumericPropertiesRyzom();

	// Init visual property tree
	_VisualPropertyTreeRoot = new TVPNodeClient();
	_VisualPropertyTreeRoot->buildTree();

#ifdef ENABLE_INCOMING_MSG_RECORDER
	_RecordIncomingMessagesOn = false;
	_ReplayIncomingMessagesOn = false;
	_NextClientTickToReplay = 0;
#endif

	// If the server run on window, those are the one to test
	_AltMsgXmlMD5 = NLMISC::getMD5("msg.xml");
	_AltDatabaseXmlMD5 = NLMISC::getMD5("database.xml");
	// If the server run on UNIX, those are the one to test
	_MsgXmlMD5 = getTextMD5("msg.xml");
	_DatabaseXmlMD5 = getTextMD5("database.xml");
}


/*
 * Sets the cookie and front-end address, resets the connection state.
 */
void	CNetworkConnection::initCookie(const string &cookie, const string &addr)
{
#ifdef ENABLE_INCOMING_MSG_RECORDER
	if ( ! ClientCfg.Local )
#endif
	{
		// set values of simulation for the udp socket
		CUdpSimSock::setSimValues(ClientCfg.ConfigFile);

		_FrontendAddress = addr;

		if (!cookie.empty ())
			_LoginCookie.setFromString (cookie);
		else if (ClientCfg.ConfigFile.exists ("UserId"))
		{
			uint32 uid = ClientCfg.ConfigFile.getVar ("UserId").asInt();
			_LoginCookie.set(0, 0, uid);
			Cookie = _LoginCookie.toString(); // to be able to do '/reconnect'
			nlinfo ("Set the cookie with the UserId %d set in config file", uid);
		}

		nlinfo ("Network initialisation with front end '%s' and cookie %s",_FrontendAddress.c_str(), _LoginCookie.toString().c_str ());
	}

	_ConnectionState = NotConnected;
}




namespace CLFECOMMON
{
	// Factory for TVPNodeBase::buildTree()
	TVPNodeBase	*NewNode()
	{
		return (TVPNodeBase*) new CNetworkConnection::TVPNodeClient();
	}
};


#ifdef ENABLE_INCOMING_MSG_RECORDER
/*
 * Start/stop recording the incoming messages (in online mode)
 */
void	CNetworkConnection::setRecordingMode( bool onOff, const std::string& filename )
{
	nlassert( ! ClientCfg.Local );
	if ( onOff )
	{
		if ( ! _RecordIncomingMessagesOn )
		{
			if ( _RecordedMessagesOut.open( filename ) )
			{
				nlinfo( "Beginning recording to %s", filename.c_str() );
				_RecordedMessagesOut.serialEnum( _ConnectionState );
				_RecordedMessagesOut.serial( _CurrentReceivedNumber );
				_RecordedMessagesOut.serial( _LastReceivedNumber );
				_RecordedMessagesOut.serial( _LastAckInLongAck );
				_RecordIncomingMessagesOn = true;
			}
			else
			{
				nlwarning( "Cannot open %s for recording", filename.c_str() );
			}
		}
	}
	else
	{
		if ( _RecordIncomingMessagesOn )
			_RecordedMessagesOut.close();
		_RecordIncomingMessagesOn = false;
	}
}


/*
 * Start/stop replaying the incoming messages (in offline mode)
 */
void	CNetworkConnection::setReplayingMode( bool onOff, const std::string& filename )
{
	nlassert( ClientCfg.Local );
	if ( onOff )
	{
		if ( ! _ReplayIncomingMessagesOn )
		{
			if ( _RecordedMessagesIn.open( filename ) )
			{
				nlinfo( "Beginning replaying of %s", filename.c_str() );
				_RecordedMessagesIn.serialEnum( _ConnectionState );
				_RecordedMessagesIn.serial( _CurrentReceivedNumber );
				_RecordedMessagesIn.serial( _LastReceivedNumber );
				_RecordedMessagesIn.serial( _LastAckInLongAck );
				// Preload first message
				if ( _RecordedMessagesIn.eof() )
				{
					// Nothing to load
					nlinfo( "Nothing to replay" );
					_RecordedMessagesIn.close();
					return;
				}
				else
				{
					_RecordedMessagesIn.serial( _NextClientTickToReplay );
					_RecordedMessagesIn.serialMemStream( _NextMessageToReplay );
					_CurrentClientTick = _NextClientTickToReplay;
					_CurrentServerTick = _CurrentClientTick + 10;
					nlinfo( "Setting initial replay tick: %u", _CurrentClientTick );
					_ReplayIncomingMessagesOn = true;
				}
			}
			else
			{
				nlwarning( "File %s for replay not found", filename.c_str() );
			}
		}
	}
	else
	{
		if ( _RecordIncomingMessagesOn )
			_RecordedMessagesIn.close();
		_ReplayIncomingMessagesOn = false;
	}
}
#endif


bool	CNetworkConnection::connect(string &result)
{
	if (_ConnectionState != NotConnected)
	{
		nlwarning("Unable to connect(): connection not properly initialised (maybe connection not closed).");
		return false;
	}

	// try to find where common data are located depending to where we'll connect
	// the goal is to use the same database.txt as the server one
	try
	{
		CConfigFile cfg;
		cfg.load (CPath::lookup("shards.cfg"));

		// do this process only if Use == 1
		if (cfg.getVar("Use").asInt() == 1)
		{
			CInetAddress fsaddr (_FrontendAddress);

			fsaddr.setPort(0);

			nlinfo ("Try to find a shard that have fsaddr = '%s'", fsaddr.asString().c_str());

			CConfigFile::CVar &shards = cfg.getVar("Shards");
			CInetAddress net;
			uint i;
			for (i = 0; i < shards.size(); i+=2)
			{
				try
				{
					net.setNameAndPort (shards.asString(i));
					nlinfo ("testAddr = '%s'", net.asString().c_str());
					if (net == fsaddr)
					{
						// ok, we found it, now overwrite files

						string srcPath = CPath::standardizeDosPath(CPath::getFullPath(shards.asString(i+1)));

						nlinfo ("srcPath = '%s'", srcPath.c_str());

						CConfigFile::CVar &needToCopy = cfg.getVar("NeedToCopy");
						for (uint j = 0; j < needToCopy.size(); j++)
						{
							string arg1 = srcPath + needToCopy.asString(j);
							string dstPath = CPath::standardizeDosPath(CPath::getFullPath(CPath::lookup (CFile::getFilename (needToCopy.asString(j))), false));
							try
							{
								if(arg1.empty () || dstPath.empty ())
								{
									nlinfo ("Can't copy, src or dst is empty");
								}
								if(arg1 != dstPath)
								{
									nlinfo ("Copying '%s' into '%s'", arg1.c_str(), dstPath.c_str());
									nlinfo ("executing 'copy /Y %s %s", arg1.c_str(), dstPath.c_str());
									string str = "copy /Y " + arg1 + " " + dstPath;
									int ret = system (str.c_str ());
									//int ret = _spawnlp (_P_WAIT, "copy", "copy", "/Y", arg1.c_str(), dstPath.c_str(), NULL);
									if (ret != 0)
									{
										nlwarning ("the copy command seems failed with the error code %d, errno %d: %s", ret, errno, strerror(errno));
									}
								}
								else
								{
									nlinfo ("Can't copy, same path '%s'", arg1.c_str());
								}
							}
							catch (Exception &)
							{
								nlwarning ("Can't copy '%s' '%s', try the next file", arg1.c_str(), dstPath.c_str());
							}
						}
						break;
					}
				}
				catch (Exception &e)
				{
					nlwarning (e.what ());
				}
			}
			if (i == shards.size())
			{
				nlwarning ("the fsaddr '%s' is not in the shards.cfg, can't copy data_common files", fsaddr.asString().c_str());
			}
		}
	}
	catch (Exception &)
	{
		nlinfo ("There's no shards.cfg, or bad file format, can't copy common files");
	}

	nlinfo ("CNET[%p]: Connecting to '%s' with cookie '%s'", this, _FrontendAddress.c_str(), _LoginCookie.toString().c_str ());

	// then connect to the frontend using the udp sock
//ace faut faire la nouveau login client 	result = CLoginClient::connectToShard (_FrontendAddress, _Connection);

	nlassert (!_Connection.connected());

	try
	{
		//
		// S12: connect to the FES. Note: In UDP mode, it's the user that have to send the cookie to the front end
		//
		_Connection.connect (CInetAddress(_FrontendAddress));
	}
	catch (ESocket &e)
	{
		result = toString ("FS refused the connection (%s)", e.what());
		return false;
	}

	_ConnectionState = Login;

	_LatestLoginTime = ryzomGetLocalTime ();
	_LatestSyncTime = _LatestLoginTime;
	_LatestProbeTime = _LatestLoginTime;

	nlinfo("CNET[%p]: Client connected to shard, attempting login", this);
	return true;
}

void	CNetworkConnection::setImpulseCallback(TImpulseCallback callback, void *argument)
{
	_ImpulseCallback = callback;
	_ImpulseArg = argument;
}

//

bool	CNetworkConnection::isConnected()
{
	return _ConnectionState == Connected;
}

#ifdef ENABLE_INCOMING_MSG_RECORDER
/*
 * Return true if there is some messages to replay (in replay mode)
 */
bool	CNetworkConnection::dataToReplayAvailable()
{
	// Test the next tick loaded with the curent client tick (set externally)
	//nldebug( "current=%u nextToReplay=%u", _CurrentClientTick, _NextClientTickToReplay );
	return ( _CurrentClientTick >= _NextClientTickToReplay ); // when true => authorize entering buildStream()...
}
#endif



/*
 * Set MsPerTick value
 */
void	CNetworkConnection::setMsPerTick(sint32 msPerTick)
{
	_MsPerTick = msPerTick;
}



//
//
//

bool	CNetworkConnection::update()
{
#ifdef ENABLE_INCOMING_MSG_RECORDER
	if ( _NextClientTickToReplay == ~0 )
	{
		setReplayingMode( false );
		return false;
	}
#endif

	_UpdateTime = ryzomGetLocalTime ();
	_UpdateTicks = ryzomGetPerformanceTime();
	_ReceivedSync = false;
	_NormalPacketsReceived = 0;
	_TotalMessages = 0;

	//nldebug("CNET[%d]: begin update()", this);

	// If we are disconnected, bypass the real network update
	if ( _ConnectionState == Disconnect )
	{
		_ConnectionQuality = false; // to block the user entity
		return false;
	}

	// Yoyo. Update the Smooth ServerTick.
	updateSmoothServerTick();


	////// MEASURE_FE_SENDING (special test mode, not used in normal mode)
#ifdef MEASURE_FE_SENDING
	if ( _ConnectionState == Login )
	{
		//_Connection.setNonBlockingMode( true );
		sendSystemLogin();
		_ConnectionState = Connected;
	}

	// Receive
	CBitMemStream msgin( true );
	bool res = buildStream( msgin );

	if ( res )
	{
		static sint32 loopcount = 0;
		++loopcount;
		static TTicks lastdisplay = CTime::getPerformanceTime();
		TTicks tn = CTime::getPerformanceTime();
		TTime diff = CTime::ticksToSecond(tn - lastdisplay) * 1000.0;
		if ( diff > 2000 )
		{
			nlinfo("Reads by second: %.1f => LoopTime = %.2f ms LoopCount = %u Diff = %u ms",(float)loopcount * 1000.0f / (float)diff, (float)diff / loopcount, loopcount, diff);
			loopcount = 0;
			lastdisplay = tn;
		}
	}

	return res;
#endif

	if (!_Connection.connected())
	{
		//if(!ClientCfg.Local)
		//	nlwarning("CNET[%p]: update() attempted whereas socket is not connected !", this);
		return false;
	}

	try
	{
		// State automaton
		bool	stateBroke = false;
		do
		{
			switch (_ConnectionState)
			{
			case Login:
				// if receives System SYNC
				//    immediate state Synchronize
				// else
				//    sends System LoginCookie
				stateBroke = stateLogin();
				break;

			case Synchronize:
				// if receives System PROBE
				//    immediate state Probe
				// else if receives Normal
				//    immediate state Connected
				// else
				//    sends System ACK_SYNC
				stateBroke = stateSynchronize();
				break;

			case Connected:
				// if receives System PROBE
				//    immediate state Probe
				// else if receives Normal
				//	   sends Normal data
				stateBroke = stateConnected();
				break;

			case Probe:
				// if receives System SYNC
				//    immediate state SYNC
				// else if receives System PROBE
				//    decode PROBE
				// sends System ACK_PROBE
				stateBroke = stateProbe();
				break;

			case Stalled:
				// if receives System SYNC
				//    immediate state SYNC
				// else if receives System STALLED
				//    decode STALLED (nothing to do)
				// else if receives System PROBE
				//    immediate state PROBE
				stateBroke = stateStalled();
				break;

			case Quit:
				// if receives System SYNC
				//    immediate state Synchronize
				// else
				//    sends System LoginCookie
				stateBroke = stateQuit();
				break;

			default:
				// Nothing here !
				stateBroke = false; // will come here if a disconnection action is received inside a method that returns true
				break;
			}
		}
		while (stateBroke);// && _TotalMessages<5);
	}
	catch (ESocket &)
	{
		_ConnectionState = Disconnect;
	}

	//updateBufferizedPackets ();

	PacketLossGraph.addOneValue (getMeanPacketLoss ());

	_ConnectionQuality = (getConnectionState() == Connected &&
						  _UpdateTime - _LastReceivedNormalTime < 2000 && _CurrentClientTick < _CurrentServerTick);

	return (_TotalMessages!=0);
}


/*
 * Receive available data and convert it to a bitmemstream
 */
bool	CNetworkConnection::buildStream( CBitMemStream &msgin )
{
#ifdef ENABLE_INCOMING_MSG_RECORDER
	if ( _ReplayIncomingMessagesOn )
	{
		// Replay message
		statsReceive( _NextMessageToReplay.length() );
		msgin.clear();
		memcpy( msgin.bufferToFill( _NextMessageToReplay.length() ), _NextMessageToReplay.buffer(), _NextMessageToReplay.length() );
		//nldebug( "Reading message for tick %u (size %u)", _NextClientTickToReplay, msgin.length() );

		// Preload next message
		if ( _RecordedMessagesIn.eof() )
		{
			// Nothing more to load
			_NextClientTickToReplay = ~0;
			nlinfo( "Nothing more to replay, end of replaying" );
		}
		else
		{
			_RecordedMessagesIn.serial( _NextClientTickToReplay );
			_NextMessageToReplay.clear();
			_RecordedMessagesIn.serialMemStream( _NextMessageToReplay );
		}

		return true;
	}
#endif

	uint32 len = 65536;
	if ( _Connection.receive( (uint8*)_ReceiveBuffer, len, false ) )
	{
		// Compute some statistics
		statsReceive( len );

		// Fill the message
		msgin.clear();
		memcpy( msgin.bufferToFill( len ), _ReceiveBuffer, len );

#ifdef ENABLE_INCOMING_MSG_RECORDER
		if ( _RecordIncomingMessagesOn )
		{
			_RecordedMessagesOut.serial( _CurrentClientTick );
			_RecordedMessagesOut.serialMemStream( msgin ); // shouldn't msgin's bufpos be resetted?
		}
#endif
		return true;
	}
	else
	{
		// A receiving error means the front-end is down
		_ConnectionState = Disconnect;
		disconnect(); // won't send a disconnection msg because state is already Disconnect
		nlwarning( "DISCONNECTION" );
		return false;
	}
}




//
// Client automaton states methods
//




//
// Login state
//


// sends system login cookie
void	CNetworkConnection::sendSystemLogin()
{
	CBitMemStream	message;

	buildSystemHeader(message);

	uint8			login = SYSTEM_LOGIN_CODE;
	message.serial(login);

	if (_LoginCookie.isValid())
		message.serial(_LoginCookie);
	else
	{
		uint32	fakeCookie = 0xDEADBEEF;
		message.serial(fakeCookie);
		message.serial(fakeCookie);
		message.serial(fakeCookie);
	}
	message.serial( ClientCfg.LanguageCode );

	// Try to send login, and handle the case when a firewall blocks the sending
	uint32 length = message.length();
	static TTime attemptStartTime = CTime::getLocalTime();
	try
	{
		//sendUDP (&(_Connection), message.buffer(), length);
		_Connection.send( message.buffer(), length );
	}
	catch ( ESocket& e )
	{
#ifdef NL_OS_WINDOWS
		// An exception (10004: Blocking operation interrupted) may occur if a firewall such as Kerio is
		// running (note: ZoneAlarm blocks connect() until a decision is made by the user).
		// Handle true network errors with a nlerror dialog box
		if ( string(e.what()).find( "10004:" ) == string::npos ) // Code of WSAEINTR
		{
			// nlerror( "Cannot login: %s", e.what() );
		}
#endif
		// The first time, display info for the user to configure his personal firewall
		static bool exceptionThrown = false;
		if ( ! exceptionThrown )
		{
			exceptionThrown = true;
			throw EBlockedByFirewall();
		}

		// Next time, disconnect if the time-out expired
		//nldebug( "Attempt interrupted at %u ms", (uint32)(CTime::getLocalTime()-attemptStartTime) );
		TTime currentTime = CTime::getLocalTime();
		if ( currentTime - attemptStartTime > 15000 ) // let 15 seconds for the user to allow the connection
		{
			nldebug( "Login failed at %u ms", (uint32)(CTime::getLocalTime()-attemptStartTime) );
			//nlerror( "Cannot login (check your firewall's settings?): %s", e.what() );
			throw EBlockedByFirewall();
		}
	}

	statsSend( length );
	nlinfo( "CNET[%p]: sent LOGIN cookie=%s", this, _LoginCookie.toString().c_str() );
	//nlinfo( "CNET[%p]: sent LOGIN cookie=%s at attempt %u at %u ms", this, _LoginCookie.toString().c_str(), nbAttempts, (uint32)(CTime::getLocalTime()-attemptStartTime) );
}

bool	CNetworkConnection::stateLogin()
{
	// if receives System SYNC
	//    immediate state Synchronize
	// else
	//    sends System LoginCookie

#ifdef ENABLE_INCOMING_MSG_RECORDER
	if ( ClientCfg.Local && !_ReplayIncomingMessagesOn )
		return false;
	while ( (_ReplayIncomingMessagesOn && dataToReplayAvailable()) ||
			_Connection.dataAvailable() )
#else
	while ( _Connection.dataAvailable() )// && _TotalMessages<5)
#endif
	{
		_DecodedHeader = false;
		CBitMemStream	msgin (true);
		if (buildStream(msgin) && decodeHeader(msgin))
		{
			if (_SystemMode)
			{
				uint8	message;
				msgin.serial(message);

				switch (message)
				{
				case SYSTEM_SYNC_CODE:
					// receive sync, decode sync
					_ConnectionState = Synchronize;
					nldebug("CNET[%p]:  login->synchronize", this);
					receiveSystemSync(msgin);
					return true;
					break;
				case SYSTEM_STALLED_CODE:
					// receive stalled, decode stalled and state stalled
					_ConnectionState = Stalled;
					nldebug("CNET[%p]: login->stalled", this);
					receiveSystemStalled(msgin);
					return true;
					break;
				case SYSTEM_PROBE_CODE:
					// receive probe, decode probe and state probe
					_ConnectionState = Probe;
					_Changes.push_back(CChange(0, ProbeReceived));
					nldebug("CNET[%p]: login->probe", this);
					receiveSystemProbe(msgin);
					return true;
					break;
				case SYSTEM_SERVER_DOWN_CODE:
					disconnect(); // will send disconnection message
					nlwarning( "BACK-END DOWN" );
					return false; // exit now from loop, don't expect a new state
					break;
				default:
					//msgin.displayStream("DBG:BEN:stateLogin:msgin");
					nlwarning("CNET[%p]: received system %d in state Login", this, message);
					break;
				}
			}
			else
			{
				//msgin.displayStream("DBG:BEN:stateLogin:msgin");
				nlwarning("CNET[%p]: received normal in state Login", this);
			}
		}
	}

	// send ack sync if received sync or last sync timed out
	if (_UpdateTime-_LatestLoginTime > 300)
	{
		sendSystemLogin();
		_LatestLoginTime = _UpdateTime;
	}

	return false;
}



//
// Sync state
//

void	CNetworkConnection::receiveSystemSync(CBitMemStream &msgin)
{
#ifdef ENABLE_INCOMING_MSG_RECORDER
	if ( _ReplayIncomingMessagesOn )
	{
		TGameCycle dummyTick;
		TTime dummyTime;
		msgin.serial( dummyTick );
		msgin.serial( dummyTime );
		return;
	}
#endif

	_LatestSyncTime = _UpdateTime;
	TTime		stime;
	msgin.serial(_Synchronize);
	msgin.serial(stime);
	msgin.serial(_LatestSync);

	if (CheckXMLSignature.get())
	{
		bool	xmlInvalid = false;

		CHashKeyMD5	checkMsgXml;
		CHashKeyMD5	checkDatabaseXml;

		try
		{
			msgin.serialBuffer(checkMsgXml.Data, sizeof(checkMsgXml.Data));
			msgin.serialBuffer(checkDatabaseXml.Data, sizeof(checkDatabaseXml.Data));

			// Since cannot now easily if the server run on Windows or unix, try the both methods
			xmlInvalid = (checkMsgXml != _MsgXmlMD5 || checkDatabaseXml != _DatabaseXmlMD5);
			if(xmlInvalid)
				xmlInvalid = (checkMsgXml != _AltMsgXmlMD5 || checkDatabaseXml != _AltDatabaseXmlMD5);
		}
		catch (NLMISC::Exception&)
		{
		}

		static bool	alreadyWarned = false;
		if (xmlInvalid && !alreadyWarned)
		{
			alreadyWarned = true;
			Driver->systemMessageBox("msg.xml and database.xml files are invalid (server version signature is different)", "XML files invalid");

			nlwarning("XML signature is invalid:");
			nlwarning("msg.xml client:%s,%s server:%s", _AltMsgXmlMD5.toString().c_str(), _MsgXmlMD5.toString().c_str(),
				checkMsgXml.toString().c_str());
			nlwarning("database.xml client:%s,%s server:%s", _AltDatabaseXmlMD5.toString().c_str(), _DatabaseXmlMD5.toString().c_str(),
				checkDatabaseXml.toString().c_str());
		}
	}

	_ReceivedSync = true;

	setMsPerTick(100);
	//_MsPerTick = 100;			// initial values

#ifdef HALF_FREQUENCY_SENDING_TO_CLIENT
#pragma message ("HALF_FREQUENCY_SENDING_TO_CLIENT")
	_CurrentServerTick = _Synchronize+_CurrentReceivedNumber*2;
#else
#pragma message ("FULL_FREQUENCY_SENDING_TO_CLIENT")
	_CurrentServerTick = _Synchronize+_CurrentReceivedNumber;
#endif
	_CurrentClientTick = uint32(_CurrentServerTick - (_LCT+_MsPerTick)/_MsPerTick);
	_CurrentClientTime = _UpdateTime - (_LCT+_MsPerTick);

	//nlinfo( "CNET[%p]: received SYNC %"NL_I64"u %"NL_I64"u - _CurrentReceivedNumber=%d _CurrentServerTick=%d", this, (uint64)_Synchronize, (uint64)stime, _CurrentReceivedNumber, _CurrentServerTick );

	sendSystemAckSync();
}

// sends system sync acknowledge
void	CNetworkConnection::sendSystemAckSync()
{
#ifdef ENABLE_INCOMING_MSG_RECORDER
	if ( _ReplayIncomingMessagesOn )
		return;
#endif

	CBitMemStream	message;

	buildSystemHeader(message);

	uint8			sync = SYSTEM_ACK_SYNC_CODE;
	message.serial(sync);
	message.serial(_LastReceivedNumber);
	message.serial(_LastAckInLongAck);
	message.serial(_LongAckBitField);
	message.serial(_LatestSync);

	uint32	length = message.length();
	_Connection.send (message.buffer(), length);
	//sendUDP (&(_Connection), message.buffer(), length);
	statsSend(length);

	_LatestSyncTime = _UpdateTime;

	//nlinfo("CNET[%p]: sent ACK_SYNC, _LastReceivedNumber=%d _LastAckInLongAck=%d", this, _LastReceivedNumber, _LastAckInLongAck);

/*	// display long ack
	uint	i;
	uint	bfsize = _LongAckBitField.size();
	uint	bbuffer = 0;
	string	buffer;
	static const char	htable[] = "0123456789ABCDEF";
	for (i=0; i<bfsize; ++i)
	{
		if (i>0 && (i&3)==0)
		{
			buffer += htable[bbuffer];
			bbuffer = 0;
		}

		bbuffer = bbuffer*2 + (_LongAckBitField.get((_LastReceivedNumber-i)&(bfsize-1)) ? 1 : 0);
	}

	buffer += htable[bbuffer];
	nlinfo("CNET[%p]: ACK=%s", buffer.c_str());
*/}

bool	CNetworkConnection::stateSynchronize()
{
	// if receives System PROBE
	//    immediate state Probe
	// else if receives Normal
	//    immediate state Connected
	// sends System ACK_SYNC
#ifdef ENABLE_INCOMING_MSG_RECORDER
	if ( ClientCfg.Local && !_ReplayIncomingMessagesOn )
		return false;
	while ( (_ReplayIncomingMessagesOn && dataToReplayAvailable()) ||
			_Connection.dataAvailable() )
#else
	while (_Connection.dataAvailable())// && _TotalMessages<5)
#endif
	{
		_DecodedHeader = false;
		CBitMemStream	msgin (true);
		if (buildStream(msgin) && decodeHeader(msgin))
		{
			if (_SystemMode)
			{
				uint8	message;
				msgin.serial(message);

				switch (message)
				{
				case SYSTEM_PROBE_CODE:
					// receive probe, decode probe and state probe
					_ConnectionState = Probe;
					//nldebug("CNET[%p]: synchronize->probe", this);
					_Changes.push_back(CChange(0, ProbeReceived));
					receiveSystemProbe(msgin);
					return true;
					break;
				case SYSTEM_STALLED_CODE:
					// receive stalled, decode stalled and state stalled
					_ConnectionState = Stalled;
					//nldebug("CNET[%p]: synchronize->stalled", this);
					receiveSystemStalled(msgin);
					return true;
					break;
				case SYSTEM_SYNC_CODE:
					// receive sync, decode sync
					receiveSystemSync(msgin);
					break;
				case SYSTEM_SERVER_DOWN_CODE:
					disconnect(); // will send disconnection message
					nlwarning( "BACK-END DOWN" );
					return false; // exit now from loop, don't expect a new state
					break;
				default:
					nlwarning("CNET[%p]: received system %d in state Synchronize", this, message);
					break;
				}
			}
			else
			{
				_ConnectionState = Connected;
				//nlwarning("CNET[%p]: synchronize->connected", this);
				_Changes.push_back(CChange(0, ConnectionReady));
				_ImpulseDecoder.reset();
				receiveNormalMessage(msgin);
				return true;
			}
		}
	}

	// send ack sync if received sync or last sync timed out
	if (_UpdateTime-_LatestSyncTime > 300)
		sendSystemAckSync();

	return false;
}


#ifdef SHOW_PROPERTIES_RECEIVED
uint8 propReceived [18];
#endif
#ifdef MEASURE_RECEIVE_DATES
TTime currentTime;
#endif

//
// Connected state
//

void	CNetworkConnection::receiveNormalMessage(CBitMemStream &msgin)
{
	//nlinfo("CNET[%p]: received normal message Packet=%d Ack=%d", this, _LastReceivedNumber, _LastReceivedAck);

	vector<CAction *> actions;
	_ImpulseDecoder.decode(msgin, _CurrentReceivedNumber, _LastReceivedAck, _CurrentSendNumber, actions);
#ifdef SHOW_PROPERTIES_RECEIVED
	for ( uint8 p=0; p!=18; ++p )
		propReceived[p] = 0;
	propReceived[2] = actions.size();
#endif

	++_NormalPacketsReceived;


	// we can now remove all old action that are acked
	while (!_Actions.empty() && _Actions.front().FirstPacket != 0 && _Actions.front().FirstPacket <= _LastReceivedAck)
	{
		// warning, CActionBlock automatically remove() actions when deleted
		_Actions.pop_front();
	}

	// now, read actions
	/*vector<CAction *> commonActions;
	CActionFactory::getInstance()->unpack (msgin, commonActions, getCurrentServerTick()+1 ); // +1 because the current tick is set a few lines further

	actions.insert(actions.end(), commonActions.begin(), commonActions.end());*/

	//_PropertyDecoder.ack(_LastReceivedNumber, _LastReceivedAck);


	//
	// update game time and ticks from network infos
	//

#ifdef ENABLE_INCOMING_MSG_RECORDER
	if ( ! _ReplayIncomingMessagesOn )
#endif
	{
		// convert the number of the packet that we just received into tick
#ifdef HALF_FREQUENCY_SENDING_TO_CLIENT
		nlassert(_CurrentReceivedNumber*2+_Synchronize > _CurrentServerTick);
		_CurrentServerTick = _CurrentReceivedNumber*2+_Synchronize;
#else
		nlassert(_CurrentReceivedNumber+_Synchronize > _CurrentServerTick);
		_CurrentServerTick = _CurrentReceivedNumber+_Synchronize;
#endif
		//nldebug( "_CurrentServerTick=%d _CurrentReceivedNumber=%d _Synchronize=%d", _CurrentServerTick, _CurrentReceivedNumber, _Synchronize );
	}

	// remove useless stamps in queue
	while (!_PacketStamps.empty() && _LastReceivedAck > _PacketStamps.front().first)
		_PacketStamps.pop_front();

#ifdef ENABLE_INCOMING_MSG_RECORDER
	if ( (! _ReplayIncomingMessagesOn) && (_PacketStamps.empty() || _PacketStamps.front().first > _LastReceivedAck) )
#else
	if (_PacketStamps.empty() || _PacketStamps.front().first > _LastReceivedAck)
#endif
	{
		//nlwarning("Frontend ack'ed message %d not stamp dated", _LastReceivedAck);
	}
	else
	{
		// get the send time of the acknowledged packet
		TTime	ackedPacketTime = _PacketStamps.front().second;

		// update ping
		uint32	ping = (uint32)(_UpdateTime-ackedPacketTime);
		_InstantPing = ping;
		if (ping < _BestPing)
			_BestPing = ping;

		PingGraph.addOneValue (float(ping));

		// earliest estimation of server packet send time and latest estimation (based on ping and acknowledge)
		TTime	earliest = ackedPacketTime + _BestPing/2,
				latest = _UpdateTime - _BestPing/2;

		// compute number of ticks between frame currently played by client and packet received from server
		sint32	numStepTick = (sint32)(_CurrentServerTick-_CurrentClientTick);

		// if enough steps and times are valid
		if (numStepTick > 0 && earliest > _CurrentClientTime && latest > _CurrentClientTime)
		{
			// exact formula for _MsPerTick = (_CurrentServerTime-_CurrentClientTime)/numStepTick
			// where _CurrentServerTime is the actual server packet send time
			// but as the exact time is unknown, we use a predictive time window instead, based on
			// the acknwoledged packet send time, the received packet time and the ping

			// adjust if estimation of _MsPerTick is too small
			if ((TTime)(_CurrentClientTime+_MsPerTick*numStepTick) < earliest)
				setMsPerTick((sint32)(earliest-_CurrentClientTime)/numStepTick);
				//_MsPerTick = (sint32)(earliest-_CurrentClientTime)/numStepTick;

			// adjust if estimation of _MsPerTick is too large
			if ((TTime)(_CurrentClientTime+_MsPerTick*numStepTick) > latest)
				setMsPerTick((sint32)(latest-_CurrentClientTime)/numStepTick);
				//_MsPerTick = (sint32)(latest-_CurrentClientTime)/numStepTick;

			// _MsPerTick should be positive here -- seems to crash yet
			/// \todo we should instead of putting 1, returning in probe mode because it means that we had a very big lag
			if (_MsPerTick == 0)
			{
				nlwarning ("_MsPerTick is 0 because server tick is too big %d compare to the client tick is %d", _CurrentServerTick, _CurrentClientTick);
				setMsPerTick(1);
				//_MsPerTick = 1;
			}
		}
		else if (numStepTick <= 0)
		{
			setMsPerTick((sint32)_LCT);
			//_MsPerTick = (sint32)_LCT;
		}
		MsPerTickGraph.addOneValue (float(_MsPerTick));

	}

#ifdef MEASURE_RECEIVE_DATES
	currentTime = ryzomGetLocalTime ();
#endif

	// Decode the actions received in the impulsions
	uint i;
	for (i = 0; i < actions.size (); i++)
	{
		switch (actions[i]->Code)
		{

		case ACTION_DISCONNECTION_CODE:
			{
				// Self disconnection
				nlwarning( "You were disconnected by the server" );
				disconnect(); // will send disconnection message
				LoginSM.pushEvent( CLoginStateMachine::ev_conn_dropped );
			}
			break;
		case ACTION_GENERIC_CODE:
			{
				genericAction((CActionGeneric *)actions[i]);
			}
			break;
		case ACTION_GENERIC_MULTI_PART_CODE:
			{
				genericAction((CActionGenericMultiPart *)actions[i]);
			}
			break;
		case ACTION_DUMMY_CODE:
			{
				CActionDummy	*dummy = ((CActionDummy*)actions[i]);
				nldebug("CNET[%d] Received Dummy %d", this, dummy->Dummy1);
				// Nothing to do
			}
			break;
		}

		CActionFactory::getInstance()->remove(actions[i]);
	}


	// Decode the visual properties
	decodeVisualProperties( msgin );

	_LastReceivedNormalTime = _UpdateTime;

#ifdef DISPLAY_ENTITIES
	DownloadGraph.addValue ((float)(msgin.length()));
	DpfGraph.addValue ((float)(msgin.length()));
#endif
#ifdef SHOW_PROPERTIES_RECEIVED

	string str = "Received: ";
//	stringstream ss;
//	ss << "Received: ";
	if ( propReceived[2] != 0 )
		str += NLMISC::toString(propReceived[2]) + " impuls. ";
//		ss << propReceived[2] << " impuls. ";
	if ( propReceived[0] != 0 )
		str += NLMISC::toString(propReceived[0]) + " pos; ";
//	ss << propReceived[0] << " pos; ";
	if ( propReceived[3] != 0 )
		str += NLMISC::toString(propReceived[3]) + " orient; ";
//	ss << propReceived[3] << " orient; ";
	uint sum = propReceived[4] + propReceived[5] + propReceived[6] + propReceived[7] + propReceived[8] + propReceived[9];
	if ( sum != 0 )
		str += NLMISC::toString(sum) + " discreet; ";
//	ss << sum << " discreet; ";
	if ( propReceived[16] != 0 )
		str += NLMISC::toString(propReceived[16]) + "assoc; ";
//	ss << propReceived[16] << "assoc; ";
	if ( propReceived[17] != 0 )
		str += NLMISC::toString(propReceived[17]) + "disac; ";
//	ss << propReceived[17] << "disac; ";
	str += "TOTAL: " + NLMISC::toString(propReceived[2]) + " + " + NLMISC::toString(propReceived[0] + propReceived[3] + sum);
	//ss << "TOTAL: " << propReceived[2] << " + " << propReceived[0] + propReceived[3] + sum;
	nlwarning( "%s", str.c_str() );
#endif
}


void	CNetworkConnection::decodeVisualProperties( CBitMemStream& msgin )
{
	try
	{
		//nldebug( "pos: %d  len: %u", msgin.getPos(), msgin.length() );
		while ( true )
		{
			//nlinfo( "Reading pass %u, BEFORE HEADER: pos: %d  len: %u", ++i, msgin.getPosInBit(), msgin.length() * 8 );

			// Check if there is a new block to read
			if ( msgin.getPosInBit() + (sizeof(TCLEntityId)*8) > msgin.length()*8 )
				return;



			// Header
			TCLEntityId slot;
			msgin.serialAndLog1( slot );

			uint32 associationBits;
			msgin.serialAndLog2( associationBits, 2 );
			//nlinfo( "slot %hu AB: %u", (uint16)slot, associationBits );
			if ( associationBitsHaveChanged( slot, associationBits ) &&  (!IgnoreEntityDbUpdates || slot==0))
			{
			   //displayBitStream( msgin, beginbitpos, msgin.getPosInBit() );
//			   nlinfo ("Disassociating S%hu (AB %u)", (uint16)slot, associationBits );
				if ( _PropertyDecoder.isUsed( slot ) )
				{
					TSheetId sheet = _PropertyDecoder.sheet( slot );
					TIdMap::iterator it = _IdMap.find( sheet );
					if ( it != _IdMap.end() )
						_IdMap.erase(it);
					_PropertyDecoder.removeEntity( slot );

					CChange theChange( slot, RemoveOldEntity );
					_Changes.push_back( theChange );
				}
				else
				{
//					nlinfo( "Cannot disassociate slot %hu: sheet not received yet", (uint16)slot );
				}
			}

			// Read the timestamp delta if there's one (otherwise take _CurrentServerTick)
			TGameCycle timestamp;
			bool timestampIsThere;
			msgin.serialBitAndLog( timestampIsThere );
			if ( timestampIsThere )
			{
				uint32 timestampDelta;
				msgin.serialAndLog2( timestampDelta, 4 );
				timestamp = _CurrentServerTick - timestampDelta;
				//nldebug( "TD: %u (S%hu)", timestampDelta, (uint16)slot );
			}
			else
			{
				timestamp = _CurrentServerTick;
			}

			// Tree
			//nlinfo( "AFTER HEADER: posBit: %d pos: %d  len: %u", msgin.getPosInBit(), msgin.getPos(), msgin.length() );

			TVPNodeClient *currentNode = _VisualPropertyTreeRoot;
			msgin.serialBitAndLog( currentNode->a()->BranchHasPayload );
			if ( currentNode->a()->BranchHasPayload )
			{
				CActionPosition *ap = (CActionPosition*)CActionFactory::getInstance()->create( slot, ACTION_POSITION_CODE );
				ap->unpack( msgin );
				_PropertyDecoder.receive( _CurrentReceivedNumber, ap );
#ifdef SHOW_PROPERTIES_RECEIVED
				++propReceived[PROPERTY_POSITION];
#endif

				/*
				 * Set into property database
				 */

				// TEMP
				if ( ap->Position[0]==0 || ap->Position[1]==0 )
					nlwarning( "S%hu: Receiving an invalid position", (uint16)slot );

				if (_DataBase != NULL &&  (!IgnoreEntityDbUpdates || slot==0))
				{
					CCDBNodeBranch	*nodeRoot;
					nodeRoot = dynamic_cast<CCDBNodeBranch*>(_DataBase->getNode((uint16)0));
					if(nodeRoot)
					{
						CCDBNodeLeaf	*node;
						node = dynamic_cast<CCDBNodeLeaf*>(nodeRoot->getNode(slot)->getNode(0));
						nlassert(node != NULL);
						node->setValue64(ap->Position[0]);
						node = dynamic_cast<CCDBNodeLeaf*>(nodeRoot->getNode(slot)->getNode(1));
						nlassert(node != NULL);
						node->setValue64(ap->Position[1]);
						node = dynamic_cast<CCDBNodeLeaf*>(nodeRoot->getNode(slot)->getNode(2));
						nlassert(node != NULL);
						node->setValue64(ap->Position[2]);

						if ( LoggingMode )
						{
							nlinfo( "recvd position (%d,%d) for slot %hu, date %u", (sint32)(ap->Position[0]), (sint32)(ap->Position[1]), (uint16)slot, timestamp );
						}
					}
				}

				bool interior = ap->Interior;

				CActionFactory::getInstance()->remove( (CAction*&)ap );


				/*
				 * Statistical prediction of time before next position update: set PredictedInterval
				 */

				//nlassert( MAX_POSUPDATETICKQUEUE_SIZE > 1 );
				deque<TGameCycle>& puTicks = _PosUpdateTicks[slot];
				multiset<TGameCycle>& puIntervals = _PosUpdateIntervals[slot];

				// Flush the old element of tick queue and of the interval sorted set
				if ( puTicks.size() == MAX_POSUPDATETICKQUEUE_SIZE )
				{
					puIntervals.erase( puIntervals.find( puTicks[1] - puTicks[0] ) ); // erase only one element, not all corresponding to the value
					puTicks.pop_front();
				}

				// Add a new element to the tick queue and possibly to the interval sorted set
				// Still to choose: _CurrentServerTick or timestamp ?
				TGameCycle latestInterval = 0;
				if ( ! puTicks.empty() )
				{
					latestInterval =  timestamp - puTicks.back();
					puIntervals.insert( latestInterval );

					if ( PosUpdateIntervalGraph )
						PosUpdateIntervalGraph->addOneValue( slot, (float)latestInterval );
				}
				puTicks.push_back( timestamp );

				nlassert( puTicks.size() == puIntervals.size()+1 );

				// Prediction function : Percentile(25 last, 0.8) + 1
				TGameCycle predictedInterval;
				if ( puIntervals.empty() )
				{
					predictedInterval = 0;
				}
				else
				{
					predictedInterval = (TGameCycle)(percentileRev( puIntervals, PREDICTION_REV_PERCENTILE ) + 1);

					//if ( predictedInterval > 100 )
					//	nlwarning( "Slot %hu: Predicted interval %u exceeds 100 ticks", (uint16)slot, predictedInterval );

					if ( PosUpdatePredictionGraph )
						PosUpdatePredictionGraph->addOneValue( slot, (float)predictedInterval );
				}

				//nlinfo( "Slot %hu: Interval=%u Predicted=%u", (uint16)slot, latestInterval, predictedInterval );

				/*
				 * Add into the changes vector
				 */
				CChange thechange( slot, PROPERTY_POSITION, timestamp );
				thechange.PositionInfo.PredictedInterval = predictedInterval;
				thechange.PositionInfo.IsInterior = interior;
				_Changes.push_back( thechange );

#ifdef MEASURE_RECEIVE_DATES
				// Stat log
				if ( LogReceiveEnabled && (WatchedEntitySlot == 256) || (WatchedEntitySlot == slot) )
				{
					TRDateState ds( timestamp, predictedInterval, currentTime );
					ReceivePosDateLog[slot].push_back( ds );
				}
#endif

			}

			currentNode = currentNode->b();
			msgin.serialBitAndLog( currentNode->BranchHasPayload );
			if ( currentNode->BranchHasPayload )
			{
				msgin.serialBitAndLog( currentNode->a()->BranchHasPayload );
				if ( currentNode->a()->BranchHasPayload )
				{
					CActionSint64 *ac = (CActionSint64*)CActionFactory::getInstance()->createByPropIndex( slot, PROPERTY_ORIENTATION );
					ac->unpack( msgin );

					// Process orientation
					CChange thechange(slot, PROPERTY_ORIENTATION, timestamp);
					_Changes.push_back( thechange );
	#ifdef SHOW_PROPERTIES_RECEIVED
					++propReceived[PROPERTY_ORIENTATION];
	#endif
					if (_DataBase != NULL &&  (!IgnoreEntityDbUpdates || slot==0))
					{
						CCDBNodeBranch	*nodeRoot;
						nodeRoot = dynamic_cast<CCDBNodeBranch*>(_DataBase->getNode(0));
						if ( nodeRoot )
						{
							CCDBNodeLeaf *node = dynamic_cast<CCDBNodeLeaf*>(nodeRoot->getNode(slot)->getNode( PROPERTY_ORIENTATION ));
							nlassert(node != NULL);
							node->setValue64(ac->getValue());
							if ( LoggingMode )
							{
								nlinfo( "CLIENT: recvd property %hu (%s) for slot %hu, date %u", (uint16)PROPERTY_ORIENTATION, getPropText(PROPERTY_ORIENTATION), (uint16)slot, timestamp );
							}
							//nldebug("CLPROPNET[%p]: received property %d for entity %d: %"NL_I64"u", this, action->PropIndex, action->CLEntityId, action->getValue());
						}
					}

					CActionFactory::getInstance()->remove( (CAction*&)ac );
				}

				TVPNodeClient::SlotContext.NetworkConnection = this;
				TVPNodeClient::SlotContext.Slot = slot;
				TVPNodeClient::SlotContext.Timestamp = timestamp;

				// Discreet properties
				currentNode->b()->decodeDiscreetProperties( msgin );
			}
		}
	}
	catch ( EStreamOverflow& )
	{
		// End of stream (saves useless bits)
	}
}

/*
 *
 */

static vector<TCLEntityId>	TargetSlotsList(256);

void	CNetworkConnection::decodeDiscreetProperty( CBitMemStream& msgin, TPropIndex propIndex )
{
	//nldebug( "Reading discreet property %hu at bitpos %d", (uint16)propIndex, msgin.getPosInBit() );

	TCLEntityId slot = TVPNodeClient::SlotContext.Slot;

	// \todo BEN this is temp, put it somewhere in database
	if (propIndex == PROPERTY_TARGET_LIST)
	{
		uint8	listSize;
		msgin.serial(listSize);

		TargetSlotsList.resize(listSize);
		if (listSize > 0)
			msgin.serialBuffer(&(TargetSlotsList[0]), listSize);

		// Set target list value in database
		if (_DataBase != NULL && (!IgnoreEntityDbUpdates || slot==0))
		{
			CCDBNodeBranch	*nodeRoot;
			nodeRoot = dynamic_cast<CCDBNodeBranch*>(_DataBase->getNode(0));
			if ( nodeRoot )
			{
				CCDBNodeBranch *nodeEntity = dynamic_cast<CCDBNodeBranch*>(nodeRoot->getNode(slot));
				nlassert(nodeEntity != NULL);

				uint	writeProp = PROPERTY_TARGET_LIST;
				uint	place = 0;

				if (listSize >= 32)
				{
					listSize = 32;
				}
				else
				{
					TargetSlotsList.push_back(INVALID_SLOT);
					++listSize;
				}

				CCDBNodeLeaf *nodeProp = NULL;

				uint	i;
				uint64	value;
				for (i=0; i<listSize; ++i)
				{
					if (place == 0)
						value = 0;

					value += (((uint64)TargetSlotsList[i]) << (place*8));

					++place;
					if (place == 8)
					{
						nodeProp = dynamic_cast<CCDBNodeLeaf*>(nodeEntity->getNode(writeProp));
						nlassert(nodeProp != NULL);
						nodeProp->setValue64(value);
						++writeProp;
						place = 0;
					}
				}

				if (place != 0)
				{
					nodeProp = dynamic_cast<CCDBNodeLeaf*>(nodeEntity->getNode(writeProp));
					nlassert(nodeProp != NULL);
					nodeProp->setValue64(value);
				}
			}

			if ( LoggingMode )
			{
				nlinfo( "CLIENT: recvd property %hu (%s) for slot %hu, date %u", (uint16)propIndex, getPropText(propIndex), (uint16)slot, TVPNodeClient::SlotContext.Timestamp );
			}
		}

		CChange thechange( slot, propIndex, TVPNodeClient::SlotContext.Timestamp );
		_Changes.push_back( thechange );

		return;
	}

	CActionSint64 *ac = (CActionSint64*)CActionFactory::getInstance()->createByPropIndex( slot, propIndex );
	ac->unpack( msgin );

#ifdef SHOW_PROPERTIES_RECEIVED
		++propReceived[propIndex];
#endif

	switch ( propIndex )
	{
		case PROPERTY_SHEET:
		{
			// Special case for sheet
//			nlinfo ("Associating S%hu", (uint16)slot );
			if ( _PropertyDecoder.isUsed( slot ) )
			{
				TSheetId sheet = _PropertyDecoder.sheet( slot );
				TIdMap::iterator it = _IdMap.find(sheet);
				if ( it != _IdMap.end() )
					_IdMap.erase(it);
				_PropertyDecoder.removeEntity( slot );
			}

			TSheetId newSheetId = (TSheetId)(ac->getValue() & 0xffffffff);
			_IdMap.insert( make_pair( newSheetId, slot) );
			_PropertyDecoder.addEntity( slot, newSheetId );

			// Reset the position update statistical data
			_PosUpdateTicks[slot].clear();
			_PosUpdateIntervals[slot].clear();

			// Read optional alias block
			uint32 alias = 0;
			bool aliasBit = false;
			msgin.serialBitAndLog( aliasBit );
			if ( aliasBit )
				msgin.serialAndLog1( alias );

			// Set information
			CChange thechange( slot, AddNewEntity );
			thechange.NewEntityInfo.DataSetIndex = (TClientDataSetIndex)((ac->getValue() >> 32) & 0xffffffff);
			thechange.NewEntityInfo.Alias = alias;
			_Changes.push_back( thechange );
			break;
		}
		case PROPERTY_MODE:
		{
			// Special case for mode: push theta or pos, then mode
			uint64 mode44 = ac->getValue();
			uint32 modeTimestamp = _CurrentServerTick - (uint32)(((mode44 >> 8) & 0xF));

			// Push the mode Before the position or the orientation
			CChange thechangeMode( slot, PROPERTY_MODE, modeTimestamp );
			_Changes.push_back( thechangeMode );

			// Set mode value in database
			if (_DataBase != NULL &&  (!IgnoreEntityDbUpdates || slot==0))
			{
				CCDBNodeBranch	*nodeRoot;
				nodeRoot = dynamic_cast<CCDBNodeBranch*>(_DataBase->getNode(0));
				if ( nodeRoot )
				{
					CCDBNodeLeaf *node = dynamic_cast<CCDBNodeLeaf*>(nodeRoot->getNode(slot)->getNode( propIndex ));
					nlassert(node != NULL);
					node->setValue64(ac->getValue() & 0xFF); // (8 bits)
					if ( LoggingMode )
					{
						nlinfo( "CLIENT: recvd property %hu (%s) for slot %hu, date %u", (uint16)propIndex, getPropText(propIndex), (uint16)slot, TVPNodeClient::SlotContext.Timestamp );
					}
				}
			}

			// Set the position or orientation received along with the mode in the database
			uint8 modeEnum = (uint8)(mode44 & 0xFF);
			if ( modeEnum == MBEHAV::COMBAT_FLOAT )
			{
				// Set theta
				if (_DataBase != NULL &&  (!IgnoreEntityDbUpdates || slot==0))
				{
					CCDBNodeBranch	*nodeRoot;
					nodeRoot = dynamic_cast<CCDBNodeBranch*>(_DataBase->getNode(0));
					if ( nodeRoot )
					{
						CCDBNodeLeaf *node = dynamic_cast<CCDBNodeLeaf*>(nodeRoot->getNode(slot)->getNode( PROPERTY_ORIENTATION ));
						nlassert(node != NULL);
						node->setValue64( (mode44 >> 12) /*&& 0xFFFFFFFF*/ );
					}
				}
			}
			else
			{
				// Set 2D position (the position at TVPNodeClient::SlotContext.Timestamp is not sent at the same time as the position for Mode)
				if ( _DataBase != NULL &&  (!IgnoreEntityDbUpdates || slot==0))
				{
					uint16 x16 = (uint16)((ac->getValue() >> 12) & 0xFFFF);
					uint16 y16 = (uint16)((ac->getValue() >> 28) & 0xFFFF);
					if ( ! (x16==0 && y16==0) ) // don't set the position if it was not initialized yet
					{
						sint32 x, y;
						_PropertyDecoder.decodeAbsPos2D( x, y, x16, y16 );

						CCDBNodeBranch	*nodeRoot;
						nodeRoot = dynamic_cast<CCDBNodeBranch*>(_DataBase->getNode(0));
						if ( nodeRoot )
						{
							CCDBNodeLeaf	*node;
							node = dynamic_cast<CCDBNodeLeaf*>(nodeRoot->getNode(slot)->getNode(0));
							nlassert(node != NULL);
							node->setValue64( x );
							node = dynamic_cast<CCDBNodeLeaf*>(nodeRoot->getNode(slot)->getNode(1));
							nlassert(node != NULL);
							node->setValue64( y );
						}
					}
					else
					{
						nldebug( "%u: S%hu: Received mode with null pos", _CurrentServerTick, (uint16)slot ); // TEMP
					}
				}
			}
			break;
		}
/*		case PROPERTY_GUILD_SYMBOL:
			nlinfo("GuildSymbol received...");
*/
		default:
		{
			// special for Bars, always take _CurrentServerTick timestamp (delta timestamp decoded is mainly for position purpose...)
			NLMISC::TGameCycle	timeStamp= TVPNodeClient::SlotContext.Timestamp;
			/* YOYO: i don't know what to do with others property that really use the gamecycle and are maybe buggued:
				ENTITY_MOUNTED_ID,RIDER_ENTITY_ID,BEHAVIOUR,TARGET_LIST,TARGET_ID,VISUAL_FX
				But bars timestamp accuracy is very important (else could take DB property with falsly newer timestamp)
			*/
			if(propIndex== PROPERTY_BARS)
				timeStamp= _CurrentServerTick;

			// Process property
			CChange thechange( slot, propIndex, timeStamp );
			_Changes.push_back( thechange );
			if (_DataBase != NULL && (!IgnoreEntityDbUpdates || slot==0) )
			{
				CCDBNodeBranch	*nodeRoot;
				nodeRoot = dynamic_cast<CCDBNodeBranch*>(_DataBase->getNode(0));
				if ( nodeRoot )
				{
					CCDBNodeLeaf *node = dynamic_cast<CCDBNodeLeaf*>(nodeRoot->getNode(slot)->getNode( propIndex ));
					nlassert(node != NULL);
					node->setValue64(ac->getValue());
					if ( LoggingMode )
					{
						nlinfo( "CLIENT: recvd property %hu (%s) for slot %hu, date %u", (uint16)propIndex, getPropText(propIndex), (uint16)slot, TVPNodeClient::SlotContext.Timestamp );
					}
					//nldebug("CLPROPNET[%p]: received property %d for entity %d: %"NL_I64"u", this, action->PropIndex, action->CLEntityId, action->getValue());
				}
			}
		}
	}
	CActionFactory::getInstance()->remove( (CAction*&)ac );

#ifdef SHOW_PROPERTIES_RECEIVED
//	stringstream ss;
//	ss << "Received: ";
//	if ( propReceived[2] != 0 )
//		ss << propReceived[2] << " impuls. ";
//	if ( propReceived[0] != 0 )
//		ss << propReceived[0] << " pos; ";
//	if ( propReceived[3] != 0 )
//		ss << propReceived[3] << " orient; ";
//	uint sum = propReceived[4] + propReceived[5] + propReceived[6] + propReceived[7] + propReceived[8] + propReceived[9];
//	if ( sum != 0 )
//		ss << sum << " discreet; ";
//	if ( propReceived[16] != 0 )
//		ss << propReceived[16] << "assoc; ";
//	if ( propReceived[17] != 0 )
//		ss << propReceived[17] << "disac; ";
//	ss << "TOTAL: " << propReceived[2] << " + " << propReceived[0] + propReceived[3] + sum;

	string str = "Received: ";
	if ( propReceived[2] != 0 )
		str += NLMISC::toString(propReceived[2]) + " impuls. ";
	if ( propReceived[0] != 0 )
		str += NLMISC::toString(propReceived[0]) + " pos; ";
	if ( propReceived[3] != 0 )
		str += NLMISC::toString(propReceived[3]) + " orient; ";
	uint sum = propReceived[4] + propReceived[5] + propReceived[6] + propReceived[7] + propReceived[8] + propReceived[9];
	if ( sum != 0 )
		str += NLMISC::toString(sum) + " discreet; ";
	if ( propReceived[16] != 0 )
		str += NLMISC::toString(propReceived[16]) + "assoc; ";
	if ( propReceived[17] != 0 )
		str += NLMISC::toString(propReceived[17]) + "disac; ";
	str += "TOTAL: " + NLMISC::toString(propReceived[2]) + " + " + NLMISC::toString(propReceived[0] + propReceived[3] + sum);

	nlwarning( "%s", str.c_str() );
#endif
}


void	CNetworkConnection::sendNormalMessage()
{
	//nlinfo("CNET[%p]: send normal message Packet=%d Ack=%d AckBits=%08X", this, _CurrentSendNumber, _LastReceivedNumber, _AckBitMask);

	//
	// Create the message to send to the server
	//

	CBitMemStream	message;

	bool			systemMode = false;

	message.serial (_CurrentSendNumber);
	message.serial (systemMode);
	message.serial (_LastReceivedNumber);
	message.serial (_AckBitMask);

	uint			numPacked = 0;

	// pack each block
	TGameCycle						lastPackedCycle = 0;
	list<CActionBlock>::iterator	itblock;

	//nldebug("CNET[%p]: sending message %d", this, _CurrentSendNumber);

	for (itblock=_Actions.begin(); itblock!=_Actions.end(); ++itblock)
	{
		CActionBlock	&block = *itblock;

		// if block contains action that are not already stamped, don't send it now
		if (block.Cycle == 0)
			break;

		// Prevent to send a message too big
		//if (message.getPosInBit() + (*itblock).bitSize() > FrontEndInputBufferSize) // hard version
		//	break;

		if (block.FirstPacket == 0)
			block.FirstPacket = _CurrentSendNumber;

		//nlassertex((*itblock).Cycle > lastPackedCycle, ("(*itblock).Cycle=%d lastPackedCycle=%d", (*itblock).Cycle, lastPackedCycle));

		lastPackedCycle = block.Cycle;

		block.serial(message);
		++numPacked;

		//nldebug("CNET[%p]: packed block %d, message is currently %d bits long", this, block.Cycle, message.getPosInBit());

		// Prevent to send a message too big
		//if (message.getPosInBit() + (*itblock).bitSize() > FrontEndInputBufferSize) // hard version
		if ( message.getPosInBit() > 480*8 ) // easy version
			break;
	}

	//_PropertyDecoder.send (_CurrentSendNumber, _LastReceivedNumber);
	uint32	length = message.length();
	_Connection.send (message.buffer(), length);
	//sendUDP (&(_Connection), message.buffer(), length);
	statsSend(length);
	// remember send time
	_LastSendTime = CTime::getLocalTime();

	_PacketStamps.push_back(make_pair(_CurrentSendNumber, _UpdateTime));

	_CurrentSendNumber++;
}

bool	CNetworkConnection::stateConnected()
{
	// if receives System PROBE
	//    immediate state Probe
	// else if receives Normal
	//	   sends Normal data

#ifdef ENABLE_INCOMING_MSG_RECORDER
	if ( ! _ReplayIncomingMessagesOn )
#endif
	{
		// Prevent to increment the client time when the front-end does not respond
		static TTime previousTime = ryzomGetLocalTime ();
		TTime now = ryzomGetLocalTime ();
		TTime diff = now - previousTime;
		previousTime = now;
		if ( (diff > 3000) && (! _Connection.dataAvailable()) )
		{
			return false;
		}

		// update the current time;
		while (_CurrentClientTime < (TTime)(_UpdateTime - _MsPerTick - _LCT) && _CurrentClientTick < _CurrentServerTick)
		{
			_CurrentClientTime += _MsPerTick;

			_CurrentClientTick++;

			_MachineTimeAtTick = _UpdateTime;
			_MachineTicksAtTick = _UpdateTicks;
		}

		if (_CurrentClientTick >= _CurrentServerTick && !_Connection.dataAvailable())
		{
			return false;
		}
	}

#ifdef ENABLE_INCOMING_MSG_RECORDER
	if ( ClientCfg.Local && !_ReplayIncomingMessagesOn )
		return false;
	while ( (_ReplayIncomingMessagesOn && dataToReplayAvailable()) ||
			_Connection.dataAvailable() )
#else
	while (_Connection.dataAvailable())// && _TotalMessages<5)
#endif
	{
		_DecodedHeader = false;
		CBitMemStream	msgin (true);

		if (buildStream(msgin) && decodeHeader(msgin))
		{
			if (_SystemMode)
			{
				uint8	message;
				msgin.serial(message);

				switch (message)
				{
				case SYSTEM_PROBE_CODE:
					// receive probe, and goto state probe
					_ConnectionState = Probe;
					// reset client impulse & vars
/*
					_ImpulseDecoder.reset();
					_PropertyDecoder.clear();
					_PacketStamps.clear();
					// clears sent actions
					while (!_Actions.empty())
						CActionFactory::getInstance()->remove(_Actions.front().Actions),
					_Actions.clear();
					_AckBitMask = 0;
					_LastReceivedNumber = 0xffffffff;
*/
					//nldebug("CNET[%p]: connected->probe", this);
					_Changes.push_back(CChange(0, ProbeReceived));
					receiveSystemProbe(msgin);
					return true;
					break;
				case SYSTEM_SYNC_CODE:
					// receive stalled, decode stalled and state stalled
					_ConnectionState = Synchronize;
					//nldebug("CNET[%p]: connected->synchronize", this);
					receiveSystemSync(msgin);
					return true;
					break;
				case SYSTEM_STALLED_CODE:
					// receive stalled, decode stalled and state stalled
					_ConnectionState = Stalled;
					//nldebug("CNET[%p]: connected->stalled", this);
					receiveSystemStalled(msgin);
					return true;
					break;
				case SYSTEM_SERVER_DOWN_CODE:
					disconnect(); // will send disconnection message
					nlwarning( "BACK-END DOWN" );
					return false; // exit now from loop, don't expect a new state
					break;
				default:
					nlwarning("CNET[%p]: received system %d in state Connected", this, message);
					break;
				}
			}
			else
			{
				receiveNormalMessage(msgin);
			}

		}
	}

	return false;
}




//
// Probe state
//

void	CNetworkConnection::receiveSystemProbe(CBitMemStream &msgin)
{
	_LatestProbeTime = _UpdateTime;
	msgin.serial(_LatestProbe);
	_LatestProbes.push_back(_LatestProbe);

	//nldebug("CNET[%p]: received PROBE %d", this, _LatestProbe);
}

// sends system sync acknowledge
void	CNetworkConnection::sendSystemAckProbe()
{
	CBitMemStream	message;

	buildSystemHeader(message);

	uint8			probe = SYSTEM_ACK_PROBE_CODE;
	uint32			numprobes = (uint32)_LatestProbes.size();

	message.serial(probe);
	message.serial(numprobes);

	uint	i;
	for (i=0; i<numprobes; ++i)
		message.serial(_LatestProbes[i]);

	_LatestProbes.clear();

	uint32	length = message.length();
	_Connection.send (message.buffer(), length);
	//sendUDP (&(_Connection), message.buffer(), length);
	statsSend(length);

	//nlinfo("CNET[%p]: sent ACK_PROBE (%d probes)", this, numprobes);
}

bool	CNetworkConnection::stateProbe()
{
	// if receives System SYNC
	//    immediate state SYNC
	// else if receives System PROBE
	//    decode PROBE
	// sends System ACK_PROBE
#ifdef ENABLE_INCOMING_MSG_RECORDER
	if ( ClientCfg.Local && !_ReplayIncomingMessagesOn )
		return false;
	while ( (_ReplayIncomingMessagesOn && dataToReplayAvailable()) ||
			_Connection.dataAvailable() )
#else
	while (_Connection.dataAvailable())// && _TotalMessages<5)
#endif
	{
		_DecodedHeader = false;
		CBitMemStream	msgin (true);
		if (buildStream(msgin) && decodeHeader(msgin))
		{
			if (_SystemMode)
			{
				uint8	message;
				msgin.serial(message);

				switch (message)
				{
				case SYSTEM_SYNC_CODE:
					// receive sync, decode sync and state synchronize
					_ConnectionState = Synchronize;
					//nldebug("CNET[%p]: probe->synchronize", this);
					receiveSystemSync(msgin);
					return true;
					break;
				case SYSTEM_STALLED_CODE:
					// receive sync, decode sync and state synchronize
					_ConnectionState = Stalled;
					//nldebug("CNET[%p]: probe->stalled", this);
					receiveSystemStalled(msgin);
					return true;
					break;
				case SYSTEM_PROBE_CODE:
					// receive sync, decode sync
					receiveSystemProbe(msgin);
					break;
				case SYSTEM_SERVER_DOWN_CODE:
					disconnect(); // will send disconnection message
					nlwarning( "BACK-END DOWN" );
					return false; // exit now from loop, don't expect a new state
					break;
				default:
					nlwarning("CNET[%p]: received system %d in state Probe", message);
					break;
				}
			}
			else
			{
				nlwarning("CNET[%p]: received normal in state Probe", this);
			}
		}
	}

	// send ack sync if received sync or last sync timed out
	if (!_LatestProbes.empty() || _UpdateTime-_LatestProbeTime > 300)
	{
		sendSystemAckProbe();
		_LatestProbeTime = _UpdateTime;
	}
	else
		nlSleep(10);

	return false;
}





//
// Stalled state
//

void	CNetworkConnection::receiveSystemStalled(CBitMemStream &/* msgin */)
{
	nldebug("CNET[%p]: received STALLED", this);
}

bool	CNetworkConnection::stateStalled()
{
	// if receives System SYNC
	//    immediate state SYNC
	// else if receives System STALLED
	//    decode STALLED (nothing to do)
	// else if receives System PROBE
	//    immediate state PROBE
#ifdef ENABLE_INCOMING_MSG_RECORDER
	if ( ClientCfg.Local && !_ReplayIncomingMessagesOn )
		return false;
	while ( (_ReplayIncomingMessagesOn && dataToReplayAvailable()) ||
			_Connection.dataAvailable() )
#else
	while (_Connection.dataAvailable())// && _TotalMessages<5)
#endif
	{
		_DecodedHeader = false;
		CBitMemStream	msgin (true);
		if (buildStream(msgin) && decodeHeader(msgin))
		{
			if (_SystemMode)
			{
				uint8	message;
				msgin.serial(message);

				switch (message)
				{
				case SYSTEM_SYNC_CODE:
					// receive sync, decode sync and state synchronize
					_ConnectionState = Synchronize;
					nldebug("CNET[%p]: stalled->synchronize", this);
					receiveSystemSync(msgin);
					return true;
					break;
				case SYSTEM_PROBE_CODE:
					// receive sync, decode sync
					_ConnectionState = Probe;
					nldebug("CNET[%p]: stalled->probe", this);
					receiveSystemProbe(msgin);
					break;
				case SYSTEM_STALLED_CODE:
					// receive stalled, decode stalled
					receiveSystemStalled(msgin);
					break;
				case SYSTEM_SERVER_DOWN_CODE:
					disconnect(); // will send disconnection message
					nlwarning( "BACK-END DOWN" );
					return false; // exit now from loop, don't expect a new state
					break;
				default:
					nlwarning("CNET[%p]: received system %d in state Stalled", message);
					break;
				}
			}
			else
			{
				nlwarning("CNET[%p]: received normal in state Stalled", this);
			}
		}
	}

	return false;
}





//
// encoding / decoding methods
//

bool	CNetworkConnection::decodeHeader(CBitMemStream &msgin, bool checkMessageNumber)
{
	if (_DecodedHeader)
		return true;

	// simulate packet loss
#if !FINAL_VERSION
	if(uint((rand()%100)) < ClientCfg.SimulatePacketLossRatio)
		return false;
#endif

	++_TotalMessages;

	_LastReceivedTime = _UpdateTime;

	msgin.serial (_CurrentReceivedNumber);
	msgin.serial (_SystemMode);

	if ((sint)_CurrentReceivedNumber > (sint)_LastReceivedPacketInBothModes && checkMessageNumber)
	{
		_TotalLostPackets += (_CurrentReceivedNumber-_LastReceivedPacketInBothModes - 1);
		_LastReceivedPacketInBothModes = _CurrentReceivedNumber;
	}

	_MeanPackets.update((float)_CurrentReceivedNumber, ryzomGetLocalTime ());

	/// \todo remove
	//nlinfo("DBG:BEN: decodeHeader, packet=%d, %s", _CurrentReceivedNumber, _SystemMode ? "SYSTEM" : "NORMAL");
	///

	if (_SystemMode)
	{
	}
	else
	{
		msgin.serial (_LastReceivedAck);

#ifdef INCLUDE_FE_STATS_IN_PACKETS
		// receive debug info in the message header
		uint32			UserLWatch,
						CycleWatch,
						ReceiveWatch,
						SendWatch;
		float			PriorityAmount;
		uint16			SeenEntities;
		//float			HpT;
		msgin.serial (UserLWatch);
		msgin.serial (CycleWatch);
		msgin.serial (ReceiveWatch);
		msgin.serial (SendWatch);
		msgin.serial (PriorityAmount);
		msgin.serial (SeenEntities);
		//msgin.serial (HpT);
#endif

#ifdef DISPLAY_ENTITIES
		UserLWatchGraph.addOneValue ((float)UserLWatch);
		CycleWatchGraph.addOneValue ((float)CycleWatch);
		ReceiveWatchGraph.addOneValue ((float)ReceiveWatch);
		SendWatchGraph.addOneValue ((float)SendWatch);
		PriorityAmountGraph.addOneValue(PriorityAmount);
		SeenEntitiesGraph.addOneValue(SeenEntities);
		//HPThreshold = HpT;
#else
		static sint counter = 128;
		--counter;
		if ( counter == 0 )
		{
//			nlinfo( "User:%u Cycle:%u Rcv:%u Snd:%u PrioAmount:%.2f",
//					UserLWatch, CycleWatch, ReceiveWatch, SendWatch, PriorityAmount );
			counter = 128;
		}
#endif // DISPLAY_ENTITIES
	}

	if (!checkMessageNumber)
		return true;

	// display info on this packet
	//nlinfo("CNET[%p] received packet %d, %s mode - LastReceivedAck=%d", this, _CurrentReceivedNumber, _SystemMode ? "SYTEM" : "NORMAL", _LastReceivedAck);

	// todo doesn't work if we receive the packet in bad order or 2 same packet

	if (_CurrentReceivedNumber > _LastReceivedNumber+1)
	{
		// we lost some messages...
		nldebug ("CNET[%p] lost messages server->client [%d; %d]", this, _LastReceivedNumber+1, _CurrentReceivedNumber-1);
		_MeanLoss.update((float)(_CurrentReceivedNumber-_LastReceivedNumber-1), ryzomGetLocalTime ());
	}
	else if (_CurrentReceivedNumber == _LastReceivedNumber)
	{
		// we receive the same packet that the last one
		nldebug ("CNET[%p] awaiting packet %d, received packet %d", this, _LastReceivedNumber+1, _CurrentReceivedNumber);
		return false;
	}
	else if (_CurrentReceivedNumber < _LastReceivedNumber)
	{
		// it's an older message than the current
		nldebug ("CNET[%p] received an old message, awaiting packet %d, received packet %d", this, _LastReceivedNumber+1, _CurrentReceivedNumber);
		return false;
	}

	// don't acknowledge system messages and normal messages in
	// because this will disturb impulsion from frontend, that will interpret it as if previous messages were ok
	bool	ackBool = (!_SystemMode && (_ConnectionState == Connected || _ConnectionState == Synchronize));
	uint	ackBit = (ackBool ? 1 : 0);

	if (_CurrentReceivedNumber - _LastReceivedNumber < 32)
	{
		_AckBitMask <<= _CurrentReceivedNumber - _LastReceivedNumber;
		_AckBitMask |= _LastAckBit << (_CurrentReceivedNumber - _LastReceivedNumber - 1);
	}
	else
	{
		_AckBitMask = (_CurrentReceivedNumber - _LastReceivedNumber == 32 && _LastAckBit != 0) ? 0x80000000 : 0x00000000;
	}

	_LastAckBit = ackBit;

	// encode long ack bitfield
	TPacketNumber	i;
	for (i=_LastReceivedNumber+1; i<_CurrentReceivedNumber; ++i)
		_LongAckBitField.clear(i&(NumBitsInLongAck-1));

	_LongAckBitField.set(_CurrentReceivedNumber&(NumBitsInLongAck-1), ackBool);


	// no more than NumBitsInLongAck ack in field
	if ((TPacketNumber)_LastAckInLongAck <= (TPacketNumber)(_CurrentReceivedNumber-NumBitsInLongAck))
		_LastAckInLongAck = _CurrentReceivedNumber-NumBitsInLongAck+1;

	_LastReceivedNumber = _CurrentReceivedNumber;

	_DecodedHeader = true;

	return true;
}

void	CNetworkConnection::buildSystemHeader(NLMISC::CBitMemStream &msgout)
{
	msgout.serial (_CurrentSendNumber);
	bool			systemMode = true;
	msgout.serial (systemMode);

	_PacketStamps.push_back(make_pair(_CurrentSendNumber, _UpdateTime));

	++_CurrentSendNumber;
}

//
//
//


void	CNetworkConnection::setDataBase(CCDBNodeBranch *database)
{
	_DataBase = database;
}


//
//
//

void	CNetworkConnection::push(CBitMemStream &msg)
{
	sint32	maxImpulseBitSize = 230*8;

	CActionGeneric *ag = (CActionGeneric *)CActionFactory::getInstance ()->create (INVALID_SLOT, ACTION_GENERIC_CODE);
	if( ag == NULL ) //TODO: see that with oliver...
		return;

	uint	bytelen = msg.length();
	sint32	impulseMinBitSize = (sint32)CActionFactory::getInstance ()->size( ag );
	sint32	impulseBitSize = impulseMinBitSize + (4 + bytelen)*8;

	if (impulseBitSize < maxImpulseBitSize)
	{
		ag->set(msg);
		push(ag);
	}
	else
	{
		CAction	*casted = ag;
		CActionFactory::getInstance()->remove(casted);
		ag = NULL;

		// MultiPart impulsion
		CActionGenericMultiPart *agmp = (CActionGenericMultiPart *)CActionFactory::getInstance ()->create (INVALID_SLOT, ACTION_GENERIC_MULTI_PART_CODE);
		sint32 minimumBitSizeForMP = CActionFactory::getInstance ()->size (agmp);

		sint32 availableSize = (maxImpulseBitSize - minimumBitSizeForMP) / 8; // (in bytes)
#ifdef NL_DEBUG
		nlassert( availableSize > 0 ); // the available size must be larger than the 'empty' size
#endif
		sint32 nbBlock = (bytelen + availableSize - 1) / availableSize;

		uint8 num = _ImpulseMultiPartNumber++;

		for (sint32 i = 0; i < nbBlock; i++)
		{
			if (i != 0)
				agmp = (CActionGenericMultiPart *)CActionFactory::getInstance ()->create (INVALID_SLOT, ACTION_GENERIC_MULTI_PART_CODE);

			agmp->set(num, (uint16)i, msg.buffer(), bytelen, availableSize, (uint16)nbBlock);
			push(agmp);
		}
	}
}

void	CNetworkConnection::pushTarget(TCLEntityId slot, LHSTATE::TLHState targetOrPickup )
{
	CActionTargetSlot *ats = (CActionTargetSlot*)CActionFactory::getInstance ()->create (INVALID_SLOT, ACTION_TARGET_SLOT_CODE);
	nlassert (ats != NULL);
	ats->Slot = slot;
	switch ( targetOrPickup ) // ensure the value is good for the FE
	{
		case LHSTATE::NONE: ats->TargetOrPickup = 0; break;
		case LHSTATE::LOOTABLE: ats->TargetOrPickup = 1; break;
		case LHSTATE::HARVESTABLE: ats->TargetOrPickup = 2; break;
	}

	ats->TargetOrPickup = (uint32)targetOrPickup;
	push(ats);
}


void	CNetworkConnection::push(CAction *action)
{
	if (_Actions.empty() || _Actions.back().Cycle != 0)
	{
		//nlinfo("-BEEN- push back 2 [size=%d, cycle=%d]", _Actions.size(), _Actions.empty() ? 0 : _Actions.back().Cycle);
		_Actions.push_back(CLFECOMMON::CActionBlock());
	}

	_Actions.back().Actions.push_back(action);
}


//

void	CNetworkConnection::send(TGameCycle cycle)
{
	try
	{
		// check the current game cycle was not already sent
		nlassertex(_LastSentCycle < cycle, ("Client=%p, _LastSentCycle=%d, cycle=%d", this, _LastSentCycle, cycle));

	/*
		if (_LastSentCycle == cycle)	// delay send till next tick
			return;
	*/
		_LastSentCycle = cycle;

		// if no actions were sent at this cyle, create a new block
		if (_Actions.empty() || _Actions.back().Cycle != 0)
		{
	//		nlinfo("-BEEN- push back 1 [size=%d, cycle=%d]", _Actions.size(), _Actions.empty() ? 0 : _Actions.back().Cycle);
	//		_Actions.push_back();
		}
		else
		{
			CActionBlock	&block = _Actions.back();
/*
			CAction	*dummy = CActionFactory::getInstance()->create(INVALID_SLOT, ACTION_DUMMY_CODE);
			((CActionDummy*)dummy)->Dummy1 = _DummySend++;
			push(dummy);
*/

			_Actions.back().Cycle = cycle;

			// check last block isn't bigger than maximum allowed
			uint	i;
			uint	bitSize = 32+8;		// block size is 32 (cycle) + 8 (number of actions
			for (i=0; i<block.Actions.size(); ++i)
			{
				bitSize += CActionFactory::getInstance()->size(block.Actions[i]);
				if (bitSize >= 480*8)
					break;
			}

			if (i<block.Actions.size())
			{
				nldebug( "Postponing %u actions exceeding max size in block %d (block size is %d bits long)", block.Actions.size()-i, cycle, bitSize );

				// last block is bigger than allowed

				// allocate a new block
				_Actions.push_back(CActionBlock());
				CActionBlock	&newBlock = _Actions.back();

				// reset block stamp
				newBlock.Cycle = 0;

				// copy remaining actions in new block
				newBlock.Actions.insert(newBlock.Actions.begin(),
										block.Actions.begin()+i,
										block.Actions.end());

				// remove remaining actions of block
				block.Actions.erase(block.Actions.begin()+i, block.Actions.end());
			}

			//nlinfo("-BEEN- setcycle [size=%d, cycle=%d]", _Actions.size(), _Actions.empty() ? 0 : _Actions.back().Cycle);
		}

		if (_ConnectionState == Connected)
		{
			sendNormalMessage();
		}
	}
	catch (ESocket &/*e*/)
	{
		_ConnectionState = Disconnect;
		disconnect(); // won't send disconnection message as state is already Disconnect
	}
}


void	CNetworkConnection::send()
{
	try
	{
		// Send is temporised, that is the packet may not be actually sent.
		// We don't care, since:
		// - this packet has no new data (not ticked send)
		// - a next send() will send packet if time elapsed enough
		// - a next send(tick) will really be sent
		// This way, we can say that at most 15 packets will be delivered each second
		// (5 send(tick), and 10 send() -- if you take getLocalTime() inaccuracy into account)
		if (_ConnectionState == Connected && CTime::getLocalTime()-_LastSendTime > 100)
		{
			sendNormalMessage();
		}
	}
	catch (ESocket &/*e*/)
	{
		_ConnectionState = Disconnect;
	}
}

//
//
//

// sends system sync acknowledge
void	CNetworkConnection::sendSystemDisconnection()
{
	CBitMemStream	message;

	buildSystemHeader(message);

	uint8			disconnection = SYSTEM_DISCONNECTION_CODE;

	message.serial(disconnection);

	uint32	length = message.length();

	if (_Connection.connected())
		_Connection.send (message.buffer(), length);
	//sendUDP (&(_Connection), message.buffer(), length);
	statsSend(length);

	updateBufferizedPackets ();
	nlinfo("CNET[%p]: sent DISCONNECTION", this);
}

void	CNetworkConnection::disconnect()
{
#ifdef MEASURE_RECEIVE_DATES
	if ( LogReceiveEnabled )
	{
		displayReceiveLog();
	}
#endif

	if (_ConnectionState == NotInitialised ||
		_ConnectionState == NotConnected ||
		_ConnectionState == Authenticate ||
		_ConnectionState == Disconnect)
	{
		//nlwarning("Unable to disconnect(): not connected yet, or already disconnected.");
		return;
	}

	sendSystemDisconnection();
	_Connection.close();
	_ConnectionState = Disconnect;
}



//
// Quit state
//

void	CNetworkConnection::receiveSystemAckQuit(CBitMemStream &/* msgin */)
{
	nldebug("CNET[%p]: received ACK_QUIT", this);
	_ReceivedAckQuit = true;

}

bool	CNetworkConnection::stateQuit()
{

#ifdef ENABLE_INCOMING_MSG_RECORDER
	if ( ClientCfg.Local && !_ReplayIncomingMessagesOn )
		return false;
	while ( (_ReplayIncomingMessagesOn && dataToReplayAvailable()) ||
			_Connection.dataAvailable() )
#else
	while (_Connection.dataAvailable())// && _TotalMessages<5)
#endif
	{
		_DecodedHeader = false;
		CBitMemStream	msgin (true);
		if (buildStream(msgin) && decodeHeader(msgin, false))
		{
			if (_SystemMode)
			{
				uint8	message;
				msgin.serial(message);

				switch (message)
				{
				case SYSTEM_SYNC_CODE:
					// receive sync, decode sync and state synchronize
					reset();
					_ConnectionState = Synchronize;
					nldebug("CNET[%p]: quit->synchronize", this);
					receiveSystemSync(msgin);
					return true;
					break;
/*
				case SYSTEM_PROBE_CODE:
					// receive sync, decode sync
					_ConnectionState = Probe;
					nldebug("CNET[%p]: stalled->probe", this);
					receiveSystemProbe(msgin);
					break;
				case SYSTEM_STALLED_CODE:
					// receive stalled, decode stalled
					_ConnectionState = Stalled;
					receiveSystemStalled(msgin);
					return true;
					break;
*/
				case SYSTEM_SERVER_DOWN_CODE:
					disconnect(); // will send disconnection message
					nlwarning( "BACK-END DOWN" );
					return false; // exit now from loop, don't expect a new state
					break;
				case SYSTEM_ACK_QUIT_CODE:
					// receive ack quit -> reset connection state
					receiveSystemAckQuit(msgin);
					break;
				default:
					nlwarning("CNET[%p]: received system %d in state Stalled", message);
					break;
				}
			}
			else
			{
				nlwarning("CNET[%p]: received normal in state Stalled", this);
			}
		}
	}

	// send quit if not yet received a ack quit
	if (!_ReceivedAckQuit && _UpdateTime-_LatestQuitTime > 100)
	{
		sendSystemQuit();
		_LatestQuitTime = _UpdateTime;
	}

	return false;
}

/*
 * Quit the game till the connection is reset
 */
void	CNetworkConnection::quit()
{
	nlinfo("CNetworkConnection::quit() called, setting to quitting state.");

	++_QuitId;
	_ConnectionState = Quit;
	_ReceivedAckQuit = false;
	_LatestQuitTime = _UpdateTime;

	sendSystemQuit();
}

void	CNetworkConnection::reset()
{
	_CurrentSendNumber = 0;
	_LastReceivedNumber = 0;
	_LastReceivedTime = 0;
	_LastReceivedNormalTime = 0;
	_AckBitMask = 0;
	_LastAckBit = 0;

	_Synchronize = 0;
	_InstantPing = 10000;
	_BestPing = 10000;
	_LCT = 100;
	_MachineTimeAtTick = ryzomGetLocalTime ();
	_MachineTicksAtTick = CTime::getPerformanceTime();
	_LastSentSync = 0;
	_LatestSync = 0;

	_PropertyDecoder.init (256);

	_DummySend = 0;
	_LongAckBitField.resize(1024);
	_LastAckInLongAck = 0;
	_LastSentCycle = 0;

	_TotalReceivedBytes = 0;
	_PartialReceivedBytes = 0;
	_TotalSentBytes = 0;
	_PartialSentBytes = 0;
	_MeanPackets.MeanPeriod = 5000;
	_MeanLoss.MeanPeriod = 5000;

	_LastReceivedPacketInBothModes = 0;
	_TotalLostPackets = 0;
	_ConnectionQuality = false;

	_CurrentSmoothServerTick= 0;
	_SSTLastLocalTime= 0;
}

void	CNetworkConnection::initTicks()
{
	_CurrentClientTick = 0;
	_CurrentServerTick = 0;
	_MsPerTick = 100;
	_LCT = 1000;
}

void	CNetworkConnection::reinit()
{
	// Reset data
	_ImpulseDecoder.reset();
	if (_DataBase)
		_DataBase->resetData(_CurrentServerTick, true);
	_LongAckBitField.clearAll();
	_PacketStamps.clear();
	_Actions.clear();
	_Changes.clear();
	_GenericMultiPartTemp.clear();
	_IdMap.clear();
	reset();
	initTicks();

	// Reuse the udp socket
	_Connection.~CUdpSimSock();
	new (&_Connection) CUdpSimSock();
}

// sends system sync acknowledge
void	CNetworkConnection::sendSystemQuit()
{
	CBitMemStream	message;

	buildSystemHeader(message);

	uint8			quit = SYSTEM_QUIT_CODE;

	message.serial(quit);
	message.serial(_QuitId);

	uint32	length = message.length();
	_Connection.send (message.buffer(), length);
	//sendUDP (&(_Connection), message.buffer(), length);
	statsSend(length);

	updateBufferizedPackets ();
	nlinfo("CNET[%p]: sent QUIT", this);
}

//

void	CNetworkConnection::displayAllocationStats()
{
	nlinfo("CNET[%p]: %d queued blocks, %d changes", this, _Actions.size(), _Changes.size());
}

string	CNetworkConnection::getAllocationStats()
{
	char	buf[128];
	sprintf(buf, "CNET[%p]: %d queued blocks, %d changes", this, _Actions.size(), _Changes.size());
	return string(buf);
}


//
//
//

void CNetworkConnection::genericAction (CActionGeneric *ag)
{
	// manage a generic action
	CBitMemStream &bms = ag->get ();

	//nldebug("CNET: Calling impulsion callback (size %u) :'%s'", this, bms.length(), toHexaString(bms.bufferAsVector()).c_str());
	//nldebug("CNET[%p]: Calling impulsion callback (size %u)", this, bms.length());

	if (_ImpulseCallback != NULL)
		_ImpulseCallback(bms, _LastReceivedNumber, _ImpulseArg);
}

void CNetworkConnection::CGenericMultiPartTemp::set (CActionGenericMultiPart *agmp, CNetworkConnection *parent)
{
	if (NbBlock == 0xFFFFFFFF)
	{
		// new GenericMultiPart
		NbBlock = agmp->NbBlock;
		NbCurrentBlock = 0;
		TempSize = 0;
		Temp.clear();
		Temp.resize(NbBlock);
		BlockReceived.resize(NbBlock);
		for (uint i = 0; i < NbBlock; i++)
			BlockReceived[i] = false;
	}

	nlassert (NbBlock == agmp->NbBlock);
	nlassert (NbBlock > agmp->Part);

	// check if the block was already received
	if (BlockReceived[agmp->Part])
	{
		nlwarning ("CLMPNET[%p]: This part is already received, discard it", this);
		return;
	}

	Temp[agmp->Part] = agmp->PartCont;
	BlockReceived[agmp->Part] = true;

	NbCurrentBlock++;
	TempSize += (uint32)agmp->PartCont.size();

	if (NbCurrentBlock == NbBlock)
	{
		// reform the total action

		//nldebug("CLMPNET[%p]: Received a TOTAL generic action MP size: number %d nbblock %d", this,  agmp->Number, NbBlock);

		CBitMemStream bms(true);

		uint8 *ptr = bms.bufferToFill (TempSize);

		for (uint i = 0; i < Temp.size (); i++)
		{
			memcpy (ptr, &(Temp[i][0]), Temp[i].size());
			ptr += Temp[i].size();
		}

		NbBlock = 0xFFFFFFFF;

		//nldebug("CLMPNET[%p]: Received a generic action size %d", this, bms.length());
		// todo interface api, call a user callback

		if (parent->_ImpulseCallback != NULL)
			parent->_ImpulseCallback(bms, parent->_LastReceivedNumber, parent->_ImpulseArg);

	}
}

void CNetworkConnection::genericAction (CActionGenericMultiPart *agmp)
{
	// manage a generic action (big one that comes by blocks)
	vector<uint8> &v = agmp->PartCont;

	//nldebug("CLMPNET[%p]: Received a generic action MP size %d: number %d part %d nbblock %d", this, v.size(), agmp->Number, agmp->Part, agmp->NbBlock);

	// add it

	if (_GenericMultiPartTemp.size() <= agmp->Number)
	{
		_GenericMultiPartTemp.resize (agmp->Number+1);
	}

	_GenericMultiPartTemp[agmp->Number].set(agmp, this);

}


CNetworkConnection::TVPNodeClient::TSlotContext							CNetworkConnection::TVPNodeClient::SlotContext;

/*
 * Return the average billed upload rate in kbps, including all headers (UDP+IP+Ethernet)
 */
void CNetworkConnection::statsSend(uint32 bytes)
{
	_TotalSentBytes += bytes;
	_PartialSentBytes += bytes;
	_MeanUpload.update((float)bytes, ryzomGetLocalTime ());

	UploadGraph.addValue ((float)bytes);
}


/*
 * Return the average billed download rate in kbps, including all headers (UDP+IP+Ethernet)
 */
void CNetworkConnection::statsReceive(uint32 bytes)
{
	_TotalReceivedBytes += bytes;
	_PartialReceivedBytes += bytes;
	_MeanDownload.update((float)bytes, ryzomGetLocalTime ());

	DownloadGraph.addValue ((float)bytes);
}


NLMISC_COMMAND( displayPosUpdateGraph, "Display position update interval graph", "0|<slot>" )
{
	// Stop graph in all cases
	if ( PosUpdateIntervalGraph )
	{
		delete PosUpdateIntervalGraph;
		delete PosUpdatePredictionGraph;
		PosUpdateIntervalGraph = NULL;
		PosUpdatePredictionGraph = NULL;
	}

	// Start graph if argument is not 0
	if ( (args.size() != 0) && (args[0] != "0") )
	{
		uint8 slot;
		fromString(args[0], slot);
		PosUpdateIntervalGraph = new CSlotGraph( "Interval", 350, 2, 100, 200, CRGBA(128,0,0,64), 1000, 20, true, slot );
		PosUpdatePredictionGraph = new CSlotGraph( "                    Prediction", 350, 2, 100, 200, CRGBA(0,0,128,64), 1000, 20, true, slot );
	}
	return true;
}


// ***************************************************************************
sint64		CNetworkConnection::convertToSmoothServerTick(NLMISC::TGameCycle t) const
{
	return t*SMOOTH_SERVER_TICK_PER_TICK;
}


// ***************************************************************************
void		CNetworkConnection::updateSmoothServerTick()
{
	// Get deltaT
	NLMISC::TTime	t= ryzomGetLocalTime ();
	sint32	deltaT= (sint32)(t - _SSTLastLocalTime);
	_SSTLastLocalTime= t;

	// Get the actual ServerTick not smoothed value
	sint64	actualST= _CurrentServerTick*SMOOTH_SERVER_TICK_PER_TICK;

	// Special bound cases
	if( _CurrentSmoothServerTick < actualST+SMOOTH_SERVER_TICK_DIFF_MIN )
	{
		// Reset (possible jump to future!)
		_CurrentSmoothServerTick= actualST;
	}
	else if( _CurrentSmoothServerTick>= actualST+SMOOTH_SERVER_TICK_DIFF_MAX )
	{
		// Clamp (no reset, no back to past!)
		_CurrentSmoothServerTick= actualST+SMOOTH_SERVER_TICK_DIFF_MAX;
	}
	else
	{
		// Compute the Factor of acceleration according to error difference (FIXED 16:16)
		sint64	factor;
		sint64	errorDiff= _CurrentSmoothServerTick-actualST;
		// If the estimation is in the TimeWindow, no acceleration
		if( errorDiff>=-SMOOTH_SERVER_TICK_WINDOW && errorDiff<=SMOOTH_SERVER_TICK_WINDOW)
		{
			factor= 65536;
		}
		// If the estimation is late, accelerate
		else if( errorDiff<0 )
		{
			float	f= (float)(errorDiff+SMOOTH_SERVER_TICK_WINDOW)/(SMOOTH_SERVER_TICK_DIFF_MIN+SMOOTH_SERVER_TICK_WINDOW);
			f*= SMOOTH_SERVER_TICK_ACCEL;
			factor= sint64(f*65536);
		}
		// Else the estimation is too early, slowDown
		else
		{
			float	f= (float)(errorDiff-SMOOTH_SERVER_TICK_WINDOW)/(SMOOTH_SERVER_TICK_DIFF_MAX-SMOOTH_SERVER_TICK_WINDOW);
			f= 1-f;
			factor= sint64(f*65536);
		}

		// Update the Smooth
		_CurrentSmoothServerTick+= ((deltaT*SMOOTH_SERVER_TICK_PER_TICK*factor)/getMsPerTick()) >> 16;
	}
}