145 lines
4.5 KiB
C++
145 lines
4.5 KiB
C++
#include "ContinentBuilder.h"
|
|
#include "TileBuilder.h"
|
|
#include "WDT.h"
|
|
#include "Utils.h"
|
|
#include "DetourNavMesh.h"
|
|
#include "Cache.h"
|
|
#include "ace/Task.h"
|
|
#include "Recast.h"
|
|
|
|
class BuilderThread : public ACE_Task_Base
|
|
{
|
|
private:
|
|
int X, Y, MapId;
|
|
std::string Continent;
|
|
bool debug;
|
|
dtNavMeshParams Params;
|
|
ContinentBuilder* cBuilder;
|
|
public:
|
|
BuilderThread(ContinentBuilder* _cBuilder, bool deb, dtNavMeshParams& params) : Free(true), debug(deb), Params(params), cBuilder(_cBuilder) {}
|
|
void SetData(int x, int y, int map, std::string cont) { X = x; Y = y; MapId = map; Continent = cont; }
|
|
|
|
int svc()
|
|
{
|
|
Free = false;
|
|
printf("[%02i,%02i] Building tile\n", X, Y);
|
|
TileBuilder builder(cBuilder, Continent, X, Y, MapId);
|
|
char buff[100];
|
|
sprintf(buff, "mmaps/%03u%02u%02u.mmtile", MapId, Y, X);
|
|
FILE* f = fopen(buff, "r");
|
|
if (f) // Check if file already exists.
|
|
{
|
|
printf("[%02i,%02i] Tile skipped, file already exists\n", X, Y);
|
|
fclose(f);
|
|
Free = true;
|
|
return 0;
|
|
}
|
|
uint8* nav = builder.Build(debug, Params);
|
|
if (nav)
|
|
{
|
|
f = fopen(buff, "wb");
|
|
if (!f)
|
|
{
|
|
printf("Could not create file %s. Check that you have write permissions to the destination folder and try again\n", buff);
|
|
return 0;
|
|
}
|
|
MmapTileHeader header;
|
|
header.size = builder.DataSize;
|
|
fwrite(&header, sizeof(MmapTileHeader), 1, f);
|
|
fwrite(nav, sizeof(unsigned char), builder.DataSize, f);
|
|
fclose(f);
|
|
}
|
|
dtFree(nav);
|
|
printf("[%02u,%02u] Tile Built!\n", X, Y);
|
|
Free = true;
|
|
return 0;
|
|
}
|
|
|
|
bool Free;
|
|
};
|
|
|
|
void ContinentBuilder::getTileBounds(uint32 tileX, uint32 tileY, float* verts, int vertCount, float* bmin, float* bmax)
|
|
{
|
|
// this is for elevation
|
|
if (verts && vertCount)
|
|
rcCalcBounds(verts, vertCount, bmin, bmax);
|
|
else
|
|
{
|
|
bmin[1] = FLT_MIN;
|
|
bmax[1] = FLT_MAX;
|
|
}
|
|
|
|
// this is for width and depth
|
|
bmax[0] = (32 - int(tileX)) * Constants::TileSize;
|
|
bmax[2] = (32 - int(tileY)) * Constants::TileSize;
|
|
bmin[0] = bmax[0] - Constants::TileSize;
|
|
bmin[2] = bmax[2] - Constants::TileSize;
|
|
}
|
|
|
|
void ContinentBuilder::CalculateTileBounds()
|
|
{
|
|
for (std::vector<TilePos>::iterator itr = TileMap->TileTable.begin(); itr != TileMap->TileTable.end(); ++itr)
|
|
{
|
|
tileXMax = std::max(itr->X, tileXMax);
|
|
tileXMin = std::min(itr->X, tileXMin);
|
|
|
|
tileYMax = std::max(itr->Y, tileYMax);
|
|
tileYMin = std::min(itr->Y, tileYMin);
|
|
}
|
|
getTileBounds(tileXMax, tileYMax, NULL, 0, bmin, bmax);
|
|
}
|
|
|
|
void ContinentBuilder::Build(bool debug)
|
|
{
|
|
char buff[50];
|
|
sprintf(buff, "mmaps/%03u.mmap", MapId);
|
|
FILE* mmap = fopen(buff, "wb");
|
|
if (!mmap)
|
|
{
|
|
printf("Could not create file %s. Check that you have write permissions to the destination folder and try again\n", buff);
|
|
return;
|
|
}
|
|
|
|
CalculateTileBounds();
|
|
|
|
dtNavMeshParams params;
|
|
params.maxPolys = 1 << STATIC_POLY_BITS;
|
|
params.maxTiles = TileMap->TileTable.size();
|
|
rcVcopy(params.orig, bmin);
|
|
params.tileHeight = Constants::TileSize;
|
|
params.tileWidth = Constants::TileSize;
|
|
fwrite(¶ms, sizeof(dtNavMeshParams), 1, mmap);
|
|
fclose(mmap);
|
|
std::vector<BuilderThread*> Threads;
|
|
for (uint32 i = 0; i < NumberOfThreads; ++i)
|
|
Threads.push_back(new BuilderThread(this, debug, params));
|
|
printf("Map %s ( %i ) has %i tiles. Building them with %i threads\n", Continent.c_str(), MapId, TileMap->TileTable.size(), NumberOfThreads);
|
|
for (std::vector<TilePos>::iterator itr = TileMap->TileTable.begin(); itr != TileMap->TileTable.end(); ++itr)
|
|
{
|
|
bool next = false;
|
|
while (!next)
|
|
{
|
|
for (std::vector<BuilderThread*>::iterator _th = Threads.begin(); _th != Threads.end(); ++_th)
|
|
{
|
|
if ((*_th)->Free)
|
|
{
|
|
(*_th)->SetData(itr->X, itr->Y, MapId, Continent);
|
|
(*_th)->activate();
|
|
next = true;
|
|
break;
|
|
}
|
|
}
|
|
// Wait for 20 seconds
|
|
ACE_OS::sleep(ACE_Time_Value (0, 20000));
|
|
}
|
|
}
|
|
Cache->Clear();
|
|
|
|
// Free memory
|
|
for (std::vector<BuilderThread*>::iterator _th = Threads.begin(); _th != Threads.end(); ++_th)
|
|
{
|
|
(*_th)->wait();
|
|
delete *_th;
|
|
}
|
|
}
|