ChunkGeneratorThread.h

Go to the documentation of this file.

#pragma once
 
#include "OSSupport/IsThread.h"
#include "ChunkDef.h"
 
 
 
 
// fwd:
class cIniFile;
class cChunkDesc;
class cChunkGenerator;
 
 
 
 
 
class cChunkGeneratorThread :
    public cIsThread
{
    using Super = cIsThread;
 
public:
 
    class cPluginInterface
    {
    public:
        // Force a virtual destructor
        virtual ~cPluginInterface() {}
 
        virtual void CallHookChunkGenerating(cChunkDesc & a_ChunkDesc) = 0;
 
        virtual void CallHookChunkGenerated(cChunkDesc & a_ChunkDesc) = 0;
    } ;
 
 
    class cChunkSink
    {
    public:
        // Force a virtual destructor
        virtual ~cChunkSink() {}
 
        virtual void OnChunkGenerated(cChunkDesc & a_ChunkDesc) = 0;
 
        virtual bool IsChunkValid(cChunkCoords a_Coords) = 0;
 
        virtual bool HasChunkAnyClients(cChunkCoords a_Coords) = 0;
 
        virtual bool IsChunkQueued(cChunkCoords a_Coords) = 0;
    } ;
 
 
    cChunkGeneratorThread (void);
    virtual ~cChunkGeneratorThread() override;
 
    bool Initialize(cPluginInterface & a_PluginInterface, cChunkSink & a_ChunkSink, cIniFile & a_IniFile);
 
    void Stop(void);
 
    void QueueGenerateChunk(cChunkCoords a_Coords, bool a_ForceRegeneration, cChunkCoordCallback * a_Callback = nullptr);
 
    void GenerateBiomes(cChunkCoords a_Coords, cChunkDef::BiomeMap & a_BiomeMap);
 
    void WaitForQueueEmpty();
 
    size_t GetQueueLength() const;
 
    int GetSeed() const;
 
    EMCSBiome GetBiomeAt(int a_BlockX, int a_BlockZ);
 
 
private:
 
    struct QueueItem
    {
        cChunkCoords m_Coords;
 
        bool m_ForceRegeneration;
 
        cChunkCoordCallback * m_Callback;
 
        QueueItem(cChunkCoords a_Coords, bool a_ForceRegeneration, cChunkCoordCallback * a_Callback):
            m_Coords(a_Coords),
            m_ForceRegeneration(a_ForceRegeneration),
            m_Callback(a_Callback)
        {
        }
    };
 
    using Queue = std::list<QueueItem>;
 
 
    mutable cCriticalSection m_CS;
 
    Queue m_Queue;
 
    cEvent m_Event;
 
    cEvent m_evtRemoved;
 
    std::unique_ptr<cChunkGenerator> m_Generator;
 
    cPluginInterface * m_PluginInterface;
 
    cChunkSink * m_ChunkSink;
 
 
    // cIsThread override:
    virtual void Execute(void) override;
 
    void DoGenerate(cChunkCoords a_Coords);
};