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"
24 Environment::Environment()
26 m_daynight_ratio = 0.5;
29 Environment::~Environment()
32 for(core::list<Player*>::Iterator i = m_players.begin();
33 i != m_players.end(); i++)
39 void Environment::addPlayer(Player *player)
41 DSTACK(__FUNCTION_NAME);
43 Check that peer_ids are unique.
44 Also check that names are unique.
45 Exception: there can be multiple players with peer_id=0
47 // If peer id is non-zero, it has to be unique.
48 if(player->peer_id != 0)
49 assert(getPlayer(player->peer_id) == NULL);
50 // Name has to be unique.
51 assert(getPlayer(player->getName()) == NULL);
53 m_players.push_back(player);
56 void Environment::removePlayer(u16 peer_id)
58 DSTACK(__FUNCTION_NAME);
60 for(core::list<Player*>::Iterator i = m_players.begin();
61 i != m_players.end(); i++)
64 if(player->peer_id != peer_id)
69 // See if there is an another one
70 // (shouldn't be, but just to be sure)
75 Player * Environment::getPlayer(u16 peer_id)
77 for(core::list<Player*>::Iterator i = m_players.begin();
78 i != m_players.end(); i++)
81 if(player->peer_id == peer_id)
87 Player * Environment::getPlayer(const char *name)
89 for(core::list<Player*>::Iterator i = m_players.begin();
90 i != m_players.end(); i++)
93 if(strcmp(player->getName(), name) == 0)
99 Player * Environment::getRandomConnectedPlayer()
101 core::list<Player*> connected_players = getPlayers(true);
102 u32 chosen_one = myrand() % connected_players.size();
104 for(core::list<Player*>::Iterator
105 i = connected_players.begin();
106 i != connected_players.end(); i++)
118 Player * Environment::getNearestConnectedPlayer(v3f pos)
120 core::list<Player*> connected_players = getPlayers(true);
122 Player *nearest_player = NULL;
123 for(core::list<Player*>::Iterator
124 i = connected_players.begin();
125 i != connected_players.end(); i++)
128 f32 d = player->getPosition().getDistanceFrom(pos);
129 if(d < nearest_d || nearest_player == NULL)
132 nearest_player = player;
135 return nearest_player;
138 core::list<Player*> Environment::getPlayers()
143 core::list<Player*> Environment::getPlayers(bool ignore_disconnected)
145 core::list<Player*> newlist;
146 for(core::list<Player*>::Iterator
147 i = m_players.begin();
148 i != m_players.end(); i++)
152 if(ignore_disconnected)
154 // Ignore disconnected players
155 if(player->peer_id == 0)
159 newlist.push_back(player);
164 void Environment::printPlayers(std::ostream &o)
166 o<<"Players in environment:"<<std::endl;
167 for(core::list<Player*>::Iterator i = m_players.begin();
168 i != m_players.end(); i++)
171 o<<"Player peer_id="<<player->peer_id<<std::endl;
175 void Environment::setDayNightRatio(u32 r)
177 m_daynight_ratio = r;
180 u32 Environment::getDayNightRatio()
182 return m_daynight_ratio;
189 ServerEnvironment::ServerEnvironment(ServerMap *map, Server *server):
192 m_random_spawn_timer(0)
196 ServerEnvironment::~ServerEnvironment()
202 void ServerEnvironment::serializePlayers(const std::string &savedir)
204 std::string players_path = savedir + "/players";
205 fs::CreateDir(players_path);
207 core::map<Player*, bool> saved_players;
209 std::vector<fs::DirListNode> player_files = fs::GetDirListing(players_path);
210 for(u32 i=0; i<player_files.size(); i++)
212 if(player_files[i].dir)
215 // Full path to this file
216 std::string path = players_path + "/" + player_files[i].name;
218 //dstream<<"Checking player file "<<path<<std::endl;
220 // Load player to see what is its name
221 ServerRemotePlayer testplayer;
223 // Open file and deserialize
224 std::ifstream is(path.c_str(), std::ios_base::binary);
225 if(is.good() == false)
227 dstream<<"Failed to read "<<path<<std::endl;
230 testplayer.deSerialize(is);
233 //dstream<<"Loaded test player with name "<<testplayer.getName()<<std::endl;
235 // Search for the player
236 std::string playername = testplayer.getName();
237 Player *player = getPlayer(playername.c_str());
240 dstream<<"Didn't find matching player, ignoring file "<<path<<std::endl;
244 //dstream<<"Found matching player, overwriting."<<std::endl;
246 // OK, found. Save player there.
248 // Open file and serialize
249 std::ofstream os(path.c_str(), std::ios_base::binary);
250 if(os.good() == false)
252 dstream<<"Failed to overwrite "<<path<<std::endl;
255 player->serialize(os);
256 saved_players.insert(player, true);
260 for(core::list<Player*>::Iterator i = m_players.begin();
261 i != m_players.end(); i++)
264 if(saved_players.find(player) != NULL)
266 /*dstream<<"Player "<<player->getName()
267 <<" was already saved."<<std::endl;*/
270 std::string playername = player->getName();
271 // Don't save unnamed player
274 //dstream<<"Not saving unnamed player."<<std::endl;
280 if(string_allowed(playername, PLAYERNAME_ALLOWED_CHARS) == false)
281 playername = "player";
282 std::string path = players_path + "/" + playername;
284 for(u32 i=0; i<1000; i++)
286 if(fs::PathExists(path) == false)
291 path = players_path + "/" + playername + itos(i);
295 dstream<<"WARNING: Didn't find free file for player"<<std::endl;
300 /*dstream<<"Saving player "<<player->getName()<<" to "
302 // Open file and serialize
303 std::ofstream os(path.c_str(), std::ios_base::binary);
304 if(os.good() == false)
306 dstream<<"WARNING: Failed to overwrite "<<path<<std::endl;
309 player->serialize(os);
310 saved_players.insert(player, true);
314 //dstream<<"Saved "<<saved_players.size()<<" players."<<std::endl;
317 void ServerEnvironment::deSerializePlayers(const std::string &savedir)
319 std::string players_path = savedir + "/players";
321 core::map<Player*, bool> saved_players;
323 std::vector<fs::DirListNode> player_files = fs::GetDirListing(players_path);
324 for(u32 i=0; i<player_files.size(); i++)
326 if(player_files[i].dir)
329 // Full path to this file
330 std::string path = players_path + "/" + player_files[i].name;
332 dstream<<"Checking player file "<<path<<std::endl;
334 // Load player to see what is its name
335 ServerRemotePlayer testplayer;
337 // Open file and deserialize
338 std::ifstream is(path.c_str(), std::ios_base::binary);
339 if(is.good() == false)
341 dstream<<"Failed to read "<<path<<std::endl;
344 testplayer.deSerialize(is);
347 dstream<<"Loaded test player with name "<<testplayer.getName()<<std::endl;
349 // Search for the player
350 std::string playername = testplayer.getName();
351 Player *player = getPlayer(playername.c_str());
352 bool newplayer = false;
355 dstream<<"Is a new player"<<std::endl;
356 player = new ServerRemotePlayer();
362 dstream<<"Reading player "<<testplayer.getName()<<" from "
364 // Open file and deserialize
365 std::ifstream is(path.c_str(), std::ios_base::binary);
366 if(is.good() == false)
368 dstream<<"Failed to read "<<path<<std::endl;
371 player->deSerialize(is);
379 void ServerEnvironment::step(float dtime)
381 DSTACK(__FUNCTION_NAME);
384 //bool free_move = g_settings.getBool("free_move");
385 bool footprints = g_settings.getBool("footprints");
388 //TimeTaker timer("Server m_map->timerUpdate()", g_device);
389 m_map->timerUpdate(dtime);
395 for(core::list<Player*>::Iterator i = m_players.begin();
396 i != m_players.end(); i++)
399 v3f playerpos = player->getPosition();
402 player->move(dtime, *m_map, 100*BS);
405 Add footsteps to grass
409 // Get node that is at BS/4 under player
410 v3s16 bottompos = floatToInt(playerpos + v3f(0,-BS/4,0), BS);
412 MapNode n = m_map->getNode(bottompos);
413 if(n.d == CONTENT_GRASS)
415 n.d = CONTENT_GRASS_FOOTSTEPS;
416 m_map->setNode(bottompos, n);
419 catch(InvalidPositionException &e)
425 if(g_settings.getBool("enable_experimental"))
431 for(core::map<u16, ServerActiveObject*>::Iterator
432 i = m_active_objects.getIterator();
433 i.atEnd()==false; i++)
435 ServerActiveObject* obj = i.getNode()->getValue();
436 // Step object, putting messages directly to the queue
437 obj->step(dtime, m_active_object_messages);
441 Remove (m_removed && m_known_by_count==0) objects
444 core::list<u16> objects_to_remove;
445 for(core::map<u16, ServerActiveObject*>::Iterator
446 i = m_active_objects.getIterator();
447 i.atEnd()==false; i++)
449 u16 id = i.getNode()->getKey();
450 ServerActiveObject* obj = i.getNode()->getValue();
451 // This shouldn't happen but check it
454 dstream<<"WARNING: NULL object found in ServerEnvironment"
455 <<" while finding removed objects. id="<<id<<std::endl;
456 // Id to be removed from m_active_objects
457 objects_to_remove.push_back(id);
462 // If not m_removed, don't remove.
463 if(obj->m_removed == false)
467 // Id to be removed from m_active_objects
468 objects_to_remove.push_back(id);
471 // Remove references from m_active_objects
472 for(core::list<u16>::Iterator i = objects_to_remove.begin();
473 i != objects_to_remove.end(); i++)
475 m_active_objects.remove(*i);
482 m_random_spawn_timer -= dtime;
483 if(m_random_spawn_timer < 0)
485 m_random_spawn_timer += myrand_range(2.0, 20.0);
487 /*TestSAO *obj = new TestSAO(0,
488 v3f(myrand_range(-2*BS,2*BS), BS*5, myrand_range(-2*BS,2*BS)));*/
494 /*v2s16 p2d(myrand_range(-5,5), myrand_range(-5,5));
495 s16 y = 1 + getServerMap().findGroundLevel(p2d);
496 v3f pos(p2d.X*BS,y*BS,p2d.Y*BS);*/
498 Player *player = getRandomConnectedPlayer();
501 pos = player->getPosition();
503 myrand_range(-3,3)*BS,
505 myrand_range(-3,3)*BS
509 Create a LuaSAO (ServerActiveObject)
512 LuaSAO *obj = new LuaSAO(this, 0, pos);
515 Select a random type for it
517 std::string objectdir = porting::getDataPath("scripts/objects");
518 std::vector<fs::DirListNode> dirlist = fs::GetDirListing(objectdir);
519 if(dirlist.size() > 0)
521 u32 selected_i = myrand_range(0, dirlist.size()-1);
522 std::string selected_name = "";
523 selected_name = dirlist[selected_i].name;
524 /*for(u32 i=0; i<dirlist.size(); i++)*/
526 dstream<<"ServerEnvironment: Selected script name \""<<selected_name
527 <<"\" for new lua object"<<std::endl;
530 Load the scripts for the type
532 obj->initializeFromNothing(selected_name.c_str());
534 // Add the object to the environment
535 addActiveObject(obj);
539 } // enable_experimental
542 ServerActiveObject* ServerEnvironment::getActiveObject(u16 id)
544 core::map<u16, ServerActiveObject*>::Node *n;
545 n = m_active_objects.find(id);
548 return n->getValue();
551 bool isFreeServerActiveObjectId(u16 id,
552 core::map<u16, ServerActiveObject*> &objects)
557 for(core::map<u16, ServerActiveObject*>::Iterator
558 i = objects.getIterator();
559 i.atEnd()==false; i++)
561 if(i.getNode()->getKey() == id)
567 u16 getFreeServerActiveObjectId(
568 core::map<u16, ServerActiveObject*> &objects)
573 if(isFreeServerActiveObjectId(new_id, objects))
583 u16 ServerEnvironment::addActiveObject(ServerActiveObject *object)
586 if(object->getId() == 0)
588 u16 new_id = getFreeServerActiveObjectId(m_active_objects);
591 dstream<<"WARNING: ServerEnvironment::addActiveObject(): "
592 <<"no free ids available"<<std::endl;
596 object->setId(new_id);
598 if(isFreeServerActiveObjectId(object->getId(), m_active_objects) == false)
600 dstream<<"WARNING: ServerEnvironment::addActiveObject(): "
601 <<"id is not free ("<<object->getId()<<")"<<std::endl;
605 dstream<<"INGO: ServerEnvironment::addActiveObject(): "
606 <<"added (id="<<object->getId()<<")"<<std::endl;
607 m_active_objects.insert(object->getId(), object);
608 return object->getId();
612 Finds out what new objects have been added to
613 inside a radius around a position
615 void ServerEnvironment::getAddedActiveObjects(v3s16 pos, s16 radius,
616 core::map<u16, bool> ¤t_objects,
617 core::map<u16, bool> &added_objects)
619 v3f pos_f = intToFloat(pos, BS);
620 f32 radius_f = radius * BS;
622 Go through the object list,
623 - discard m_removed objects,
624 - discard objects that are too far away,
625 - discard objects that are found in current_objects.
626 - add remaining objects to added_objects
628 for(core::map<u16, ServerActiveObject*>::Iterator
629 i = m_active_objects.getIterator();
630 i.atEnd()==false; i++)
632 u16 id = i.getNode()->getKey();
634 ServerActiveObject *object = i.getNode()->getValue();
637 // Discard if removed
638 if(object->m_removed)
640 // Discard if too far
641 f32 distance_f = object->getBasePosition().getDistanceFrom(pos_f);
642 if(distance_f > radius_f)
644 // Discard if already on current_objects
645 core::map<u16, bool>::Node *n;
646 n = current_objects.find(id);
649 // Add to added_objects
650 added_objects.insert(id, false);
655 Finds out what objects have been removed from
656 inside a radius around a position
658 void ServerEnvironment::getRemovedActiveObjects(v3s16 pos, s16 radius,
659 core::map<u16, bool> ¤t_objects,
660 core::map<u16, bool> &removed_objects)
662 v3f pos_f = intToFloat(pos, BS);
663 f32 radius_f = radius * BS;
665 Go through current_objects; object is removed if:
666 - object is not found in m_active_objects (this is actually an
667 error condition; objects should be set m_removed=true and removed
668 only after all clients have been informed about removal), or
669 - object has m_removed=true, or
670 - object is too far away
672 for(core::map<u16, bool>::Iterator
673 i = current_objects.getIterator();
674 i.atEnd()==false; i++)
676 u16 id = i.getNode()->getKey();
677 ServerActiveObject *object = getActiveObject(id);
680 dstream<<"WARNING: ServerEnvironment::getRemovedActiveObjects():"
681 <<" object in current_objects is NULL"<<std::endl;
683 else if(object->m_removed == false)
685 f32 distance_f = object->getBasePosition().getDistanceFrom(pos_f);
686 /*dstream<<"removed == false"
687 <<"distance_f = "<<distance_f
688 <<", radius_f = "<<radius_f<<std::endl;*/
689 if(distance_f < radius_f)
695 removed_objects.insert(id, false);
699 ActiveObjectMessage ServerEnvironment::getActiveObjectMessage()
701 if(m_active_object_messages.size() == 0)
702 return ActiveObjectMessage(0);
704 return m_active_object_messages.pop_front();
713 ClientEnvironment::ClientEnvironment(ClientMap *map, scene::ISceneManager *smgr):
721 ClientEnvironment::~ClientEnvironment()
723 // delete active objects
724 for(core::map<u16, ClientActiveObject*>::Iterator
725 i = m_active_objects.getIterator();
726 i.atEnd()==false; i++)
728 delete i.getNode()->getValue();
735 void ClientEnvironment::addPlayer(Player *player)
737 DSTACK(__FUNCTION_NAME);
739 It is a failure if player is local and there already is a local
742 assert(!(player->isLocal() == true && getLocalPlayer() != NULL));
744 Environment::addPlayer(player);
747 LocalPlayer * ClientEnvironment::getLocalPlayer()
749 for(core::list<Player*>::Iterator i = m_players.begin();
750 i != m_players.end(); i++)
753 if(player->isLocal())
754 return (LocalPlayer*)player;
759 void ClientEnvironment::step(float dtime)
761 DSTACK(__FUNCTION_NAME);
764 bool free_move = g_settings.getBool("free_move");
765 bool footprints = g_settings.getBool("footprints");
768 //TimeTaker timer("Client m_map->timerUpdate()", g_device);
769 m_map->timerUpdate(dtime);
773 Get the speed the player is going
775 f32 player_speed = 0.001; // just some small value
776 LocalPlayer *lplayer = getLocalPlayer();
778 player_speed = lplayer->getSpeed().getLength();
781 Maximum position increment
783 //f32 position_max_increment = 0.05*BS;
784 f32 position_max_increment = 0.1*BS;
786 // Maximum time increment (for collision detection etc)
787 // time = distance / speed
788 f32 dtime_max_increment = position_max_increment / player_speed;
790 // Maximum time increment is 10ms or lower
791 if(dtime_max_increment > 0.01)
792 dtime_max_increment = 0.01;
794 // Don't allow overly huge dtime
798 f32 dtime_downcount = dtime;
801 Stuff that has a maximum time increment
810 if(dtime_downcount > dtime_max_increment)
812 dtime_part = dtime_max_increment;
813 dtime_downcount -= dtime_part;
817 dtime_part = dtime_downcount;
819 Setting this to 0 (no -=dtime_part) disables an infinite loop
820 when dtime_part is so small that dtime_downcount -= dtime_part
831 Player *player = getLocalPlayer();
833 v3f playerpos = player->getPosition();
836 if(free_move == false)
839 v3f speed = player->getSpeed();
840 if(player->swimming_up == false)
841 speed.Y -= 9.81 * BS * dtime_part * 2;
844 if(player->in_water_stable || player->in_water)
846 f32 max_down = 2.0*BS;
847 if(speed.Y < -max_down) speed.Y = -max_down;
850 if(speed.getLength() > max)
852 speed = speed / speed.getLength() * max;
856 player->setSpeed(speed);
861 This also does collision detection.
863 player->move(dtime_part, *m_map, position_max_increment);
866 while(dtime_downcount > 0.001);
868 //std::cout<<"Looped "<<loopcount<<" times."<<std::endl;
871 Stuff that can be done in an arbitarily large dtime
873 for(core::list<Player*>::Iterator i = m_players.begin();
874 i != m_players.end(); i++)
877 v3f playerpos = player->getPosition();
880 Handle non-local players
882 if(player->isLocal() == false)
885 player->move(dtime, *m_map, 100*BS);
887 // Update lighting on remote players on client
888 u8 light = LIGHT_MAX;
891 v3s16 p = floatToInt(playerpos + v3f(0,BS+BS/2,0), BS);
892 MapNode n = m_map->getNode(p);
893 light = n.getLightBlend(m_daynight_ratio);
895 catch(InvalidPositionException &e) {}
896 player->updateLight(light);
900 Add footsteps to grass
904 // Get node that is at BS/4 under player
905 v3s16 bottompos = floatToInt(playerpos + v3f(0,-BS/4,0), BS);
907 MapNode n = m_map->getNode(bottompos);
908 if(n.d == CONTENT_GRASS)
910 n.d = CONTENT_GRASS_FOOTSTEPS;
911 m_map->setNode(bottompos, n);
912 // Update mesh on client
913 if(m_map->mapType() == MAPTYPE_CLIENT)
915 v3s16 p_blocks = getNodeBlockPos(bottompos);
916 MapBlock *b = m_map->getBlockNoCreate(p_blocks);
917 b->updateMesh(m_daynight_ratio);
921 catch(InvalidPositionException &e)
930 for(core::map<u16, ClientActiveObject*>::Iterator
931 i = m_active_objects.getIterator();
932 i.atEnd()==false; i++)
934 ClientActiveObject* obj = i.getNode()->getValue();
940 void ClientEnvironment::updateMeshes(v3s16 blockpos)
942 m_map->updateMeshes(blockpos, m_daynight_ratio);
945 void ClientEnvironment::expireMeshes(bool only_daynight_diffed)
947 m_map->expireMeshes(only_daynight_diffed);
950 ClientActiveObject* ClientEnvironment::getActiveObject(u16 id)
952 core::map<u16, ClientActiveObject*>::Node *n;
953 n = m_active_objects.find(id);
956 return n->getValue();
959 bool isFreeClientActiveObjectId(u16 id,
960 core::map<u16, ClientActiveObject*> &objects)
965 for(core::map<u16, ClientActiveObject*>::Iterator
966 i = objects.getIterator();
967 i.atEnd()==false; i++)
969 if(i.getNode()->getKey() == id)
975 u16 getFreeClientActiveObjectId(
976 core::map<u16, ClientActiveObject*> &objects)
981 if(isFreeClientActiveObjectId(new_id, objects))
991 u16 ClientEnvironment::addActiveObject(ClientActiveObject *object)
994 if(object->getId() == 0)
996 u16 new_id = getFreeClientActiveObjectId(m_active_objects);
999 dstream<<"WARNING: ClientEnvironment::addActiveObject(): "
1000 <<"no free ids available"<<std::endl;
1004 object->setId(new_id);
1006 if(isFreeClientActiveObjectId(object->getId(), m_active_objects) == false)
1008 dstream<<"WARNING: ClientEnvironment::addActiveObject(): "
1009 <<"id is not free ("<<object->getId()<<")"<<std::endl;
1013 dstream<<"INGO: ClientEnvironment::addActiveObject(): "
1014 <<"added (id="<<object->getId()<<")"<<std::endl;
1015 m_active_objects.insert(object->getId(), object);
1016 object->addToScene(m_smgr);
1017 return object->getId();
1020 void ClientEnvironment::addActiveObject(u16 id, u8 type,
1021 const std::string &init_data)
1023 ClientActiveObject* obj = ClientActiveObject::create(type);
1026 dstream<<"WARNING: ClientEnvironment::addActiveObject(): "
1027 <<"id="<<id<<" type="<<type<<": Couldn't create object"
1034 addActiveObject(obj);
1036 obj->initialize(init_data);
1039 void ClientEnvironment::removeActiveObject(u16 id)
1041 dstream<<"ClientEnvironment::removeActiveObject(): "
1042 <<"id="<<id<<std::endl;
1043 ClientActiveObject* obj = getActiveObject(id);
1046 dstream<<"WARNING: ClientEnvironment::removeActiveObject(): "
1047 <<"id="<<id<<" not found"<<std::endl;
1050 obj->removeFromScene();
1052 m_active_objects.remove(id);
1055 void ClientEnvironment::processActiveObjectMessage(u16 id,
1056 const std::string &data)
1058 ClientActiveObject* obj = getActiveObject(id);
1061 dstream<<"WARNING: ClientEnvironment::processActiveObjectMessage():"
1062 <<" got message for id="<<id<<", which doesn't exist."
1066 obj->processMessage(data);
1069 #endif // #ifndef SERVER