summaryrefslogtreecommitdiffstats
path: root/source
diff options
context:
space:
mode:
Diffstat (limited to '')
-rw-r--r--source/cClientHandle.cpp18
-rw-r--r--source/cClientHandle.h3
2 files changed, 16 insertions, 5 deletions
diff --git a/source/cClientHandle.cpp b/source/cClientHandle.cpp
index 4db64cfde..29446615f 100644
--- a/source/cClientHandle.cpp
+++ b/source/cClientHandle.cpp
@@ -94,6 +94,7 @@ cClientHandle::cClientHandle(const cSocket & a_Socket, int a_ViewDistance)
, m_State(csConnected)
, m_LastStreamedChunkX(0x7fffffff) // bogus chunk coords to force streaming upon login
, m_LastStreamedChunkZ(0x7fffffff)
+ , m_ShouldCheckDownloaded(false)
, m_UniqueID(0)
{
m_Protocol = new cProtocolRecognizer(this);
@@ -923,8 +924,9 @@ void cClientHandle::SendData(const char * a_Data, int a_Size)
cCSLock Lock(m_CSOutgoingData);
if (!m_OutgoingData.Write(a_Data, a_Size))
{
- // Client has too much outgoing data queued, drop them silently:
- Destroy();
+ // Client has too much outgoing data queued, drop them silently by timing them out:
+ // (So that they're dropped in the tick thread and not the sender thread)
+ m_LastPingTime = 0;
}
}
@@ -979,6 +981,12 @@ void cClientHandle::Tick(float a_Dt)
Destroy();
}
+ if ((m_State == csDownloadingWorld) && m_ShouldCheckDownloaded)
+ {
+ CheckIfWorldDownloaded();
+ m_ShouldCheckDownloaded = false;
+ }
+
cTimer t1;
// Send ping packet
if (
@@ -1359,9 +1367,9 @@ void cClientHandle::SendChunkData(int a_ChunkX, int a_ChunkZ, cChunkDataSerializ
{
m_ChunksToSend.erase(itr);
- // TODO: _X: Decouple this from packet sending, it creates a deadlock possibility
- // -- postpone till Tick() instead, using a bool flag
- CheckIfWorldDownloaded();
+ // Make the tick thread check if all the needed chunks have been downloaded
+ // -- needed to offload this from here due to a deadlock possibility
+ m_ShouldCheckDownloaded = true;
Found = true;
break;
diff --git a/source/cClientHandle.h b/source/cClientHandle.h
index 0b25365df..e6887d752 100644
--- a/source/cClientHandle.h
+++ b/source/cClientHandle.h
@@ -223,6 +223,9 @@ private:
eState m_State;
bool m_bKeepThreadGoing;
+
+ /// If set to true during csDownloadingWorld, the tick thread calls CheckIfWorldDownloaded()
+ bool m_ShouldCheckDownloaded;
/// Returns true if the rate block interactions is within a reasonable limit (bot protection)
bool CheckBlockInteractionsRate(void);