1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807180818091810181118121813181418151816181718181819182018211822182318241825182618271828182918301831183218331834183518361837183818391840184118421843184418451846184718481849185018511852185318541855185618571858185918601861186218631864186518661867186818691870187118721873187418751876187718781879188018811882188318841885188618871888188918901891189218931894189518961897189818991900190119021903190419051906190719081909191019111912191319141915191619171918191919201921192219231924192519261927192819291930193119321933193419351936193719381939194019411942194319441945194619471948194919501951195219531954195519561957195819591960196119621963196419651966196719681969197019711972197319741975197619771978197919801981198219831984198519861987198819891990199119921993199419951996199719981999200020012002200320042005200620072008200920102011201220132014201520162017201820192020202120222023202420252026202720282029203020312032203320342035203620372038203920402041204220432044204520462047204820492050205120522053205420552056205720582059206020612062206320642065206620672068206920702071207220732074207520762077207820792080208120822083208420852086208720882089209020912092209320942095209620972098209921002101210221032104210521062107210821092110211121122113211421152116211721182119212021212122212321242125212621272128212921302131213221332134213521362137213821392140214121422143214421452146214721482149215021512152215321542155215621572158215921602161216221632164216521662167216821692170217121722173217421752176217721782179218021812182218321842185218621872188218921902191219221932194219521962197219821992200220122022203220422052206220722082209221022112212221322142215221622172218221922202221222222232224222522262227222822292230223122322233223422352236223722382239224022412242224322442245224622472248224922502251225222532254225522562257225822592260226122622263226422652266226722682269227022712272227322742275227622772278227922802281228222832284228522862287228822892290229122922293229422952296229722982299230023012302230323042305230623072308230923102311231223132314231523162317231823192320232123222323232423252326232723282329233023312332233323342335233623372338233923402341234223432344234523462347234823492350235123522353235423552356235723582359236023612362236323642365236623672368236923702371237223732374237523762377237823792380238123822383238423852386238723882389239023912392239323942395239623972398239924002401240224032404240524062407240824092410241124122413241424152416241724182419242024212422242324242425242624272428242924302431243224332434243524362437243824392440244124422443244424452446244724482449245024512452245324542455245624572458245924602461246224632464246524662467246824692470247124722473247424752476247724782479248024812482248324842485248624872488248924902491249224932494249524962497249824992500250125022503250425052506250725082509251025112512251325142515251625172518251925202521252225232524252525262527252825292530253125322533253425352536253725382539254025412542254325442545254625472548254925502551255225532554255525562557255825592560256125622563256425652566256725682569257025712572257325742575257625772578257925802581258225832584258525862587258825892590259125922593259425952596259725982599260026012602260326042605260626072608260926102611261226132614261526162617261826192620262126222623262426252626262726282629263026312632263326342635263626372638263926402641264226432644264526462647264826492650265126522653265426552656265726582659266026612662266326642665266626672668266926702671267226732674267526762677267826792680268126822683268426852686268726882689269026912692269326942695269626972698269927002701270227032704270527062707270827092710271127122713271427152716271727182719272027212722272327242725272627272728272927302731273227332734273527362737273827392740274127422743274427452746274727482749275027512752275327542755275627572758275927602761276227632764276527662767276827692770277127722773277427752776277727782779278027812782278327842785278627872788278927902791279227932794279527962797279827992800280128022803280428052806280728082809281028112812281328142815281628172818281928202821282228232824282528262827282828292830283128322833283428352836283728382839284028412842284328442845284628472848284928502851285228532854285528562857285828592860286128622863286428652866286728682869287028712872287328742875287628772878287928802881288228832884288528862887288828892890289128922893289428952896289728982899290029012902290329042905290629072908290929102911291229132914291529162917291829192920292129222923292429252926292729282929293029312932293329342935293629372938293929402941294229432944294529462947294829492950295129522953295429552956295729582959296029612962296329642965296629672968296929702971297229732974297529762977297829792980298129822983298429852986298729882989299029912992299329942995299629972998299930003001300230033004300530063007300830093010301130123013301430153016301730183019302030213022302330243025302630273028302930303031303230333034303530363037303830393040304130423043304430453046304730483049305030513052305330543055305630573058305930603061306230633064306530663067306830693070307130723073307430753076307730783079308030813082308330843085308630873088308930903091309230933094309530963097309830993100310131023103310431053106310731083109311031113112311331143115311631173118311931203121312231233124312531263127312831293130313131323133313431353136313731383139314031413142314331443145314631473148314931503151315231533154315531563157315831593160316131623163316431653166316731683169317031713172317331743175317631773178317931803181318231833184318531863187318831893190319131923193319431953196319731983199320032013202320332043205320632073208320932103211321232133214321532163217321832193220322132223223322432253226322732283229323032313232323332343235323632373238323932403241324232433244324532463247324832493250325132523253325432553256325732583259326032613262326332643265326632673268326932703271327232733274327532763277327832793280328132823283328432853286328732883289329032913292329332943295329632973298329933003301330233033304330533063307330833093310331133123313331433153316331733183319332033213322332333243325332633273328332933303331333233333334333533363337333833393340334133423343334433453346334733483349335033513352335333543355335633573358335933603361336233633364336533663367336833693370337133723373337433753376337733783379338033813382338333843385338633873388338933903391339233933394339533963397339833993400340134023403340434053406340734083409341034113412341334143415341634173418341934203421342234233424342534263427342834293430343134323433343434353436343734383439344034413442344334443445344634473448344934503451345234533454345534563457345834593460346134623463346434653466346734683469347034713472347334743475347634773478347934803481348234833484348534863487348834893490349134923493349434953496349734983499350035013502350335043505350635073508350935103511351235133514351535163517351835193520352135223523352435253526352735283529353035313532 |
- /*
- Minetest
- Copyright (C) 2010-2013 celeron55, Perttu Ahola <celeron55@gmail.com>
- This program is free software; you can redistribute it and/or modify
- it under the terms of the GNU Lesser General Public License as published by
- the Free Software Foundation; either version 2.1 of the License, or
- (at your option) any later version.
- This program is distributed in the hope that it will be useful,
- but WITHOUT ANY WARRANTY; without even the implied warranty of
- MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
- GNU Lesser General Public License for more details.
- You should have received a copy of the GNU Lesser General Public License along
- with this program; if not, write to the Free Software Foundation, Inc.,
- 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
- */
- #include "server.h"
- #include <iostream>
- #include <queue>
- #include <algorithm>
- #include "network/networkprotocol.h"
- #include "network/serveropcodes.h"
- #include "ban.h"
- #include "environment.h"
- #include "map.h"
- #include "threading/mutex_auto_lock.h"
- #include "constants.h"
- #include "voxel.h"
- #include "config.h"
- #include "version.h"
- #include "filesys.h"
- #include "mapblock.h"
- #include "serverobject.h"
- #include "genericobject.h"
- #include "settings.h"
- #include "profiler.h"
- #include "log.h"
- #include "scripting_game.h"
- #include "nodedef.h"
- #include "itemdef.h"
- #include "craftdef.h"
- #include "emerge.h"
- #include "mapgen.h"
- #include "mg_biome.h"
- #include "content_mapnode.h"
- #include "content_nodemeta.h"
- #include "content_abm.h"
- #include "content_sao.h"
- #include "mods.h"
- #include "sound.h" // dummySoundManager
- #include "event_manager.h"
- #include "serverlist.h"
- #include "util/string.h"
- #include "util/mathconstants.h"
- #include "rollback.h"
- #include "util/serialize.h"
- #include "util/thread.h"
- #include "defaultsettings.h"
- #include "util/base64.h"
- #include "util/sha1.h"
- #include "util/hex.h"
- class ClientNotFoundException : public BaseException
- {
- public:
- ClientNotFoundException(const char *s):
- BaseException(s)
- {}
- };
- class ServerThread : public Thread
- {
- public:
- ServerThread(Server *server):
- Thread("Server"),
- m_server(server)
- {}
- void *run();
- private:
- Server *m_server;
- };
- void *ServerThread::run()
- {
- DSTACK(FUNCTION_NAME);
- BEGIN_DEBUG_EXCEPTION_HANDLER
- m_server->AsyncRunStep(true);
- while (!stopRequested()) {
- try {
- //TimeTaker timer("AsyncRunStep() + Receive()");
- m_server->AsyncRunStep();
- m_server->Receive();
- } catch (con::NoIncomingDataException &e) {
- } catch (con::PeerNotFoundException &e) {
- infostream<<"Server: PeerNotFoundException"<<std::endl;
- } catch (ClientNotFoundException &e) {
- } catch (con::ConnectionBindFailed &e) {
- m_server->setAsyncFatalError(e.what());
- } catch (LuaError &e) {
- m_server->setAsyncFatalError("Lua: " + std::string(e.what()));
- }
- }
- END_DEBUG_EXCEPTION_HANDLER
- return NULL;
- }
- v3f ServerSoundParams::getPos(ServerEnvironment *env, bool *pos_exists) const
- {
- if(pos_exists) *pos_exists = false;
- switch(type){
- case SSP_LOCAL:
- return v3f(0,0,0);
- case SSP_POSITIONAL:
- if(pos_exists) *pos_exists = true;
- return pos;
- case SSP_OBJECT: {
- if(object == 0)
- return v3f(0,0,0);
- ServerActiveObject *sao = env->getActiveObject(object);
- if(!sao)
- return v3f(0,0,0);
- if(pos_exists) *pos_exists = true;
- return sao->getBasePosition(); }
- }
- return v3f(0,0,0);
- }
- /*
- Server
- */
- Server::Server(
- const std::string &path_world,
- const SubgameSpec &gamespec,
- bool simple_singleplayer_mode,
- bool ipv6,
- ChatInterface *iface
- ):
- m_path_world(path_world),
- m_gamespec(gamespec),
- m_simple_singleplayer_mode(simple_singleplayer_mode),
- m_async_fatal_error(""),
- m_env(NULL),
- m_con(PROTOCOL_ID,
- 512,
- CONNECTION_TIMEOUT,
- ipv6,
- this),
- m_banmanager(NULL),
- m_rollback(NULL),
- m_enable_rollback_recording(false),
- m_emerge(NULL),
- m_script(NULL),
- m_itemdef(createItemDefManager()),
- m_nodedef(createNodeDefManager()),
- m_craftdef(createCraftDefManager()),
- m_event(new EventManager()),
- m_thread(NULL),
- m_time_of_day_send_timer(0),
- m_uptime(0),
- m_clients(&m_con),
- m_shutdown_requested(false),
- m_shutdown_ask_reconnect(false),
- m_admin_chat(iface),
- m_ignore_map_edit_events(false),
- m_ignore_map_edit_events_peer_id(0),
- m_next_sound_id(0)
- {
- m_liquid_transform_timer = 0.0;
- m_liquid_transform_every = 1.0;
- m_masterserver_timer = 0.0;
- m_emergethread_trigger_timer = 0.0;
- m_savemap_timer = 0.0;
- m_step_dtime = 0.0;
- m_lag = g_settings->getFloat("dedicated_server_step");
- if(path_world == "")
- throw ServerError("Supplied empty world path");
- if(!gamespec.isValid())
- throw ServerError("Supplied invalid gamespec");
- infostream<<"Server created for gameid \""<<m_gamespec.id<<"\"";
- if(m_simple_singleplayer_mode)
- infostream<<" in simple singleplayer mode"<<std::endl;
- else
- infostream<<std::endl;
- infostream<<"- world: "<<m_path_world<<std::endl;
- infostream<<"- game: "<<m_gamespec.path<<std::endl;
- // Create world if it doesn't exist
- if(!loadGameConfAndInitWorld(m_path_world, m_gamespec))
- throw ServerError("Failed to initialize world");
- // Create server thread
- m_thread = new ServerThread(this);
- // Create emerge manager
- m_emerge = new EmergeManager(this);
- // Create ban manager
- std::string ban_path = m_path_world + DIR_DELIM "ipban.txt";
- m_banmanager = new BanManager(ban_path);
- ModConfiguration modconf(m_path_world);
- m_mods = modconf.getMods();
- std::vector<ModSpec> unsatisfied_mods = modconf.getUnsatisfiedMods();
- // complain about mods with unsatisfied dependencies
- if(!modconf.isConsistent()) {
- for(std::vector<ModSpec>::iterator it = unsatisfied_mods.begin();
- it != unsatisfied_mods.end(); ++it) {
- ModSpec mod = *it;
- errorstream << "mod \"" << mod.name << "\" has unsatisfied dependencies: ";
- for(std::set<std::string>::iterator dep_it = mod.unsatisfied_depends.begin();
- dep_it != mod.unsatisfied_depends.end(); ++dep_it)
- errorstream << " \"" << *dep_it << "\"";
- errorstream << std::endl;
- }
- }
- Settings worldmt_settings;
- std::string worldmt = m_path_world + DIR_DELIM + "world.mt";
- worldmt_settings.readConfigFile(worldmt.c_str());
- std::vector<std::string> names = worldmt_settings.getNames();
- std::set<std::string> load_mod_names;
- for(std::vector<std::string>::iterator it = names.begin();
- it != names.end(); ++it) {
- std::string name = *it;
- if(name.compare(0,9,"load_mod_")==0 && worldmt_settings.getBool(name))
- load_mod_names.insert(name.substr(9));
- }
- // complain about mods declared to be loaded, but not found
- for(std::vector<ModSpec>::iterator it = m_mods.begin();
- it != m_mods.end(); ++it)
- load_mod_names.erase((*it).name);
- for(std::vector<ModSpec>::iterator it = unsatisfied_mods.begin();
- it != unsatisfied_mods.end(); ++it)
- load_mod_names.erase((*it).name);
- if(!load_mod_names.empty()) {
- errorstream << "The following mods could not be found:";
- for(std::set<std::string>::iterator it = load_mod_names.begin();
- it != load_mod_names.end(); ++it)
- errorstream << " \"" << (*it) << "\"";
- errorstream << std::endl;
- }
- //lock environment
- MutexAutoLock envlock(m_env_mutex);
- // Create the Map (loads map_meta.txt, overriding configured mapgen params)
- ServerMap *servermap = new ServerMap(path_world, this, m_emerge);
- // Initialize scripting
- infostream<<"Server: Initializing Lua"<<std::endl;
- m_script = new GameScripting(this);
- std::string script_path = getBuiltinLuaPath() + DIR_DELIM "init.lua";
- m_script->loadMod(script_path, BUILTIN_MOD_NAME);
- // Print mods
- infostream << "Server: Loading mods: ";
- for(std::vector<ModSpec>::iterator i = m_mods.begin();
- i != m_mods.end(); ++i) {
- const ModSpec &mod = *i;
- infostream << mod.name << " ";
- }
- infostream << std::endl;
- // Load and run "mod" scripts
- for (std::vector<ModSpec>::iterator it = m_mods.begin();
- it != m_mods.end(); ++it) {
- const ModSpec &mod = *it;
- if (!string_allowed(mod.name, MODNAME_ALLOWED_CHARS)) {
- throw ModError("Error loading mod \"" + mod.name +
- "\": Mod name does not follow naming conventions: "
- "Only chararacters [a-z0-9_] are allowed.");
- }
- std::string script_path = mod.path + DIR_DELIM + "init.lua";
- infostream << " [" << padStringRight(mod.name, 12) << "] [\""
- << script_path << "\"]" << std::endl;
- m_script->loadMod(script_path, mod.name);
- }
- // Read Textures and calculate sha1 sums
- fillMediaCache();
- // Apply item aliases in the node definition manager
- m_nodedef->updateAliases(m_itemdef);
- // Apply texture overrides from texturepack/override.txt
- std::string texture_path = g_settings->get("texture_path");
- if (texture_path != "" && fs::IsDir(texture_path))
- m_nodedef->applyTextureOverrides(texture_path + DIR_DELIM + "override.txt");
- m_nodedef->setNodeRegistrationStatus(true);
- // Perform pending node name resolutions
- m_nodedef->runNodeResolveCallbacks();
- // unmap node names for connected nodeboxes
- m_nodedef->mapNodeboxConnections();
- // init the recipe hashes to speed up crafting
- m_craftdef->initHashes(this);
- // Initialize Environment
- m_env = new ServerEnvironment(servermap, m_script, this, m_path_world);
- m_clients.setEnv(m_env);
- if (!servermap->settings_mgr.makeMapgenParams())
- FATAL_ERROR("Couldn't create any mapgen type");
- // Initialize mapgens
- m_emerge->initMapgens(servermap->getMapgenParams());
- m_enable_rollback_recording = g_settings->getBool("enable_rollback_recording");
- if (m_enable_rollback_recording) {
- // Create rollback manager
- m_rollback = new RollbackManager(m_path_world, this);
- }
- // Give environment reference to scripting api
- m_script->initializeEnvironment(m_env);
- // Register us to receive map edit events
- servermap->addEventReceiver(this);
- // If file exists, load environment metadata
- if (fs::PathExists(m_path_world + DIR_DELIM "env_meta.txt")) {
- infostream << "Server: Loading environment metadata" << std::endl;
- m_env->loadMeta();
- } else {
- m_env->loadDefaultMeta();
- }
- // Add some test ActiveBlockModifiers to environment
- add_legacy_abms(m_env, m_nodedef);
- m_liquid_transform_every = g_settings->getFloat("liquid_update");
- m_max_chatmessage_length = g_settings->getU16("chat_message_max_size");
- }
- Server::~Server()
- {
- infostream<<"Server destructing"<<std::endl;
- // Send shutdown message
- SendChatMessage(PEER_ID_INEXISTENT, L"*** Server shutting down");
- {
- MutexAutoLock envlock(m_env_mutex);
- // Execute script shutdown hooks
- m_script->on_shutdown();
- infostream << "Server: Saving players" << std::endl;
- m_env->saveLoadedPlayers();
- infostream << "Server: Kicking players" << std::endl;
- std::string kick_msg;
- bool reconnect = false;
- if (getShutdownRequested()) {
- reconnect = m_shutdown_ask_reconnect;
- kick_msg = m_shutdown_msg;
- }
- if (kick_msg == "") {
- kick_msg = g_settings->get("kick_msg_shutdown");
- }
- m_env->kickAllPlayers(SERVER_ACCESSDENIED_SHUTDOWN,
- kick_msg, reconnect);
- infostream << "Server: Saving environment metadata" << std::endl;
- m_env->saveMeta();
- }
- // Stop threads
- stop();
- delete m_thread;
- // stop all emerge threads before deleting players that may have
- // requested blocks to be emerged
- m_emerge->stopThreads();
- // Delete things in the reverse order of creation
- delete m_emerge;
- delete m_env;
- delete m_rollback;
- delete m_banmanager;
- delete m_event;
- delete m_itemdef;
- delete m_nodedef;
- delete m_craftdef;
- // Deinitialize scripting
- infostream<<"Server: Deinitializing scripting"<<std::endl;
- delete m_script;
- // Delete detached inventories
- for (std::map<std::string, Inventory*>::iterator
- i = m_detached_inventories.begin();
- i != m_detached_inventories.end(); ++i) {
- delete i->second;
- }
- }
- void Server::start(Address bind_addr)
- {
- DSTACK(FUNCTION_NAME);
- m_bind_addr = bind_addr;
- infostream<<"Starting server on "
- << bind_addr.serializeString() <<"..."<<std::endl;
- // Stop thread if already running
- m_thread->stop();
- // Initialize connection
- m_con.SetTimeoutMs(30);
- m_con.Serve(bind_addr);
- // Start thread
- m_thread->start();
- // ASCII art for the win!
- actionstream
- <<" .__ __ __ "<<std::endl
- <<" _____ |__| ____ _____/ |_ ____ _______/ |_ "<<std::endl
- <<" / \\| |/ \\_/ __ \\ __\\/ __ \\ / ___/\\ __\\"<<std::endl
- <<"| Y Y \\ | | \\ ___/| | \\ ___/ \\___ \\ | | "<<std::endl
- <<"|__|_| /__|___| /\\___ >__| \\___ >____ > |__| "<<std::endl
- <<" \\/ \\/ \\/ \\/ \\/ "<<std::endl;
- actionstream<<"World at ["<<m_path_world<<"]"<<std::endl;
- actionstream<<"Server for gameid=\""<<m_gamespec.id
- <<"\" listening on "<<bind_addr.serializeString()<<":"
- <<bind_addr.getPort() << "."<<std::endl;
- }
- void Server::stop()
- {
- DSTACK(FUNCTION_NAME);
- infostream<<"Server: Stopping and waiting threads"<<std::endl;
- // Stop threads (set run=false first so both start stopping)
- m_thread->stop();
- //m_emergethread.setRun(false);
- m_thread->wait();
- //m_emergethread.stop();
- infostream<<"Server: Threads stopped"<<std::endl;
- }
- void Server::step(float dtime)
- {
- DSTACK(FUNCTION_NAME);
- // Limit a bit
- if (dtime > 2.0)
- dtime = 2.0;
- {
- MutexAutoLock lock(m_step_dtime_mutex);
- m_step_dtime += dtime;
- }
- // Throw if fatal error occurred in thread
- std::string async_err = m_async_fatal_error.get();
- if (!async_err.empty()) {
- if (!m_simple_singleplayer_mode) {
- m_env->kickAllPlayers(SERVER_ACCESSDENIED_CRASH,
- g_settings->get("kick_msg_crash"),
- g_settings->getBool("ask_reconnect_on_crash"));
- }
- throw ServerError(async_err);
- }
- }
- void Server::AsyncRunStep(bool initial_step)
- {
- DSTACK(FUNCTION_NAME);
- g_profiler->add("Server::AsyncRunStep (num)", 1);
- float dtime;
- {
- MutexAutoLock lock1(m_step_dtime_mutex);
- dtime = m_step_dtime;
- }
- {
- // Send blocks to clients
- SendBlocks(dtime);
- }
- if((dtime < 0.001) && (initial_step == false))
- return;
- g_profiler->add("Server::AsyncRunStep with dtime (num)", 1);
- //infostream<<"Server steps "<<dtime<<std::endl;
- //infostream<<"Server::AsyncRunStep(): dtime="<<dtime<<std::endl;
- {
- MutexAutoLock lock1(m_step_dtime_mutex);
- m_step_dtime -= dtime;
- }
- /*
- Update uptime
- */
- {
- m_uptime.set(m_uptime.get() + dtime);
- }
- handlePeerChanges();
- /*
- Update time of day and overall game time
- */
- m_env->setTimeOfDaySpeed(g_settings->getFloat("time_speed"));
- /*
- Send to clients at constant intervals
- */
- m_time_of_day_send_timer -= dtime;
- if(m_time_of_day_send_timer < 0.0) {
- m_time_of_day_send_timer = g_settings->getFloat("time_send_interval");
- u16 time = m_env->getTimeOfDay();
- float time_speed = g_settings->getFloat("time_speed");
- SendTimeOfDay(PEER_ID_INEXISTENT, time, time_speed);
- }
- {
- MutexAutoLock lock(m_env_mutex);
- // Figure out and report maximum lag to environment
- float max_lag = m_env->getMaxLagEstimate();
- max_lag *= 0.9998; // Decrease slowly (about half per 5 minutes)
- if(dtime > max_lag){
- if(dtime > 0.1 && dtime > max_lag * 2.0)
- infostream<<"Server: Maximum lag peaked to "<<dtime
- <<" s"<<std::endl;
- max_lag = dtime;
- }
- m_env->reportMaxLagEstimate(max_lag);
- // Step environment
- ScopeProfiler sp(g_profiler, "SEnv step");
- ScopeProfiler sp2(g_profiler, "SEnv step avg", SPT_AVG);
- m_env->step(dtime);
- }
- static const float map_timer_and_unload_dtime = 2.92;
- if(m_map_timer_and_unload_interval.step(dtime, map_timer_and_unload_dtime))
- {
- MutexAutoLock lock(m_env_mutex);
- // Run Map's timers and unload unused data
- ScopeProfiler sp(g_profiler, "Server: map timer and unload");
- m_env->getMap().timerUpdate(map_timer_and_unload_dtime,
- g_settings->getFloat("server_unload_unused_data_timeout"),
- U32_MAX);
- }
- /*
- Listen to the admin chat, if available
- */
- if (m_admin_chat) {
- if (!m_admin_chat->command_queue.empty()) {
- MutexAutoLock lock(m_env_mutex);
- while (!m_admin_chat->command_queue.empty()) {
- ChatEvent *evt = m_admin_chat->command_queue.pop_frontNoEx();
- handleChatInterfaceEvent(evt);
- delete evt;
- }
- }
- m_admin_chat->outgoing_queue.push_back(
- new ChatEventTimeInfo(m_env->getGameTime(), m_env->getTimeOfDay()));
- }
- /*
- Do background stuff
- */
- /* Transform liquids */
- m_liquid_transform_timer += dtime;
- if(m_liquid_transform_timer >= m_liquid_transform_every)
- {
- m_liquid_transform_timer -= m_liquid_transform_every;
- MutexAutoLock lock(m_env_mutex);
- ScopeProfiler sp(g_profiler, "Server: liquid transform");
- std::map<v3s16, MapBlock*> modified_blocks;
- m_env->getMap().transformLiquids(modified_blocks);
- #if 0
- /*
- Update lighting
- */
- core::map<v3s16, MapBlock*> lighting_modified_blocks;
- ServerMap &map = ((ServerMap&)m_env->getMap());
- map.updateLighting(modified_blocks, lighting_modified_blocks);
- // Add blocks modified by lighting to modified_blocks
- for(core::map<v3s16, MapBlock*>::Iterator
- i = lighting_modified_blocks.getIterator();
- i.atEnd() == false; i++)
- {
- MapBlock *block = i.getNode()->getValue();
- modified_blocks.insert(block->getPos(), block);
- }
- #endif
- /*
- Set the modified blocks unsent for all the clients
- */
- if(!modified_blocks.empty())
- {
- SetBlocksNotSent(modified_blocks);
- }
- }
- m_clients.step(dtime);
- m_lag += (m_lag > dtime ? -1 : 1) * dtime/100;
- #if USE_CURL
- // send masterserver announce
- {
- float &counter = m_masterserver_timer;
- if(!isSingleplayer() && (!counter || counter >= 300.0) &&
- g_settings->getBool("server_announce"))
- {
- ServerList::sendAnnounce(counter ? "update" : "start",
- m_bind_addr.getPort(),
- m_clients.getPlayerNames(),
- m_uptime.get(),
- m_env->getGameTime(),
- m_lag,
- m_gamespec.id,
- Mapgen::getMapgenName(m_emerge->mgparams->mgtype),
- m_mods);
- counter = 0.01;
- }
- counter += dtime;
- }
- #endif
- /*
- Check added and deleted active objects
- */
- {
- //infostream<<"Server: Checking added and deleted active objects"<<std::endl;
- MutexAutoLock envlock(m_env_mutex);
- m_clients.lock();
- UNORDERED_MAP<u16, RemoteClient*> clients = m_clients.getClientList();
- ScopeProfiler sp(g_profiler, "Server: checking added and deleted objs");
- // Radius inside which objects are active
- static const s16 radius =
- g_settings->getS16("active_object_send_range_blocks") * MAP_BLOCKSIZE;
- // Radius inside which players are active
- static const bool is_transfer_limited =
- g_settings->exists("unlimited_player_transfer_distance") &&
- !g_settings->getBool("unlimited_player_transfer_distance");
- static const s16 player_transfer_dist = g_settings->getS16("player_transfer_distance") * MAP_BLOCKSIZE;
- s16 player_radius = player_transfer_dist;
- if (player_radius == 0 && is_transfer_limited)
- player_radius = radius;
- for (UNORDERED_MAP<u16, RemoteClient*>::iterator i = clients.begin();
- i != clients.end(); ++i) {
- RemoteClient *client = i->second;
- // If definitions and textures have not been sent, don't
- // send objects either
- if (client->getState() < CS_DefinitionsSent)
- continue;
- RemotePlayer *player = m_env->getPlayer(client->peer_id);
- if (player == NULL) {
- // This can happen if the client timeouts somehow
- /*warningstream<<FUNCTION_NAME<<": Client "
- <<client->peer_id
- <<" has no associated player"<<std::endl;*/
- continue;
- }
- PlayerSAO *playersao = player->getPlayerSAO();
- if (playersao == NULL)
- continue;
- std::queue<u16> removed_objects;
- std::queue<u16> added_objects;
- m_env->getRemovedActiveObjects(playersao, radius, player_radius,
- client->m_known_objects, removed_objects);
- m_env->getAddedActiveObjects(playersao, radius, player_radius,
- client->m_known_objects, added_objects);
- // Ignore if nothing happened
- if (removed_objects.empty() && added_objects.empty()) {
- continue;
- }
- std::string data_buffer;
- char buf[4];
- // Handle removed objects
- writeU16((u8*)buf, removed_objects.size());
- data_buffer.append(buf, 2);
- while (!removed_objects.empty()) {
- // Get object
- u16 id = removed_objects.front();
- ServerActiveObject* obj = m_env->getActiveObject(id);
- // Add to data buffer for sending
- writeU16((u8*)buf, id);
- data_buffer.append(buf, 2);
- // Remove from known objects
- client->m_known_objects.erase(id);
- if(obj && obj->m_known_by_count > 0)
- obj->m_known_by_count--;
- removed_objects.pop();
- }
- // Handle added objects
- writeU16((u8*)buf, added_objects.size());
- data_buffer.append(buf, 2);
- while (!added_objects.empty()) {
- // Get object
- u16 id = added_objects.front();
- ServerActiveObject* obj = m_env->getActiveObject(id);
- // Get object type
- u8 type = ACTIVEOBJECT_TYPE_INVALID;
- if(obj == NULL)
- warningstream<<FUNCTION_NAME
- <<": NULL object"<<std::endl;
- else
- type = obj->getSendType();
- // Add to data buffer for sending
- writeU16((u8*)buf, id);
- data_buffer.append(buf, 2);
- writeU8((u8*)buf, type);
- data_buffer.append(buf, 1);
- if(obj)
- data_buffer.append(serializeLongString(
- obj->getClientInitializationData(client->net_proto_version)));
- else
- data_buffer.append(serializeLongString(""));
- // Add to known objects
- client->m_known_objects.insert(id);
- if(obj)
- obj->m_known_by_count++;
- added_objects.pop();
- }
- u32 pktSize = SendActiveObjectRemoveAdd(client->peer_id, data_buffer);
- verbosestream << "Server: Sent object remove/add: "
- << removed_objects.size() << " removed, "
- << added_objects.size() << " added, "
- << "packet size is " << pktSize << std::endl;
- }
- m_clients.unlock();
- }
- /*
- Send object messages
- */
- {
- MutexAutoLock envlock(m_env_mutex);
- ScopeProfiler sp(g_profiler, "Server: sending object messages");
- // Key = object id
- // Value = data sent by object
- UNORDERED_MAP<u16, std::vector<ActiveObjectMessage>* > buffered_messages;
- // Get active object messages from environment
- for(;;) {
- ActiveObjectMessage aom = m_env->getActiveObjectMessage();
- if (aom.id == 0)
- break;
- std::vector<ActiveObjectMessage>* message_list = NULL;
- UNORDERED_MAP<u16, std::vector<ActiveObjectMessage>* >::iterator n;
- n = buffered_messages.find(aom.id);
- if (n == buffered_messages.end()) {
- message_list = new std::vector<ActiveObjectMessage>;
- buffered_messages[aom.id] = message_list;
- }
- else {
- message_list = n->second;
- }
- message_list->push_back(aom);
- }
- m_clients.lock();
- UNORDERED_MAP<u16, RemoteClient*> clients = m_clients.getClientList();
- // Route data to every client
- for (UNORDERED_MAP<u16, RemoteClient*>::iterator i = clients.begin();
- i != clients.end(); ++i) {
- RemoteClient *client = i->second;
- std::string reliable_data;
- std::string unreliable_data;
- // Go through all objects in message buffer
- for (UNORDERED_MAP<u16, std::vector<ActiveObjectMessage>* >::iterator
- j = buffered_messages.begin();
- j != buffered_messages.end(); ++j) {
- // If object is not known by client, skip it
- u16 id = j->first;
- if (client->m_known_objects.find(id) == client->m_known_objects.end())
- continue;
- // Get message list of object
- std::vector<ActiveObjectMessage>* list = j->second;
- // Go through every message
- for (std::vector<ActiveObjectMessage>::iterator
- k = list->begin(); k != list->end(); ++k) {
- // Compose the full new data with header
- ActiveObjectMessage aom = *k;
- std::string new_data;
- // Add object id
- char buf[2];
- writeU16((u8*)&buf[0], aom.id);
- new_data.append(buf, 2);
- // Add data
- new_data += serializeString(aom.datastring);
- // Add data to buffer
- if(aom.reliable)
- reliable_data += new_data;
- else
- unreliable_data += new_data;
- }
- }
- /*
- reliable_data and unreliable_data are now ready.
- Send them.
- */
- if(reliable_data.size() > 0) {
- SendActiveObjectMessages(client->peer_id, reliable_data);
- }
- if(unreliable_data.size() > 0) {
- SendActiveObjectMessages(client->peer_id, unreliable_data, false);
- }
- }
- m_clients.unlock();
- // Clear buffered_messages
- for (UNORDERED_MAP<u16, std::vector<ActiveObjectMessage>* >::iterator
- i = buffered_messages.begin();
- i != buffered_messages.end(); ++i) {
- delete i->second;
- }
- }
- /*
- Send queued-for-sending map edit events.
- */
- {
- // We will be accessing the environment
- MutexAutoLock lock(m_env_mutex);
- // Don't send too many at a time
- //u32 count = 0;
- // Single change sending is disabled if queue size is not small
- bool disable_single_change_sending = false;
- if(m_unsent_map_edit_queue.size() >= 4)
- disable_single_change_sending = true;
- int event_count = m_unsent_map_edit_queue.size();
- // We'll log the amount of each
- Profiler prof;
- while(m_unsent_map_edit_queue.size() != 0)
- {
- MapEditEvent* event = m_unsent_map_edit_queue.front();
- m_unsent_map_edit_queue.pop();
- // Players far away from the change are stored here.
- // Instead of sending the changes, MapBlocks are set not sent
- // for them.
- std::vector<u16> far_players;
- switch (event->type) {
- case MEET_ADDNODE:
- case MEET_SWAPNODE:
- prof.add("MEET_ADDNODE", 1);
- sendAddNode(event->p, event->n, event->already_known_by_peer,
- &far_players, disable_single_change_sending ? 5 : 30,
- event->type == MEET_ADDNODE);
- break;
- case MEET_REMOVENODE:
- prof.add("MEET_REMOVENODE", 1);
- sendRemoveNode(event->p, event->already_known_by_peer,
- &far_players, disable_single_change_sending ? 5 : 30);
- break;
- case MEET_BLOCK_NODE_METADATA_CHANGED:
- infostream << "Server: MEET_BLOCK_NODE_METADATA_CHANGED" << std::endl;
- prof.add("MEET_BLOCK_NODE_METADATA_CHANGED", 1);
- setBlockNotSent(event->p);
- break;
- case MEET_OTHER:
- infostream << "Server: MEET_OTHER" << std::endl;
- prof.add("MEET_OTHER", 1);
- for(std::set<v3s16>::iterator
- i = event->modified_blocks.begin();
- i != event->modified_blocks.end(); ++i) {
- setBlockNotSent(*i);
- }
- break;
- default:
- prof.add("unknown", 1);
- warningstream << "Server: Unknown MapEditEvent "
- << ((u32)event->type) << std::endl;
- break;
- }
- /*
- Set blocks not sent to far players
- */
- if(!far_players.empty()) {
- // Convert list format to that wanted by SetBlocksNotSent
- std::map<v3s16, MapBlock*> modified_blocks2;
- for(std::set<v3s16>::iterator
- i = event->modified_blocks.begin();
- i != event->modified_blocks.end(); ++i) {
- modified_blocks2[*i] =
- m_env->getMap().getBlockNoCreateNoEx(*i);
- }
- // Set blocks not sent
- for(std::vector<u16>::iterator
- i = far_players.begin();
- i != far_players.end(); ++i) {
- if(RemoteClient *client = getClient(*i))
- client->SetBlocksNotSent(modified_blocks2);
- }
- }
- delete event;
- /*// Don't send too many at a time
- count++;
- if(count >= 1 && m_unsent_map_edit_queue.size() < 100)
- break;*/
- }
- if(event_count >= 5){
- infostream<<"Server: MapEditEvents:"<<std::endl;
- prof.print(infostream);
- } else if(event_count != 0){
- verbosestream<<"Server: MapEditEvents:"<<std::endl;
- prof.print(verbosestream);
- }
- }
- /*
- Trigger emergethread (it somehow gets to a non-triggered but
- bysy state sometimes)
- */
- {
- float &counter = m_emergethread_trigger_timer;
- counter += dtime;
- if (counter >= 2.0) {
- counter = 0.0;
- m_emerge->startThreads();
- }
- }
- // Save map, players and auth stuff
- {
- float &counter = m_savemap_timer;
- counter += dtime;
- static const float save_interval =
- g_settings->getFloat("server_map_save_interval");
- if (counter >= save_interval) {
- counter = 0.0;
- MutexAutoLock lock(m_env_mutex);
- ScopeProfiler sp(g_profiler, "Server: saving stuff");
- // Save ban file
- if (m_banmanager->isModified()) {
- m_banmanager->save();
- }
- // Save changed parts of map
- m_env->getMap().save(MOD_STATE_WRITE_NEEDED);
- // Save players
- m_env->saveLoadedPlayers();
- // Save environment metadata
- m_env->saveMeta();
- }
- }
- }
- void Server::Receive()
- {
- DSTACK(FUNCTION_NAME);
- SharedBuffer<u8> data;
- u16 peer_id;
- try {
- NetworkPacket pkt;
- m_con.Receive(&pkt);
- peer_id = pkt.getPeerId();
- ProcessData(&pkt);
- }
- catch(con::InvalidIncomingDataException &e) {
- infostream<<"Server::Receive(): "
- "InvalidIncomingDataException: what()="
- <<e.what()<<std::endl;
- }
- catch(SerializationError &e) {
- infostream<<"Server::Receive(): "
- "SerializationError: what()="
- <<e.what()<<std::endl;
- }
- catch(ClientStateError &e) {
- errorstream << "ProcessData: peer=" << peer_id << e.what() << std::endl;
- DenyAccess_Legacy(peer_id, L"Your client sent something server didn't expect."
- L"Try reconnecting or updating your client");
- }
- catch(con::PeerNotFoundException &e) {
- // Do nothing
- }
- }
- PlayerSAO* Server::StageTwoClientInit(u16 peer_id)
- {
- std::string playername = "";
- PlayerSAO *playersao = NULL;
- m_clients.lock();
- try {
- RemoteClient* client = m_clients.lockedGetClientNoEx(peer_id, CS_InitDone);
- if (client != NULL) {
- playername = client->getName();
- playersao = emergePlayer(playername.c_str(), peer_id, client->net_proto_version);
- }
- } catch (std::exception &e) {
- m_clients.unlock();
- throw;
- }
- m_clients.unlock();
- RemotePlayer *player =
- static_cast<RemotePlayer*>(m_env->getPlayer(playername.c_str()));
- // If failed, cancel
- if ((playersao == NULL) || (player == NULL)) {
- if (player && player->peer_id != 0) {
- actionstream << "Server: Failed to emerge player \"" << playername
- << "\" (player allocated to an another client)" << std::endl;
- DenyAccess_Legacy(peer_id, L"Another client is connected with this "
- L"name. If your client closed unexpectedly, try again in "
- L"a minute.");
- } else {
- errorstream << "Server: " << playername << ": Failed to emerge player"
- << std::endl;
- DenyAccess_Legacy(peer_id, L"Could not allocate player.");
- }
- return NULL;
- }
- /*
- Send complete position information
- */
- SendMovePlayer(peer_id);
- // Send privileges
- SendPlayerPrivileges(peer_id);
- // Send inventory formspec
- SendPlayerInventoryFormspec(peer_id);
- // Send inventory
- SendInventory(playersao);
- // Send HP
- SendPlayerHPOrDie(playersao);
- // Send Breath
- SendPlayerBreath(peer_id);
- // Show death screen if necessary
- if (playersao->isDead())
- SendDeathscreen(peer_id, false, v3f(0,0,0));
- // Note things in chat if not in simple singleplayer mode
- if(!m_simple_singleplayer_mode) {
- // Send information about server to player in chat
- SendChatMessage(peer_id, getStatusString());
- }
- Address addr = getPeerAddress(player->peer_id);
- std::string ip_str = addr.serializeString();
- actionstream<<player->getName() <<" [" << ip_str << "] joins game. " << std::endl;
- /*
- Print out action
- */
- {
- const std::vector<std::string> &names = m_clients.getPlayerNames();
- actionstream << player->getName() << " joins game. List of players: ";
- for (std::vector<std::string>::const_iterator i = names.begin();
- i != names.end(); ++i) {
- actionstream << *i << " ";
- }
- actionstream << player->getName() <<std::endl;
- }
- return playersao;
- }
- inline void Server::handleCommand(NetworkPacket* pkt)
- {
- const ToServerCommandHandler& opHandle = toServerCommandTable[pkt->getCommand()];
- (this->*opHandle.handler)(pkt);
- }
- void Server::ProcessData(NetworkPacket *pkt)
- {
- DSTACK(FUNCTION_NAME);
- // Environment is locked first.
- MutexAutoLock envlock(m_env_mutex);
- ScopeProfiler sp(g_profiler, "Server::ProcessData");
- u32 peer_id = pkt->getPeerId();
- try {
- Address address = getPeerAddress(peer_id);
- std::string addr_s = address.serializeString();
- if(m_banmanager->isIpBanned(addr_s)) {
- std::string ban_name = m_banmanager->getBanName(addr_s);
- infostream << "Server: A banned client tried to connect from "
- << addr_s << "; banned name was "
- << ban_name << std::endl;
- // This actually doesn't seem to transfer to the client
- DenyAccess_Legacy(peer_id, L"Your ip is banned. Banned name was "
- + utf8_to_wide(ban_name));
- return;
- }
- }
- catch(con::PeerNotFoundException &e) {
- /*
- * no peer for this packet found
- * most common reason is peer timeout, e.g. peer didn't
- * respond for some time, your server was overloaded or
- * things like that.
- */
- infostream << "Server::ProcessData(): Canceling: peer "
- << peer_id << " not found" << std::endl;
- return;
- }
- try {
- ToServerCommand command = (ToServerCommand) pkt->getCommand();
- // Command must be handled into ToServerCommandHandler
- if (command >= TOSERVER_NUM_MSG_TYPES) {
- infostream << "Server: Ignoring unknown command "
- << command << std::endl;
- return;
- }
- if (toServerCommandTable[command].state == TOSERVER_STATE_NOT_CONNECTED) {
- handleCommand(pkt);
- return;
- }
- u8 peer_ser_ver = getClient(peer_id, CS_InitDone)->serialization_version;
- if(peer_ser_ver == SER_FMT_VER_INVALID) {
- errorstream << "Server::ProcessData(): Cancelling: Peer"
- " serialization format invalid or not initialized."
- " Skipping incoming command=" << command << std::endl;
- return;
- }
- /* Handle commands related to client startup */
- if (toServerCommandTable[command].state == TOSERVER_STATE_STARTUP) {
- handleCommand(pkt);
- return;
- }
- if (m_clients.getClientState(peer_id) < CS_Active) {
- if (command == TOSERVER_PLAYERPOS) return;
- errorstream << "Got packet command: " << command << " for peer id "
- << peer_id << " but client isn't active yet. Dropping packet "
- << std::endl;
- return;
- }
- handleCommand(pkt);
- } catch (SendFailedException &e) {
- errorstream << "Server::ProcessData(): SendFailedException: "
- << "what=" << e.what()
- << std::endl;
- } catch (PacketError &e) {
- actionstream << "Server::ProcessData(): PacketError: "
- << "what=" << e.what()
- << std::endl;
- }
- }
- void Server::setTimeOfDay(u32 time)
- {
- m_env->setTimeOfDay(time);
- m_time_of_day_send_timer = 0;
- }
- void Server::onMapEditEvent(MapEditEvent *event)
- {
- if(m_ignore_map_edit_events)
- return;
- if(m_ignore_map_edit_events_area.contains(event->getArea()))
- return;
- MapEditEvent *e = event->clone();
- m_unsent_map_edit_queue.push(e);
- }
- Inventory* Server::getInventory(const InventoryLocation &loc)
- {
- switch (loc.type) {
- case InventoryLocation::UNDEFINED:
- case InventoryLocation::CURRENT_PLAYER:
- break;
- case InventoryLocation::PLAYER:
- {
- RemotePlayer *player = dynamic_cast<RemotePlayer *>(m_env->getPlayer(loc.name.c_str()));
- if(!player)
- return NULL;
- PlayerSAO *playersao = player->getPlayerSAO();
- if(!playersao)
- return NULL;
- return playersao->getInventory();
- }
- break;
- case InventoryLocation::NODEMETA:
- {
- NodeMetadata *meta = m_env->getMap().getNodeMetadata(loc.p);
- if(!meta)
- return NULL;
- return meta->getInventory();
- }
- break;
- case InventoryLocation::DETACHED:
- {
- if(m_detached_inventories.count(loc.name) == 0)
- return NULL;
- return m_detached_inventories[loc.name];
- }
- break;
- default:
- sanity_check(false); // abort
- break;
- }
- return NULL;
- }
- void Server::setInventoryModified(const InventoryLocation &loc, bool playerSend)
- {
- switch(loc.type){
- case InventoryLocation::UNDEFINED:
- break;
- case InventoryLocation::PLAYER:
- {
- if (!playerSend)
- return;
- RemotePlayer *player =
- dynamic_cast<RemotePlayer *>(m_env->getPlayer(loc.name.c_str()));
- if (!player)
- return;
- PlayerSAO *playersao = player->getPlayerSAO();
- if(!playersao)
- return;
- SendInventory(playersao);
- }
- break;
- case InventoryLocation::NODEMETA:
- {
- v3s16 blockpos = getNodeBlockPos(loc.p);
- MapBlock *block = m_env->getMap().getBlockNoCreateNoEx(blockpos);
- if(block)
- block->raiseModified(MOD_STATE_WRITE_NEEDED);
- setBlockNotSent(blockpos);
- }
- break;
- case InventoryLocation::DETACHED:
- {
- sendDetachedInventory(loc.name,PEER_ID_INEXISTENT);
- }
- break;
- default:
- sanity_check(false); // abort
- break;
- }
- }
- void Server::SetBlocksNotSent(std::map<v3s16, MapBlock *>& block)
- {
- std::vector<u16> clients = m_clients.getClientIDs();
- m_clients.lock();
- // Set the modified blocks unsent for all the clients
- for (std::vector<u16>::iterator i = clients.begin();
- i != clients.end(); ++i) {
- if (RemoteClient *client = m_clients.lockedGetClientNoEx(*i))
- client->SetBlocksNotSent(block);
- }
- m_clients.unlock();
- }
- void Server::peerAdded(con::Peer *peer)
- {
- DSTACK(FUNCTION_NAME);
- verbosestream<<"Server::peerAdded(): peer->id="
- <<peer->id<<std::endl;
- con::PeerChange c;
- c.type = con::PEER_ADDED;
- c.peer_id = peer->id;
- c.timeout = false;
- m_peer_change_queue.push(c);
- }
- void Server::deletingPeer(con::Peer *peer, bool timeout)
- {
- DSTACK(FUNCTION_NAME);
- verbosestream<<"Server::deletingPeer(): peer->id="
- <<peer->id<<", timeout="<<timeout<<std::endl;
- m_clients.event(peer->id, CSE_Disconnect);
- con::PeerChange c;
- c.type = con::PEER_REMOVED;
- c.peer_id = peer->id;
- c.timeout = timeout;
- m_peer_change_queue.push(c);
- }
- bool Server::getClientConInfo(u16 peer_id, con::rtt_stat_type type, float* retval)
- {
- *retval = m_con.getPeerStat(peer_id,type);
- if (*retval == -1) return false;
- return true;
- }
- bool Server::getClientInfo(
- u16 peer_id,
- ClientState* state,
- u32* uptime,
- u8* ser_vers,
- u16* prot_vers,
- u8* major,
- u8* minor,
- u8* patch,
- std::string* vers_string
- )
- {
- *state = m_clients.getClientState(peer_id);
- m_clients.lock();
- RemoteClient* client = m_clients.lockedGetClientNoEx(peer_id, CS_Invalid);
- if (client == NULL) {
- m_clients.unlock();
- return false;
- }
- *uptime = client->uptime();
- *ser_vers = client->serialization_version;
- *prot_vers = client->net_proto_version;
- *major = client->getMajor();
- *minor = client->getMinor();
- *patch = client->getPatch();
- *vers_string = client->getPatch();
- m_clients.unlock();
- return true;
- }
- void Server::handlePeerChanges()
- {
- while(m_peer_change_queue.size() > 0)
- {
- con::PeerChange c = m_peer_change_queue.front();
- m_peer_change_queue.pop();
- verbosestream<<"Server: Handling peer change: "
- <<"id="<<c.peer_id<<", timeout="<<c.timeout
- <<std::endl;
- switch(c.type)
- {
- case con::PEER_ADDED:
- m_clients.CreateClient(c.peer_id);
- break;
- case con::PEER_REMOVED:
- DeleteClient(c.peer_id, c.timeout?CDR_TIMEOUT:CDR_LEAVE);
- break;
- default:
- FATAL_ERROR("Invalid peer change event received!");
- break;
- }
- }
- }
- void Server::printToConsoleOnly(const std::string &text)
- {
- if (m_admin_chat) {
- m_admin_chat->outgoing_queue.push_back(
- new ChatEventChat("", utf8_to_wide(text)));
- } else {
- std::cout << text << std::endl;
- }
- }
- void Server::Send(NetworkPacket* pkt)
- {
- m_clients.send(pkt->getPeerId(),
- clientCommandFactoryTable[pkt->getCommand()].channel,
- pkt,
- clientCommandFactoryTable[pkt->getCommand()].reliable);
- }
- void Server::SendMovement(u16 peer_id)
- {
- DSTACK(FUNCTION_NAME);
- std::ostringstream os(std::ios_base::binary);
- NetworkPacket pkt(TOCLIENT_MOVEMENT, 12 * sizeof(float), peer_id);
- pkt << g_settings->getFloat("movement_acceleration_default");
- pkt << g_settings->getFloat("movement_acceleration_air");
- pkt << g_settings->getFloat("movement_acceleration_fast");
- pkt << g_settings->getFloat("movement_speed_walk");
- pkt << g_settings->getFloat("movement_speed_crouch");
- pkt << g_settings->getFloat("movement_speed_fast");
- pkt << g_settings->getFloat("movement_speed_climb");
- pkt << g_settings->getFloat("movement_speed_jump");
- pkt << g_settings->getFloat("movement_liquid_fluidity");
- pkt << g_settings->getFloat("movement_liquid_fluidity_smooth");
- pkt << g_settings->getFloat("movement_liquid_sink");
- pkt << g_settings->getFloat("movement_gravity");
- Send(&pkt);
- }
- void Server::SendPlayerHPOrDie(PlayerSAO *playersao)
- {
- if (!g_settings->getBool("enable_damage"))
- return;
- u16 peer_id = playersao->getPeerID();
- bool is_alive = playersao->getHP() > 0;
- if (is_alive)
- SendPlayerHP(peer_id);
- else
- DiePlayer(peer_id);
- }
- void Server::SendHP(u16 peer_id, u8 hp)
- {
- DSTACK(FUNCTION_NAME);
- NetworkPacket pkt(TOCLIENT_HP, 1, peer_id);
- pkt << hp;
- Send(&pkt);
- }
- void Server::SendBreath(u16 peer_id, u16 breath)
- {
- DSTACK(FUNCTION_NAME);
- NetworkPacket pkt(TOCLIENT_BREATH, 2, peer_id);
- pkt << (u16) breath;
- Send(&pkt);
- }
- void Server::SendAccessDenied(u16 peer_id, AccessDeniedCode reason,
- const std::string &custom_reason, bool reconnect)
- {
- assert(reason < SERVER_ACCESSDENIED_MAX);
- NetworkPacket pkt(TOCLIENT_ACCESS_DENIED, 1, peer_id);
- pkt << (u8)reason;
- if (reason == SERVER_ACCESSDENIED_CUSTOM_STRING)
- pkt << custom_reason;
- else if (reason == SERVER_ACCESSDENIED_SHUTDOWN ||
- reason == SERVER_ACCESSDENIED_CRASH)
- pkt << custom_reason << (u8)reconnect;
- Send(&pkt);
- }
- void Server::SendAccessDenied_Legacy(u16 peer_id,const std::wstring &reason)
- {
- DSTACK(FUNCTION_NAME);
- NetworkPacket pkt(TOCLIENT_ACCESS_DENIED_LEGACY, 0, peer_id);
- pkt << reason;
- Send(&pkt);
- }
- void Server::SendDeathscreen(u16 peer_id,bool set_camera_point_target,
- v3f camera_point_target)
- {
- DSTACK(FUNCTION_NAME);
- NetworkPacket pkt(TOCLIENT_DEATHSCREEN, 1 + sizeof(v3f), peer_id);
- pkt << set_camera_point_target << camera_point_target;
- Send(&pkt);
- }
- void Server::SendItemDef(u16 peer_id,
- IItemDefManager *itemdef, u16 protocol_version)
- {
- DSTACK(FUNCTION_NAME);
- NetworkPacket pkt(TOCLIENT_ITEMDEF, 0, peer_id);
- /*
- u16 command
- u32 length of the next item
- zlib-compressed serialized ItemDefManager
- */
- std::ostringstream tmp_os(std::ios::binary);
- itemdef->serialize(tmp_os, protocol_version);
- std::ostringstream tmp_os2(std::ios::binary);
- compressZlib(tmp_os.str(), tmp_os2);
- pkt.putLongString(tmp_os2.str());
- // Make data buffer
- verbosestream << "Server: Sending item definitions to id(" << peer_id
- << "): size=" << pkt.getSize() << std::endl;
- Send(&pkt);
- }
- void Server::SendNodeDef(u16 peer_id,
- INodeDefManager *nodedef, u16 protocol_version)
- {
- DSTACK(FUNCTION_NAME);
- NetworkPacket pkt(TOCLIENT_NODEDEF, 0, peer_id);
- /*
- u16 command
- u32 length of the next item
- zlib-compressed serialized NodeDefManager
- */
- std::ostringstream tmp_os(std::ios::binary);
- nodedef->serialize(tmp_os, protocol_version);
- std::ostringstream tmp_os2(std::ios::binary);
- compressZlib(tmp_os.str(), tmp_os2);
- pkt.putLongString(tmp_os2.str());
- // Make data buffer
- verbosestream << "Server: Sending node definitions to id(" << peer_id
- << "): size=" << pkt.getSize() << std::endl;
- Send(&pkt);
- }
- /*
- Non-static send methods
- */
- void Server::SendInventory(PlayerSAO* playerSAO)
- {
- DSTACK(FUNCTION_NAME);
- UpdateCrafting(playerSAO->getPlayer());
- /*
- Serialize it
- */
- NetworkPacket pkt(TOCLIENT_INVENTORY, 0, playerSAO->getPeerID());
- std::ostringstream os;
- playerSAO->getInventory()->serialize(os);
- std::string s = os.str();
- pkt.putRawString(s.c_str(), s.size());
- Send(&pkt);
- }
- void Server::SendChatMessage(u16 peer_id, const std::wstring &message)
- {
- DSTACK(FUNCTION_NAME);
- NetworkPacket pkt(TOCLIENT_CHAT_MESSAGE, 0, peer_id);
- pkt << message;
- if (peer_id != PEER_ID_INEXISTENT) {
- Send(&pkt);
- }
- else {
- m_clients.sendToAll(0, &pkt, true);
- }
- }
- void Server::SendShowFormspecMessage(u16 peer_id, const std::string &formspec,
- const std::string &formname)
- {
- DSTACK(FUNCTION_NAME);
- NetworkPacket pkt(TOCLIENT_SHOW_FORMSPEC, 0 , peer_id);
- pkt.putLongString(FORMSPEC_VERSION_STRING + formspec);
- pkt << formname;
- Send(&pkt);
- }
- // Spawns a particle on peer with peer_id
- void Server::SendSpawnParticle(u16 peer_id, v3f pos, v3f velocity, v3f acceleration,
- float expirationtime, float size, bool collisiondetection,
- bool collision_removal,
- bool vertical, const std::string &texture)
- {
- DSTACK(FUNCTION_NAME);
- NetworkPacket pkt(TOCLIENT_SPAWN_PARTICLE, 0, peer_id);
- pkt << pos << velocity << acceleration << expirationtime
- << size << collisiondetection;
- pkt.putLongString(texture);
- pkt << vertical;
- pkt << collision_removal;
- if (peer_id != PEER_ID_INEXISTENT) {
- Send(&pkt);
- }
- else {
- m_clients.sendToAll(0, &pkt, true);
- }
- }
- // Adds a ParticleSpawner on peer with peer_id
- void Server::SendAddParticleSpawner(u16 peer_id, u16 amount, float spawntime, v3f minpos, v3f maxpos,
- v3f minvel, v3f maxvel, v3f minacc, v3f maxacc, float minexptime, float maxexptime,
- float minsize, float maxsize, bool collisiondetection, bool collision_removal,
- u16 attached_id, bool vertical, const std::string &texture, u32 id)
- {
- DSTACK(FUNCTION_NAME);
- NetworkPacket pkt(TOCLIENT_ADD_PARTICLESPAWNER, 0, peer_id);
- pkt << amount << spawntime << minpos << maxpos << minvel << maxvel
- << minacc << maxacc << minexptime << maxexptime << minsize
- << maxsize << collisiondetection;
- pkt.putLongString(texture);
- pkt << id << vertical;
- pkt << collision_removal;
- pkt << attached_id;
- if (peer_id != PEER_ID_INEXISTENT) {
- Send(&pkt);
- }
- else {
- m_clients.sendToAll(0, &pkt, true);
- }
- }
- void Server::SendDeleteParticleSpawner(u16 peer_id, u32 id)
- {
- DSTACK(FUNCTION_NAME);
- NetworkPacket pkt(TOCLIENT_DELETE_PARTICLESPAWNER_LEGACY, 2, peer_id);
- // Ugly error in this packet
- pkt << (u16) id;
- if (peer_id != PEER_ID_INEXISTENT) {
- Send(&pkt);
- }
- else {
- m_clients.sendToAll(0, &pkt, true);
- }
- }
- void Server::SendHUDAdd(u16 peer_id, u32 id, HudElement *form)
- {
- NetworkPacket pkt(TOCLIENT_HUDADD, 0 , peer_id);
- pkt << id << (u8) form->type << form->pos << form->name << form->scale
- << form->text << form->number << form->item << form->dir
- << form->align << form->offset << form->world_pos << form->size;
- Send(&pkt);
- }
- void Server::SendHUDRemove(u16 peer_id, u32 id)
- {
- NetworkPacket pkt(TOCLIENT_HUDRM, 4, peer_id);
- pkt << id;
- Send(&pkt);
- }
- void Server::SendHUDChange(u16 peer_id, u32 id, HudElementStat stat, void *value)
- {
- NetworkPacket pkt(TOCLIENT_HUDCHANGE, 0, peer_id);
- pkt << id << (u8) stat;
- switch (stat) {
- case HUD_STAT_POS:
- case HUD_STAT_SCALE:
- case HUD_STAT_ALIGN:
- case HUD_STAT_OFFSET:
- pkt << *(v2f *) value;
- break;
- case HUD_STAT_NAME:
- case HUD_STAT_TEXT:
- pkt << *(std::string *) value;
- break;
- case HUD_STAT_WORLD_POS:
- pkt << *(v3f *) value;
- break;
- case HUD_STAT_SIZE:
- pkt << *(v2s32 *) value;
- break;
- case HUD_STAT_NUMBER:
- case HUD_STAT_ITEM:
- case HUD_STAT_DIR:
- default:
- pkt << *(u32 *) value;
- break;
- }
- Send(&pkt);
- }
- void Server::SendHUDSetFlags(u16 peer_id, u32 flags, u32 mask)
- {
- NetworkPacket pkt(TOCLIENT_HUD_SET_FLAGS, 4 + 4, peer_id);
- flags &= ~(HUD_FLAG_HEALTHBAR_VISIBLE | HUD_FLAG_BREATHBAR_VISIBLE);
- pkt << flags << mask;
- Send(&pkt);
- }
- void Server::SendHUDSetParam(u16 peer_id, u16 param, const std::string &value)
- {
- NetworkPacket pkt(TOCLIENT_HUD_SET_PARAM, 0, peer_id);
- pkt << param << value;
- Send(&pkt);
- }
- void Server::SendSetSky(u16 peer_id, const video::SColor &bgcolor,
- const std::string &type, const std::vector<std::string> ¶ms)
- {
- NetworkPacket pkt(TOCLIENT_SET_SKY, 0, peer_id);
- pkt << bgcolor << type << (u16) params.size();
- for(size_t i=0; i<params.size(); i++)
- pkt << params[i];
- Send(&pkt);
- }
- void Server::SendOverrideDayNightRatio(u16 peer_id, bool do_override,
- float ratio)
- {
- NetworkPacket pkt(TOCLIENT_OVERRIDE_DAY_NIGHT_RATIO,
- 1 + 2, peer_id);
- pkt << do_override << (u16) (ratio * 65535);
- Send(&pkt);
- }
- void Server::SendTimeOfDay(u16 peer_id, u16 time, f32 time_speed)
- {
- DSTACK(FUNCTION_NAME);
- NetworkPacket pkt(TOCLIENT_TIME_OF_DAY, 0, peer_id);
- pkt << time << time_speed;
- if (peer_id == PEER_ID_INEXISTENT) {
- m_clients.sendToAll(0, &pkt, true);
- }
- else {
- Send(&pkt);
- }
- }
- void Server::SendPlayerHP(u16 peer_id)
- {
- DSTACK(FUNCTION_NAME);
- PlayerSAO *playersao = getPlayerSAO(peer_id);
- // In some rare case if the player is disconnected
- // while Lua call l_punch, for example, this can be NULL
- if (!playersao)
- return;
- SendHP(peer_id, playersao->getHP());
- m_script->player_event(playersao,"health_changed");
- // Send to other clients
- std::string str = gob_cmd_punched(playersao->readDamage(), playersao->getHP());
- ActiveObjectMessage aom(playersao->getId(), true, str);
- playersao->m_messages_out.push(aom);
- }
- void Server::SendPlayerBreath(u16 peer_id)
- {
- DSTACK(FUNCTION_NAME);
- PlayerSAO *playersao = getPlayerSAO(peer_id);
- assert(playersao);
- m_script->player_event(playersao, "breath_changed");
- SendBreath(peer_id, playersao->getBreath());
- }
- void Server::SendMovePlayer(u16 peer_id)
- {
- DSTACK(FUNCTION_NAME);
- RemotePlayer *player = m_env->getPlayer(peer_id);
- assert(player);
- PlayerSAO *sao = player->getPlayerSAO();
- assert(sao);
- NetworkPacket pkt(TOCLIENT_MOVE_PLAYER, sizeof(v3f) + sizeof(f32) * 2, peer_id);
- pkt << sao->getBasePosition() << sao->getPitch() << sao->getYaw();
- {
- v3f pos = sao->getBasePosition();
- verbosestream << "Server: Sending TOCLIENT_MOVE_PLAYER"
- << " pos=(" << pos.X << "," << pos.Y << "," << pos.Z << ")"
- << " pitch=" << sao->getPitch()
- << " yaw=" << sao->getYaw()
- << std::endl;
- }
- Send(&pkt);
- }
- void Server::SendLocalPlayerAnimations(u16 peer_id, v2s32 animation_frames[4], f32 animation_speed)
- {
- NetworkPacket pkt(TOCLIENT_LOCAL_PLAYER_ANIMATIONS, 0,
- peer_id);
- pkt << animation_frames[0] << animation_frames[1] << animation_frames[2]
- << animation_frames[3] << animation_speed;
- Send(&pkt);
- }
- void Server::SendEyeOffset(u16 peer_id, v3f first, v3f third)
- {
- NetworkPacket pkt(TOCLIENT_EYE_OFFSET, 0, peer_id);
- pkt << first << third;
- Send(&pkt);
- }
- void Server::SendPlayerPrivileges(u16 peer_id)
- {
- RemotePlayer *player = m_env->getPlayer(peer_id);
- assert(player);
- if(player->peer_id == PEER_ID_INEXISTENT)
- return;
- std::set<std::string> privs;
- m_script->getAuth(player->getName(), NULL, &privs);
- NetworkPacket pkt(TOCLIENT_PRIVILEGES, 0, peer_id);
- pkt << (u16) privs.size();
- for(std::set<std::string>::const_iterator i = privs.begin();
- i != privs.end(); ++i) {
- pkt << (*i);
- }
- Send(&pkt);
- }
- void Server::SendPlayerInventoryFormspec(u16 peer_id)
- {
- RemotePlayer *player = m_env->getPlayer(peer_id);
- assert(player);
- if(player->peer_id == PEER_ID_INEXISTENT)
- return;
- NetworkPacket pkt(TOCLIENT_INVENTORY_FORMSPEC, 0, peer_id);
- pkt.putLongString(FORMSPEC_VERSION_STRING + player->inventory_formspec);
- Send(&pkt);
- }
- u32 Server::SendActiveObjectRemoveAdd(u16 peer_id, const std::string &datas)
- {
- NetworkPacket pkt(TOCLIENT_ACTIVE_OBJECT_REMOVE_ADD, datas.size(), peer_id);
- pkt.putRawString(datas.c_str(), datas.size());
- Send(&pkt);
- return pkt.getSize();
- }
- void Server::SendActiveObjectMessages(u16 peer_id, const std::string &datas, bool reliable)
- {
- NetworkPacket pkt(TOCLIENT_ACTIVE_OBJECT_MESSAGES,
- datas.size(), peer_id);
- pkt.putRawString(datas.c_str(), datas.size());
- m_clients.send(pkt.getPeerId(),
- reliable ? clientCommandFactoryTable[pkt.getCommand()].channel : 1,
- &pkt, reliable);
- }
- s32 Server::playSound(const SimpleSoundSpec &spec,
- const ServerSoundParams ¶ms)
- {
- // Find out initial position of sound
- bool pos_exists = false;
- v3f pos = params.getPos(m_env, &pos_exists);
- // If position is not found while it should be, cancel sound
- if(pos_exists != (params.type != ServerSoundParams::SSP_LOCAL))
- return -1;
- // Filter destination clients
- std::vector<u16> dst_clients;
- if(params.to_player != "")
- {
- RemotePlayer *player = m_env->getPlayer(params.to_player.c_str());
- if(!player){
- infostream<<"Server::playSound: Player \""<<params.to_player
- <<"\" not found"<<std::endl;
- return -1;
- }
- if(player->peer_id == PEER_ID_INEXISTENT){
- infostream<<"Server::playSound: Player \""<<params.to_player
- <<"\" not connected"<<std::endl;
- return -1;
- }
- dst_clients.push_back(player->peer_id);
- }
- else {
- std::vector<u16> clients = m_clients.getClientIDs();
- for (std::vector<u16>::iterator i = clients.begin(); i != clients.end(); ++i) {
- RemotePlayer *player = m_env->getPlayer(*i);
- if (!player)
- continue;
- PlayerSAO *sao = player->getPlayerSAO();
- if (!sao)
- continue;
- if (pos_exists) {
- if(sao->getBasePosition().getDistanceFrom(pos) >
- params.max_hear_distance)
- continue;
- }
- dst_clients.push_back(*i);
- }
- }
- if(dst_clients.empty())
- return -1;
- // Create the sound
- s32 id = m_next_sound_id++;
- // The sound will exist as a reference in m_playing_sounds
- m_playing_sounds[id] = ServerPlayingSound();
- ServerPlayingSound &psound = m_playing_sounds[id];
- psound.params = params;
- NetworkPacket pkt(TOCLIENT_PLAY_SOUND, 0);
- pkt << id << spec.name << (float) (spec.gain * params.gain)
- << (u8) params.type << pos << params.object << params.loop;
- for(std::vector<u16>::iterator i = dst_clients.begin();
- i != dst_clients.end(); ++i) {
- psound.clients.insert(*i);
- m_clients.send(*i, 0, &pkt, true);
- }
- return id;
- }
- void Server::stopSound(s32 handle)
- {
- // Get sound reference
- UNORDERED_MAP<s32, ServerPlayingSound>::iterator i = m_playing_sounds.find(handle);
- if (i == m_playing_sounds.end())
- return;
- ServerPlayingSound &psound = i->second;
- NetworkPacket pkt(TOCLIENT_STOP_SOUND, 4);
- pkt << handle;
- for (UNORDERED_SET<u16>::iterator i = psound.clients.begin();
- i != psound.clients.end(); ++i) {
- // Send as reliable
- m_clients.send(*i, 0, &pkt, true);
- }
- // Remove sound reference
- m_playing_sounds.erase(i);
- }
- void Server::sendRemoveNode(v3s16 p, u16 ignore_id,
- std::vector<u16> *far_players, float far_d_nodes)
- {
- float maxd = far_d_nodes*BS;
- v3f p_f = intToFloat(p, BS);
- NetworkPacket pkt(TOCLIENT_REMOVENODE, 6);
- pkt << p;
- std::vector<u16> clients = m_clients.getClientIDs();
- for (std::vector<u16>::iterator i = clients.begin(); i != clients.end(); ++i) {
- if (far_players) {
- // Get player
- if (RemotePlayer *player = m_env->getPlayer(*i)) {
- PlayerSAO *sao = player->getPlayerSAO();
- if (!sao)
- continue;
- // If player is far away, only set modified blocks not sent
- v3f player_pos = sao->getBasePosition();
- if (player_pos.getDistanceFrom(p_f) > maxd) {
- far_players->push_back(*i);
- continue;
- }
- }
- }
- // Send as reliable
- m_clients.send(*i, 0, &pkt, true);
- }
- }
- void Server::sendAddNode(v3s16 p, MapNode n, u16 ignore_id,
- std::vector<u16> *far_players, float far_d_nodes,
- bool remove_metadata)
- {
- float maxd = far_d_nodes*BS;
- v3f p_f = intToFloat(p, BS);
- std::vector<u16> clients = m_clients.getClientIDs();
- for(std::vector<u16>::iterator i = clients.begin(); i != clients.end(); ++i) {
- if (far_players) {
- // Get player
- if (RemotePlayer *player = m_env->getPlayer(*i)) {
- PlayerSAO *sao = player->getPlayerSAO();
- if (!sao)
- continue;
- // If player is far away, only set modified blocks not sent
- v3f player_pos = sao->getBasePosition();
- if(player_pos.getDistanceFrom(p_f) > maxd) {
- far_players->push_back(*i);
- continue;
- }
- }
- }
- NetworkPacket pkt(TOCLIENT_ADDNODE, 6 + 2 + 1 + 1 + 1);
- m_clients.lock();
- RemoteClient* client = m_clients.lockedGetClientNoEx(*i);
- if (client != 0) {
- pkt << p << n.param0 << n.param1 << n.param2
- << (u8) (remove_metadata ? 0 : 1);
- if (!remove_metadata) {
- if (client->net_proto_version <= 21) {
- // Old clients always clear metadata; fix it
- // by sending the full block again.
- client->SetBlockNotSent(getNodeBlockPos(p));
- }
- }
- }
- m_clients.unlock();
- // Send as reliable
- if (pkt.getSize() > 0)
- m_clients.send(*i, 0, &pkt, true);
- }
- }
- void Server::setBlockNotSent(v3s16 p)
- {
- std::vector<u16> clients = m_clients.getClientIDs();
- m_clients.lock();
- for(std::vector<u16>::iterator i = clients.begin();
- i != clients.end(); ++i) {
- RemoteClient *client = m_clients.lockedGetClientNoEx(*i);
- client->SetBlockNotSent(p);
- }
- m_clients.unlock();
- }
- void Server::SendBlockNoLock(u16 peer_id, MapBlock *block, u8 ver, u16 net_proto_version)
- {
- DSTACK(FUNCTION_NAME);
- v3s16 p = block->getPos();
- /*
- Create a packet with the block in the right format
- */
- std::ostringstream os(std::ios_base::binary);
- block->serialize(os, ver, false);
- block->serializeNetworkSpecific(os, net_proto_version);
- std::string s = os.str();
- NetworkPacket pkt(TOCLIENT_BLOCKDATA, 2 + 2 + 2 + 2 + s.size(), peer_id);
- pkt << p;
- pkt.putRawString(s.c_str(), s.size());
- Send(&pkt);
- }
- void Server::SendBlocks(float dtime)
- {
- DSTACK(FUNCTION_NAME);
- MutexAutoLock envlock(m_env_mutex);
- //TODO check if one big lock could be faster then multiple small ones
- ScopeProfiler sp(g_profiler, "Server: sel and send blocks to clients");
- std::vector<PrioritySortedBlockTransfer> queue;
- s32 total_sending = 0;
- {
- ScopeProfiler sp(g_profiler, "Server: selecting blocks for sending");
- std::vector<u16> clients = m_clients.getClientIDs();
- m_clients.lock();
- for(std::vector<u16>::iterator i = clients.begin();
- i != clients.end(); ++i) {
- RemoteClient *client = m_clients.lockedGetClientNoEx(*i, CS_Active);
- if (client == NULL)
- continue;
- total_sending += client->SendingCount();
- client->GetNextBlocks(m_env,m_emerge, dtime, queue);
- }
- m_clients.unlock();
- }
- // Sort.
- // Lowest priority number comes first.
- // Lowest is most important.
- std::sort(queue.begin(), queue.end());
- m_clients.lock();
- for(u32 i=0; i<queue.size(); i++)
- {
- //TODO: Calculate limit dynamically
- if(total_sending >= g_settings->getS32
- ("max_simultaneous_block_sends_server_total"))
- break;
- PrioritySortedBlockTransfer q = queue[i];
- MapBlock *block = NULL;
- try
- {
- block = m_env->getMap().getBlockNoCreate(q.pos);
- }
- catch(InvalidPositionException &e)
- {
- continue;
- }
- RemoteClient *client = m_clients.lockedGetClientNoEx(q.peer_id, CS_Active);
- if(!client)
- continue;
- SendBlockNoLock(q.peer_id, block, client->serialization_version, client->net_proto_version);
- client->SentBlock(q.pos);
- total_sending++;
- }
- m_clients.unlock();
- }
- void Server::fillMediaCache()
- {
- DSTACK(FUNCTION_NAME);
- infostream<<"Server: Calculating media file checksums"<<std::endl;
- // Collect all media file paths
- std::vector<std::string> paths;
- for(std::vector<ModSpec>::iterator i = m_mods.begin();
- i != m_mods.end(); ++i) {
- const ModSpec &mod = *i;
- paths.push_back(mod.path + DIR_DELIM + "textures");
- paths.push_back(mod.path + DIR_DELIM + "sounds");
- paths.push_back(mod.path + DIR_DELIM + "media");
- paths.push_back(mod.path + DIR_DELIM + "models");
- }
- paths.push_back(porting::path_user + DIR_DELIM + "textures" + DIR_DELIM + "server");
- // Collect media file information from paths into cache
- for(std::vector<std::string>::iterator i = paths.begin();
- i != paths.end(); ++i) {
- std::string mediapath = *i;
- std::vector<fs::DirListNode> dirlist = fs::GetDirListing(mediapath);
- for (u32 j = 0; j < dirlist.size(); j++) {
- if (dirlist[j].dir) // Ignode dirs
- continue;
- std::string filename = dirlist[j].name;
- // If name contains illegal characters, ignore the file
- if (!string_allowed(filename, TEXTURENAME_ALLOWED_CHARS)) {
- infostream<<"Server: ignoring illegal file name: \""
- << filename << "\"" << std::endl;
- continue;
- }
- // If name is not in a supported format, ignore it
- const char *supported_ext[] = {
- ".png", ".jpg", ".bmp", ".tga",
- ".pcx", ".ppm", ".psd", ".wal", ".rgb",
- ".ogg",
- ".x", ".b3d", ".md2", ".obj",
- NULL
- };
- if (removeStringEnd(filename, supported_ext) == ""){
- infostream << "Server: ignoring unsupported file extension: \""
- << filename << "\"" << std::endl;
- continue;
- }
- // Ok, attempt to load the file and add to cache
- std::string filepath = mediapath + DIR_DELIM + filename;
- // Read data
- std::ifstream fis(filepath.c_str(), std::ios_base::binary);
- if (!fis.good()) {
- errorstream << "Server::fillMediaCache(): Could not open \""
- << filename << "\" for reading" << std::endl;
- continue;
- }
- std::ostringstream tmp_os(std::ios_base::binary);
- bool bad = false;
- for(;;) {
- char buf[1024];
- fis.read(buf, 1024);
- std::streamsize len = fis.gcount();
- tmp_os.write(buf, len);
- if (fis.eof())
- break;
- if (!fis.good()) {
- bad = true;
- break;
- }
- }
- if(bad) {
- errorstream<<"Server::fillMediaCache(): Failed to read \""
- << filename << "\"" << std::endl;
- continue;
- }
- if(tmp_os.str().length() == 0) {
- errorstream << "Server::fillMediaCache(): Empty file \""
- << filepath << "\"" << std::endl;
- continue;
- }
- SHA1 sha1;
- sha1.addBytes(tmp_os.str().c_str(), tmp_os.str().length());
- unsigned char *digest = sha1.getDigest();
- std::string sha1_base64 = base64_encode(digest, 20);
- std::string sha1_hex = hex_encode((char*)digest, 20);
- free(digest);
- // Put in list
- m_media[filename] = MediaInfo(filepath, sha1_base64);
- verbosestream << "Server: " << sha1_hex << " is " << filename
- << std::endl;
- }
- }
- }
- void Server::sendMediaAnnouncement(u16 peer_id)
- {
- DSTACK(FUNCTION_NAME);
- verbosestream << "Server: Announcing files to id(" << peer_id << ")"
- << std::endl;
- // Make packet
- std::ostringstream os(std::ios_base::binary);
- NetworkPacket pkt(TOCLIENT_ANNOUNCE_MEDIA, 0, peer_id);
- pkt << (u16) m_media.size();
- for (UNORDERED_MAP<std::string, MediaInfo>::iterator i = m_media.begin();
- i != m_media.end(); ++i) {
- pkt << i->first << i->second.sha1_digest;
- }
- pkt << g_settings->get("remote_media");
- Send(&pkt);
- }
- struct SendableMedia
- {
- std::string name;
- std::string path;
- std::string data;
- SendableMedia(const std::string &name_="", const std::string &path_="",
- const std::string &data_=""):
- name(name_),
- path(path_),
- data(data_)
- {}
- };
- void Server::sendRequestedMedia(u16 peer_id,
- const std::vector<std::string> &tosend)
- {
- DSTACK(FUNCTION_NAME);
- verbosestream<<"Server::sendRequestedMedia(): "
- <<"Sending files to client"<<std::endl;
- /* Read files */
- // Put 5kB in one bunch (this is not accurate)
- u32 bytes_per_bunch = 5000;
- std::vector< std::vector<SendableMedia> > file_bunches;
- file_bunches.push_back(std::vector<SendableMedia>());
- u32 file_size_bunch_total = 0;
- for(std::vector<std::string>::const_iterator i = tosend.begin();
- i != tosend.end(); ++i) {
- const std::string &name = *i;
- if (m_media.find(name) == m_media.end()) {
- errorstream<<"Server::sendRequestedMedia(): Client asked for "
- <<"unknown file \""<<(name)<<"\""<<std::endl;
- continue;
- }
- //TODO get path + name
- std::string tpath = m_media[name].path;
- // Read data
- std::ifstream fis(tpath.c_str(), std::ios_base::binary);
- if(fis.good() == false){
- errorstream<<"Server::sendRequestedMedia(): Could not open \""
- <<tpath<<"\" for reading"<<std::endl;
- continue;
- }
- std::ostringstream tmp_os(std::ios_base::binary);
- bool bad = false;
- for(;;) {
- char buf[1024];
- fis.read(buf, 1024);
- std::streamsize len = fis.gcount();
- tmp_os.write(buf, len);
- file_size_bunch_total += len;
- if(fis.eof())
- break;
- if(!fis.good()) {
- bad = true;
- break;
- }
- }
- if(bad) {
- errorstream<<"Server::sendRequestedMedia(): Failed to read \""
- <<name<<"\""<<std::endl;
- continue;
- }
- /*infostream<<"Server::sendRequestedMedia(): Loaded \""
- <<tname<<"\""<<std::endl;*/
- // Put in list
- file_bunches[file_bunches.size()-1].push_back(
- SendableMedia(name, tpath, tmp_os.str()));
- // Start next bunch if got enough data
- if(file_size_bunch_total >= bytes_per_bunch) {
- file_bunches.push_back(std::vector<SendableMedia>());
- file_size_bunch_total = 0;
- }
- }
- /* Create and send packets */
- u16 num_bunches = file_bunches.size();
- for(u16 i = 0; i < num_bunches; i++) {
- /*
- u16 command
- u16 total number of texture bunches
- u16 index of this bunch
- u32 number of files in this bunch
- for each file {
- u16 length of name
- string name
- u32 length of data
- data
- }
- */
- NetworkPacket pkt(TOCLIENT_MEDIA, 4 + 0, peer_id);
- pkt << num_bunches << i << (u32) file_bunches[i].size();
- for(std::vector<SendableMedia>::iterator
- j = file_bunches[i].begin();
- j != file_bunches[i].end(); ++j) {
- pkt << j->name;
- pkt.putLongString(j->data);
- }
- verbosestream << "Server::sendRequestedMedia(): bunch "
- << i << "/" << num_bunches
- << " files=" << file_bunches[i].size()
- << " size=" << pkt.getSize() << std::endl;
- Send(&pkt);
- }
- }
- void Server::sendDetachedInventory(const std::string &name, u16 peer_id)
- {
- if(m_detached_inventories.count(name) == 0) {
- errorstream<<FUNCTION_NAME<<": \""<<name<<"\" not found"<<std::endl;
- return;
- }
- Inventory *inv = m_detached_inventories[name];
- std::ostringstream os(std::ios_base::binary);
- os << serializeString(name);
- inv->serialize(os);
- // Make data buffer
- std::string s = os.str();
- NetworkPacket pkt(TOCLIENT_DETACHED_INVENTORY, 0, peer_id);
- pkt.putRawString(s.c_str(), s.size());
- if (peer_id != PEER_ID_INEXISTENT) {
- Send(&pkt);
- }
- else {
- m_clients.sendToAll(0, &pkt, true);
- }
- }
- void Server::sendDetachedInventories(u16 peer_id)
- {
- DSTACK(FUNCTION_NAME);
- for(std::map<std::string, Inventory*>::iterator
- i = m_detached_inventories.begin();
- i != m_detached_inventories.end(); ++i) {
- const std::string &name = i->first;
- //Inventory *inv = i->second;
- sendDetachedInventory(name, peer_id);
- }
- }
- /*
- Something random
- */
- void Server::DiePlayer(u16 peer_id)
- {
- DSTACK(FUNCTION_NAME);
- PlayerSAO *playersao = getPlayerSAO(peer_id);
- // In some rare cases this can be NULL -- if the player is disconnected
- // when a Lua function modifies l_punch, for example
- if (!playersao)
- return;
- infostream << "Server::DiePlayer(): Player "
- << playersao->getPlayer()->getName()
- << " dies" << std::endl;
- playersao->setHP(0);
- // Trigger scripted stuff
- m_script->on_dieplayer(playersao);
- SendPlayerHP(peer_id);
- SendDeathscreen(peer_id, false, v3f(0,0,0));
- }
- void Server::RespawnPlayer(u16 peer_id)
- {
- DSTACK(FUNCTION_NAME);
- PlayerSAO *playersao = getPlayerSAO(peer_id);
- assert(playersao);
- infostream << "Server::RespawnPlayer(): Player "
- << playersao->getPlayer()->getName()
- << " respawns" << std::endl;
- playersao->setHP(PLAYER_MAX_HP);
- playersao->setBreath(PLAYER_MAX_BREATH);
- SendPlayerHP(peer_id);
- SendPlayerBreath(peer_id);
- bool repositioned = m_script->on_respawnplayer(playersao);
- if(!repositioned){
- v3f pos = findSpawnPos();
- // setPos will send the new position to client
- playersao->setPos(pos);
- }
- }
- void Server::DenySudoAccess(u16 peer_id)
- {
- DSTACK(FUNCTION_NAME);
- NetworkPacket pkt(TOCLIENT_DENY_SUDO_MODE, 0, peer_id);
- Send(&pkt);
- }
- void Server::DenyAccessVerCompliant(u16 peer_id, u16 proto_ver, AccessDeniedCode reason,
- const std::string &str_reason, bool reconnect)
- {
- if (proto_ver >= 25) {
- SendAccessDenied(peer_id, reason, str_reason, reconnect);
- } else {
- std::wstring wreason = utf8_to_wide(
- reason == SERVER_ACCESSDENIED_CUSTOM_STRING ? str_reason :
- accessDeniedStrings[(u8)reason]);
- SendAccessDenied_Legacy(peer_id, wreason);
- }
- m_clients.event(peer_id, CSE_SetDenied);
- m_con.DisconnectPeer(peer_id);
- }
- void Server::DenyAccess(u16 peer_id, AccessDeniedCode reason, const std::string &custom_reason)
- {
- DSTACK(FUNCTION_NAME);
- SendAccessDenied(peer_id, reason, custom_reason);
- m_clients.event(peer_id, CSE_SetDenied);
- m_con.DisconnectPeer(peer_id);
- }
- // 13/03/15: remove this function when protocol version 25 will become
- // the minimum version for MT users, maybe in 1 year
- void Server::DenyAccess_Legacy(u16 peer_id, const std::wstring &reason)
- {
- DSTACK(FUNCTION_NAME);
- SendAccessDenied_Legacy(peer_id, reason);
- m_clients.event(peer_id, CSE_SetDenied);
- m_con.DisconnectPeer(peer_id);
- }
- void Server::acceptAuth(u16 peer_id, bool forSudoMode)
- {
- DSTACK(FUNCTION_NAME);
- if (!forSudoMode) {
- RemoteClient* client = getClient(peer_id, CS_Invalid);
- NetworkPacket resp_pkt(TOCLIENT_AUTH_ACCEPT, 1 + 6 + 8 + 4, peer_id);
- // Right now, the auth mechs don't change between login and sudo mode.
- u32 sudo_auth_mechs = client->allowed_auth_mechs;
- client->allowed_sudo_mechs = sudo_auth_mechs;
- resp_pkt << v3f(0,0,0) << (u64) m_env->getServerMap().getSeed()
- << g_settings->getFloat("dedicated_server_step")
- << sudo_auth_mechs;
- Send(&resp_pkt);
- m_clients.event(peer_id, CSE_AuthAccept);
- } else {
- NetworkPacket resp_pkt(TOCLIENT_ACCEPT_SUDO_MODE, 1 + 6 + 8 + 4, peer_id);
- // We only support SRP right now
- u32 sudo_auth_mechs = AUTH_MECHANISM_FIRST_SRP;
- resp_pkt << sudo_auth_mechs;
- Send(&resp_pkt);
- m_clients.event(peer_id, CSE_SudoSuccess);
- }
- }
- void Server::DeleteClient(u16 peer_id, ClientDeletionReason reason)
- {
- DSTACK(FUNCTION_NAME);
- std::wstring message;
- {
- /*
- Clear references to playing sounds
- */
- for (UNORDERED_MAP<s32, ServerPlayingSound>::iterator
- i = m_playing_sounds.begin(); i != m_playing_sounds.end();) {
- ServerPlayingSound &psound = i->second;
- psound.clients.erase(peer_id);
- if (psound.clients.empty())
- m_playing_sounds.erase(i++);
- else
- ++i;
- }
- RemotePlayer *player = m_env->getPlayer(peer_id);
- /* Run scripts and remove from environment */
- if(player != NULL) {
- PlayerSAO *playersao = player->getPlayerSAO();
- assert(playersao);
- m_script->on_leaveplayer(playersao, reason == CDR_TIMEOUT);
- playersao->disconnected();
- }
- /*
- Print out action
- */
- {
- if(player != NULL && reason != CDR_DENY) {
- std::ostringstream os(std::ios_base::binary);
- std::vector<u16> clients = m_clients.getClientIDs();
- for(std::vector<u16>::iterator i = clients.begin();
- i != clients.end(); ++i) {
- // Get player
- RemotePlayer *player = m_env->getPlayer(*i);
- if (!player)
- continue;
- // Get name of player
- os << player->getName() << " ";
- }
- std::string name = player->getName();
- actionstream << name << " "
- << (reason == CDR_TIMEOUT ? "times out." : "leaves game.")
- << " List of players: " << os.str() << std::endl;
- if (m_admin_chat)
- m_admin_chat->outgoing_queue.push_back(
- new ChatEventNick(CET_NICK_REMOVE, name));
- }
- }
- {
- MutexAutoLock env_lock(m_env_mutex);
- m_clients.DeleteClient(peer_id);
- }
- }
- // Send leave chat message to all remaining clients
- if(message.length() != 0)
- SendChatMessage(PEER_ID_INEXISTENT,message);
- }
- void Server::UpdateCrafting(RemotePlayer *player)
- {
- DSTACK(FUNCTION_NAME);
- // Get a preview for crafting
- ItemStack preview;
- InventoryLocation loc;
- loc.setPlayer(player->getName());
- std::vector<ItemStack> output_replacements;
- getCraftingResult(&player->inventory, preview, output_replacements, false, this);
- m_env->getScriptIface()->item_CraftPredict(preview, player->getPlayerSAO(),
- (&player->inventory)->getList("craft"), loc);
- // Put the new preview in
- InventoryList *plist = player->inventory.getList("craftpreview");
- sanity_check(plist);
- sanity_check(plist->getSize() >= 1);
- plist->changeItem(0, preview);
- }
- void Server::handleChatInterfaceEvent(ChatEvent *evt)
- {
- if (evt->type == CET_NICK_ADD) {
- // The terminal informed us of its nick choice
- m_admin_nick = ((ChatEventNick *)evt)->nick;
- if (!m_script->getAuth(m_admin_nick, NULL, NULL)) {
- errorstream << "You haven't set up an account." << std::endl
- << "Please log in using the client as '"
- << m_admin_nick << "' with a secure password." << std::endl
- << "Until then, you can't execute admin tasks via the console," << std::endl
- << "and everybody can claim the user account instead of you," << std::endl
- << "giving them full control over this server." << std::endl;
- }
- } else {
- assert(evt->type == CET_CHAT);
- handleAdminChat((ChatEventChat *)evt);
- }
- }
- std::wstring Server::handleChat(const std::string &name, const std::wstring &wname,
- const std::wstring &wmessage, bool check_shout_priv, RemotePlayer *player)
- {
- // If something goes wrong, this player is to blame
- RollbackScopeActor rollback_scope(m_rollback,
- std::string("player:") + name);
- // Line to send
- std::wstring line;
- // Whether to send line to the player that sent the message, or to all players
- bool broadcast_line = true;
- // Run script hook
- bool ate = m_script->on_chat_message(name,
- wide_to_utf8(wmessage));
- // If script ate the message, don't proceed
- if (ate)
- return L"";
- if (player) {
- switch (player->canSendChatMessage()) {
- case RPLAYER_CHATRESULT_FLOODING: {
- std::wstringstream ws;
- ws << L"You cannot send more messages. You are limited to "
- << g_settings->getFloat("chat_message_limit_per_10sec")
- << L" messages per 10 seconds.";
- return ws.str();
- }
- case RPLAYER_CHATRESULT_KICK:
- DenyAccess_Legacy(player->peer_id, L"You have been kicked due to message flooding.");
- return L"";
- case RPLAYER_CHATRESULT_OK: break;
- default: FATAL_ERROR("Unhandled chat filtering result found.");
- }
- }
- if (m_max_chatmessage_length > 0 && wmessage.length() > m_max_chatmessage_length) {
- return L"Your message exceed the maximum chat message limit set on the server. "
- L"It was refused. Send a shorter message";
- }
- // Commands are implemented in Lua, so only catch invalid
- // commands that were not "eaten" and send an error back
- if (wmessage[0] == L'/') {
- std::wstring wcmd = wmessage.substr(1);
- broadcast_line = false;
- if (wcmd.length() == 0)
- line += L"-!- Empty command";
- else
- line += L"-!- Invalid command: " + str_split(wcmd, L' ')[0];
- } else {
- if (check_shout_priv && !checkPriv(name, "shout")) {
- line += L"-!- You don't have permission to shout.";
- broadcast_line = false;
- } else {
- line += L"<";
- line += wname;
- line += L"> ";
- line += wmessage;
- }
- }
- /*
- Tell calling method to send the message to sender
- */
- if (!broadcast_line) {
- return line;
- } else {
- /*
- Send the message to others
- */
- actionstream << "CHAT: " << wide_to_narrow(line) << std::endl;
- std::vector<u16> clients = m_clients.getClientIDs();
- u16 peer_id_to_avoid_sending = (player ? player->peer_id : PEER_ID_INEXISTENT);
- for (u16 i = 0; i < clients.size(); i++) {
- u16 cid = clients[i];
- if (cid != peer_id_to_avoid_sending)
- SendChatMessage(cid, line);
- }
- }
- return L"";
- }
- void Server::handleAdminChat(const ChatEventChat *evt)
- {
- std::string name = evt->nick;
- std::wstring wname = utf8_to_wide(name);
- std::wstring wmessage = evt->evt_msg;
- std::wstring answer = handleChat(name, wname, wmessage);
- // If asked to send answer to sender
- if (!answer.empty()) {
- m_admin_chat->outgoing_queue.push_back(new ChatEventChat("", answer));
- }
- }
- RemoteClient* Server::getClient(u16 peer_id, ClientState state_min)
- {
- RemoteClient *client = getClientNoEx(peer_id,state_min);
- if(!client)
- throw ClientNotFoundException("Client not found");
- return client;
- }
- RemoteClient* Server::getClientNoEx(u16 peer_id, ClientState state_min)
- {
- return m_clients.getClientNoEx(peer_id, state_min);
- }
- std::string Server::getPlayerName(u16 peer_id)
- {
- RemotePlayer *player = m_env->getPlayer(peer_id);
- if (player == NULL)
- return "[id="+itos(peer_id)+"]";
- return player->getName();
- }
- PlayerSAO* Server::getPlayerSAO(u16 peer_id)
- {
- RemotePlayer *player = m_env->getPlayer(peer_id);
- if (player == NULL)
- return NULL;
- return player->getPlayerSAO();
- }
- std::wstring Server::getStatusString()
- {
- std::wostringstream os(std::ios_base::binary);
- os<<L"# Server: ";
- // Version
- os<<L"version="<<narrow_to_wide(g_version_string);
- // Uptime
- os<<L", uptime="<<m_uptime.get();
- // Max lag estimate
- os<<L", max_lag="<<m_env->getMaxLagEstimate();
- // Information about clients
- bool first = true;
- os<<L", clients={";
- std::vector<u16> clients = m_clients.getClientIDs();
- for (std::vector<u16>::iterator i = clients.begin(); i != clients.end(); ++i) {
- // Get player
- RemotePlayer *player = m_env->getPlayer(*i);
- // Get name of player
- std::wstring name = L"unknown";
- if (player != NULL)
- name = narrow_to_wide(player->getName());
- // Add name to information string
- if(!first)
- os << L", ";
- else
- first = false;
- os << name;
- }
- os << L"}";
- if(((ServerMap*)(&m_env->getMap()))->isSavingEnabled() == false)
- os<<std::endl<<L"# Server: "<<" WARNING: Map saving is disabled.";
- if(g_settings->get("motd") != "")
- os<<std::endl<<L"# Server: "<<narrow_to_wide(g_settings->get("motd"));
- return os.str();
- }
- std::set<std::string> Server::getPlayerEffectivePrivs(const std::string &name)
- {
- std::set<std::string> privs;
- m_script->getAuth(name, NULL, &privs);
- return privs;
- }
- bool Server::checkPriv(const std::string &name, const std::string &priv)
- {
- std::set<std::string> privs = getPlayerEffectivePrivs(name);
- return (privs.count(priv) != 0);
- }
- void Server::reportPrivsModified(const std::string &name)
- {
- if(name == "") {
- std::vector<u16> clients = m_clients.getClientIDs();
- for(std::vector<u16>::iterator i = clients.begin();
- i != clients.end(); ++i) {
- RemotePlayer *player = m_env->getPlayer(*i);
- reportPrivsModified(player->getName());
- }
- } else {
- RemotePlayer *player = m_env->getPlayer(name.c_str());
- if (!player)
- return;
- SendPlayerPrivileges(player->peer_id);
- PlayerSAO *sao = player->getPlayerSAO();
- if(!sao)
- return;
- sao->updatePrivileges(
- getPlayerEffectivePrivs(name),
- isSingleplayer());
- }
- }
- void Server::reportInventoryFormspecModified(const std::string &name)
- {
- RemotePlayer *player = m_env->getPlayer(name.c_str());
- if (!player)
- return;
- SendPlayerInventoryFormspec(player->peer_id);
- }
- void Server::setIpBanned(const std::string &ip, const std::string &name)
- {
- m_banmanager->add(ip, name);
- }
- void Server::unsetIpBanned(const std::string &ip_or_name)
- {
- m_banmanager->remove(ip_or_name);
- }
- std::string Server::getBanDescription(const std::string &ip_or_name)
- {
- return m_banmanager->getBanDescription(ip_or_name);
- }
- void Server::notifyPlayer(const char *name, const std::wstring &msg)
- {
- // m_env will be NULL if the server is initializing
- if (!m_env)
- return;
- if (m_admin_nick == name && !m_admin_nick.empty()) {
- m_admin_chat->outgoing_queue.push_back(new ChatEventChat("", msg));
- }
- RemotePlayer *player = m_env->getPlayer(name);
- if (!player) {
- return;
- }
- if (player->peer_id == PEER_ID_INEXISTENT)
- return;
- SendChatMessage(player->peer_id, msg);
- }
- bool Server::showFormspec(const char *playername, const std::string &formspec,
- const std::string &formname)
- {
- // m_env will be NULL if the server is initializing
- if (!m_env)
- return false;
- RemotePlayer *player = m_env->getPlayer(playername);
- if (!player)
- return false;
- SendShowFormspecMessage(player->peer_id, formspec, formname);
- return true;
- }
- u32 Server::hudAdd(RemotePlayer *player, HudElement *form)
- {
- if (!player)
- return -1;
- u32 id = player->addHud(form);
- SendHUDAdd(player->peer_id, id, form);
- return id;
- }
- bool Server::hudRemove(RemotePlayer *player, u32 id) {
- if (!player)
- return false;
- HudElement* todel = player->removeHud(id);
- if (!todel)
- return false;
- delete todel;
- SendHUDRemove(player->peer_id, id);
- return true;
- }
- bool Server::hudChange(RemotePlayer *player, u32 id, HudElementStat stat, void *data)
- {
- if (!player)
- return false;
- SendHUDChange(player->peer_id, id, stat, data);
- return true;
- }
- bool Server::hudSetFlags(RemotePlayer *player, u32 flags, u32 mask)
- {
- if (!player)
- return false;
- SendHUDSetFlags(player->peer_id, flags, mask);
- player->hud_flags &= ~mask;
- player->hud_flags |= flags;
- PlayerSAO* playersao = player->getPlayerSAO();
- if (playersao == NULL)
- return false;
- m_script->player_event(playersao, "hud_changed");
- return true;
- }
- bool Server::hudSetHotbarItemcount(RemotePlayer *player, s32 hotbar_itemcount)
- {
- if (!player)
- return false;
- if (hotbar_itemcount <= 0 || hotbar_itemcount > HUD_HOTBAR_ITEMCOUNT_MAX)
- return false;
- player->setHotbarItemcount(hotbar_itemcount);
- std::ostringstream os(std::ios::binary);
- writeS32(os, hotbar_itemcount);
- SendHUDSetParam(player->peer_id, HUD_PARAM_HOTBAR_ITEMCOUNT, os.str());
- return true;
- }
- void Server::hudSetHotbarImage(RemotePlayer *player, std::string name)
- {
- if (!player)
- return;
- player->setHotbarImage(name);
- SendHUDSetParam(player->peer_id, HUD_PARAM_HOTBAR_IMAGE, name);
- }
- std::string Server::hudGetHotbarImage(RemotePlayer *player)
- {
- if (!player)
- return "";
- return player->getHotbarImage();
- }
- void Server::hudSetHotbarSelectedImage(RemotePlayer *player, std::string name)
- {
- if (!player)
- return;
- player->setHotbarSelectedImage(name);
- SendHUDSetParam(player->peer_id, HUD_PARAM_HOTBAR_SELECTED_IMAGE, name);
- }
- bool Server::setLocalPlayerAnimations(RemotePlayer *player,
- v2s32 animation_frames[4], f32 frame_speed)
- {
- if (!player)
- return false;
- player->setLocalAnimations(animation_frames, frame_speed);
- SendLocalPlayerAnimations(player->peer_id, animation_frames, frame_speed);
- return true;
- }
- bool Server::setPlayerEyeOffset(RemotePlayer *player, v3f first, v3f third)
- {
- if (!player)
- return false;
- player->eye_offset_first = first;
- player->eye_offset_third = third;
- SendEyeOffset(player->peer_id, first, third);
- return true;
- }
- bool Server::setSky(RemotePlayer *player, const video::SColor &bgcolor,
- const std::string &type, const std::vector<std::string> ¶ms)
- {
- if (!player)
- return false;
- player->setSky(bgcolor, type, params);
- SendSetSky(player->peer_id, bgcolor, type, params);
- return true;
- }
- bool Server::overrideDayNightRatio(RemotePlayer *player, bool do_override,
- float ratio)
- {
- if (!player)
- return false;
- player->overrideDayNightRatio(do_override, ratio);
- SendOverrideDayNightRatio(player->peer_id, do_override, ratio);
- return true;
- }
- void Server::notifyPlayers(const std::wstring &msg)
- {
- SendChatMessage(PEER_ID_INEXISTENT,msg);
- }
- void Server::spawnParticle(const std::string &playername, v3f pos,
- v3f velocity, v3f acceleration,
- float expirationtime, float size, bool
- collisiondetection, bool collision_removal,
- bool vertical, const std::string &texture)
- {
- // m_env will be NULL if the server is initializing
- if (!m_env)
- return;
- u16 peer_id = PEER_ID_INEXISTENT;
- if (playername != "") {
- RemotePlayer *player = m_env->getPlayer(playername.c_str());
- if (!player)
- return;
- peer_id = player->peer_id;
- }
- SendSpawnParticle(peer_id, pos, velocity, acceleration,
- expirationtime, size, collisiondetection,
- collision_removal, vertical, texture);
- }
- u32 Server::addParticleSpawner(u16 amount, float spawntime,
- v3f minpos, v3f maxpos, v3f minvel, v3f maxvel, v3f minacc, v3f maxacc,
- float minexptime, float maxexptime, float minsize, float maxsize,
- bool collisiondetection, bool collision_removal,
- ServerActiveObject *attached, bool vertical, const std::string &texture,
- const std::string &playername)
- {
- // m_env will be NULL if the server is initializing
- if (!m_env)
- return -1;
- u16 peer_id = PEER_ID_INEXISTENT;
- if (playername != "") {
- RemotePlayer *player = m_env->getPlayer(playername.c_str());
- if (!player)
- return -1;
- peer_id = player->peer_id;
- }
- u16 attached_id = attached ? attached->getId() : 0;
- u32 id;
- if (attached_id == 0)
- id = m_env->addParticleSpawner(spawntime);
- else
- id = m_env->addParticleSpawner(spawntime, attached_id);
- SendAddParticleSpawner(peer_id, amount, spawntime,
- minpos, maxpos, minvel, maxvel, minacc, maxacc,
- minexptime, maxexptime, minsize, maxsize,
- collisiondetection, collision_removal, attached_id, vertical,
- texture, id);
- return id;
- }
- void Server::deleteParticleSpawner(const std::string &playername, u32 id)
- {
- // m_env will be NULL if the server is initializing
- if (!m_env)
- throw ServerError("Can't delete particle spawners during initialisation!");
- u16 peer_id = PEER_ID_INEXISTENT;
- if (playername != "") {
- RemotePlayer *player = m_env->getPlayer(playername.c_str());
- if (!player)
- return;
- peer_id = player->peer_id;
- }
- m_env->deleteParticleSpawner(id);
- SendDeleteParticleSpawner(peer_id, id);
- }
- Inventory* Server::createDetachedInventory(const std::string &name)
- {
- if(m_detached_inventories.count(name) > 0){
- infostream<<"Server clearing detached inventory \""<<name<<"\""<<std::endl;
- delete m_detached_inventories[name];
- } else {
- infostream<<"Server creating detached inventory \""<<name<<"\""<<std::endl;
- }
- Inventory *inv = new Inventory(m_itemdef);
- sanity_check(inv);
- m_detached_inventories[name] = inv;
- //TODO find a better way to do this
- sendDetachedInventory(name,PEER_ID_INEXISTENT);
- return inv;
- }
- // actions: time-reversed list
- // Return value: success/failure
- bool Server::rollbackRevertActions(const std::list<RollbackAction> &actions,
- std::list<std::string> *log)
- {
- infostream<<"Server::rollbackRevertActions(len="<<actions.size()<<")"<<std::endl;
- ServerMap *map = (ServerMap*)(&m_env->getMap());
- // Fail if no actions to handle
- if(actions.empty()){
- log->push_back("Nothing to do.");
- return false;
- }
- int num_tried = 0;
- int num_failed = 0;
- for(std::list<RollbackAction>::const_iterator
- i = actions.begin();
- i != actions.end(); ++i)
- {
- const RollbackAction &action = *i;
- num_tried++;
- bool success = action.applyRevert(map, this, this);
- if(!success){
- num_failed++;
- std::ostringstream os;
- os<<"Revert of step ("<<num_tried<<") "<<action.toString()<<" failed";
- infostream<<"Map::rollbackRevertActions(): "<<os.str()<<std::endl;
- if(log)
- log->push_back(os.str());
- }else{
- std::ostringstream os;
- os<<"Successfully reverted step ("<<num_tried<<") "<<action.toString();
- infostream<<"Map::rollbackRevertActions(): "<<os.str()<<std::endl;
- if(log)
- log->push_back(os.str());
- }
- }
- infostream<<"Map::rollbackRevertActions(): "<<num_failed<<"/"<<num_tried
- <<" failed"<<std::endl;
- // Call it done if less than half failed
- return num_failed <= num_tried/2;
- }
- // IGameDef interface
- // Under envlock
- IItemDefManager *Server::getItemDefManager()
- {
- return m_itemdef;
- }
- INodeDefManager *Server::getNodeDefManager()
- {
- return m_nodedef;
- }
- ICraftDefManager *Server::getCraftDefManager()
- {
- return m_craftdef;
- }
- ITextureSource *Server::getTextureSource()
- {
- return NULL;
- }
- IShaderSource *Server::getShaderSource()
- {
- return NULL;
- }
- scene::ISceneManager *Server::getSceneManager()
- {
- return NULL;
- }
- u16 Server::allocateUnknownNodeId(const std::string &name)
- {
- return m_nodedef->allocateDummy(name);
- }
- ISoundManager *Server::getSoundManager()
- {
- return &dummySoundManager;
- }
- MtEventManager *Server::getEventManager()
- {
- return m_event;
- }
- IWritableItemDefManager *Server::getWritableItemDefManager()
- {
- return m_itemdef;
- }
- IWritableNodeDefManager *Server::getWritableNodeDefManager()
- {
- return m_nodedef;
- }
- IWritableCraftDefManager *Server::getWritableCraftDefManager()
- {
- return m_craftdef;
- }
- const ModSpec *Server::getModSpec(const std::string &modname) const
- {
- std::vector<ModSpec>::const_iterator it;
- for (it = m_mods.begin(); it != m_mods.end(); ++it) {
- const ModSpec &mod = *it;
- if (mod.name == modname)
- return &mod;
- }
- return NULL;
- }
- void Server::getModNames(std::vector<std::string> &modlist)
- {
- std::vector<ModSpec>::iterator it;
- for (it = m_mods.begin(); it != m_mods.end(); ++it)
- modlist.push_back(it->name);
- }
- std::string Server::getBuiltinLuaPath()
- {
- return porting::path_share + DIR_DELIM + "builtin";
- }
- v3f Server::findSpawnPos()
- {
- ServerMap &map = m_env->getServerMap();
- v3f nodeposf;
- if (g_settings->getV3FNoEx("static_spawnpoint", nodeposf)) {
- return nodeposf * BS;
- }
- bool is_good = false;
- // Try to find a good place a few times
- for(s32 i = 0; i < 4000 && !is_good; i++) {
- s32 range = 1 + i;
- // We're going to try to throw the player to this position
- v2s16 nodepos2d = v2s16(
- -range + (myrand() % (range * 2)),
- -range + (myrand() % (range * 2)));
- // Get spawn level at point
- s16 spawn_level = m_emerge->getSpawnLevelAtPoint(nodepos2d);
- // Continue if MAX_MAP_GENERATION_LIMIT was returned by
- // the mapgen to signify an unsuitable spawn position
- if (spawn_level == MAX_MAP_GENERATION_LIMIT)
- continue;
- v3s16 nodepos(nodepos2d.X, spawn_level, nodepos2d.Y);
- s32 air_count = 0;
- for (s32 i = 0; i < 10; i++) {
- v3s16 blockpos = getNodeBlockPos(nodepos);
- map.emergeBlock(blockpos, true);
- content_t c = map.getNodeNoEx(nodepos).getContent();
- if (c == CONTENT_AIR || c == CONTENT_IGNORE) {
- air_count++;
- if (air_count >= 2) {
- nodeposf = intToFloat(nodepos, BS);
- // Don't spawn the player outside map boundaries
- if (objectpos_over_limit(nodeposf))
- continue;
- is_good = true;
- break;
- }
- }
- nodepos.Y++;
- }
- }
- return nodeposf;
- }
- PlayerSAO* Server::emergePlayer(const char *name, u16 peer_id, u16 proto_version)
- {
- bool newplayer = false;
- /*
- Try to get an existing player
- */
- RemotePlayer *player = m_env->getPlayer(name);
- // If player is already connected, cancel
- if (player != NULL && player->peer_id != 0) {
- infostream<<"emergePlayer(): Player already connected"<<std::endl;
- return NULL;
- }
- /*
- If player with the wanted peer_id already exists, cancel.
- */
- if (m_env->getPlayer(peer_id) != NULL) {
- infostream<<"emergePlayer(): Player with wrong name but same"
- " peer_id already exists"<<std::endl;
- return NULL;
- }
- // Create a new player active object
- PlayerSAO *playersao = new PlayerSAO(m_env, peer_id, isSingleplayer());
- player = m_env->loadPlayer(name, playersao);
- // Create player if it doesn't exist
- if (!player) {
- newplayer = true;
- player = new RemotePlayer(name, this->idef());
- // Set player position
- infostream<<"Server: Finding spawn place for player \""
- <<name<<"\""<<std::endl;
- playersao->setBasePosition(findSpawnPos());
- // Make sure the player is saved
- player->setModified(true);
- // Add player to environment
- m_env->addPlayer(player);
- } else {
- // If the player exists, ensure that they respawn inside legal bounds
- // This fixes an assert crash when the player can't be added
- // to the environment
- if (objectpos_over_limit(playersao->getBasePosition())) {
- actionstream << "Respawn position for player \""
- << name << "\" outside limits, resetting" << std::endl;
- playersao->setBasePosition(findSpawnPos());
- }
- }
- playersao->initialize(player, getPlayerEffectivePrivs(player->getName()));
- player->protocol_version = proto_version;
- /* Clean up old HUD elements from previous sessions */
- player->clearHud();
- /* Add object to environment */
- m_env->addActiveObject(playersao);
- /* Run scripts */
- if (newplayer) {
- m_script->on_newplayer(playersao);
- }
- return playersao;
- }
- void dedicated_server_loop(Server &server, bool &kill)
- {
- DSTACK(FUNCTION_NAME);
- verbosestream<<"dedicated_server_loop()"<<std::endl;
- IntervalLimiter m_profiler_interval;
- static const float steplen = g_settings->getFloat("dedicated_server_step");
- static const float profiler_print_interval =
- g_settings->getFloat("profiler_print_interval");
- for(;;) {
- // This is kind of a hack but can be done like this
- // because server.step() is very light
- {
- ScopeProfiler sp(g_profiler, "dedicated server sleep");
- sleep_ms((int)(steplen*1000.0));
- }
- server.step(steplen);
- if(server.getShutdownRequested() || kill)
- {
- infostream<<"Dedicated server quitting"<<std::endl;
- #if USE_CURL
- if(g_settings->getBool("server_announce"))
- ServerList::sendAnnounce("delete", server.m_bind_addr.getPort());
- #endif
- break;
- }
- /*
- Profiler
- */
- if (profiler_print_interval != 0) {
- if(m_profiler_interval.step(steplen, profiler_print_interval))
- {
- infostream<<"Profiler:"<<std::endl;
- g_profiler->print(infostream);
- g_profiler->clear();
- }
- }
- }
- }
|