src/emerge.h

   1 #ifndef EMERGE_HEADER
   2 #define EMERGE_HEADER
   3
   4 #include <map>
   5 #include <queue>
   6 #include "util/thread.h"
   7
   8 #define BLOCK_EMERGE_ALLOWGEN (1<<0)
   9
  10 class Mapgen;
  11 class MapgenParams;
  12 class MapgenFactory;
  13 class Biome;
  14 class BiomeDefManager;
  15 class EmergeThread;
  16 class ManualMapVoxelManipulator;
  17
  18 #include "server.h"
  19
  20 struct BlockMakeData {
  21         bool no_op;
  22         ManualMapVoxelManipulator *vmanip;
  23         u64 seed;
  24         v3s16 blockpos_min;
  25         v3s16 blockpos_max;
  26         v3s16 blockpos_requested;
  27         UniqueQueue<v3s16> transforming_liquid;
  28         INodeDefManager *nodedef;
  29
  30         BlockMakeData():
  31                 no_op(false),
  32                 vmanip(NULL),
  33                 seed(0),
  34                 nodedef(NULL)
  35         {}
  36
  37         ~BlockMakeData() { delete vmanip; }
  38 };
  39
  40 struct BlockEmergeData {
  41         u16 peer_requested;
  42         u8 flags;
  43 };
  44
  45 class EmergeManager {
  46 public:
  47         std::map<std::string, MapgenFactory *> mglist;
  48
  49         //settings
  50         MapgenParams *params;
  51
  52         JMutex queuemutex;
  53         std::map<v3s16, BlockEmergeData *> blocks_enqueued;
  54         std::map<u16, u16> peer_queue_count;
  55         Mapgen *mapgen;
  56         EmergeThread *emergethread;
  57
  58         //biome manager
  59         BiomeDefManager *biomedef;
  60
  61         EmergeManager(IGameDef *gamedef, BiomeDefManager *bdef);
  62         ~EmergeManager();
  63
  64         void initMapgens(MapgenParams *mgparams);
  65         Mapgen *createMapgen(std::string mgname, int mgid,
  66                                                 MapgenParams *mgparams, EmergeManager *emerge);
  67         MapgenParams *createMapgenParams(std::string mgname);
  68         Mapgen *getMapgen();
  69         bool enqueueBlockEmerge(u16 peer_id, v3s16 p, bool allow_generate);
  70         bool popBlockEmerge(v3s16 *pos, u8 *flags);
  71
  72         bool registerMapgen(std::string name, MapgenFactory *mgfactory);
  73         MapgenParams *getParamsFromSettings(Settings *settings);
  74         void setParamsToSettings(Settings *settings);
  75
  76         //mapgen helper methods
  77         Biome *getBiomeAtPoint(v3s16 p);
  78         int getGroundLevelAtPoint(v2s16 p);
  79         bool isBlockUnderground(v3s16 blockpos);
  80         u32 getBlockSeed(v3s16 p);
  81 };
  82
  83 class EmergeThread : public SimpleThread
  84 {
  85         Server *m_server;
  86         ServerMap *map;
  87         EmergeManager *emerge;
  88         Mapgen *mapgen;
  89         bool enable_mapgen_debug_info;
  90
  91 public:
  92         Event qevent;
  93         std::queue<v3s16> blockqueue;
  94
  95         EmergeThread(Server *server):
  96                 SimpleThread(),
  97                 m_server(server),
  98                 map(NULL),
  99                 emerge(NULL),
 100                 mapgen(NULL)
 101         {
 102                 enable_mapgen_debug_info = g_settings->getBool("enable_mapgen_debug_info");
 103         }
 104
 105         void *Thread();
 106
 107         void trigger()
 108         {
 109                 setRun(true);
 110                 if(IsRunning() == false)
 111                 {
 112                         Start();
 113                 }
 114         }
 115
 116         bool getBlockOrStartGen(v3s16 p, MapBlock **b,
 117                                                         BlockMakeData *data, bool allow_generate);
 118 };
 119
 120 #endif