utility.h: Change Buffer's interface to be more compatible with SharedBuffer's interf...
[oweals/minetest.git] / src / map.h
index 86b6b6e182aed4c2cebc85b382b296f97dcc2abd..c9bc817907b758b3ec6db645607f672a7fc94e6b 100644 (file)
--- a/src/map.h
+++ b/src/map.h
@@ -21,25 +21,26 @@ with this program; if not, write to the Free Software Foundation, Inc.,
 #define MAP_HEADER
 
 #include <jmutex.h>
+#include <jmutexautolock.h>
 #include <jthread.h>
 #include <iostream>
-
-#ifdef _WIN32
-       #include <windows.h>
-       #define sleep_s(x) Sleep((x*1000))
-#else
-       #include <unistd.h>
-       #define sleep_s(x) sleep(x)
-#endif
+#include <sstream>
 
 #include "common_irrlicht.h"
 #include "mapnode.h"
-#include "mapblock.h"
-#include "mapsector.h"
+#include "mapblock_nodemod.h"
 #include "constants.h"
 #include "voxel.h"
-#include "mapchunk.h"
-#include "nodemetadata.h"
+
+extern "C" {
+       #include "sqlite3.h"
+}
+
+class MapSector;
+class ServerMapSector;
+class ClientMapSector;
+class MapBlock;
+class NodeMetadata;
 
 namespace mapgen{
        struct BlockMakeData;
@@ -61,7 +62,7 @@ enum MapEditEventType{
        // Node metadata of block changed (not knowing which node exactly)
        // p stores block coordinate
        MEET_BLOCK_NODE_METADATA_CHANGED,
-       // Anything else
+       // Anything else (modified_blocks are set unsent)
        MEET_OTHER
 };
 
@@ -104,17 +105,17 @@ public:
        virtual void onMapEditEvent(MapEditEvent *event) = 0;
 };
 
