celisej567/mcpe
1
0
Fork 0
mirror of https://github.com/celisej567/mcpe.git synced 2026-09-11 20:11:18 +03:00
Code Issues Actions Packages Projects Releases Wiki Activity

* Finish ExternalFileLevelStorage.

Browse Source
This commit is contained in:
iProgramInCpp
2023-08-02 09:58:26 +03:00
parent 3eb8062d06
commit 16e2b79165
4 changed files with 85 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

75
source/World/Storage/ExternalFileLevelStorage.cpp
View File

@@ -1,5 +1,8 @@
#include "ExternalFileLevelStorage.hpp"
#include "LevelChunk.hpp"
#include "Level.hpp"
#include "GetTime.h"
#define C_CHUNKS_TO_SAVE_PER_TICK (2)
ExternalFileLevelStorage::ExternalFileLevelStorage(const std::string& a, const std::string& path) :
field_8(a),
@@ -76,6 +79,57 @@ void ExternalFileLevelStorage::closeAll()
void ExternalFileLevelStorage::tick()
{
m_timer++;
if (m_timer % 50 != 0 || !m_pLevel)
return;
for (int z = 0; z < C_MAX_CHUNKS_Z; z++)
{
for (int x = 0; x < C_MAX_CHUNKS_X; x++)
{
LevelChunk* pChunk = m_pLevel->getChunk(x, z);
if (!pChunk || !pChunk->m_bUnsaved)
continue;
int index = x + z * 16;
auto iter = m_unsavedLevelChunks.begin();
for (; iter != m_unsavedLevelChunks.end(); ++iter)
{
if (iter->m_index == index)
{
iter->m_foundTime = RakNet::GetTimeMS();
break;
}
}
if (iter == m_unsavedLevelChunks.end())
{
UnsavedLevelChunk ulc = { index, RakNet::GetTimeMS(), pChunk };
m_unsavedLevelChunks.push_back(ulc);
}
pChunk->m_bUnsaved = false;
}
}
int count = 0;
while (count < C_CHUNKS_TO_SAVE_PER_TICK && !m_unsavedLevelChunks.empty())
{
count++;
auto iter = m_unsavedLevelChunks.begin();
for (auto it2 = m_unsavedLevelChunks.begin(); it2 != m_unsavedLevelChunks.end(); ++it2)
{
if (iter->m_foundTime > it2->m_foundTime)
iter = it2;
}
LevelChunk* pChunk = iter->m_pChunk;
m_unsavedLevelChunks.erase(iter);
save(m_pLevel, pChunk);
}
}
void ExternalFileLevelStorage::flush()
@@ -223,3 +277,22 @@ _cleanup:
fclose(pFile);
return false;
}
bool ExternalFileLevelStorage::writeLevelData(const std::string& path, LevelData* pLevelData)
{
FILE* pFile = fopen(path.c_str(), "wb");
if (!pFile)
return false;
RakNet::BitStream bs;
pLevelData->write(bs);
fwrite(&pLevelData->field_20, sizeof(int), 1, pFile);
int length = bs.GetNumberOfBytesUsed();
fwrite(&length, sizeof(int), 1, pFile);
fwrite(bs.GetData(), 1, length, pFile);
fclose(pFile);
return true;
}