9
3

LWorld.cpp 41 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374
  1. /*
  2. EQ2Emulator: Everquest II Server Emulator
  3. Copyright (C) 2007 EQ2EMulator Development Team (http://www.eq2emulator.net)
  4. This file is part of EQ2Emulator.
  5. */
  6. #include "../common/debug.h"
  7. #include <string.h>
  8. #include <stdarg.h>
  9. #ifdef WIN32
  10. #define WIN32_LEAN_AND_MEAN
  11. #include <windows.h>
  12. #include <winsock.h>
  13. #include <process.h>
  14. #else
  15. #include <sys/socket.h>
  16. #include <netinet/in.h>
  17. #include <arpa/inet.h>
  18. #include <unistd.h>
  19. #include <errno.h>
  20. #include <stdlib.h>
  21. #include "../common/unix.h"
  22. #define SOCKET_ERROR -1
  23. #define INVALID_SOCKET -1
  24. extern int errno;
  25. #endif
  26. #include "../common/servertalk.h"
  27. #include "LWorld.h"
  28. #include "net.h"
  29. #include "client.h"
  30. #include "../common/packet_dump.h"
  31. #include "login_opcodes.h"
  32. #include "login_structs.h"
  33. #include "LoginDatabase.h"
  34. #include "PacketHeaders.h"
  35. #include "../common/ConfigReader.h"
  36. #ifdef WIN32
  37. #define snprintf _snprintf
  38. #define vsnprintf _vsnprintf
  39. #define strncasecmp _strnicmp
  40. #define strcasecmp _stricmp
  41. #endif
  42. extern ClientList client_list;
  43. extern NetConnection net;
  44. extern LWorldList world_list;
  45. extern LoginDatabase database;
  46. extern ConfigReader configReader;
  47. extern volatile bool RunLoops;
  48. #include "../common/Log.h"
  49. using namespace std;
  50. LWorld::LWorld(TCPConnection* in_con, bool in_OutgoingLoginUplink, int32 iIP, int16 iPort, bool iNeverKick) {
  51. Link = in_con;
  52. RemoteID = 0;
  53. LinkWorldID = 0;
  54. if (iIP)
  55. ip = iIP;
  56. else
  57. ip = in_con->GetrIP();
  58. if (iPort)
  59. port = iPort;
  60. else
  61. port = in_con->GetrPort();
  62. ID = 0;
  63. pClientPort = 0;
  64. memset(account, 0, sizeof(account));
  65. memset(address, 0, sizeof(address));
  66. memset(worldname, 0, sizeof(worldname));
  67. status = 0;
  68. accountid = 0;
  69. admin_id = 0;
  70. IsInit = false;
  71. kicked = false;
  72. pNeverKick = iNeverKick;
  73. pPlaceholder = false;
  74. pshowdown = false;
  75. pConnected = in_con->Connected();
  76. pReconnectTimer = 0;
  77. pStatsTimer = NULL;
  78. isAuthenticated = false;
  79. if (in_OutgoingLoginUplink) {
  80. pClientPort = port;
  81. ptype = Login;
  82. OutgoingUplink = true;
  83. if (net.GetLoginMode() == Mesh) {
  84. pReconnectTimer = new Timer(INTERSERVER_TIMER);
  85. pReconnectTimer->Trigger();
  86. }
  87. }
  88. else {
  89. ptype = UnknownW;
  90. OutgoingUplink = false;
  91. }
  92. struct in_addr in;
  93. in.s_addr = GetIP();
  94. strcpy(address, inet_ntoa(in));
  95. isaddressip = true;
  96. num_players = 0;
  97. num_zones = 0;
  98. }
  99. LWorld::LWorld(int32 in_accountid, char* in_accountname, char* in_worldname, int32 in_admin_id) {
  100. pPlaceholder = true;
  101. Link = 0;
  102. ip = 0;
  103. port = 0;
  104. ID = 0;
  105. pClientPort = 0;
  106. memset(account, 0, sizeof(account));
  107. memset(address, 0, sizeof(address));
  108. memset(worldname, 0, sizeof(worldname));
  109. status = 0;
  110. accountid = in_accountid;
  111. admin_id = in_admin_id;
  112. IsInit = false;
  113. kicked = false;
  114. pNeverKick = false;
  115. pshowdown = true;
  116. RemoteID = 0;
  117. LinkWorldID = 0;
  118. OutgoingUplink = false;
  119. pReconnectTimer = 0;
  120. pConnected = false;
  121. pStatsTimer = NULL;
  122. ptype = World;
  123. strcpy(account, in_accountname);
  124. strcpy(worldname, in_worldname);
  125. strcpy(address, "none");
  126. isaddressip = true;
  127. num_players = 0;
  128. num_zones = 0;
  129. }
  130. LWorld::LWorld(TCPConnection* in_RemoteLink, int32 in_ip, int32 in_RemoteID, int32 in_accountid, char* in_accountname, char* in_worldname, char* in_address, sint32 in_status, int32 in_adminid, bool in_showdown, int8 in_authlevel, bool in_placeholder, int32 iLinkWorldID) {
  131. Link = in_RemoteLink;
  132. RemoteID = in_RemoteID;
  133. LinkWorldID = iLinkWorldID;
  134. ip = in_ip;
  135. port = 0;
  136. ID = 0;
  137. pClientPort = 0;
  138. memset(account, 0, sizeof(account));
  139. memset(address, 0, sizeof(address));
  140. memset(worldname, 0, sizeof(worldname));
  141. status = in_status;
  142. accountid = in_accountid;
  143. admin_id = in_adminid;
  144. IsInit = true;
  145. kicked = false;
  146. pNeverKick = false;
  147. pPlaceholder = in_placeholder;
  148. pshowdown = in_showdown;
  149. OutgoingUplink = false;
  150. pReconnectTimer = 0;
  151. pConnected = true;
  152. pStatsTimer = NULL;
  153. ptype = World;
  154. strcpy(account, in_accountname);
  155. strcpy(worldname, in_worldname);
  156. strcpy(address, in_address);
  157. isaddressip = false;
  158. num_players = 0;
  159. num_zones = 0;
  160. }
  161. LWorld::~LWorld() {
  162. safe_delete ( pStatsTimer );
  163. num_zones = 0;
  164. num_players = 0;
  165. database.UpdateWorldServerStats(this, -4);
  166. if (ptype == World && RemoteID == 0) {
  167. if (net.GetLoginMode() != Mesh || (!pPlaceholder && IsInit)) {
  168. ServerPacket* pack = new ServerPacket(ServerOP_WorldListRemove, sizeof(int32));
  169. *((int32*) pack->pBuffer) = GetID();
  170. world_list.SendPacketLogin(pack);
  171. delete pack;
  172. }
  173. }
  174. if (Link != 0 && RemoteID == 0) {
  175. world_list.RemoveByLink(Link, 0, this);
  176. if (OutgoingUplink)
  177. delete Link;
  178. else
  179. Link->Free();
  180. }
  181. Link = 0;
  182. safe_delete(pReconnectTimer);
  183. world_list.RemoveByID ( this->GetID ( ) );
  184. }
  185. bool LWorld::Process() {
  186. bool ret = true;
  187. if (Link == 0)
  188. return true;
  189. if (Link->Connected()) {
  190. if (!pConnected) {
  191. pConnected = true;
  192. }
  193. }
  194. else {
  195. pConnected = false;
  196. if (pReconnectTimer) {
  197. if (pReconnectTimer->Check() && Link->ConnectReady()) {
  198. pReconnectTimer->Start(pReconnectTimer->GetTimerTime() + (rand()%15000), false);
  199. }
  200. return true;
  201. }
  202. return false;
  203. }
  204. if (RemoteID != 0)
  205. return true;
  206. if(pStatsTimer && pStatsTimer->Check())
  207. database.UpdateWorldServerStats(this, GetStatus());
  208. ServerPacket* pack = 0;
  209. while (ret && (pack = Link->PopPacket())) {
  210. // this stops connections from sending invalid packets without first authenticating
  211. // with the login server to show it is a legit server
  212. if(!isAuthenticated && pack->opcode != ServerOP_LSInfo)
  213. {
  214. Kick("This connection has not authenticated.");
  215. break;
  216. }
  217. switch(pack->opcode) {
  218. case 0:
  219. break;
  220. case ServerOP_KeepAlive: {
  221. // ignore this
  222. break;
  223. }
  224. case ServerOP_LSFatalError: {
  225. net.Uplink_WrongVersion = true;
  226. ret = false;
  227. kicked = true;
  228. break;
  229. }
  230. case ServerOP_CharacterCreate: {
  231. WorldCharNameFilterResponse_Struct* wcnfr = (WorldCharNameFilterResponse_Struct*) pack->pBuffer;
  232. Client* client = client_list.FindByLSID(wcnfr->account_id);
  233. if(!client){
  234. if(wcnfr->account_id == 0){
  235. client_list.FindByCreateRequest();
  236. }
  237. break;
  238. }
  239. if(wcnfr->response == 1)
  240. {
  241. client->CharacterApproved(GetID(),wcnfr->char_id);
  242. }
  243. else
  244. {
  245. client->CharacterRejected(wcnfr->response);
  246. }
  247. break;
  248. }
  249. case ServerOP_UsertoWorldReq: {
  250. UsertoWorldRequest_Struct* ustwr = (UsertoWorldRequest_Struct*) pack->pBuffer;
  251. if (ustwr->ToID) {
  252. LWorld* world = world_list.FindByID(ustwr->ToID);
  253. if (!world) {
  254. break;
  255. }
  256. if (this->GetType() != Login) {
  257. break;
  258. }
  259. ustwr->FromID = this->GetID();
  260. world->SendPacket(pack);
  261. }
  262. break;
  263. }
  264. case ServerOP_UsertoWorldResp: {
  265. if (pack->size != sizeof(UsertoWorldResponse_Struct))
  266. break;
  267. UsertoWorldResponse_Struct* seps = (UsertoWorldResponse_Struct*) pack->pBuffer;
  268. if (seps->ToID) {
  269. LWorld* world = world_list.FindByID(seps->ToID);
  270. if (world) {
  271. seps->ToID = world->GetRemoteID();
  272. world->SendPacket(pack);
  273. }
  274. }
  275. else {
  276. Client* client = 0;
  277. client = client_list.FindByLSID(seps->lsaccountid);
  278. if(client == 0)
  279. break;
  280. if(this->GetID() != seps->worldid && this->GetType() != Login)
  281. break;
  282. client->WorldResponse(GetID(),seps->response, seps->ip_address, seps->port, seps->access_key);
  283. }
  284. break;
  285. }
  286. case ServerOP_CharTimeStamp: { // This is being sent to synch a new timestamp on the login server
  287. if(pack->size != sizeof(CharacterTimeStamp_Struct))
  288. break;
  289. CharacterTimeStamp_Struct* cts = (CharacterTimeStamp_Struct*) pack->pBuffer;
  290. if(!database.UpdateCharacterTimeStamp(cts->account_id,cts->char_id,cts->unix_timestamp,GetAccountID()))
  291. printf("TimeStamp update error with character id %i of account id %i on server %i\n",cts->char_id,cts->account_id,GetAccountID());
  292. //Todo: Synch with the other login servers
  293. break;
  294. }
  295. case ServerOP_GetTableData:{
  296. Kick("This is not an update server, update your LoginServer.ini file.");
  297. break;
  298. }
  299. case ServerOP_GetTableQuery:{
  300. Kick("This is not an update server, update your LoginServer.ini file.");
  301. break;
  302. }
  303. case ServerOP_GetLatestTables:{
  304. Kick("This is not an update server, update your LoginServer.ini file.");
  305. break;
  306. }
  307. case ServerOP_ZoneUpdate:{
  308. if(pack->size > CHARZONESTRUCT_MAXSIZE)
  309. break;
  310. CharZoneUpdate_Struct* czu = (CharZoneUpdate_Struct*)pack->pBuffer;
  311. database.UpdateCharacterZone(czu->account_id, czu->char_id, czu->zone_id, GetAccountID());
  312. break;
  313. }
  314. case ServerOP_RaceUpdate: {
  315. if(pack->size != sizeof(RaceUpdate_Struct))
  316. break;
  317. RaceUpdate_Struct* ru = (RaceUpdate_Struct*) pack->pBuffer;
  318. database.UpdateCharacterRace(ru->account_id , ru->char_id , ru->model_type , ru->race , this->GetAccountID ( ));
  319. break;
  320. }
  321. case ServerOP_BasicCharUpdate: {
  322. if(pack->size != sizeof(CharDataUpdate_Struct))
  323. break;
  324. CharDataUpdate_Struct* cdu = (CharDataUpdate_Struct*) pack->pBuffer;
  325. switch(cdu->update_field)
  326. {
  327. case LEVEL_UPDATE_FLAG:
  328. {
  329. database.UpdateCharacterLevel(cdu->account_id,cdu->char_id,cdu->update_data,this->GetAccountID());
  330. break;
  331. }
  332. case CLASS_UPDATE_FLAG:
  333. {
  334. database.UpdateCharacterClass(cdu->account_id,cdu->char_id,cdu->update_data,this->GetAccountID());
  335. break;
  336. }
  337. case GENDER_UPDATE_FLAG:
  338. {
  339. database.UpdateCharacterGender(cdu->account_id,cdu->char_id,cdu->update_data,this->GetAccountID());
  340. break;
  341. }
  342. case DELETE_UPDATE_FLAG:
  343. {
  344. if(cdu->update_field == 1)
  345. database.DeleteCharacter(cdu->account_id,cdu->char_id,this->GetAccountID());
  346. break;
  347. }
  348. }
  349. break;
  350. }
  351. case ServerOP_LSInfo: {
  352. if (pack->size != sizeof(ServerLSInfo_Struct)) {
  353. this->Kick(ERROR_BADVERSION);
  354. ret = false;
  355. struct in_addr in;
  356. in.s_addr = GetIP();
  357. }
  358. else {
  359. ServerLSInfo_Struct* lsi = (ServerLSInfo_Struct*) pack->pBuffer;
  360. if (strcmp(lsi->protocolversion, EQEMU_PROTOCOL_VERSION) != 0 || !database.CheckVersion(lsi->serverversion)) {
  361. cout << "ERROR - KICK BAD VERSION: Got versions: protocol: '" << lsi->protocolversion << "', database version: " << lsi->serverversion << endl;
  362. cout << "To allow all world server versions to login, run query on your login database (alternatively replacing * with the database version if preferred): insert into login_versions set version = '*';" << endl;
  363. this->Kick(ERROR_BADVERSION);
  364. ret = false;
  365. struct in_addr in;
  366. in.s_addr = GetIP();
  367. }
  368. else if (!SetupWorld(lsi->name, lsi->address, lsi->account, lsi->password, lsi->serverversion)) {
  369. this->Kick(ERROR_BADPASSWORD);
  370. ret = false;
  371. struct in_addr in;
  372. in.s_addr = GetIP();
  373. }
  374. else{
  375. isAuthenticated = true;
  376. devel_server = (lsi->servertype == 4);
  377. }
  378. }
  379. break;
  380. }
  381. case ServerOP_LSStatus: {
  382. ServerLSStatus_Struct* lss = (ServerLSStatus_Struct*) pack->pBuffer;
  383. if(lss->num_players > 5000 || lss->num_zones > 500) {
  384. this->Kick("Your server has exceeded a number of players and/or zone limit.");
  385. ret = false;
  386. break;
  387. }
  388. UpdateStatus(lss->status, lss->num_players, lss->num_zones);
  389. break;
  390. }
  391. case ServerOP_SystemwideMessage: {
  392. if (this->GetType() == Login) {
  393. // no looping plz =p
  394. //world_list.SendPacket(pack, this);
  395. }
  396. else if (this->GetType() == Chat) {
  397. world_list.SendPacket(pack);
  398. }
  399. else {
  400. }
  401. break;
  402. }
  403. case ServerOP_ListWorlds: {
  404. if (pack->size <= 1 || pack->pBuffer[pack->size - 1] != 0) {
  405. break;
  406. }
  407. world_list.SendWorldStatus(this, (char*) pack->pBuffer);
  408. break;
  409. }
  410. case ServerOP_WorldListUpdate: {
  411. if (this->GetType() != Login) {
  412. break;
  413. }
  414. if (pack->size != sizeof(ServerSyncWorldList_Struct)) {
  415. break;
  416. }
  417. ServerSyncWorldList_Struct* sswls = (ServerSyncWorldList_Struct*) pack->pBuffer;
  418. if (!CheckServerName(sswls->name)) {
  419. struct in_addr in;
  420. in.s_addr = sswls->ip;
  421. break; // Someone needs to tell the other login server to update it's exe!
  422. }
  423. LWorld* world = world_list.FindByLink(this->Link, sswls->RemoteID);
  424. if (world) {
  425. world->SetRemoteInfo(sswls->ip, sswls->accountid, sswls->account, sswls->name, sswls->address, sswls->status, sswls->adminid, sswls->num_players, sswls->num_zones);
  426. }
  427. else {
  428. world = world_list.FindByAccount(sswls->accountid, World);
  429. if (world == 0 || sswls->placeholder == false) {
  430. if (world) {
  431. #ifdef _DEBUG
  432. cout << "Kick(" << world->GetID() << ") in ServerOP_WorldListUpdate" << endl;
  433. #endif
  434. world->Kick();
  435. }
  436. world = new LWorld(this->Link, sswls->ip, sswls->RemoteID, sswls->accountid, sswls->account, sswls->name, sswls->address, sswls->status, sswls->adminid, sswls->showdown, sswls->authlevel, sswls->placeholder, this->GetID());
  437. LWorld* world2=world_list.FindByID(sswls->RemoteID);
  438. if(!world2)
  439. world_list.Add(world);
  440. }
  441. }
  442. sswls->RemoteID = world->GetID();
  443. if (net.GetLoginMode() != Mesh)
  444. world_list.SendPacketLogin(pack, this);
  445. cout << "Got world update for '" << sswls->name << "', #" << world->GetID() << endl;
  446. break;
  447. }
  448. case ServerOP_WorldListRemove: {
  449. if (this->GetType() != Login) {
  450. // cout << "Error: ServerOP_WorldListRemove from a non-login connection? WTF!" << endl;
  451. break;
  452. }
  453. if (pack->size != sizeof(int32)) {
  454. // cout << "Wrong size on ServerOP_WorldListRemove. Got: " << pack->size << ", Expected: " << sizeof(int32) << endl;
  455. break;
  456. }
  457. cout << "Got world remove for remote #" << *((int32*) pack->pBuffer) << endl;
  458. if ((*((int32*) pack->pBuffer)) > 0) {
  459. LWorld* world = world_list.FindByLink(this->GetLink(), *((int32*) pack->pBuffer));
  460. if (world && world->GetRemoteID() != 0) {
  461. *((int32*) pack->pBuffer) = world->GetID();
  462. if (net.GetLoginMode() != Mesh)
  463. world_list.SendPacketLogin(pack, this);
  464. world_list.RemoveByID(*((int32*) pack->pBuffer));
  465. }
  466. }
  467. else {
  468. // cout << "Error: ServerOP_WorldListRemove: ID = 0? ops!" << endl;
  469. }
  470. break;
  471. }
  472. case ServerOP_TriggerWorldListRefresh: {
  473. world_list.UpdateWorldList();
  474. if (net.GetLoginMode() != Mesh)
  475. world_list.SendPacketLogin(pack, this);
  476. break;
  477. }
  478. case ServerOP_ZoneUpdates:{
  479. pack->Inflate();
  480. ZoneUpdateList_Struct* updates = 0;
  481. if(pack->size >= sizeof(ZoneUpdateList_Struct) && ((ZoneUpdateList_Struct*)pack->pBuffer)->total_updates <= MAX_UPDATE_COUNT){
  482. updates = (ZoneUpdateList_Struct*)pack->pBuffer;
  483. ZoneUpdate_Struct* zone = 0;
  484. int32 pos = sizeof(ZoneUpdateList_Struct);
  485. sint16 num_updates = 0;
  486. map<int32, LoginZoneUpdate> zone_updates;
  487. LoginZoneUpdate update;
  488. while(pos < pack->size && num_updates < updates->total_updates){
  489. zone = (ZoneUpdate_Struct*)(pack->pBuffer+pos);
  490. if((pos + zone->zone_name_length + zone->zone_desc_length + sizeof(ZoneUpdate_Struct)) <= pack->size){
  491. update.name = string(zone->data, zone->zone_name_length);
  492. update.description = string(zone->data + zone->zone_name_length, zone->zone_desc_length);
  493. pos += sizeof(ZoneUpdate_Struct) + zone->zone_name_length + zone->zone_desc_length;
  494. num_updates++;
  495. zone_updates[zone->zone_id] = update;
  496. }
  497. else
  498. break;
  499. }
  500. if(zone_updates.size() == updates->total_updates)
  501. world_list.AddServerZoneUpdates(this, zone_updates);
  502. else
  503. cout << "Error processing zone updates for server: " << GetAccount() << endl;
  504. }
  505. else
  506. Kick("Possible Hacking Attempt");
  507. break;
  508. }
  509. case ServerOP_BugReport:{
  510. if(pack->size == sizeof(BugReport)){
  511. BugReport* report = (BugReport*)pack->pBuffer;
  512. database.SaveBugReport(GetAccountID(), report->category, report->subcategory, report->causes_crash, report->reproducible, report->summary, report->description, report->version, report->player, report->account_id, report->spawn_name, report->spawn_id, report->zone_id);
  513. }
  514. break;
  515. }
  516. case ServerOP_EncapPacket: {
  517. if (this->GetType() != Login) {
  518. // cout << "Error: ServerOP_EncapPacket from a non-login connection? WTF!" << endl;
  519. break;
  520. }
  521. ServerEncapPacket_Struct* seps = (ServerEncapPacket_Struct*) pack->pBuffer;
  522. if (seps->ToID == 0xFFFFFFFF) { // Broadcast
  523. ServerPacket* inpack = new ServerPacket(seps->opcode);
  524. inpack->size = seps->size;
  525. // Little trick here to save a memcpy, be careful if you change this any
  526. inpack->pBuffer = seps->data;
  527. world_list.SendPacketLocal(inpack, this);
  528. inpack->pBuffer = 0;
  529. delete inpack;
  530. }
  531. else {
  532. LWorld* world = world_list.FindByID(seps->ToID);
  533. if (world) {
  534. ServerPacket* inpack = new ServerPacket(seps->opcode);
  535. inpack->size = seps->size;
  536. // Little trick here to save a memcpy, be careful if you change this any
  537. inpack->pBuffer = seps->data;
  538. world->SendPacket(inpack);
  539. inpack->pBuffer = 0;
  540. delete inpack;
  541. }
  542. }
  543. if (net.GetLoginMode() != Mesh)
  544. world_list.SendPacketLogin(pack, this);
  545. break;
  546. }
  547. default:
  548. {
  549. cout << "Unknown LoginSOPcode: 0x" << hex << (int)pack->opcode << dec;
  550. cout << " size:" << pack->size << " from " << GetAccount() << endl;
  551. DumpPacket(pack->pBuffer, pack->size);
  552. //Kick("Possible Hacking Attempt");
  553. break;
  554. }
  555. }
  556. delete pack;
  557. }
  558. return ret;
  559. }
  560. void LWorld::SendPacket(ServerPacket* pack) {
  561. if (Link == 0)
  562. return;
  563. if (RemoteID) {
  564. ServerPacket* outpack = new ServerPacket(ServerOP_EncapPacket, sizeof(ServerEncapPacket_Struct) + pack->size);
  565. ServerEncapPacket_Struct* seps = (ServerEncapPacket_Struct*) outpack->pBuffer;
  566. seps->ToID = RemoteID;
  567. seps->opcode = pack->opcode;
  568. seps->size = pack->size;
  569. memcpy(seps->data, pack->pBuffer, pack->size);
  570. Link->SendPacket(outpack);
  571. delete outpack;
  572. }
  573. else {
  574. Link->SendPacket(pack);
  575. }
  576. }
  577. void LWorld::Message(char* to, char* message, ...) {
  578. va_list argptr;
  579. char buffer[256];
  580. va_start(argptr, message);
  581. vsnprintf(buffer, 256, message, argptr);
  582. va_end(argptr);
  583. ServerPacket* pack = new ServerPacket(ServerOP_EmoteMessage, sizeof(ServerEmoteMessage_Struct) + strlen(buffer) + 1);
  584. ServerEmoteMessage_Struct* sem = (ServerEmoteMessage_Struct*) pack->pBuffer;
  585. strcpy(sem->to, to);
  586. strcpy(sem->message, buffer);
  587. SendPacket(pack);
  588. delete pack;
  589. }
  590. void LWorld::Kick(char* message, bool iSetKickedFlag) {
  591. if (iSetKickedFlag)
  592. kicked = true;
  593. if (message) {
  594. ServerPacket* pack = new ServerPacket(ServerOP_LSFatalError, strlen(message) + 1);
  595. strcpy((char*) pack->pBuffer, message);
  596. SendPacket(pack);
  597. delete pack;
  598. }
  599. if (Link && GetRemoteID() == 0)
  600. Link->Disconnect();
  601. }
  602. bool LWorld::CheckServerName(char* name) {
  603. if (strlen(name) < 10)
  604. return false;
  605. for (int i=0; i<strlen(name); i++) {
  606. if (!((name[i] >= 'a' && name[i] <= 'z') || (name[i] >= 'A' && name[i] <= 'Z') || (name[i] >= '0' && name[i] <= '9') || name[i] == ' ' || name[i] == '\'' || name[i] == '-' || name[i] == '(' || name[i] == ')' || name[i] == '[' || name[i] == ']' || name[i] == '/' || name[i] == '.' || name[i] == ',' || name[i] == '_' || name[i] == '+' || name[i] == '=' || name[i] == ':' || name[i] == '~'))
  607. return false;
  608. }
  609. return true;
  610. }
  611. bool LWorld::SetupWorld(char* in_worldname, char* in_worldaddress, char* in_account, char* in_password, char* in_version) {
  612. if (strlen(in_worldaddress) > 3) {
  613. isaddressip = false;
  614. strcpy(address, in_worldaddress);
  615. }
  616. if (strlen(in_worldname) > 3) {
  617. int32 id = database.CheckServerAccount(in_account, in_password);
  618. if(id == 0)
  619. return false;
  620. LWorld* world = world_list.FindByID(id);
  621. if(world)
  622. world->Kick("Ghost Kick!");
  623. ID = id;
  624. accountid = id;
  625. char* name = database.GetServerAccountName(id);
  626. if(name)
  627. snprintf(worldname, (sizeof(worldname)) - 1, "%s", name);
  628. else{ //failed to get account
  629. account[0] = 0;
  630. IsInit = false;
  631. this->Kick ( "Could not load server information." );
  632. return false;
  633. }
  634. //world_list.KickGhostIP(GetIP(), this);
  635. account[0] = 0;
  636. IsInit = true;
  637. ptype = World;
  638. world_list.SendWorldChanged(id, true);
  639. }
  640. else {
  641. // name too short
  642. account[0] = 0;
  643. IsInit = false;
  644. return false;
  645. }
  646. pStatsTimer = new Timer ( 60000 );
  647. pStatsTimer->Start ( 60000 );
  648. return true;
  649. }
  650. void LWorldList::SendWorldChanged(int32 server_id, bool sendtoallclients, Client* sendto){
  651. EQ2Packet* outapp = new EQ2Packet(OP_WorldStatusChangeMsg, 0, sizeof(LS_WorldStatusChanged));
  652. LS_WorldStatusChanged* world_changed = (LS_WorldStatusChanged*)outapp->pBuffer;
  653. world_changed->server_id = server_id;
  654. LWorld* world = world_list.FindByID(server_id);
  655. if(!world || world->ShowDown())
  656. world_changed->up = 0;
  657. else
  658. world_changed->up = 1;
  659. if(sendtoallclients || sendto == 0)
  660. client_list.SendPacketToAllClients(outapp);
  661. else
  662. sendto->QueuePacket(outapp);
  663. world_list.SetUpdateServerList(true);
  664. }
  665. void LWorld::UpdateWorldList(LWorld* to) {
  666. world_list.SetUpdateServerList( true );
  667. }
  668. void LWorld::ChangeToPlaceholder() {
  669. ip = 0;
  670. status = -1;
  671. pPlaceholder = true;
  672. if (Link != 0 && RemoteID == 0) {
  673. Link->Disconnect();
  674. }
  675. UpdateWorldList();
  676. }
  677. void LWorld::SetRemoteInfo(int32 in_ip, int32 in_accountid, char* in_account, char* in_name, char* in_address, int32 in_status, int32 in_adminid, sint32 in_players, sint32 in_zones) {
  678. ip = in_ip;
  679. accountid = in_accountid;
  680. strcpy(account, in_account);
  681. strcpy(worldname, in_name);
  682. strcpy(address, in_address);
  683. status = in_status;
  684. admin_id = in_adminid;
  685. num_players = in_players;
  686. num_zones = in_zones;
  687. }
  688. LWorldList::LWorldList() {
  689. server_update_thread = true;
  690. NextID = 1;
  691. tcplistener = new TCPServer(net.GetPort(), true);
  692. if (net.GetLoginMode() == Slave)
  693. OutLink = new TCPConnection(true);
  694. else
  695. OutLink = 0;
  696. ServerListData = NULL;
  697. UpdateServerList = true;
  698. #ifdef WIN32
  699. _beginthread(ServerUpdateLoop, 0, this);
  700. #else
  701. pthread_t thread;
  702. pthread_create(&thread, NULL, &ServerUpdateLoop, this);
  703. #endif
  704. }
  705. LWorldList::~LWorldList() {
  706. server_update_thread = false;
  707. while(!server_update_thread){
  708. Sleep(100);
  709. }
  710. safe_delete(tcplistener);
  711. safe_delete(OutLink);
  712. }
  713. void LWorldList::Shutdown() {
  714. LinkedListIterator<LWorld*> iterator(list);
  715. iterator.Reset();
  716. while(iterator.MoreElements())
  717. {
  718. iterator.RemoveCurrent ( );
  719. }
  720. safe_delete(tcplistener);
  721. }
  722. void LWorldList::Add(LWorld* worldserver) {
  723. LWorld* worldExist = FindByID(worldserver->GetID ( ) );
  724. if( worldExist )
  725. {
  726. worldExist->Kick();
  727. MWorldMap.writelock();
  728. worldmap.erase(worldExist->GetID());
  729. MWorldMap.releasewritelock();
  730. safe_delete(worldExist);
  731. }
  732. MWorldMap.writelock();
  733. worldmap[worldserver->GetID()] = worldserver;
  734. MWorldMap.releasewritelock();
  735. database.ResetWorldServerStatsConnectedTime(worldserver);
  736. database.UpdateWorldIPAddress(worldserver->GetID(), worldserver->GetIP());
  737. }
  738. void LWorldList::AddInitiateWorld ( LWorld* world )
  739. {
  740. list.Insert ( world );
  741. }
  742. void LWorldList::KickGhostIP(int32 ip, LWorld* NotMe, int16 iClientPort) {
  743. if (ip == 0)
  744. return;
  745. map<int32,LWorld*>::iterator map_list;
  746. MWorldMap.readlock();
  747. for( map_list = worldmap.begin(); map_list != worldmap.end(); map_list++ ) {
  748. LWorld* world = map_list->second;
  749. if (!world->IsKicked() && world->GetIP() == ip && world != NotMe) {
  750. if ((iClientPort == 0 && world->GetType() == World) || (iClientPort != 0 && world->GetClientPort() == iClientPort)) {
  751. struct in_addr in;
  752. in.s_addr = world->GetIP();
  753. // cout << "Removing GhostIP LWorld(" << world->GetID() << ") from ip: " << inet_ntoa(in) << " port: " << (int16)(world->GetPort());
  754. if (!world->Connected())
  755. // cout << " (it wasnt connected)";
  756. // cout << endl;
  757. if (NotMe) {
  758. in.s_addr = NotMe->GetIP();
  759. cout << "NotMe(" << NotMe->GetID() << ") = " << inet_ntoa(in) << ":" << NotMe->GetPort() << " (" << NotMe->GetClientPort() << ")" << endl;
  760. }
  761. world->Kick("Ghost IP kick");
  762. }
  763. }
  764. }
  765. MWorldMap.releasereadlock();
  766. }
  767. void LWorldList::KickGhost(ConType in_type, int32 in_accountid, LWorld* ButNotMe) {
  768. map<int32,LWorld*>::iterator map_list;
  769. MWorldMap.readlock();
  770. for( map_list = worldmap.begin(); map_list != worldmap.end(); map_list++ ) {
  771. LWorld* world = map_list->second;
  772. if (!world->IsKicked() && world->GetType() == in_type && world != ButNotMe && (in_accountid == 0 || world->GetAccountID() == in_accountid)) {
  773. if (world->GetIP() != 0) {
  774. struct in_addr in;
  775. in.s_addr = world->GetIP();
  776. // cout << "Removing GhostAcc LWorld(" << world->GetID() << ") from ip: " << inet_ntoa(in) << " port: " << (int16)(world->GetPort()) << endl;
  777. }
  778. if (world->GetType() == Login && world->IsOutgoingUplink()) {
  779. world->Kick("Ghost Acc Kick", false);
  780. // cout << "softkick" << endl;
  781. }
  782. else
  783. world->Kick("Ghost Acc Kick");
  784. }
  785. }
  786. MWorldMap.releasereadlock();
  787. }
  788. void LWorldList::UpdateWorldStats(){
  789. map<int32,LWorld*>::iterator map_list;
  790. MWorldMap.readlock();
  791. for(map_list = worldmap.begin(); map_list != worldmap.end(); map_list++) {
  792. LWorld* world = map_list->second;
  793. if(world && world->GetAccountID() > 0)
  794. database.UpdateWorldServerStats(world, world->GetStatus());
  795. }
  796. MWorldMap.releasereadlock();
  797. }
  798. void LWorldList::Process() {
  799. TCPConnection* newtcp = 0;
  800. LWorld* newworld = 0;
  801. LinkedListIterator<LWorld*> iterator(list);
  802. iterator.Reset();
  803. while(iterator.MoreElements())
  804. {
  805. if(iterator.GetData( )->GetID ( ) > 0 )
  806. {
  807. LWorld* world = iterator.GetData ( );
  808. iterator.RemoveCurrent ( false );
  809. Add( world );
  810. }
  811. else
  812. {
  813. if(! iterator.GetData ( )->Process ( ) )
  814. iterator.RemoveCurrent ( );
  815. else
  816. iterator.Advance();
  817. }
  818. }
  819. while ((newtcp = tcplistener->NewQueuePop())) {
  820. newworld = new LWorld(newtcp);
  821. newworld->SetID(0);
  822. AddInitiateWorld(newworld);
  823. struct in_addr in;
  824. in.s_addr = newtcp->GetrIP();
  825. LogWrite(LOGIN__INFO, 0, "Login", "New Server connection: %s port %i", inet_ntoa(in), ntohs(newtcp->GetrPort()));
  826. net.numservers++;
  827. net.UpdateWindowTitle();
  828. }
  829. map<int32,LWorld*>::iterator map_list;
  830. for( map_list = worldmap.begin(); map_list != worldmap.end(); ) {
  831. LWorld* world = map_list->second;
  832. int32 account_id = world->GetAccountID();
  833. if (world->IsKicked() && !world->IsNeverKick()) {
  834. map_list++;
  835. worldmap.erase ( account_id );
  836. net.numservers--;
  837. net.UpdateWindowTitle();
  838. safe_delete ( world );
  839. continue;
  840. }
  841. else if (!world->Process()) {
  842. struct in_addr in;
  843. in.s_addr = world->GetIP();
  844. if (world->GetAccountID() == 0 || !(world->ShowDown()) || world->GetType() == Chat) {
  845. map_list++;
  846. worldmap.erase ( account_id );
  847. net.numservers--;
  848. net.UpdateWindowTitle();
  849. if(account_id > 0){
  850. LWorld* world2 = FindByID(account_id);
  851. if(world2)
  852. world2->ShowDownActive(true);
  853. }
  854. SendWorldChanged(account_id, true);
  855. safe_delete ( world );
  856. continue;
  857. }
  858. else {
  859. world->ChangeToPlaceholder();
  860. }
  861. }
  862. map_list++;
  863. }
  864. }
  865. // Sends packet to all World and Chat servers, local and remote (but not to remote login server's ::Process())
  866. void LWorldList::SendPacket(ServerPacket* pack, LWorld* butnotme) {
  867. map<int32,LWorld*>::iterator map_list;
  868. for( map_list = worldmap.begin(); map_list != worldmap.end(); map_list++) {
  869. LWorld* world = map_list->second;
  870. if (world != butnotme) {
  871. if (world->GetType() == Login) {
  872. ServerPacket* outpack = new ServerPacket(ServerOP_EncapPacket, sizeof(ServerEncapPacket_Struct) + pack->size);
  873. ServerEncapPacket_Struct* seps = (ServerEncapPacket_Struct*) outpack->pBuffer;
  874. seps->ToID = 0xFFFFFFFF;
  875. seps->opcode = pack->opcode;
  876. seps->size = pack->size;
  877. memcpy(seps->data, pack->pBuffer, pack->size);
  878. world->SendPacket(outpack);
  879. delete outpack;
  880. }
  881. else if (world->GetRemoteID() == 0) {
  882. world->SendPacket(pack);
  883. }
  884. }
  885. }
  886. }
  887. // Sends a packet to every local TCP Connection, all types
  888. void LWorldList::SendPacketLocal(ServerPacket* pack, LWorld* butnotme) {
  889. map<int32,LWorld*>::iterator map_list;
  890. for( map_list = worldmap.begin(); map_list != worldmap.end(); map_list++) {
  891. LWorld* world = map_list->second;
  892. if (world != butnotme && world->GetRemoteID() == 0) {
  893. world->SendPacket(pack);
  894. }
  895. }
  896. }
  897. // Sends the packet to all login servers
  898. void LWorldList::SendPacketLogin(ServerPacket* pack, LWorld* butnotme) {
  899. map<int32,LWorld*>::iterator map_list;
  900. for( map_list = worldmap.begin(); map_list != worldmap.end(); map_list++ ) {
  901. LWorld* world = map_list->second;
  902. if (world != butnotme && world->GetType() == Login) {
  903. world->SendPacket(pack);
  904. }
  905. }
  906. }
  907. void LWorldList::UpdateWorldList(LWorld* to) {
  908. map<int32,LWorld*>::iterator map_list;
  909. for( map_list = worldmap.begin(); map_list != worldmap.end(); map_list++) {
  910. LWorld* world = map_list->second;
  911. if (net.GetLoginMode() != Mesh || world->GetRemoteID() == 0)
  912. world->UpdateWorldList(to);
  913. }
  914. }
  915. LWorld* LWorldList::FindByID(int32 LWorldID) {
  916. if(worldmap.count(LWorldID) > 0)
  917. return worldmap[LWorldID];
  918. return 0;
  919. }
  920. LWorld* LWorldList::FindByIP(int32 ip) {
  921. map<int32,LWorld*>::iterator map_list;
  922. LWorld* world = 0;
  923. LWorld* ret = 0;
  924. MWorldMap.readlock();
  925. for( map_list = worldmap.begin(); map_list != worldmap.end(); map_list++) {
  926. world = map_list->second;
  927. if (world->GetIP() == ip){
  928. ret = world;
  929. break;
  930. }
  931. }
  932. MWorldMap.releasereadlock();
  933. return ret;
  934. }
  935. LWorld* LWorldList::FindByAddress(char* address) {
  936. map<int32,LWorld*>::iterator map_list;
  937. LWorld* world = 0;
  938. LWorld* ret = 0;
  939. MWorldMap.readlock();
  940. for( map_list = worldmap.begin(); map_list != worldmap.end(); map_list++) {
  941. world = map_list->second;
  942. if (strcasecmp(world->GetAddress(), address) == 0){
  943. ret = world;
  944. break;
  945. }
  946. }
  947. MWorldMap.releasereadlock();
  948. return ret;
  949. }
  950. LWorld* LWorldList::FindByLink(TCPConnection* in_link, int32 in_id) {
  951. if (in_link == 0)
  952. return 0;
  953. LWorld* world = 0;
  954. LWorld* ret = 0;
  955. map<int32,LWorld*>::iterator map_list;
  956. MWorldMap.readlock();
  957. for( map_list = worldmap.begin(); map_list != worldmap.end(); map_list++) {
  958. world = map_list->second;
  959. if (world->GetLink() == in_link && world->GetRemoteID() == in_id){
  960. ret = world;
  961. break;
  962. }
  963. }
  964. MWorldMap.releasereadlock();
  965. return ret;
  966. }
  967. LWorld* LWorldList::FindByAccount(int32 in_accountid, ConType in_type) {
  968. if (in_accountid == 0)
  969. return 0;
  970. LWorld* world = 0;
  971. LWorld* ret = 0;
  972. map<int32,LWorld*>::iterator map_list;
  973. MWorldMap.readlock();
  974. for( map_list = worldmap.begin(); map_list != worldmap.end(); map_list++) {
  975. world = map_list->second;
  976. if (world->GetAccountID() == in_accountid && world->GetType() == in_type){
  977. ret = world;
  978. break;
  979. }
  980. }
  981. MWorldMap.releasereadlock();
  982. return ret;
  983. }
  984. int8 LWorld::GetWorldStatus(){
  985. if(IsDevelServer() && IsLocked() == false)
  986. return 1;
  987. else if(IsInit && IsLocked() == false)
  988. return 0;
  989. else
  990. return 2;
  991. }
  992. void LWorld::SendDeleteCharacter ( int32 char_id , int32 account_id )
  993. {
  994. ServerPacket* outpack = new ServerPacket(ServerOP_BasicCharUpdate, sizeof(CharDataUpdate_Struct));
  995. CharDataUpdate_Struct* cdu = (CharDataUpdate_Struct*)outpack->pBuffer;
  996. cdu->account_id = account_id;
  997. cdu->char_id = char_id;
  998. cdu->update_field = DELETE_UPDATE_FLAG;
  999. cdu->update_data = 1;
  1000. SendPacket(outpack);
  1001. }
  1002. vector<PacketStruct*>* LWorldList::GetServerListUpdate(int16 version){
  1003. vector<PacketStruct*>* ret = new vector<PacketStruct*>;
  1004. map<int32,LWorld*>::iterator map_list;
  1005. PacketStruct* packet = 0;
  1006. MWorldMap.readlock();
  1007. for( map_list = worldmap.begin(); map_list != worldmap.end(); map_list++) {
  1008. LWorld* world = map_list->second;
  1009. if ((world->IsInit || (world->ShowDown() && world->ShowDownActive())) && world->GetType() == World) {
  1010. packet = configReader.getStruct("LS_WorldUpdate", version);
  1011. if(packet){
  1012. packet->setDataByName("server_id", world->GetID());
  1013. packet->setDataByName("up", 1);
  1014. if(world->IsLocked())
  1015. packet->setDataByName("locked", 1);
  1016. ret->push_back(packet);
  1017. }
  1018. }
  1019. }
  1020. MWorldMap.releasereadlock();
  1021. return ret;
  1022. }
  1023. EQ2Packet* LWorldList::MakeServerListPacket(int8 lsadmin, int16 version) {
  1024. // if the latest world list has already been loaded, just return the string
  1025. if(!UpdateServerList && ServerListData)
  1026. return ServerListData;
  1027. MWorldMap.readlock();
  1028. LWorld* world = 0;
  1029. uchar num_servers[2];
  1030. int32 ServerNum = 0;
  1031. /* while(iterator.MoreElements()){
  1032. world = iterator.GetData();
  1033. if ((world->IsInit || (world->ShowDown() && world->ShowDownActive())) && world->GetType() == World)
  1034. ServerNum++;
  1035. iterator.Advance();
  1036. }
  1037. ServerNum+=3;
  1038. */
  1039. uint32 tmpCount = 0;
  1040. map<int32, LWorld*>::iterator map_list;
  1041. for (map_list = worldmap.begin(); map_list != worldmap.end(); map_list++) {
  1042. LWorld* world = map_list->second;
  1043. if ((world->IsInit || (world->ShowDown() && world->ShowDownActive())) && world->GetType() == World) {
  1044. tmpCount++;
  1045. }
  1046. }
  1047. PacketStruct* packet = configReader.getStruct("LS_WorldList", version);
  1048. packet->setArrayLengthByName("num_worlds", tmpCount);
  1049. string world_data;
  1050. for( map_list = worldmap.begin(); map_list != worldmap.end(); map_list++) {
  1051. LWorld* world = map_list->second;
  1052. if ((world->IsInit || (world->ShowDown() && world->ShowDownActive())) && world->GetType() == World) {
  1053. ServerNum++;
  1054. packet->setArrayDataByName("id", world->GetID(), ServerNum-1);
  1055. if (version < 1096)
  1056. packet->setDataByName("allowed_races", 0x0007FFFF, ServerNum - 1); // no Freeblood and Aerakyn race
  1057. else if (version < 60006)
  1058. packet->setArrayDataByName("allowed_races", 0x000FFFFF, ServerNum - 1); // + Freeblood
  1059. else
  1060. packet->setArrayDataByName("allowed_races", 0x001FFFFF, ServerNum - 1); // + Aerakyn
  1061. packet->setArrayDataByName("number_online_flag", 1, ServerNum-1);
  1062. packet->setArrayDataByName("num_players", world->GetPlayerNum(), ServerNum-1);
  1063. packet->setArrayDataByName("name", world->GetName(), ServerNum-1);
  1064. packet->setArrayDataByName("name2", world->GetName(), ServerNum-1);
  1065. packet->setArrayDataByName("feature_set",0, ServerNum-1);
  1066. packet->setArrayDataByName("load", world->GetWorldStatus(), ServerNum-1);
  1067. if(world->IsLocked())
  1068. packet->setArrayDataByName("locked", 1, ServerNum - 1);
  1069. if(world->ShowDown())
  1070. packet->setArrayDataByName("tag", 0, ServerNum - 1);
  1071. else
  1072. packet->setArrayDataByName("tag", 1, ServerNum - 1);
  1073. }
  1074. }
  1075. EQ2Packet* pack = packet->serialize();
  1076. safe_delete(ServerListData);
  1077. ServerListData = pack;
  1078. MWorldMap.releasereadlock();
  1079. SetUpdateServerList( false );
  1080. return ServerListData;
  1081. }
  1082. void LWorldList::SendWorldStatus(LWorld* chat, char* adminname) {
  1083. struct in_addr in;
  1084. int32 count = 0;
  1085. map<int32,LWorld*>::iterator map_list;
  1086. for( map_list = worldmap.begin(); map_list != worldmap.end(); map_list++) {
  1087. LWorld* world = map_list->second;
  1088. if (world->GetIP() != 0 && world->GetType() == World) {
  1089. chat->Message(adminname, "Name: %s", world->GetName());
  1090. in.s_addr = world->GetIP();
  1091. if (world->GetAccountID() != 0) {
  1092. chat->Message(adminname, " Account: %s", world->GetAccount());
  1093. }
  1094. chat->Message(adminname, " Number of Zones: %i", world->GetZoneNum());
  1095. chat->Message(adminname, " Number of Players: %i", world->GetPlayerNum());
  1096. chat->Message(adminname, " IP: %s", inet_ntoa(in));
  1097. if (!world->IsAddressIP()) {
  1098. chat->Message(adminname, " Address: %s", world->GetAddress());
  1099. }
  1100. count++;
  1101. }
  1102. }
  1103. chat->Message(adminname, "%i worlds listed.", count);
  1104. }
  1105. void LWorldList::RemoveByLink(TCPConnection* in_link, int32 in_id, LWorld* ButNotMe) {
  1106. if (in_link == 0)
  1107. return;
  1108. map<int32,LWorld*>::iterator map_list;
  1109. for( map_list = worldmap.begin(); map_list != worldmap.end(); map_list++) {
  1110. LWorld* world = map_list->second;
  1111. if (world != ButNotMe && world->GetLink() == in_link && (in_id == 0 || world->GetRemoteID() == in_id)) {
  1112. // world->Link = 0;
  1113. map_list++;
  1114. worldmap.erase ( world->GetID ( ) );
  1115. safe_delete ( world );
  1116. continue;
  1117. }
  1118. }
  1119. }
  1120. void LWorldList::RemoveByID(int32 in_id) {
  1121. if (in_id == 0)
  1122. return;
  1123. LWorld* existWorld = FindByID(in_id);
  1124. if ( existWorld != NULL )
  1125. {
  1126. MWorldMap.writelock();
  1127. worldmap.erase ( in_id );
  1128. MWorldMap.releasewritelock();
  1129. safe_delete ( existWorld );
  1130. }
  1131. }
  1132. bool LWorldList::Init() {
  1133. database.ResetWorldStats ( );
  1134. if (!tcplistener->IsOpen()) {
  1135. return tcplistener->Open(net.GetPort());
  1136. }
  1137. return false;
  1138. }
  1139. void LWorldList::InitWorlds(){
  1140. vector<LWorld*> server_list;
  1141. database.GetServerAccounts(&server_list);
  1142. vector<LWorld*>::iterator iter;
  1143. int i = 0;
  1144. for(iter = server_list.begin(); iter != server_list.end(); iter++, i++){
  1145. LWorld* world = FindByID(server_list[i]->GetAccountID());
  1146. if(!world){
  1147. server_list[i]->ShowDown(true);
  1148. server_list[i]->ShowDownActive(true);
  1149. server_list[i]->SetID ( server_list[i]->GetAccountID ( ) );
  1150. Add ( server_list[i] );
  1151. }
  1152. }
  1153. }
  1154. void LWorldList::ListWorldsToConsole() {
  1155. struct in_addr in;
  1156. cout << "World List:" << endl;
  1157. cout << "============================" << endl;
  1158. map<int32,LWorld*>::iterator map_list;
  1159. for( map_list = worldmap.begin(); map_list != worldmap.end(); map_list++) {
  1160. LWorld* world = map_list->second;
  1161. in.s_addr = world->GetIP();
  1162. if (world->GetType() == World) {
  1163. if (world->GetRemoteID() == 0)
  1164. cout << "ID: " << world->GetID() << ", Name: " << world->GetName() << ", Local, IP: " << inet_ntoa(in) << ":" << world->GetPort() << ", Status: " << world->GetStatus() << ", AccID: " << world->GetAccountID() << endl;
  1165. else
  1166. cout << "ID: " << world->GetID() << ", Name: " << world->GetName() << ", RemoteID: " << world->GetRemoteID() << ", LinkWorldID: " << world->GetLinkWorldID() << ", IP: " << inet_ntoa(in) << ":" << world->GetPort() << ", Status: " << world->GetStatus() << ", AccID: " << world->GetAccountID() << endl;
  1167. }
  1168. else if (world->GetType() == Chat) {
  1169. cout << "ID: " << world->GetID() << ", Chat Server, IP: " << inet_ntoa(in) << ":" << world->GetPort() << ", AccID: " << world->GetAccountID() << endl;
  1170. }
  1171. else if (world->GetType() == Login) {
  1172. if (world->IsOutgoingUplink()) {
  1173. if (world->Connected())
  1174. cout << "ID: " << world->GetID() << ", Login Server (out), IP: " << inet_ntoa(in) << ":" << world->GetPort() << ", AccID: " << world->GetAccountID() << endl;
  1175. else
  1176. cout << "ID: " << world->GetID() << ", Login Server (nc), IP: " << inet_ntoa(in) << ":" << world->GetPort() << ", AccID: " << world->GetAccountID() << endl;
  1177. }
  1178. else
  1179. cout << "ID: " << world->GetID() << ", Login Server (in), IP: " << inet_ntoa(in) << ":" << world->GetPort() << " (" << world->GetClientPort() << "), AccID: " << world->GetAccountID() << endl;
  1180. }
  1181. else {
  1182. cout << "ID: " << world->GetID() << ", Unknown Type, Name: " << world->GetName() << ", IP: " << inet_ntoa(in) << ":" << world->GetPort() << ", AccID: " << world->GetAccountID() << endl;
  1183. }
  1184. }
  1185. cout << "============================" << endl;
  1186. }
  1187. void LWorldList::AddServerZoneUpdates(LWorld* world, map<int32, LoginZoneUpdate> updates){
  1188. int32 server_id = world->GetID();
  1189. map<int32, LoginZoneUpdate>::iterator itr;
  1190. for(itr = updates.begin(); itr != updates.end(); itr++){
  1191. if(zone_updates_already_used.size() >= 1500 || zone_updates_already_used[server_id].count(itr->first) > 0){
  1192. world->Kick("Hacking attempt.");
  1193. return;
  1194. }
  1195. zone_updates_already_used[server_id][itr->first] = true;
  1196. }
  1197. server_zone_updates.Put(server_id, updates);
  1198. }
  1199. void LWorldList::RequestServerUpdates(LWorld* world){
  1200. if(world){
  1201. ServerPacket* pack = new ServerPacket(ServerOP_ZoneUpdates, sizeof(ZoneUpdateRequest_Struct));
  1202. ZoneUpdateRequest_Struct* request = (ZoneUpdateRequest_Struct*)pack->pBuffer;
  1203. request->max_per_batch = MAX_UPDATE_COUNT;
  1204. world->SendPacket(pack);
  1205. delete pack;
  1206. zone_update_timeouts.Put(world->GetID(), Timer::GetCurrentTime2() + 30000);
  1207. }
  1208. }
  1209. void LWorldList::ProcessServerUpdates(){
  1210. MutexMap<int32, map<int32, LoginZoneUpdate> >::iterator itr = server_zone_updates.begin();
  1211. while(itr.Next()){
  1212. if(itr->second.size() > 0){
  1213. database.SetServerZoneDescriptions(itr->first, itr->second);
  1214. if(itr->second.size() == MAX_UPDATE_COUNT)
  1215. awaiting_zone_update.Put(itr->first, Timer::GetCurrentTime2() + 10000); //only process 20 updates in a 10 second period to avoid network problems
  1216. server_zone_updates.erase(itr->first);
  1217. }
  1218. if(zone_update_timeouts.count(itr->first) == 0 || zone_update_timeouts.Get(itr->first) <= Timer::GetCurrentTime2()){
  1219. zone_update_timeouts.erase(itr->first);
  1220. server_zone_updates.erase(itr->first);
  1221. }
  1222. }
  1223. LWorld* world = 0;
  1224. MWorldMap.readlock();
  1225. map<int32, LWorld*>::iterator map_itr;
  1226. for(map_itr = worldmap.begin(); map_itr != worldmap.end(); map_itr++){
  1227. world = map_itr->second;
  1228. if(world && world->GetID()){
  1229. if(last_updated.count(world) == 0 || last_updated.Get(world) <= Timer::GetCurrentTime2()){
  1230. zone_updates_already_used[world->GetID()].clear();
  1231. RequestServerUpdates(world);
  1232. last_updated.Put(world, Timer::GetCurrentTime2() + 21600000);
  1233. }
  1234. if(awaiting_zone_update.count(world->GetID()) > 0 && awaiting_zone_update.Get(world->GetID()) <= Timer::GetCurrentTime2()){
  1235. awaiting_zone_update.erase(world->GetID());
  1236. RequestServerUpdates(world);
  1237. }
  1238. }
  1239. }
  1240. MWorldMap.releasereadlock();
  1241. }
  1242. ThreadReturnType ServerUpdateLoop(void* tmp) {
  1243. #ifdef WIN32
  1244. SetThreadPriority(GetCurrentThread(), THREAD_PRIORITY_ABOVE_NORMAL);
  1245. #endif
  1246. if (tmp == 0) {
  1247. ThrowError("ServerUpdateLoop(): tmp = 0!");
  1248. THREAD_RETURN(NULL);
  1249. }
  1250. LWorldList* worldList = (LWorldList*) tmp;
  1251. while (worldList->ContinueServerUpdates()) {
  1252. Sleep(1000);
  1253. worldList->ProcessServerUpdates();
  1254. }
  1255. worldList->ResetServerUpdates();
  1256. THREAD_RETURN(NULL);
  1257. }