ChunkGeneratorThread.h

Go to the documentation of this file.

#pragma once

#include "OSSupport/IsThread.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();

    int 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);
};