X-Git-Url: https://git.lizzy.rs/?a=blobdiff_plain;f=src%2Fenvironment.cpp;h=f233eaf7ff072ddab7ef88c824b51c2103147497;hb=e0329a3caee863a2302748f710401bfc0dfa78db;hp=e472916657ede944d490dfb9ae6ec8f603520e0e;hpb=9c72d44fe75cc448cc0da1191a36fe6a7d879f20;p=dragonfireclient.git diff --git a/src/environment.cpp b/src/environment.cpp index e47291665..f233eaf7f 100644 --- a/src/environment.cpp +++ b/src/environment.cpp @@ -22,9 +22,10 @@ with this program; if not, write to the Free Software Foundation, Inc., #include "porting.h" #include "collision.h" -Environment::Environment() + +Environment::Environment(): + m_time_of_day(9000) { - m_daynight_ratio = 0.5; } Environment::~Environment() @@ -173,14 +174,84 @@ void Environment::printPlayers(std::ostream &o) } } -void Environment::setDayNightRatio(u32 r) +/*void Environment::setDayNightRatio(u32 r) { - m_daynight_ratio = r; -} + getDayNightRatio() = r; +}*/ u32 Environment::getDayNightRatio() { - return m_daynight_ratio; + //return getDayNightRatio(); + return time_to_daynight_ratio(m_time_of_day); +} + +/* + ActiveBlockList +*/ + +void fillRadiusBlock(v3s16 p0, s16 r, core::map &list) +{ + v3s16 p; + for(p.X=p0.X-r; p.X<=p0.X+r; p.X++) + for(p.Y=p0.Y-r; p.Y<=p0.Y+r; p.Y++) + for(p.Z=p0.Z-r; p.Z<=p0.Z+r; p.Z++) + { + // Set in list + list[p] = true; + } +} + +void ActiveBlockList::update(core::list &active_positions, + s16 radius, + core::map &blocks_removed, + core::map &blocks_added) +{ + /* + Create the new list + */ + core::map newlist; + for(core::list::Iterator i = active_positions.begin(); + i != active_positions.end(); i++) + { + fillRadiusBlock(*i, radius, newlist); + } + + /* + Find out which blocks on the old list are not on the new list + */ + // Go through old list + for(core::map::Iterator i = m_list.getIterator(); + i.atEnd()==false; i++) + { + v3s16 p = i.getNode()->getKey(); + // If not on new list, it's been removed + if(newlist.find(p) == NULL) + blocks_removed.insert(p, true); + } + + /* + Find out which blocks on the new list are not on the old list + */ + // Go through new list + for(core::map::Iterator i = newlist.getIterator(); + i.atEnd()==false; i++) + { + v3s16 p = i.getNode()->getKey(); + // If not on old list, it's been added + if(m_list.find(p) == NULL) + blocks_added.insert(p, true); + } + + /* + Update m_list + */ + m_list.clear(); + for(core::map::Iterator i = newlist.getIterator(); + i.atEnd()==false; i++) + { + v3s16 p = i.getNode()->getKey(); + m_list.insert(p, true); + } } /* @@ -191,12 +262,21 @@ ServerEnvironment::ServerEnvironment(ServerMap *map, Server *server): m_map(map), m_server(server), m_random_spawn_timer(3), - m_send_recommended_timer(0) + m_send_recommended_timer(0), + m_game_time(0), + m_game_time_fraction_counter(0) { } ServerEnvironment::~ServerEnvironment() { + // Clear active block list. + // This makes the next one delete all active objects. + m_active_blocks.clear(); + + // Convert all objects to static and delete the active objects + deactivateFarObjects(true); + // Drop/delete map m_map->drop(); } @@ -378,7 +458,71 @@ void ServerEnvironment::deSerializePlayers(const std::string &savedir) } } +void ServerEnvironment::saveMeta(const std::string &savedir) +{ + std::string path = savedir + "/env_meta.txt"; + + // Open file and serialize + std::ofstream os(path.c_str(), std::ios_base::binary); + if(os.good() == false) + { + dstream<<"WARNING: ServerEnvironment::saveMeta(): Failed to open " + <timerUpdate()"); m_map->timerUpdate(dtime); @@ -481,258 +637,218 @@ void ServerEnvironment::step(float dtime) } /* - Step active objects + Manage active block list */ + if(m_active_blocks_management_interval.step(dtime, 2.0)) { - //TimeTaker timer("Step active objects"); - - bool send_recommended = false; - m_send_recommended_timer += dtime; - if(m_send_recommended_timer > 0.15) - { - m_send_recommended_timer = 0; - send_recommended = true; - } - - for(core::map::Iterator - i = m_active_objects.getIterator(); - i.atEnd()==false; i++) + /* + Get player block positions + */ + core::list players_blockpos; + for(core::list::Iterator + i = m_players.begin(); + i != m_players.end(); i++) { - ServerActiveObject* obj = i.getNode()->getValue(); - // Step object, putting messages directly to the queue - obj->step(dtime, m_active_object_messages, send_recommended); + Player *player = *i; + // Ignore disconnected players + if(player->peer_id == 0) + continue; + v3s16 blockpos = getNodeBlockPos( + floatToInt(player->getPosition(), BS)); + players_blockpos.push_back(blockpos); } - } - - if(m_object_management_interval.step(dtime, 0.5)) - { - //TimeTaker timer("ServerEnv object management"); + + /* + Update list of active blocks, collecting changes + */ + const s16 active_block_range = 5; + core::map blocks_removed; + core::map blocks_added; + m_active_blocks.update(players_blockpos, active_block_range, + blocks_removed, blocks_added); /* - Remove objects that satisfy (m_removed && m_known_by_count==0) + Handle removed blocks */ - { - core::list objects_to_remove; - for(core::map::Iterator - i = m_active_objects.getIterator(); - i.atEnd()==false; i++) - { - u16 id = i.getNode()->getKey(); - ServerActiveObject* obj = i.getNode()->getValue(); - // This shouldn't happen but check it - if(obj == NULL) - { - dstream<<"WARNING: NULL object found in ServerEnvironment" - <<" while finding removed objects. id="<m_removed == false) - continue; - // Delete static data from block - if(obj->m_static_exists) - { - MapBlock *block = m_map->getBlockNoCreateNoEx(obj->m_static_block); - if(block) - { - block->m_static_objects.remove(id); - block->setChangedFlag(); - } - } - // If m_known_by_count > 0, don't actually remove. - if(obj->m_known_by_count > 0) - continue; - // Delete - delete obj; - // Id to be removed from m_active_objects - objects_to_remove.push_back(id); - } - // Remove references from m_active_objects - for(core::list::Iterator i = objects_to_remove.begin(); - i != objects_to_remove.end(); i++) - { - m_active_objects.remove(*i); - } - } + + // Convert active objects that are no more in active blocks to static + deactivateFarObjects(false); + for(core::map::Iterator + i = blocks_removed.getIterator(); + i.atEnd()==false; i++) + { + v3s16 p = i.getNode()->getKey(); - const s16 to_active_max_blocks = 3; - const f32 to_static_max_f = (to_active_max_blocks+2)*MAP_BLOCKSIZE*BS; + /*dstream<<"Server: Block ("<getBlockNoCreateNoEx(p); + if(block==NULL) + continue; + + // Set current time as timestamp + block->setTimestamp(m_game_time); + } /* - Convert stored objects from blocks near the players to active. + Handle added blocks */ - for(core::list::Iterator i = m_players.begin(); - i != m_players.end(); i++) + + for(core::map::Iterator + i = blocks_added.getIterator(); + i.atEnd()==false; i++) { - Player *player = *i; + v3s16 p = i.getNode()->getKey(); - // Ignore disconnected players - if(player->peer_id == 0) + /*dstream<<"Server: Block ("<getBlockNoCreateNoEx(p); + if(block==NULL) continue; + + // Get time difference + u32 dtime_s = 0; + u32 stamp = block->getTimestamp(); + if(m_game_time > stamp && stamp != BLOCK_TIMESTAMP_UNDEFINED) + dtime_s = m_game_time - block->getTimestamp(); - v3f playerpos = player->getPosition(); + // Set current time as timestamp + block->setTimestamp(m_game_time); + + //dstream<<"Block is "<getBlockNoCreateNoEx(blockpos); - if(block==NULL) - continue; - // Ignore if no stored objects (to not set changed flag) - if(block->m_static_objects.m_stored.size() == 0) - continue; - // This will contain the leftovers of the stored list - core::list new_stored; - // Loop through stored static objects - for(core::list::Iterator - i = block->m_static_objects.m_stored.begin(); - i != block->m_static_objects.m_stored.end(); i++) + v3s16 p = p0 + block->getPosRelative(); + MapNode n = block->getNodeNoEx(p0); + // Test something: + // Convert all mud under proper day lighting to grass + if(n.d == CONTENT_MUD) { - /*dstream<<"INFO: Server: Creating an active object from " - <<"static data"<getNodeNoEx(p0+v3s16(0,1,0)); + if(content_features(n_top.d).walkable == false && + n_top.getLight(LIGHTBANK_DAY) >= 13) + { + n.d = CONTENT_GRASS; + m_map->addNodeWithEvent(p, n); + } } - // This will also add the object to the active static list - addActiveObject(obj); - //u16 id = addActiveObject(obj); - } - // Clear stored list - block->m_static_objects.m_stored.clear(); - // Add leftover stuff to stored list - for(core::list::Iterator - i = new_stored.begin(); - i != new_stored.end(); i++) - { - StaticObject &s_obj = *i; - block->m_static_objects.m_stored.push_back(s_obj); } - block->setChangedFlag(); } } + } - /* - Convert objects that are far away from all the players to static. - */ + /* + Mess around in active blocks + */ + if(m_active_blocks_test_interval.step(dtime, 5.0)) + { + for(core::map::Iterator + i = m_active_blocks.m_list.getIterator(); + i.atEnd()==false; i++) { - core::list objects_to_remove; - for(core::map::Iterator - i = m_active_objects.getIterator(); - i.atEnd()==false; i++) - { - ServerActiveObject* obj = i.getNode()->getValue(); - u16 id = i.getNode()->getKey(); - v3f objectpos = obj->getBasePosition(); + v3s16 p = i.getNode()->getKey(); + + /*dstream<<"Server: Block ("<m_known_by_count > 0) - continue; - - // If close to some player, don't convert to static. - bool close_to_player = false; - for(core::list::Iterator i = m_players.begin(); - i != m_players.end(); i++) - { - Player *player = *i; - - // Ignore disconnected players - if(player->peer_id == 0) - continue; - - v3f playerpos = player->getPosition(); - f32 d = playerpos.getDistanceFrom(objectpos); - if(d < to_static_max_f) - { - close_to_player = true; - break; - } - } + MapBlock *block = m_map->getBlockNoCreateNoEx(p); + if(block==NULL) + continue; + + // Set current time as timestamp + block->setTimestamp(m_game_time); + + /* + Do stuff! - if(close_to_player) - continue; + Note that map modifications should be done using the event- + making map methods so that the server gets information + about them. - /* - Update the static data and remove the active object. - */ + Reading can be done quickly directly from the block. - // Delete old static object - MapBlock *oldblock = NULL; - if(obj->m_static_exists) + Everything should bind to inside this single content + searching loop to keep things fast. + */ + + v3s16 p0; + for(p0.X=0; p0.XgetPosRelative(); + MapNode n = block->getNodeNoEx(p0); + // Test something: + // Convert mud under proper lighting to grass + if(n.d == CONTENT_MUD) { - MapBlock *block = m_map->getBlockNoCreateNoEx - (obj->m_static_block); - if(block) + if(myrand()%4 == 0) { - block->m_static_objects.remove(id); - oldblock = block; + MapNode n_top = block->getNodeNoEx(p0+v3s16(0,1,0)); + if(content_features(n_top.d).walkable == false && + n_top.getLightBlend(getDayNightRatio()) >= 13) + { + n.d = CONTENT_GRASS; + m_map->addNodeWithEvent(p, n); + } } } - // Add new static object - std::string staticdata = obj->getStaticData(); - StaticObject s_obj(obj->getType(), objectpos, staticdata); - // Add to the block where the object is located in - v3s16 blockpos = getNodeBlockPos(floatToInt(objectpos, BS)); - MapBlock *block = m_map->getBlockNoCreateNoEx(blockpos); - if(block) - { - block->m_static_objects.insert(0, s_obj); - block->setChangedFlag(); - obj->m_static_exists = true; - obj->m_static_block = block->getPos(); - } - // If not possible, add back to previous block - else if(oldblock) - { - oldblock->m_static_objects.insert(0, s_obj); - oldblock->setChangedFlag(); - obj->m_static_exists = true; - obj->m_static_block = oldblock->getPos(); - } - else{ - dstream<<"WARNING: Server: Could not find a block for " - <<"storing static object"<m_static_exists = false; - continue; - } - /*dstream<<"INFO: Server: Stored static data. Deleting object." - <::Iterator i = objects_to_remove.begin(); - i != objects_to_remove.end(); i++) - { - m_active_objects.remove(*i); } } } + + /* + Step active objects + */ + { + //TimeTaker timer("Step active objects"); + + // This helps the objects to send data at the same time + bool send_recommended = false; + m_send_recommended_timer += dtime; + if(m_send_recommended_timer > 0.15) + { + m_send_recommended_timer = 0; + send_recommended = true; + } + + for(core::map::Iterator + i = m_active_objects.getIterator(); + i.atEnd()==false; i++) + { + ServerActiveObject* obj = i.getNode()->getValue(); + // Don't step if is to be removed or stored statically + if(obj->m_removed || obj->m_pending_deactivation) + continue; + // Step object, putting messages directly to the queue + obj->step(dtime, m_active_object_messages, send_recommended); + } + } + + /* + Manage active objects + */ + if(m_object_management_interval.step(dtime, 0.5)) + { + /* + Remove objects that satisfy (m_removed && m_known_by_count==0) + */ + removeRemovedObjects(); + } if(g_settings.getBool("enable_experimental")) { @@ -966,6 +1082,226 @@ ActiveObjectMessage ServerEnvironment::getActiveObjectMessage() return m_active_object_messages.pop_front(); } +/* + ************ Private methods ************* +*/ + +/* + Remove objects that satisfy (m_removed && m_known_by_count==0) +*/ +void ServerEnvironment::removeRemovedObjects() +{ + core::list objects_to_remove; + for(core::map::Iterator + i = m_active_objects.getIterator(); + i.atEnd()==false; i++) + { + u16 id = i.getNode()->getKey(); + ServerActiveObject* obj = i.getNode()->getValue(); + // This shouldn't happen but check it + if(obj == NULL) + { + dstream<<"WARNING: NULL object found in ServerEnvironment" + <<" while finding removed objects. id="<m_removed == false && obj->m_pending_deactivation == false) + continue; + + /* + Delete static data from block if is marked as removed + */ + if(obj->m_static_exists && obj->m_removed) + { + MapBlock *block = m_map->getBlockNoCreateNoEx(obj->m_static_block); + if(block) + { + block->m_static_objects.remove(id); + block->setChangedFlag(); + } + } + + // If m_known_by_count > 0, don't actually remove. + if(obj->m_known_by_count > 0) + continue; + + // Delete + delete obj; + // Id to be removed from m_active_objects + objects_to_remove.push_back(id); + } + // Remove references from m_active_objects + for(core::list::Iterator i = objects_to_remove.begin(); + i != objects_to_remove.end(); i++) + { + m_active_objects.remove(*i); + } +} + +/* + Convert stored objects from blocks near the players to active. +*/ +void ServerEnvironment::activateObjects(MapBlock *block) +{ + if(block==NULL) + return; + // Ignore if no stored objects (to not set changed flag) + if(block->m_static_objects.m_stored.size() == 0) + return; + // A list for objects that couldn't be converted to static for some + // reason. They will be stored back. + core::list new_stored; + // Loop through stored static objects + for(core::list::Iterator + i = block->m_static_objects.m_stored.begin(); + i != block->m_static_objects.m_stored.end(); i++) + { + /*dstream<<"INFO: Server: Creating an active object from " + <<"static data"<m_static_objects.m_stored.clear(); + // Add leftover failed stuff to stored list + for(core::list::Iterator + i = new_stored.begin(); + i != new_stored.end(); i++) + { + StaticObject &s_obj = *i; + block->m_static_objects.m_stored.push_back(s_obj); + } + // Block has been modified + block->setChangedFlag(); +} + +/* + Convert objects that are not in active blocks to static. + + If m_known_by_count != 0, active object is not deleted, but static + data is still updated. + + If force_delete is set, active object is deleted nevertheless. It + shall only be set so in the destructor of the environment. +*/ +void ServerEnvironment::deactivateFarObjects(bool force_delete) +{ + core::list objects_to_remove; + for(core::map::Iterator + i = m_active_objects.getIterator(); + i.atEnd()==false; i++) + { + ServerActiveObject* obj = i.getNode()->getValue(); + u16 id = i.getNode()->getKey(); + v3f objectpos = obj->getBasePosition(); + + // This shouldn't happen but check it + if(obj == NULL) + { + dstream<<"WARNING: NULL object found in ServerEnvironment" + <m_static_exists) + { + MapBlock *block = m_map->getBlockNoCreateNoEx + (obj->m_static_block); + if(block) + { + block->m_static_objects.remove(id); + oldblock = block; + } + } + // Create new static object + std::string staticdata = obj->getStaticData(); + StaticObject s_obj(obj->getType(), objectpos, staticdata); + // Add to the block where the object is located in + v3s16 blockpos = getNodeBlockPos(floatToInt(objectpos, BS)); + MapBlock *block = m_map->getBlockNoCreateNoEx(blockpos); + if(block) + { + block->m_static_objects.insert(0, s_obj); + block->setChangedFlag(); + obj->m_static_exists = true; + obj->m_static_block = block->getPos(); + } + // If not possible, add back to previous block + else if(oldblock) + { + oldblock->m_static_objects.insert(0, s_obj); + oldblock->setChangedFlag(); + obj->m_static_exists = true; + obj->m_static_block = oldblock->getPos(); + } + else{ + dstream<<"WARNING: Server: Could not find a block for " + <<"storing static object"<m_static_exists = false; + continue; + } + + /* + Delete active object if not known by some client, + else set pending deactivation + */ + + // If known by some client, don't delete. + if(obj->m_known_by_count > 0 && force_delete == false) + { + obj->m_pending_deactivation = true; + continue; + } + + /*dstream<<"INFO: Server: Stored static data. Deleting object." + <::Iterator i = objects_to_remove.begin(); + i != objects_to_remove.end(); i++) + { + m_active_objects.remove(*i); + } +} + + #ifndef SERVER /* @@ -1182,7 +1518,7 @@ void ClientEnvironment::step(float dtime) // Get node at head v3s16 p = floatToInt(playerpos + v3f(0,BS+BS/2,0), BS); MapNode n = m_map->getNode(p); - light = n.getLightBlend(m_daynight_ratio); + light = n.getLightBlend(getDayNightRatio()); } catch(InvalidPositionException &e) {} player->updateLight(light); @@ -1206,7 +1542,7 @@ void ClientEnvironment::step(float dtime) { v3s16 p_blocks = getNodeBlockPos(bottompos); MapBlock *b = m_map->getBlockNoCreate(p_blocks); - //b->updateMesh(m_daynight_ratio); + //b->updateMesh(getDayNightRatio()); b->setMeshExpired(true); } } @@ -1235,7 +1571,7 @@ void ClientEnvironment::step(float dtime) // Get node at head v3s16 p = obj->getLightPosition(); MapNode n = m_map->getNode(p); - light = n.getLightBlend(m_daynight_ratio); + light = n.getLightBlend(getDayNightRatio()); } catch(InvalidPositionException &e) {} obj->updateLight(light); @@ -1244,7 +1580,7 @@ void ClientEnvironment::step(float dtime) void ClientEnvironment::updateMeshes(v3s16 blockpos) { - m_map->updateMeshes(blockpos, m_daynight_ratio); + m_map->updateMeshes(blockpos, getDayNightRatio()); } void ClientEnvironment::expireMeshes(bool only_daynight_diffed)