summaryrefslogtreecommitdiffstats
path: root/src/ChunkSender.h
diff options
context:
space:
mode:
authortycho <work.tycho@gmail.com>2015-05-31 16:28:38 +0200
committertycho <work.tycho@gmail.com>2015-06-05 23:31:21 +0200
commitbfe52277b4a17c4a3a97bf479e20d7b5f0f068d2 (patch)
tree8039f30cb090e5e5aed4f26e257bf13338e7769e /src/ChunkSender.h
parentMoved Chunk Broadcasts over to the regular queue (diff)
downloadcuberite-bfe52277b4a17c4a3a97bf479e20d7b5f0f068d2.tar
cuberite-bfe52277b4a17c4a3a97bf479e20d7b5f0f068d2.tar.gz
cuberite-bfe52277b4a17c4a3a97bf479e20d7b5f0f068d2.tar.bz2
cuberite-bfe52277b4a17c4a3a97bf479e20d7b5f0f068d2.tar.lz
cuberite-bfe52277b4a17c4a3a97bf479e20d7b5f0f068d2.tar.xz
cuberite-bfe52277b4a17c4a3a97bf479e20d7b5f0f068d2.tar.zst
cuberite-bfe52277b4a17c4a3a97bf479e20d7b5f0f068d2.zip
Diffstat (limited to '')
-rw-r--r--src/ChunkSender.h71
1 files changed, 26 insertions, 45 deletions
diff --git a/src/ChunkSender.h b/src/ChunkSender.h
index 1f87e9e08..b0c48b92b 100644
--- a/src/ChunkSender.h
+++ b/src/ChunkSender.h
@@ -29,6 +29,9 @@ Note that it may be called by world's BroadcastToChunk() if the client is still
#include "ChunkDef.h"
#include "ChunkDataCallback.h"
+#include <unordered_set>
+#include <unordered_map>
+
@@ -59,9 +62,10 @@ public:
enum eChunkPriority
{
E_CHUNK_PRIORITY_HIGH = 0,
- E_CHUNK_PRIORITY_MEDIUM = 1,
- E_CHUNK_PRIORITY_LOW = 2,
- PRIORITY_BROADCAST
+ PRIORITY_BROADCAST,
+ E_CHUNK_PRIORITY_MEDIUM,
+ E_CHUNK_PRIORITY_LOW,
+
};
bool Start();
@@ -76,62 +80,40 @@ public:
void RemoveClient(cClientHandle * a_Client);
protected:
+
+ struct sChunkQueue
+ {
+ eChunkPriority m_Priority;
+ cChunkCoords m_Chunk;
+
+ bool operator <(const sChunkQueue & a_Other) const { return this->m_Priority < a_Other.m_Priority; }
+ };
/// Used for sending chunks to specific clients
struct sSendChunk
{
- int m_ChunkX;
- int m_ChunkZ;
- cClientHandle * m_Client;
-
- sSendChunk(int a_ChunkX, int a_ChunkZ, cClientHandle * a_Client) :
- m_ChunkX(a_ChunkX),
- m_ChunkZ(a_ChunkZ),
- m_Client(a_Client)
- {
- }
-
- bool operator ==(const sSendChunk & a_Other)
- {
- return (
- (a_Other.m_ChunkX == m_ChunkX) &&
- (a_Other.m_ChunkZ == m_ChunkZ) &&
- (a_Other.m_Client == m_Client)
- );
- }
- } ;
- typedef std::list<sSendChunk> sSendChunkList;
-
- struct sBlockCoord
- {
- int m_BlockX;
- int m_BlockY;
- int m_BlockZ;
-
- sBlockCoord(int a_BlockX, int a_BlockY, int a_BlockZ) :
- m_BlockX(a_BlockX),
- m_BlockY(a_BlockY),
- m_BlockZ(a_BlockZ)
+ cChunkCoords m_Chunk;
+ std::unordered_set<cClientHandle *> m_Clients;
+ eChunkPriority m_Priority;
+ sSendChunk(cChunkCoords a_Chunk, eChunkPriority a_Priority) :
+ m_Chunk(a_Chunk),
+ m_Priority(a_Priority)
{
}
- } ;
-
- typedef std::vector<sBlockCoord> sBlockCoords;
+ };
cWorld & m_World;
cCriticalSection m_CS;
- sSendChunkList m_SendChunksLowPriority;
- sSendChunkList m_SendChunksMediumPriority;
- sSendChunkList m_SendChunksBroadcastPriority;
- sSendChunkList m_SendChunksHighPriority;
+ std::priority_queue<sChunkQueue> m_SendChunks;
+ std::unordered_map<cChunkCoords, sSendChunk, cChunkCoordsHash> m_ChunkInfo;
cEvent m_evtQueue; // Set when anything is added to m_ChunksReady
cEvent m_evtRemoved; // Set when removed clients are safe to be deleted
int m_RemoveCount; // Number of threads waiting for a client removal (m_evtRemoved needs to be set this many times)
// Data about the chunk that is being sent:
// NOTE that m_BlockData[] is inherited from the cChunkDataCollector
unsigned char m_BiomeMap[cChunkDef::Width * cChunkDef::Width];
- sBlockCoords m_BlockEntities; // Coords of the block entities to send
+ std::vector<Vector3i> m_BlockEntities; // Coords of the block entities to send
// TODO: sEntityIDs m_Entities; // Entity-IDs of the entities to send
// cIsThread override:
@@ -144,9 +126,8 @@ protected:
virtual void BlockEntity (cBlockEntity * a_Entity) override;
/// Sends the specified chunk to a_Client, or to all chunk clients if a_Client == nullptr
- void SendChunk(int a_ChunkX, int a_ChunkZ, cClientHandle * a_Client);
+ void SendChunk(int a_ChunkX, int a_ChunkZ, std::unordered_set<cClientHandle *> a_Clients);
} ;
-