Fixed c++11 branch issues.
This commit is contained in:
parent
d00ebd7ee7
commit
3c3cb198f3
@ -436,7 +436,8 @@ bool cConnection::RelayFromClient(void)
|
|||||||
|
|
||||||
double cConnection::GetRelativeTime(void)
|
double cConnection::GetRelativeTime(void)
|
||||||
{
|
{
|
||||||
return std::chrono::duration_cast<std::chrono::milliseconds>(std::chrono::steady_clock::now() - m_BeginTick).count() / 1000;
|
Int64 msec = std::chrono::duration_cast<std::chrono::milliseconds>(std::chrono::steady_clock::now() - m_BeginTick).count();
|
||||||
|
return static_cast<double>(msec) / 1000;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
@ -38,6 +38,11 @@
|
|||||||
/** Maximum number of block change interactions a player can perform per tick - exceeding this causes a kick */
|
/** Maximum number of block change interactions a player can perform per tick - exceeding this causes a kick */
|
||||||
#define MAX_BLOCK_CHANGE_INTERACTIONS 20
|
#define MAX_BLOCK_CHANGE_INTERACTIONS 20
|
||||||
|
|
||||||
|
/** The interval for sending pings to clients.
|
||||||
|
Vanilla sends one ping every 1 second. */
|
||||||
|
static const std::chrono::milliseconds PING_TIME_MS = std::chrono::milliseconds(1000);
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
@ -86,7 +91,7 @@ cClientHandle::cClientHandle(const cSocket * a_Socket, int a_ViewDistance) :
|
|||||||
|
|
||||||
s_ClientCount++; // Not protected by CS because clients are always constructed from the same thread
|
s_ClientCount++; // Not protected by CS because clients are always constructed from the same thread
|
||||||
m_UniqueID = s_ClientCount;
|
m_UniqueID = s_ClientCount;
|
||||||
m_LastPingTime = std::chrono::steady_clock::now();
|
m_PingStartTime = std::chrono::steady_clock::now();
|
||||||
|
|
||||||
LOGD("New ClientHandle created at %p", this);
|
LOGD("New ClientHandle created at %p", this);
|
||||||
}
|
}
|
||||||
@ -384,7 +389,7 @@ void cClientHandle::Authenticate(const AString & a_Name, const AString & a_UUID,
|
|||||||
|
|
||||||
// Delay the first ping until the client "settles down"
|
// Delay the first ping until the client "settles down"
|
||||||
// This should fix #889, "BadCast exception, cannot convert bit to fm" error in client
|
// This should fix #889, "BadCast exception, cannot convert bit to fm" error in client
|
||||||
m_LastPingTime = std::chrono::steady_clock::now() + std::chrono::seconds(3); // Send the first KeepAlive packet in 3 seconds
|
m_PingStartTime = std::chrono::steady_clock::now() + std::chrono::seconds(3); // Send the first KeepAlive packet in 3 seconds
|
||||||
|
|
||||||
cRoot::Get()->GetPluginManager()->CallHookPlayerSpawned(*m_Player);
|
cRoot::Get()->GetPluginManager()->CallHookPlayerSpawned(*m_Player);
|
||||||
}
|
}
|
||||||
@ -1990,12 +1995,11 @@ void cClientHandle::Tick(float a_Dt)
|
|||||||
// Send a ping packet:
|
// Send a ping packet:
|
||||||
if (m_State == csPlaying)
|
if (m_State == csPlaying)
|
||||||
{
|
{
|
||||||
if ((m_LastPingTime + cClientHandle::PING_TIME_MS <= std::chrono::steady_clock::now()))
|
if ((m_PingStartTime + PING_TIME_MS <= std::chrono::steady_clock::now()))
|
||||||
{
|
{
|
||||||
m_PingID++;
|
m_PingID++;
|
||||||
m_PingStartTime = std::chrono::steady_clock::now();
|
m_PingStartTime = std::chrono::steady_clock::now();
|
||||||
m_Protocol->SendKeepAlive(m_PingID);
|
m_Protocol->SendKeepAlive(m_PingID);
|
||||||
m_LastPingTime = m_PingStartTime;
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -378,12 +378,15 @@ private:
|
|||||||
/** Seconds since the last packet data was received (updated in Tick(), reset in DataReceived()) */
|
/** Seconds since the last packet data was received (updated in Tick(), reset in DataReceived()) */
|
||||||
float m_TimeSinceLastPacket;
|
float m_TimeSinceLastPacket;
|
||||||
|
|
||||||
|
/** Duration of the last completed client ping. */
|
||||||
std::chrono::steady_clock::duration m_Ping;
|
std::chrono::steady_clock::duration m_Ping;
|
||||||
int m_PingID;
|
|
||||||
|
/** ID of the last ping request sent to the client. */
|
||||||
|
int m_PingID;
|
||||||
|
|
||||||
|
/** Time of the last ping request sent to the client. */
|
||||||
std::chrono::steady_clock::time_point m_PingStartTime;
|
std::chrono::steady_clock::time_point m_PingStartTime;
|
||||||
std::chrono::steady_clock::time_point m_LastPingTime;
|
|
||||||
std::chrono::milliseconds PING_TIME_MS = std::chrono::milliseconds(1000); // Vanilla sends 1 per 20 ticks (1 second or every 1000 ms)
|
|
||||||
|
|
||||||
// Values required for block dig animation
|
// Values required for block dig animation
|
||||||
int m_BlockDigAnimStage; // Current stage of the animation; -1 if not digging
|
int m_BlockDigAnimStage; // Current stage of the animation; -1 if not digging
|
||||||
int m_BlockDigAnimSpeed; // Current speed of the animation (units ???)
|
int m_BlockDigAnimSpeed; // Current speed of the animation (units ???)
|
||||||
|
@ -96,8 +96,8 @@ cFastRandom::cFastRandom(void) :
|
|||||||
|
|
||||||
int cFastRandom::NextInt(int a_Range)
|
int cFastRandom::NextInt(int a_Range)
|
||||||
{
|
{
|
||||||
m_IntDistribution = std::uniform_int_distribution<>(0, a_Range - 1);
|
std::uniform_int_distribution<> distribution(0, a_Range - 1);
|
||||||
return m_IntDistribution(m_LinearRand);
|
return distribution(m_LinearRand);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
@ -108,8 +108,8 @@ int cFastRandom::NextInt(int a_Range)
|
|||||||
int cFastRandom::NextInt(int a_Range, int a_Salt)
|
int cFastRandom::NextInt(int a_Range, int a_Salt)
|
||||||
{
|
{
|
||||||
m_LinearRand.seed(a_Salt);
|
m_LinearRand.seed(a_Salt);
|
||||||
m_IntDistribution = std::uniform_int_distribution<>(0, a_Range - 1);
|
std::uniform_int_distribution<> distribution(0, a_Range - 1);
|
||||||
return m_IntDistribution(m_LinearRand);
|
return distribution(m_LinearRand);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
@ -119,8 +119,8 @@ int cFastRandom::NextInt(int a_Range, int a_Salt)
|
|||||||
|
|
||||||
float cFastRandom::NextFloat(float a_Range)
|
float cFastRandom::NextFloat(float a_Range)
|
||||||
{
|
{
|
||||||
m_FloatDistribution = std::uniform_real_distribution<float>(0, a_Range - 1);
|
std::uniform_real_distribution<float> distribution(0, a_Range);
|
||||||
return m_FloatDistribution(m_LinearRand);
|
return distribution(m_LinearRand);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
@ -131,8 +131,8 @@ float cFastRandom::NextFloat(float a_Range)
|
|||||||
float cFastRandom::NextFloat(float a_Range, int a_Salt)
|
float cFastRandom::NextFloat(float a_Range, int a_Salt)
|
||||||
{
|
{
|
||||||
m_LinearRand.seed(a_Salt);
|
m_LinearRand.seed(a_Salt);
|
||||||
m_FloatDistribution = std::uniform_real_distribution<float>(0, a_Range - 1);
|
std::uniform_real_distribution<float> distribution(0, a_Range);
|
||||||
return m_FloatDistribution(m_LinearRand);
|
return distribution(m_LinearRand);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
@ -142,8 +142,8 @@ float cFastRandom::NextFloat(float a_Range, int a_Salt)
|
|||||||
|
|
||||||
int cFastRandom::GenerateRandomInteger(int a_Begin, int a_End)
|
int cFastRandom::GenerateRandomInteger(int a_Begin, int a_End)
|
||||||
{
|
{
|
||||||
m_IntDistribution = std::uniform_int_distribution<>(a_Begin, a_End - 1);
|
std::uniform_int_distribution<> distribution(a_Begin, a_End);
|
||||||
return m_IntDistribution(m_LinearRand);
|
return distribution(m_LinearRand);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
@ -164,8 +164,8 @@ MTRand::MTRand() :
|
|||||||
|
|
||||||
int MTRand::randInt(int a_Range)
|
int MTRand::randInt(int a_Range)
|
||||||
{
|
{
|
||||||
m_IntDistribution = std::uniform_int_distribution<>(0, a_Range);
|
std::uniform_int_distribution<> distribution(0, a_Range);
|
||||||
return m_IntDistribution(m_MersenneRand);
|
return distribution(m_MersenneRand);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
@ -174,8 +174,8 @@ int MTRand::randInt(int a_Range)
|
|||||||
|
|
||||||
int MTRand::randInt()
|
int MTRand::randInt()
|
||||||
{
|
{
|
||||||
m_IntDistribution = std::uniform_int_distribution<>(0, std::numeric_limits<int>::max());
|
std::uniform_int_distribution<> distribution(0, std::numeric_limits<int>::max());
|
||||||
return m_IntDistribution(m_MersenneRand);
|
return distribution(m_MersenneRand);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
@ -184,8 +184,8 @@ int MTRand::randInt()
|
|||||||
|
|
||||||
double MTRand::rand(double a_Range)
|
double MTRand::rand(double a_Range)
|
||||||
{
|
{
|
||||||
m_DoubleDistribution = std::uniform_real_distribution<>(0, a_Range);
|
std::uniform_real_distribution<> distribution(0, a_Range);
|
||||||
return m_DoubleDistribution(m_MersenneRand);
|
return distribution(m_MersenneRand);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
@ -34,16 +34,16 @@ public:
|
|||||||
|
|
||||||
cFastRandom(void);
|
cFastRandom(void);
|
||||||
|
|
||||||
/// Returns a random int in the range [0 .. a_Range - 1]; a_Range must be less than 1M
|
/** Returns a random int in the range [0 .. a_Range - 1]; a_Range must be less than 1M */
|
||||||
int NextInt(int a_Range);
|
int NextInt(int a_Range);
|
||||||
|
|
||||||
/// Returns a random int in the range [0 .. a_Range - 1]; a_Range must be less than 1M; a_Salt is additional source of randomness
|
/** Returns a random int in the range [0 .. a_Range - 1]; a_Range must be less than 1M; a_Salt is additional source of randomness */
|
||||||
int NextInt(int a_Range, int a_Salt);
|
int NextInt(int a_Range, int a_Salt);
|
||||||
|
|
||||||
/// Returns a random float in the range [0 .. a_Range]; a_Range must be less than 1M
|
/** Returns a random float in the range [0 .. a_Range]; a_Range must be less than 1M */
|
||||||
float NextFloat(float a_Range);
|
float NextFloat(float a_Range);
|
||||||
|
|
||||||
/// Returns a random float in the range [0 .. a_Range]; a_Range must be less than 1M; a_Salt is additional source of randomness
|
/** Returns a random float in the range [0 .. a_Range]; a_Range must be less than 1M; a_Salt is additional source of randomness */
|
||||||
float NextFloat(float a_Range, int a_Salt);
|
float NextFloat(float a_Range, int a_Salt);
|
||||||
|
|
||||||
/** Returns a random float between 0 and 1. */
|
/** Returns a random float between 0 and 1. */
|
||||||
@ -55,8 +55,6 @@ public:
|
|||||||
private:
|
private:
|
||||||
|
|
||||||
std::minstd_rand m_LinearRand;
|
std::minstd_rand m_LinearRand;
|
||||||
std::uniform_int_distribution<> m_IntDistribution;
|
|
||||||
std::uniform_real_distribution<float> m_FloatDistribution;
|
|
||||||
};
|
};
|
||||||
|
|
||||||
|
|
||||||
@ -69,15 +67,20 @@ public:
|
|||||||
|
|
||||||
MTRand(void);
|
MTRand(void);
|
||||||
|
|
||||||
|
/** Returns a random integer in the range [0 .. a_Range]. */
|
||||||
int randInt(int a_Range);
|
int randInt(int a_Range);
|
||||||
|
|
||||||
|
/** Returns a random integer in the range [0 .. MAX_INT]. */
|
||||||
int randInt(void);
|
int randInt(void);
|
||||||
|
|
||||||
|
/** Returns a random floating point number in the range [0 .. a_Range]. */
|
||||||
double rand(double a_Range);
|
double rand(double a_Range);
|
||||||
|
|
||||||
private:
|
private:
|
||||||
|
|
||||||
std::mt19937 m_MersenneRand;
|
std::mt19937 m_MersenneRand;
|
||||||
std::uniform_int_distribution<> m_IntDistribution;
|
|
||||||
std::uniform_real_distribution<> m_DoubleDistribution;
|
|
||||||
};
|
};
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
@ -85,7 +85,7 @@ bool cIsThread::Start(void)
|
|||||||
}
|
}
|
||||||
catch (std::system_error & a_Exception)
|
catch (std::system_error & a_Exception)
|
||||||
{
|
{
|
||||||
LOGERROR("cIsThread::Wait (std::thread) error %i: could not construct thread %s; %s", a_Exception.code().value(), m_ThreadName.c_str(), a_Exception.what());
|
LOGERROR("cIsThread::Start error %i: could not construct thread %s; %s", a_Exception.code().value(), m_ThreadName.c_str(), a_Exception.code().message().c_str());
|
||||||
return false;
|
return false;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@ -96,6 +96,12 @@ bool cIsThread::Start(void)
|
|||||||
|
|
||||||
void cIsThread::Stop(void)
|
void cIsThread::Stop(void)
|
||||||
{
|
{
|
||||||
|
if (!m_Thread.joinable())
|
||||||
|
{
|
||||||
|
// The thread hasn't been started or has already been joined
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
m_ShouldTerminate = true;
|
m_ShouldTerminate = true;
|
||||||
Wait();
|
Wait();
|
||||||
}
|
}
|
||||||
@ -106,10 +112,7 @@ void cIsThread::Stop(void)
|
|||||||
|
|
||||||
bool cIsThread::Wait(void)
|
bool cIsThread::Wait(void)
|
||||||
{
|
{
|
||||||
#ifdef LOGD // ProtoProxy doesn't have LOGD
|
LOGD("Waiting for thread %s to finish", m_ThreadName.c_str());
|
||||||
LOGD("Waiting for thread %s to finish", m_ThreadName.c_str());
|
|
||||||
#endif // LOGD
|
|
||||||
|
|
||||||
if (m_Thread.joinable())
|
if (m_Thread.joinable())
|
||||||
{
|
{
|
||||||
try
|
try
|
||||||
@ -119,15 +122,12 @@ bool cIsThread::Wait(void)
|
|||||||
}
|
}
|
||||||
catch (std::system_error & a_Exception)
|
catch (std::system_error & a_Exception)
|
||||||
{
|
{
|
||||||
LOGERROR("cIsThread::Wait (std::thread) error %i: could not join thread %s; %s", a_Exception.code().value(), m_ThreadName.c_str(), a_Exception.what());
|
LOGERROR("cIsThread::Wait error %i: could not join thread %s; %s", a_Exception.code().value(), m_ThreadName.c_str(), a_Exception.code().message().c_str());
|
||||||
return false;
|
return false;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
#ifdef LOGD // ProtoProxy doesn't have LOGD
|
LOGD("Thread %s finished", m_ThreadName.c_str());
|
||||||
LOGD("Thread %s finished", m_ThreadName.c_str());
|
|
||||||
#endif
|
|
||||||
|
|
||||||
return true;
|
return true;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -78,7 +78,8 @@ void cServer::cTickThread::Execute(void)
|
|||||||
while (!m_ShouldTerminate)
|
while (!m_ShouldTerminate)
|
||||||
{
|
{
|
||||||
auto NowTime = std::chrono::steady_clock::now();
|
auto NowTime = std::chrono::steady_clock::now();
|
||||||
m_ShouldTerminate = !m_Server.Tick(static_cast<float>(std::chrono::duration_cast<std::chrono::milliseconds>(NowTime - LastTime).count()));
|
auto msec = std::chrono::duration_cast<std::chrono::milliseconds>(NowTime - LastTime).count();
|
||||||
|
m_ShouldTerminate = !m_Server.Tick(static_cast<float>(msec));
|
||||||
auto TickTime = std::chrono::steady_clock::now() - NowTime;
|
auto TickTime = std::chrono::steady_clock::now() - NowTime;
|
||||||
|
|
||||||
if (TickTime < msPerTick)
|
if (TickTime < msPerTick)
|
||||||
|
@ -239,7 +239,9 @@ void cWorld::cTickThread::Execute(void)
|
|||||||
while (!m_ShouldTerminate)
|
while (!m_ShouldTerminate)
|
||||||
{
|
{
|
||||||
auto NowTime = std::chrono::steady_clock::now();
|
auto NowTime = std::chrono::steady_clock::now();
|
||||||
m_World.Tick(static_cast<float>(std::chrono::duration_cast<std::chrono::milliseconds>(NowTime - LastTime).count()), std::chrono::duration_cast<std::chrono::duration<int>>(TickTime).count());
|
auto msec = std::chrono::duration_cast<std::chrono::milliseconds>(NowTime - LastTime).count();
|
||||||
|
auto LastTickMsec = std::chrono::duration_cast<std::chrono::duration<int>>(TickTime).count();
|
||||||
|
m_World.Tick(static_cast<float>(msec), LastTickMsec);
|
||||||
TickTime = std::chrono::steady_clock::now() - NowTime;
|
TickTime = std::chrono::steady_clock::now() - NowTime;
|
||||||
|
|
||||||
if (TickTime < msPerTick)
|
if (TickTime < msPerTick)
|
||||||
|
Loading…
Reference in New Issue
Block a user