-class Map : public NodeContainer
+class Map /*: public NodeContainer*/
 {
 public:
 
        Map(std::ostream &dout);
        virtual ~Map();
 
-       virtual u16 nodeContainerId() const
+       /*virtual u16 nodeContainerId() const
        {
                return NODECONTAINER_ID_MAP;
-       }
+       }*/
 
        virtual s32 mapType() const
        {
@@ -155,66 +156,24 @@ public:
        MapBlock * getBlockNoCreate(v3s16 p);
        // Returns NULL if not found
        MapBlock * getBlockNoCreateNoEx(v3s16 p);
-       // Gets an existing block or creates an empty one
-       //MapBlock * getBlockCreate(v3s16 p);
        
+       /* Server overrides */
+       virtual MapBlock * emergeBlock(v3s16 p, bool allow_generate=true)
+       { return getBlockNoCreateNoEx(p); }
+
        // Returns InvalidPositionException if not found
        bool isNodeUnderground(v3s16 p);
        
-       // virtual from NodeContainer
-       bool isValidPosition(v3s16 p)
-       {
-               v3s16 blockpos = getNodeBlockPos(p);
-               MapBlock *blockref;
-               try{
-                       blockref = getBlockNoCreate(blockpos);
-               }
-               catch(InvalidPositionException &e)
-               {
-                       return false;
-               }
-               return true;
-               /*v3s16 relpos = p - blockpos*MAP_BLOCKSIZE;
-               bool is_valid = blockref->isValidPosition(relpos);
-               return is_valid;*/
-       }
+       bool isValidPosition(v3s16 p);
        
-       // virtual from NodeContainer
        // throws InvalidPositionException if not found
-       MapNode getNode(v3s16 p)
-       {
-               v3s16 blockpos = getNodeBlockPos(p);
-               MapBlock * blockref = getBlockNoCreate(blockpos);
-               v3s16 relpos = p - blockpos*MAP_BLOCKSIZE;
-
-               return blockref->getNodeNoCheck(relpos);
-       }
+       MapNode getNode(v3s16 p);
 
-       // virtual from NodeContainer
        // throws InvalidPositionException if not found
-       void setNode(v3s16 p, MapNode & n)
-       {
-               v3s16 blockpos = getNodeBlockPos(p);
-               MapBlock * blockref = getBlockNoCreate(blockpos);
-               v3s16 relpos = p - blockpos*MAP_BLOCKSIZE;
-               blockref->setNodeNoCheck(relpos, n);
-       }
+       void setNode(v3s16 p, MapNode & n);
        
        // Returns a CONTENT_IGNORE node if not found
-       MapNode getNodeNoEx(v3s16 p)
-       {
-               try{
-                       v3s16 blockpos = getNodeBlockPos(p);
-                       MapBlock * blockref = getBlockNoCreate(blockpos);
-                       v3s16 relpos = p - blockpos*MAP_BLOCKSIZE;
-
-                       return blockref->getNodeNoCheck(relpos);
-               }
-               catch(InvalidPositionException &e)
-               {
-                       return MapNode(CONTENT_IGNORE);
-               }
-       }
+       MapNode getNodeNoEx(v3s16 p);
 
        void unspreadLight(enum LightBank bank,
                        core::map<v3s16, u8> & from_nodes,
@@ -250,7 +209,7 @@ public:
                These handle lighting but not faces.
        */
        void addNodeAndUpdate(v3s16 p, MapNode n,
-                       core::map<v3s16, MapBlock*> &modified_blocks);
+                       core::map<v3s16, MapBlock*> &modified_blocks, std::string &player_name);
        void removeNodeAndUpdate(v3s16 p,
                        core::map<v3s16, MapBlock*> &modified_blocks);
 
@@ -270,26 +229,40 @@ public:
        //core::aabbox3d<s16> getDisplayedBlockArea();
 
        //bool updateChangedVisibleArea();
+
+       // Call these before and after saving of many blocks
+       virtual void beginSave() {return;};
+       virtual void endSave() {return;};
        
        virtual void save(bool only_changed){assert(0);};
        
-       // Server implements this
+       // Server implements this.
+       // Client leaves it as no-op.
        virtual void saveBlock(MapBlock *block){};
 
        /*
-               Updates usage timers
+               Updates usage timers and unloads unused blocks and sectors.
+               Saves modified blocks before unloading on MAPTYPE_SERVER.
        */
-       void timerUpdate(float dtime);
-       
+       void timerUpdate(float dtime, float unload_timeout,
+                       core::list<v3s16> *unloaded_blocks=NULL);
+               
+       // Deletes sectors and their blocks from memory
        // Takes cache into account
-       // sector mutex should be locked when calling
-       void deleteSectors(core::list<v2s16> &list, bool only_blocks);
-       
-       // Returns count of deleted sectors
-       u32 unloadUnusedData(float timeout, bool only_blocks=false,
+       // If deleted sector is in sector cache, clears cache
+       void deleteSectors(core::list<v2s16> &list);
+
+#if 0
+       /*
+               Unload unused data
+               = flush changed to disk and delete from memory, if usage timer of
+                 block is more than timeout
+       */
+       void unloadUnusedData(float timeout,
                        core::list<v3s16> *deleted_blocks=NULL);
+#endif
 
-       // For debug printing
+       // For debug printing. Prints "Map: ", "ServerMap: " or "ClientMap: "
        virtual void PrintInfo(std::ostream &out);
        
        void transformLiquids(core::map<v3s16, MapBlock*> & modified_blocks);
@@ -321,7 +294,6 @@ protected:
        core::map<MapEventReceiver*, bool> m_event_receivers;
        
        core::map<v2s16, MapSector*> m_sectors;
-       //JMutex m_sector_mutex;
 
        // Be sure to set this to NULL when the cached sector is deleted 
        MapSector *m_sector_cache;
@@ -379,24 +351,13 @@ public:
        */
        MapBlock * createBlock(v3s16 p);
 
-#if 0
        /*
-               NOTE: This comment might be outdated
-               
                Forcefully get a block from somewhere.
-
-               InvalidPositionException possible if only_from_disk==true
-               
-               Parameters:
-               changed_blocks: Blocks that have been modified
+               - Memory
+               - Load from disk
+               - Generate
        */
-       MapBlock * emergeBlock(
-                       v3s16 p,
-                       bool only_from_disk,
-                       core::map<v3s16, MapBlock*> &changed_blocks,
-                       core::map<v3s16, MapBlock*> &lighting_invalidated_blocks
-       );
-#endif
+       MapBlock * emergeBlock(v3s16 p, bool allow_generate=true);
        
        // Helper for placing objects on ground level
        s16 findGroundLevel(v2s16 p2d);
@@ -413,9 +374,29 @@ public:
        v3s16 getBlockPos(std::string sectordir, std::string blockfile);
        static std::string getBlockFilename(v3s16 p);
 
+       /*
+               Database functions
+       */
+       // Create the database structure
+       void createDatabase();
+       // Verify we can read/write to the database
+       void verifyDatabase();
+       // Get an integer suitable for a block
+       static sqlite3_int64 getBlockAsInteger(const v3s16 pos);
+       static v3s16 getIntegerAsBlock(sqlite3_int64 i);
+
+       // Returns true if the database file does not exist
+       bool loadFromFolders();
+
+       // Call these before and after saving of blocks
+       void beginSave();
+       void endSave();
+
        void save(bool only_changed);
        //void loadAll();
        
+       void listAllLoadableBlocks(core::list<v3s16> &dst);
+       
        // Saves map seed and possibly other stuff
        void saveMapMeta();
        void loadMapMeta();
@@ -443,6 +424,8 @@ public:
        // This will generate a sector with getSector if not found.
        void loadBlock(std::string sectordir, std::string blockfile, MapSector *sector, bool save_after_load=false);
        MapBlock* loadBlock(v3s16 p);
+       // Database version
+       void loadBlock(std::string *blob, v3s16 p3d, MapSector *sector, bool save_after_load=false);
 
        // For debug printing
        virtual void PrintInfo(std::ostream &out);
@@ -471,6 +454,14 @@ private:
                This is reset to false when written on disk.
        */
        bool m_map_metadata_changed;
+       
+       /*
+               SQLite database and statements
+       */
+       sqlite3 *m_database;
+       sqlite3_stmt *m_database_read;
+       sqlite3_stmt *m_database_write;
+       sqlite3_stmt *m_database_list;
 };
 
 /*
@@ -535,11 +526,12 @@ public:
                ISceneNode::drop();
        }
 
-       void updateCamera(v3f pos, v3f dir)
+       void updateCamera(v3f pos, v3f dir, f32 fov)
        {
                JMutexAutoLock lock(m_camera_mutex);
                m_camera_position = pos;
                m_camera_direction = dir;
+               m_camera_fov = fov;
        }
 
        /*
@@ -547,7 +539,7 @@ public:
        */
        MapSector * emergeSector(v2s16 p);
 
-       void deSerializeSector(v2s16 p2d, std::istream &is);
+       //void deSerializeSector(v2s16 p2d, std::istream &is);
 
        /*
                ISceneNode methods
@@ -569,6 +561,8 @@ public:
 
        void renderMap(video::IVideoDriver* driver, s32 pass);
 
+       void renderPostFx();
+
        /*
                Methods for setting temporary modifications to nodes for
                drawing.
@@ -618,6 +612,7 @@ private:
 
        v3f m_camera_position;
        v3f m_camera_direction;
+       f32 m_camera_fov;
        JMutex m_camera_mutex;
        
        core::map<v2s16, bool> m_last_drawn_sectors;