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