blob: 47ae1c99921095ceaac37352075a88a17e2353b7 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
|
#pragma once
using namespace std;
#include "ChunkStorage.h"
#include "LevelChunk.h"
#include "RegionFileCache.h"
#include "com.mojang.nbt.h"
#include "OldChunkStorage.h"
class ConsoleSaveFile;
class McRegionChunkStorage : public ChunkStorage
{
private:
const wstring m_prefix;
ConsoleSaveFile *m_saveFile;
static CRITICAL_SECTION cs_memory;
unordered_map<int64_t, byteArray> m_entityData;
static std::deque<DataOutputStream *> s_chunkDataQueue;
static int s_runningThreadCount;
static C4JThread *s_saveThreads[3];
public:
McRegionChunkStorage(ConsoleSaveFile *saveFile, const wstring &prefix);
~McRegionChunkStorage();
static void staticCtor();
virtual LevelChunk *load(Level *level, int x, int z);
virtual void save(Level *level, LevelChunk *levelChunk);
virtual void saveEntities(Level *level, LevelChunk *levelChunk);
virtual void loadEntities(Level *level, LevelChunk *levelChunk);
virtual void tick();
virtual void flush();
virtual void WaitForAll(); // 4J Added
virtual void WaitIfTooManyQueuedChunks(); // 4J Added
private:
static void WaitForAllSaves();
static void WaitForSaves();
static int runSaveThreadProc(LPVOID lpParam);
};
|
