3 Copyright (C) 2010 celeron55, Perttu Ahola <celeron55@gmail.com>
5 This program is free software; you can redistribute it and/or modify
6 it under the terms of the GNU General Public License as published by
7 the Free Software Foundation; either version 2 of the License, or
8 (at your option) any later version.
10 This program is distributed in the hope that it will be useful,
11 but WITHOUT ANY WARRANTY; without even the implied warranty of
12 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
13 GNU General Public License for more details.
15 You should have received a copy of the GNU General Public License along
16 with this program; if not, write to the Free Software Foundation, Inc.,
17 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
20 #include "environment.h"
23 Environment::Environment()
25 m_daynight_ratio = 0.5;
28 Environment::~Environment()
31 for(core::list<Player*>::Iterator i = m_players.begin();
32 i != m_players.end(); i++)
38 void Environment::addPlayer(Player *player)
40 DSTACK(__FUNCTION_NAME);
42 Check that peer_ids are unique.
43 Also check that names are unique.
44 Exception: there can be multiple players with peer_id=0
46 // If peer id is non-zero, it has to be unique.
47 if(player->peer_id != 0)
48 assert(getPlayer(player->peer_id) == NULL);
49 // Name has to be unique.
50 assert(getPlayer(player->getName()) == NULL);
52 m_players.push_back(player);
55 void Environment::removePlayer(u16 peer_id)
57 DSTACK(__FUNCTION_NAME);
59 for(core::list<Player*>::Iterator i = m_players.begin();
60 i != m_players.end(); i++)
63 if(player->peer_id != peer_id)
68 // See if there is an another one
69 // (shouldn't be, but just to be sure)
74 Player * Environment::getPlayer(u16 peer_id)
76 for(core::list<Player*>::Iterator i = m_players.begin();
77 i != m_players.end(); i++)
80 if(player->peer_id == peer_id)
86 Player * Environment::getPlayer(const char *name)
88 for(core::list<Player*>::Iterator i = m_players.begin();
89 i != m_players.end(); i++)
92 if(strcmp(player->getName(), name) == 0)
98 core::list<Player*> Environment::getPlayers()
103 core::list<Player*> Environment::getPlayers(bool ignore_disconnected)
105 core::list<Player*> newlist;
106 for(core::list<Player*>::Iterator
107 i = m_players.begin();
108 i != m_players.end(); i++)
112 if(ignore_disconnected)
114 // Ignore disconnected players
115 if(player->peer_id == 0)
119 newlist.push_back(player);
124 void Environment::printPlayers(std::ostream &o)
126 o<<"Players in environment:"<<std::endl;
127 for(core::list<Player*>::Iterator i = m_players.begin();
128 i != m_players.end(); i++)
131 o<<"Player peer_id="<<player->peer_id<<std::endl;
135 void Environment::setDayNightRatio(u32 r)
137 m_daynight_ratio = r;
140 u32 Environment::getDayNightRatio()
142 return m_daynight_ratio;
149 ServerEnvironment::ServerEnvironment(ServerMap *map):
151 m_random_spawn_timer(0)
156 TestSAO *obj = new TestSAO(0, v3f(0, BS*5, 0));
157 addActiveObject(obj);
160 ServerEnvironment::~ServerEnvironment()
166 void ServerEnvironment::serializePlayers(const std::string &savedir)
168 std::string players_path = savedir + "/players";
169 fs::CreateDir(players_path);
171 core::map<Player*, bool> saved_players;
173 std::vector<fs::DirListNode> player_files = fs::GetDirListing(players_path);
174 for(u32 i=0; i<player_files.size(); i++)
176 if(player_files[i].dir)
179 // Full path to this file
180 std::string path = players_path + "/" + player_files[i].name;
182 //dstream<<"Checking player file "<<path<<std::endl;
184 // Load player to see what is its name
185 ServerRemotePlayer testplayer;
187 // Open file and deserialize
188 std::ifstream is(path.c_str(), std::ios_base::binary);
189 if(is.good() == false)
191 dstream<<"Failed to read "<<path<<std::endl;
194 testplayer.deSerialize(is);
197 //dstream<<"Loaded test player with name "<<testplayer.getName()<<std::endl;
199 // Search for the player
200 std::string playername = testplayer.getName();
201 Player *player = getPlayer(playername.c_str());
204 dstream<<"Didn't find matching player, ignoring file "<<path<<std::endl;
208 //dstream<<"Found matching player, overwriting."<<std::endl;
210 // OK, found. Save player there.
212 // Open file and serialize
213 std::ofstream os(path.c_str(), std::ios_base::binary);
214 if(os.good() == false)
216 dstream<<"Failed to overwrite "<<path<<std::endl;
219 player->serialize(os);
220 saved_players.insert(player, true);
224 for(core::list<Player*>::Iterator i = m_players.begin();
225 i != m_players.end(); i++)
228 if(saved_players.find(player) != NULL)
230 /*dstream<<"Player "<<player->getName()
231 <<" was already saved."<<std::endl;*/
234 std::string playername = player->getName();
235 // Don't save unnamed player
238 //dstream<<"Not saving unnamed player."<<std::endl;
244 if(string_allowed(playername, PLAYERNAME_ALLOWED_CHARS) == false)
245 playername = "player";
246 std::string path = players_path + "/" + playername;
248 for(u32 i=0; i<1000; i++)
250 if(fs::PathExists(path) == false)
255 path = players_path + "/" + playername + itos(i);
259 dstream<<"WARNING: Didn't find free file for player"<<std::endl;
264 /*dstream<<"Saving player "<<player->getName()<<" to "
266 // Open file and serialize
267 std::ofstream os(path.c_str(), std::ios_base::binary);
268 if(os.good() == false)
270 dstream<<"WARNING: Failed to overwrite "<<path<<std::endl;
273 player->serialize(os);
274 saved_players.insert(player, true);
278 //dstream<<"Saved "<<saved_players.size()<<" players."<<std::endl;
281 void ServerEnvironment::deSerializePlayers(const std::string &savedir)
283 std::string players_path = savedir + "/players";
285 core::map<Player*, bool> saved_players;
287 std::vector<fs::DirListNode> player_files = fs::GetDirListing(players_path);
288 for(u32 i=0; i<player_files.size(); i++)
290 if(player_files[i].dir)
293 // Full path to this file
294 std::string path = players_path + "/" + player_files[i].name;
296 dstream<<"Checking player file "<<path<<std::endl;
298 // Load player to see what is its name
299 ServerRemotePlayer testplayer;
301 // Open file and deserialize
302 std::ifstream is(path.c_str(), std::ios_base::binary);
303 if(is.good() == false)
305 dstream<<"Failed to read "<<path<<std::endl;
308 testplayer.deSerialize(is);
311 dstream<<"Loaded test player with name "<<testplayer.getName()<<std::endl;
313 // Search for the player
314 std::string playername = testplayer.getName();
315 Player *player = getPlayer(playername.c_str());
316 bool newplayer = false;
319 dstream<<"Is a new player"<<std::endl;
320 player = new ServerRemotePlayer();
326 dstream<<"Reading player "<<testplayer.getName()<<" from "
328 // Open file and deserialize
329 std::ifstream is(path.c_str(), std::ios_base::binary);
330 if(is.good() == false)
332 dstream<<"Failed to read "<<path<<std::endl;
335 player->deSerialize(is);
343 void ServerEnvironment::step(float dtime)
345 DSTACK(__FUNCTION_NAME);
348 //bool free_move = g_settings.getBool("free_move");
349 bool footprints = g_settings.getBool("footprints");
352 //TimeTaker timer("Server m_map->timerUpdate()", g_device);
353 m_map->timerUpdate(dtime);
359 for(core::list<Player*>::Iterator i = m_players.begin();
360 i != m_players.end(); i++)
363 v3f playerpos = player->getPosition();
366 player->move(dtime, *m_map, 100*BS);
369 Add footsteps to grass
373 // Get node that is at BS/4 under player
374 v3s16 bottompos = floatToInt(playerpos + v3f(0,-BS/4,0), BS);
376 MapNode n = m_map->getNode(bottompos);
377 if(n.d == CONTENT_GRASS)
379 n.d = CONTENT_GRASS_FOOTSTEPS;
380 m_map->setNode(bottompos, n);
383 catch(InvalidPositionException &e)
392 for(core::map<u16, ServerActiveObject*>::Iterator
393 i = m_active_objects.getIterator();
394 i.atEnd()==false; i++)
396 ServerActiveObject* obj = i.getNode()->getValue();
397 // Step object, putting messages directly to the queue
398 obj->step(dtime, m_active_object_messages);
402 Remove (m_removed && m_known_by_count==0) objects
405 core::list<u16> objects_to_remove;
406 for(core::map<u16, ServerActiveObject*>::Iterator
407 i = m_active_objects.getIterator();
408 i.atEnd()==false; i++)
410 u16 id = i.getNode()->getKey();
411 ServerActiveObject* obj = i.getNode()->getValue();
412 // This shouldn't happen but check it
415 dstream<<"WARNING: NULL object found in ServerEnvironment"
416 <<" while finding removed objects. id="<<id<<std::endl;
417 // Id to be removed from m_active_objects
418 objects_to_remove.push_back(id);
423 // If not m_removed, don't remove.
424 if(obj->m_removed == false)
428 // Id to be removed from m_active_objects
429 objects_to_remove.push_back(id);
432 // Remove references from m_active_objects
433 for(core::list<u16>::Iterator i = objects_to_remove.begin();
434 i != objects_to_remove.end(); i++)
436 m_active_objects.remove(*i);
443 m_random_spawn_timer -= dtime;
444 if(m_random_spawn_timer < 0)
446 m_random_spawn_timer += 0.1;
447 TestSAO *obj = new TestSAO(0,
448 v3f(myrand_range(-2*BS,2*BS), BS*5, myrand_range(-2*BS,2*BS)));
449 addActiveObject(obj);
453 ServerActiveObject* ServerEnvironment::getActiveObject(u16 id)
455 core::map<u16, ServerActiveObject*>::Node *n;
456 n = m_active_objects.find(id);
459 return n->getValue();
462 bool isFreeServerActiveObjectId(u16 id,
463 core::map<u16, ServerActiveObject*> &objects)
468 for(core::map<u16, ServerActiveObject*>::Iterator
469 i = objects.getIterator();
470 i.atEnd()==false; i++)
472 if(i.getNode()->getKey() == id)
478 u16 getFreeServerActiveObjectId(
479 core::map<u16, ServerActiveObject*> &objects)
484 if(isFreeServerActiveObjectId(new_id, objects))
494 u16 ServerEnvironment::addActiveObject(ServerActiveObject *object)
497 if(object->getId() == 0)
499 u16 new_id = getFreeServerActiveObjectId(m_active_objects);
502 dstream<<"WARNING: ServerEnvironment::addActiveObject(): "
503 <<"no free ids available"<<std::endl;
507 object->setId(new_id);
509 if(isFreeServerActiveObjectId(object->getId(), m_active_objects) == false)
511 dstream<<"WARNING: ServerEnvironment::addActiveObject(): "
512 <<"id is not free ("<<object->getId()<<")"<<std::endl;
516 dstream<<"INGO: ServerEnvironment::addActiveObject(): "
517 <<"added (id="<<object->getId()<<")"<<std::endl;
518 m_active_objects.insert(object->getId(), object);
519 return object->getId();
523 Finds out what new objects have been added to
524 inside a radius around a position
526 void ServerEnvironment::getAddedActiveObjects(v3s16 pos, s16 radius,
527 core::map<u16, bool> ¤t_objects,
528 core::map<u16, bool> &added_objects)
530 v3f pos_f = intToFloat(pos, BS);
531 f32 radius_f = radius * BS;
533 Go through the object list,
534 - discard m_removed objects,
535 - discard objects that are too far away,
536 - discard objects that are found in current_objects.
537 - add remaining objects to added_objects
539 for(core::map<u16, ServerActiveObject*>::Iterator
540 i = m_active_objects.getIterator();
541 i.atEnd()==false; i++)
543 u16 id = i.getNode()->getKey();
545 ServerActiveObject *object = i.getNode()->getValue();
548 // Discard if removed
549 if(object->m_removed)
551 // Discard if too far
552 f32 distance_f = object->getBasePosition().getDistanceFrom(pos_f);
553 if(distance_f > radius_f)
555 // Discard if already on current_objects
556 core::map<u16, bool>::Node *n;
557 n = current_objects.find(id);
560 // Add to added_objects
561 added_objects.insert(id, false);
566 Finds out what objects have been removed from
567 inside a radius around a position
569 void ServerEnvironment::getRemovedActiveObjects(v3s16 pos, s16 radius,
570 core::map<u16, bool> ¤t_objects,
571 core::map<u16, bool> &removed_objects)
573 v3f pos_f = intToFloat(pos, BS);
574 f32 radius_f = radius * BS;
576 Go through current_objects; object is removed if:
577 - object is not found in m_active_objects (this is actually an
578 error condition; objects should be set m_removed=true and removed
579 only after all clients have been informed about removal), or
580 - object has m_removed=true, or
581 - object is too far away
583 for(core::map<u16, bool>::Iterator
584 i = current_objects.getIterator();
585 i.atEnd()==false; i++)
587 u16 id = i.getNode()->getKey();
588 ServerActiveObject *object = getActiveObject(id);
591 dstream<<"WARNING: ServerEnvironment::getRemovedActiveObjects():"
592 <<" object in current_objects is NULL"<<std::endl;
594 else if(object->m_removed == false)
596 f32 distance_f = object->getBasePosition().getDistanceFrom(pos_f);
597 /*dstream<<"removed == false"
598 <<"distance_f = "<<distance_f
599 <<", radius_f = "<<radius_f<<std::endl;*/
600 if(distance_f < radius_f)
606 removed_objects.insert(id, false);
610 ActiveObjectMessage ServerEnvironment::getActiveObjectMessage()
612 if(m_active_object_messages.size() == 0)
613 return ActiveObjectMessage(0);
615 return m_active_object_messages.pop_front();
624 ClientEnvironment::ClientEnvironment(ClientMap *map, scene::ISceneManager *smgr):
632 ClientEnvironment::~ClientEnvironment()
634 // delete active objects
635 for(core::map<u16, ClientActiveObject*>::Iterator
636 i = m_active_objects.getIterator();
637 i.atEnd()==false; i++)
639 delete i.getNode()->getValue();
646 void ClientEnvironment::addPlayer(Player *player)
648 DSTACK(__FUNCTION_NAME);
650 It is a failure if player is local and there already is a local
653 assert(!(player->isLocal() == true && getLocalPlayer() != NULL));
655 Environment::addPlayer(player);
658 LocalPlayer * ClientEnvironment::getLocalPlayer()
660 for(core::list<Player*>::Iterator i = m_players.begin();
661 i != m_players.end(); i++)
664 if(player->isLocal())
665 return (LocalPlayer*)player;
670 void ClientEnvironment::step(float dtime)
672 DSTACK(__FUNCTION_NAME);
675 bool free_move = g_settings.getBool("free_move");
676 bool footprints = g_settings.getBool("footprints");
679 //TimeTaker timer("Client m_map->timerUpdate()", g_device);
680 m_map->timerUpdate(dtime);
684 Get the speed the player is going
686 f32 player_speed = 0.001; // just some small value
687 LocalPlayer *lplayer = getLocalPlayer();
689 player_speed = lplayer->getSpeed().getLength();
692 Maximum position increment
694 //f32 position_max_increment = 0.05*BS;
695 f32 position_max_increment = 0.1*BS;
697 // Maximum time increment (for collision detection etc)
698 // time = distance / speed
699 f32 dtime_max_increment = position_max_increment / player_speed;
701 // Maximum time increment is 10ms or lower
702 if(dtime_max_increment > 0.01)
703 dtime_max_increment = 0.01;
705 // Don't allow overly huge dtime
709 f32 dtime_downcount = dtime;
712 Stuff that has a maximum time increment
721 if(dtime_downcount > dtime_max_increment)
722 dtime_part = dtime_max_increment;
725 dtime_downcount -= dtime_part;
732 Player *player = getLocalPlayer();
734 v3f playerpos = player->getPosition();
737 if(free_move == false)
740 v3f speed = player->getSpeed();
741 if(player->swimming_up == false)
742 speed.Y -= 9.81 * BS * dtime_part * 2;
745 if(player->in_water_stable || player->in_water)
747 f32 max_down = 2.0*BS;
748 if(speed.Y < -max_down) speed.Y = -max_down;
751 if(speed.getLength() > max)
753 speed = speed / speed.getLength() * max;
757 player->setSpeed(speed);
762 This also does collision detection.
764 player->move(dtime_part, *m_map, position_max_increment);
767 while(dtime_downcount > 0.001);
769 //std::cout<<"Looped "<<loopcount<<" times."<<std::endl;
772 Stuff that can be done in an arbitarily large dtime
774 for(core::list<Player*>::Iterator i = m_players.begin();
775 i != m_players.end(); i++)
778 v3f playerpos = player->getPosition();
781 Handle non-local players
783 if(player->isLocal() == false)
786 player->move(dtime, *m_map, 100*BS);
788 // Update lighting on remote players on client
789 u8 light = LIGHT_MAX;
792 v3s16 p = floatToInt(playerpos + v3f(0,BS+BS/2,0), BS);
793 MapNode n = m_map->getNode(p);
794 light = n.getLightBlend(m_daynight_ratio);
796 catch(InvalidPositionException &e) {}
797 player->updateLight(light);
801 Add footsteps to grass
805 // Get node that is at BS/4 under player
806 v3s16 bottompos = floatToInt(playerpos + v3f(0,-BS/4,0), BS);
808 MapNode n = m_map->getNode(bottompos);
809 if(n.d == CONTENT_GRASS)
811 n.d = CONTENT_GRASS_FOOTSTEPS;
812 m_map->setNode(bottompos, n);
813 // Update mesh on client
814 if(m_map->mapType() == MAPTYPE_CLIENT)
816 v3s16 p_blocks = getNodeBlockPos(bottompos);
817 MapBlock *b = m_map->getBlockNoCreate(p_blocks);
818 b->updateMesh(m_daynight_ratio);
822 catch(InvalidPositionException &e)
831 for(core::map<u16, ClientActiveObject*>::Iterator
832 i = m_active_objects.getIterator();
833 i.atEnd()==false; i++)
835 ClientActiveObject* obj = i.getNode()->getValue();
841 void ClientEnvironment::updateMeshes(v3s16 blockpos)
843 m_map->updateMeshes(blockpos, m_daynight_ratio);
846 void ClientEnvironment::expireMeshes(bool only_daynight_diffed)
848 m_map->expireMeshes(only_daynight_diffed);
851 ClientActiveObject* ClientEnvironment::getActiveObject(u16 id)
853 core::map<u16, ClientActiveObject*>::Node *n;
854 n = m_active_objects.find(id);
857 return n->getValue();
860 bool isFreeClientActiveObjectId(u16 id,
861 core::map<u16, ClientActiveObject*> &objects)
866 for(core::map<u16, ClientActiveObject*>::Iterator
867 i = objects.getIterator();
868 i.atEnd()==false; i++)
870 if(i.getNode()->getKey() == id)
876 u16 getFreeClientActiveObjectId(
877 core::map<u16, ClientActiveObject*> &objects)
882 if(isFreeClientActiveObjectId(new_id, objects))
892 u16 ClientEnvironment::addActiveObject(ClientActiveObject *object)
895 if(object->getId() == 0)
897 u16 new_id = getFreeClientActiveObjectId(m_active_objects);
900 dstream<<"WARNING: ClientEnvironment::addActiveObject(): "
901 <<"no free ids available"<<std::endl;
905 object->setId(new_id);
907 if(isFreeClientActiveObjectId(object->getId(), m_active_objects) == false)
909 dstream<<"WARNING: ClientEnvironment::addActiveObject(): "
910 <<"id is not free ("<<object->getId()<<")"<<std::endl;
914 dstream<<"INGO: ClientEnvironment::addActiveObject(): "
915 <<"added (id="<<object->getId()<<")"<<std::endl;
916 m_active_objects.insert(object->getId(), object);
917 object->addToScene(m_smgr);
918 return object->getId();
921 void ClientEnvironment::addActiveObject(u16 id, u8 type)
923 ClientActiveObject* obj = ClientActiveObject::create(type);
926 dstream<<"WARNING: ClientEnvironment::addActiveObject(): "
927 <<"id="<<id<<" type="<<type<<": Couldn't create object"
934 addActiveObject(obj);
937 void ClientEnvironment::removeActiveObject(u16 id)
939 dstream<<"ClientEnvironment::removeActiveObject(): "
940 <<"id="<<id<<std::endl;
941 ClientActiveObject* obj = getActiveObject(id);
944 dstream<<"WARNING: ClientEnvironment::removeActiveObject(): "
945 <<"id="<<id<<" not found"<<std::endl;
948 obj->removeFromScene();
950 m_active_objects.remove(id);
953 void ClientEnvironment::processActiveObjectMessage(u16 id,
954 const std::string &data)
956 ClientActiveObject* obj = getActiveObject(id);
959 dstream<<"WARNING: ClientEnvironment::processActiveObjectMessage():"
960 <<" got message for id="<<id<<", which doesn't exist."
964 obj->processMessage(data);
967 #endif // #ifndef SERVER