LWorld.cpp 41 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387
  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. UpdateServerList = true;
  697. #ifdef WIN32
  698. _beginthread(ServerUpdateLoop, 0, this);
  699. #else
  700. pthread_t thread;
  701. pthread_create(&thread, NULL, &ServerUpdateLoop, this);
  702. #endif
  703. }
  704. LWorldList::~LWorldList() {
  705. server_update_thread = false;
  706. while(!server_update_thread){
  707. Sleep(100);
  708. }
  709. safe_delete(tcplistener);
  710. safe_delete(OutLink);
  711. }
  712. void LWorldList::Shutdown() {
  713. LinkedListIterator<LWorld*> iterator(list);
  714. iterator.Reset();
  715. while(iterator.MoreElements())
  716. {
  717. iterator.RemoveCurrent ( );
  718. }
  719. safe_delete(tcplistener);
  720. }
  721. void LWorldList::Add(LWorld* worldserver) {
  722. LWorld* worldExist = FindByID(worldserver->GetID ( ) );
  723. if( worldExist )
  724. {
  725. worldExist->Kick();
  726. MWorldMap.writelock();
  727. worldmap.erase(worldExist->GetID());
  728. MWorldMap.releasewritelock();
  729. safe_delete(worldExist);
  730. }
  731. MWorldMap.writelock();
  732. worldmap[worldserver->GetID()] = worldserver;
  733. MWorldMap.releasewritelock();
  734. database.ResetWorldServerStatsConnectedTime(worldserver);
  735. database.UpdateWorldIPAddress(worldserver->GetID(), worldserver->GetIP());
  736. }
  737. void LWorldList::AddInitiateWorld ( LWorld* world )
  738. {
  739. list.Insert ( world );
  740. }
  741. void LWorldList::KickGhostIP(int32 ip, LWorld* NotMe, int16 iClientPort) {
  742. if (ip == 0)
  743. return;
  744. map<int32,LWorld*>::iterator map_list;
  745. MWorldMap.readlock();
  746. for( map_list = worldmap.begin(); map_list != worldmap.end(); map_list++ ) {
  747. LWorld* world = map_list->second;
  748. if (!world->IsKicked() && world->GetIP() == ip && world != NotMe) {
  749. if ((iClientPort == 0 && world->GetType() == World) || (iClientPort != 0 && world->GetClientPort() == iClientPort)) {
  750. struct in_addr in;
  751. in.s_addr = world->GetIP();
  752. // cout << "Removing GhostIP LWorld(" << world->GetID() << ") from ip: " << inet_ntoa(in) << " port: " << (int16)(world->GetPort());
  753. if (!world->Connected())
  754. // cout << " (it wasnt connected)";
  755. // cout << endl;
  756. if (NotMe) {
  757. in.s_addr = NotMe->GetIP();
  758. cout << "NotMe(" << NotMe->GetID() << ") = " << inet_ntoa(in) << ":" << NotMe->GetPort() << " (" << NotMe->GetClientPort() << ")" << endl;
  759. }
  760. world->Kick("Ghost IP kick");
  761. }
  762. }
  763. }
  764. MWorldMap.releasereadlock();
  765. }
  766. void LWorldList::KickGhost(ConType in_type, int32 in_accountid, LWorld* ButNotMe) {
  767. map<int32,LWorld*>::iterator map_list;
  768. MWorldMap.readlock();
  769. for( map_list = worldmap.begin(); map_list != worldmap.end(); map_list++ ) {
  770. LWorld* world = map_list->second;
  771. if (!world->IsKicked() && world->GetType() == in_type && world != ButNotMe && (in_accountid == 0 || world->GetAccountID() == in_accountid)) {
  772. if (world->GetIP() != 0) {
  773. struct in_addr in;
  774. in.s_addr = world->GetIP();
  775. // cout << "Removing GhostAcc LWorld(" << world->GetID() << ") from ip: " << inet_ntoa(in) << " port: " << (int16)(world->GetPort()) << endl;
  776. }
  777. if (world->GetType() == Login && world->IsOutgoingUplink()) {
  778. world->Kick("Ghost Acc Kick", false);
  779. // cout << "softkick" << endl;
  780. }
  781. else
  782. world->Kick("Ghost Acc Kick");
  783. }
  784. }
  785. MWorldMap.releasereadlock();
  786. }
  787. void LWorldList::UpdateWorldStats(){
  788. map<int32,LWorld*>::iterator map_list;
  789. MWorldMap.readlock();
  790. for(map_list = worldmap.begin(); map_list != worldmap.end(); map_list++) {
  791. LWorld* world = map_list->second;
  792. if(world && world->GetAccountID() > 0)
  793. database.UpdateWorldServerStats(world, world->GetStatus());
  794. }
  795. MWorldMap.releasereadlock();
  796. }
  797. void LWorldList::Process() {
  798. TCPConnection* newtcp = 0;
  799. LWorld* newworld = 0;
  800. LinkedListIterator<LWorld*> iterator(list);
  801. iterator.Reset();
  802. while(iterator.MoreElements())
  803. {
  804. if(iterator.GetData( )->GetID ( ) > 0 )
  805. {
  806. LWorld* world = iterator.GetData ( );
  807. iterator.RemoveCurrent ( false );
  808. Add( world );
  809. }
  810. else
  811. {
  812. if(! iterator.GetData ( )->Process ( ) )
  813. iterator.RemoveCurrent ( );
  814. else
  815. iterator.Advance();
  816. }
  817. }
  818. while ((newtcp = tcplistener->NewQueuePop())) {
  819. newworld = new LWorld(newtcp);
  820. newworld->SetID(0);
  821. AddInitiateWorld(newworld);
  822. struct in_addr in;
  823. in.s_addr = newtcp->GetrIP();
  824. LogWrite(LOGIN__INFO, 0, "Login", "New Server connection: %s port %i", inet_ntoa(in), ntohs(newtcp->GetrPort()));
  825. net.numservers++;
  826. net.UpdateWindowTitle();
  827. }
  828. map<int32,LWorld*>::iterator map_list;
  829. for( map_list = worldmap.begin(); map_list != worldmap.end(); ) {
  830. LWorld* world = map_list->second;
  831. int32 account_id = world->GetAccountID();
  832. if (world->IsKicked() && !world->IsNeverKick()) {
  833. map_list++;
  834. worldmap.erase ( account_id );
  835. net.numservers--;
  836. net.UpdateWindowTitle();
  837. safe_delete ( world );
  838. continue;
  839. }
  840. else if (!world->Process()) {
  841. struct in_addr in;
  842. in.s_addr = world->GetIP();
  843. if (world->GetAccountID() == 0 || !(world->ShowDown()) || world->GetType() == Chat) {
  844. map_list++;
  845. worldmap.erase ( account_id );
  846. net.numservers--;
  847. net.UpdateWindowTitle();
  848. if(account_id > 0){
  849. LWorld* world2 = FindByID(account_id);
  850. if(world2)
  851. world2->ShowDownActive(true);
  852. }
  853. SendWorldChanged(account_id, true);
  854. safe_delete ( world );
  855. continue;
  856. }
  857. else {
  858. world->ChangeToPlaceholder();
  859. }
  860. }
  861. map_list++;
  862. }
  863. }
  864. // Sends packet to all World and Chat servers, local and remote (but not to remote login server's ::Process())
  865. void LWorldList::SendPacket(ServerPacket* pack, LWorld* butnotme) {
  866. map<int32,LWorld*>::iterator map_list;
  867. for( map_list = worldmap.begin(); map_list != worldmap.end(); map_list++) {
  868. LWorld* world = map_list->second;
  869. if (world != butnotme) {
  870. if (world->GetType() == Login) {
  871. ServerPacket* outpack = new ServerPacket(ServerOP_EncapPacket, sizeof(ServerEncapPacket_Struct) + pack->size);
  872. ServerEncapPacket_Struct* seps = (ServerEncapPacket_Struct*) outpack->pBuffer;
  873. seps->ToID = 0xFFFFFFFF;
  874. seps->opcode = pack->opcode;
  875. seps->size = pack->size;
  876. memcpy(seps->data, pack->pBuffer, pack->size);
  877. world->SendPacket(outpack);
  878. delete outpack;
  879. }
  880. else if (world->GetRemoteID() == 0) {
  881. world->SendPacket(pack);
  882. }
  883. }
  884. }
  885. }
  886. // Sends a packet to every local TCP Connection, all types
  887. void LWorldList::SendPacketLocal(ServerPacket* pack, LWorld* butnotme) {
  888. map<int32,LWorld*>::iterator map_list;
  889. for( map_list = worldmap.begin(); map_list != worldmap.end(); map_list++) {
  890. LWorld* world = map_list->second;
  891. if (world != butnotme && world->GetRemoteID() == 0) {
  892. world->SendPacket(pack);
  893. }
  894. }
  895. }
  896. // Sends the packet to all login servers
  897. void LWorldList::SendPacketLogin(ServerPacket* pack, LWorld* butnotme) {
  898. map<int32,LWorld*>::iterator map_list;
  899. for( map_list = worldmap.begin(); map_list != worldmap.end(); map_list++ ) {
  900. LWorld* world = map_list->second;
  901. if (world != butnotme && world->GetType() == Login) {
  902. world->SendPacket(pack);
  903. }
  904. }
  905. }
  906. void LWorldList::UpdateWorldList(LWorld* to) {
  907. map<int32,LWorld*>::iterator map_list;
  908. for( map_list = worldmap.begin(); map_list != worldmap.end(); map_list++) {
  909. LWorld* world = map_list->second;
  910. if (net.GetLoginMode() != Mesh || world->GetRemoteID() == 0)
  911. world->UpdateWorldList(to);
  912. }
  913. }
  914. LWorld* LWorldList::FindByID(int32 LWorldID) {
  915. if(worldmap.count(LWorldID) > 0)
  916. return worldmap[LWorldID];
  917. return 0;
  918. }
  919. LWorld* LWorldList::FindByIP(int32 ip) {
  920. map<int32,LWorld*>::iterator map_list;
  921. LWorld* world = 0;
  922. LWorld* ret = 0;
  923. MWorldMap.readlock();
  924. for( map_list = worldmap.begin(); map_list != worldmap.end(); map_list++) {
  925. world = map_list->second;
  926. if (world->GetIP() == ip){
  927. ret = world;
  928. break;
  929. }
  930. }
  931. MWorldMap.releasereadlock();
  932. return ret;
  933. }
  934. LWorld* LWorldList::FindByAddress(char* address) {
  935. map<int32,LWorld*>::iterator map_list;
  936. LWorld* world = 0;
  937. LWorld* ret = 0;
  938. MWorldMap.readlock();
  939. for( map_list = worldmap.begin(); map_list != worldmap.end(); map_list++) {
  940. world = map_list->second;
  941. if (strcasecmp(world->GetAddress(), address) == 0){
  942. ret = world;
  943. break;
  944. }
  945. }
  946. MWorldMap.releasereadlock();
  947. return ret;
  948. }
  949. LWorld* LWorldList::FindByLink(TCPConnection* in_link, int32 in_id) {
  950. if (in_link == 0)
  951. return 0;
  952. LWorld* world = 0;
  953. LWorld* ret = 0;
  954. map<int32,LWorld*>::iterator map_list;
  955. MWorldMap.readlock();
  956. for( map_list = worldmap.begin(); map_list != worldmap.end(); map_list++) {
  957. world = map_list->second;
  958. if (world->GetLink() == in_link && world->GetRemoteID() == in_id){
  959. ret = world;
  960. break;
  961. }
  962. }
  963. MWorldMap.releasereadlock();
  964. return ret;
  965. }
  966. LWorld* LWorldList::FindByAccount(int32 in_accountid, ConType in_type) {
  967. if (in_accountid == 0)
  968. return 0;
  969. LWorld* world = 0;
  970. LWorld* ret = 0;
  971. map<int32,LWorld*>::iterator map_list;
  972. MWorldMap.readlock();
  973. for( map_list = worldmap.begin(); map_list != worldmap.end(); map_list++) {
  974. world = map_list->second;
  975. if (world->GetAccountID() == in_accountid && world->GetType() == in_type){
  976. ret = world;
  977. break;
  978. }
  979. }
  980. MWorldMap.releasereadlock();
  981. return ret;
  982. }
  983. int8 LWorld::GetWorldStatus(){
  984. if(IsDevelServer() && IsLocked() == false)
  985. return 1;
  986. else if(IsInit && IsLocked() == false)
  987. return 0;
  988. else
  989. return 2;
  990. }
  991. void LWorld::SendDeleteCharacter ( int32 char_id , int32 account_id )
  992. {
  993. ServerPacket* outpack = new ServerPacket(ServerOP_BasicCharUpdate, sizeof(CharDataUpdate_Struct));
  994. CharDataUpdate_Struct* cdu = (CharDataUpdate_Struct*)outpack->pBuffer;
  995. cdu->account_id = account_id;
  996. cdu->char_id = char_id;
  997. cdu->update_field = DELETE_UPDATE_FLAG;
  998. cdu->update_data = 1;
  999. SendPacket(outpack);
  1000. }
  1001. vector<PacketStruct*>* LWorldList::GetServerListUpdate(int16 version){
  1002. vector<PacketStruct*>* ret = new vector<PacketStruct*>;
  1003. map<int32,LWorld*>::iterator map_list;
  1004. PacketStruct* packet = 0;
  1005. MWorldMap.readlock();
  1006. for( map_list = worldmap.begin(); map_list != worldmap.end(); map_list++) {
  1007. LWorld* world = map_list->second;
  1008. if ((world->IsInit || (world->ShowDown() && world->ShowDownActive())) && world->GetType() == World) {
  1009. packet = configReader.getStruct("LS_WorldUpdate", version);
  1010. if(packet){
  1011. packet->setDataByName("server_id", world->GetID());
  1012. packet->setDataByName("up", 1);
  1013. if(world->IsLocked())
  1014. packet->setDataByName("locked", 1);
  1015. ret->push_back(packet);
  1016. }
  1017. }
  1018. }
  1019. MWorldMap.releasereadlock();
  1020. return ret;
  1021. }
  1022. EQ2Packet* LWorldList::MakeServerListPacket(int8 lsadmin, int16 version) {
  1023. // if the latest world list has already been loaded, just return the string
  1024. MWorldMap.readlock();
  1025. if (!UpdateServerList && ServerListData.count(version))
  1026. {
  1027. MWorldMap.releasereadlock();
  1028. return ServerListData[version];
  1029. }
  1030. LWorld* world = 0;
  1031. uchar num_servers[2];
  1032. int32 ServerNum = 0;
  1033. /* while(iterator.MoreElements()){
  1034. world = iterator.GetData();
  1035. if ((world->IsInit || (world->ShowDown() && world->ShowDownActive())) && world->GetType() == World)
  1036. ServerNum++;
  1037. iterator.Advance();
  1038. }
  1039. ServerNum+=3;
  1040. */
  1041. uint32 tmpCount = 0;
  1042. map<int32, LWorld*>::iterator map_list;
  1043. for (map_list = worldmap.begin(); map_list != worldmap.end(); map_list++) {
  1044. LWorld* world = map_list->second;
  1045. if ((world->IsInit || (world->ShowDown() && world->ShowDownActive())) && world->GetType() == World) {
  1046. tmpCount++;
  1047. }
  1048. }
  1049. PacketStruct* packet = configReader.getStruct("LS_WorldList", version);
  1050. packet->setArrayLengthByName("num_worlds", tmpCount);
  1051. string world_data;
  1052. for( map_list = worldmap.begin(); map_list != worldmap.end(); map_list++) {
  1053. LWorld* world = map_list->second;
  1054. if ((world->IsInit || (world->ShowDown() && world->ShowDownActive())) && world->GetType() == World) {
  1055. ServerNum++;
  1056. packet->setArrayDataByName("id", world->GetID(), ServerNum-1);
  1057. if (version < 1212)
  1058. packet->setArrayDataByName("allowed_races", 0xFFFFFFFF, ServerNum - 1);
  1059. else if (version < 60006)
  1060. packet->setArrayDataByName("allowed_races", 0x000FFFFF, ServerNum - 1); // + Freeblood
  1061. else
  1062. packet->setArrayDataByName("allowed_races", 0x001FFFFF, ServerNum - 1); // + Aerakyn
  1063. packet->setArrayDataByName("number_online_flag", 1, ServerNum-1);
  1064. packet->setArrayDataByName("num_players", world->GetPlayerNum(), ServerNum-1);
  1065. packet->setArrayDataByName("name", world->GetName(), ServerNum-1);
  1066. packet->setArrayDataByName("name2", world->GetName(), ServerNum-1);
  1067. packet->setArrayDataByName("feature_set",0, ServerNum-1);
  1068. packet->setArrayDataByName("load", world->GetWorldStatus(), ServerNum-1);
  1069. if(world->IsLocked())
  1070. packet->setArrayDataByName("locked", 1, ServerNum - 1);
  1071. if(world->ShowDown())
  1072. packet->setArrayDataByName("tag", 0, ServerNum - 1);
  1073. else
  1074. packet->setArrayDataByName("tag", 1, ServerNum - 1);
  1075. if ( version < 1212 )
  1076. packet->setArrayDataByName("unknown", ServerNum, ServerNum - 1);
  1077. }
  1078. }
  1079. EQ2Packet* pack = packet->serialize();
  1080. printf("WorldList:\n");
  1081. DumpPacket(pack->pBuffer, pack->size);
  1082. if (ServerListData.count(version))
  1083. {
  1084. map<int32, EQ2Packet*>::iterator it = ServerListData.find(version);
  1085. EQ2Packet* tmpPack = ServerListData[version];
  1086. safe_delete(tmpPack);
  1087. ServerListData.erase(it);
  1088. }
  1089. ServerListData.insert(make_pair(version, pack));
  1090. MWorldMap.releasereadlock();
  1091. SetUpdateServerList( false );
  1092. return ServerListData[version];
  1093. }
  1094. void LWorldList::SendWorldStatus(LWorld* chat, char* adminname) {
  1095. struct in_addr in;
  1096. int32 count = 0;
  1097. map<int32,LWorld*>::iterator map_list;
  1098. for( map_list = worldmap.begin(); map_list != worldmap.end(); map_list++) {
  1099. LWorld* world = map_list->second;
  1100. if (world->GetIP() != 0 && world->GetType() == World) {
  1101. chat->Message(adminname, "Name: %s", world->GetName());
  1102. in.s_addr = world->GetIP();
  1103. if (world->GetAccountID() != 0) {
  1104. chat->Message(adminname, " Account: %s", world->GetAccount());
  1105. }
  1106. chat->Message(adminname, " Number of Zones: %i", world->GetZoneNum());
  1107. chat->Message(adminname, " Number of Players: %i", world->GetPlayerNum());
  1108. chat->Message(adminname, " IP: %s", inet_ntoa(in));
  1109. if (!world->IsAddressIP()) {
  1110. chat->Message(adminname, " Address: %s", world->GetAddress());
  1111. }
  1112. count++;
  1113. }
  1114. }
  1115. chat->Message(adminname, "%i worlds listed.", count);
  1116. }
  1117. void LWorldList::RemoveByLink(TCPConnection* in_link, int32 in_id, LWorld* ButNotMe) {
  1118. if (in_link == 0)
  1119. return;
  1120. map<int32,LWorld*>::iterator map_list;
  1121. for( map_list = worldmap.begin(); map_list != worldmap.end(); map_list++) {
  1122. LWorld* world = map_list->second;
  1123. if (world != ButNotMe && world->GetLink() == in_link && (in_id == 0 || world->GetRemoteID() == in_id)) {
  1124. // world->Link = 0;
  1125. map_list++;
  1126. worldmap.erase ( world->GetID ( ) );
  1127. safe_delete ( world );
  1128. continue;
  1129. }
  1130. }
  1131. }
  1132. void LWorldList::RemoveByID(int32 in_id) {
  1133. if (in_id == 0)
  1134. return;
  1135. LWorld* existWorld = FindByID(in_id);
  1136. if ( existWorld != NULL )
  1137. {
  1138. MWorldMap.writelock();
  1139. worldmap.erase ( in_id );
  1140. MWorldMap.releasewritelock();
  1141. safe_delete ( existWorld );
  1142. }
  1143. }
  1144. bool LWorldList::Init() {
  1145. database.ResetWorldStats ( );
  1146. if (!tcplistener->IsOpen()) {
  1147. return tcplistener->Open(net.GetPort());
  1148. }
  1149. return false;
  1150. }
  1151. void LWorldList::InitWorlds(){
  1152. vector<LWorld*> server_list;
  1153. database.GetServerAccounts(&server_list);
  1154. vector<LWorld*>::iterator iter;
  1155. int i = 0;
  1156. for(iter = server_list.begin(); iter != server_list.end(); iter++, i++){
  1157. LWorld* world = FindByID(server_list[i]->GetAccountID());
  1158. if(!world){
  1159. server_list[i]->ShowDown(true);
  1160. server_list[i]->ShowDownActive(true);
  1161. server_list[i]->SetID ( server_list[i]->GetAccountID ( ) );
  1162. Add ( server_list[i] );
  1163. }
  1164. }
  1165. }
  1166. void LWorldList::ListWorldsToConsole() {
  1167. struct in_addr in;
  1168. cout << "World List:" << endl;
  1169. cout << "============================" << endl;
  1170. map<int32,LWorld*>::iterator map_list;
  1171. for( map_list = worldmap.begin(); map_list != worldmap.end(); map_list++) {
  1172. LWorld* world = map_list->second;
  1173. in.s_addr = world->GetIP();
  1174. if (world->GetType() == World) {
  1175. if (world->GetRemoteID() == 0)
  1176. cout << "ID: " << world->GetID() << ", Name: " << world->GetName() << ", Local, IP: " << inet_ntoa(in) << ":" << world->GetPort() << ", Status: " << world->GetStatus() << ", AccID: " << world->GetAccountID() << endl;
  1177. else
  1178. 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;
  1179. }
  1180. else if (world->GetType() == Chat) {
  1181. cout << "ID: " << world->GetID() << ", Chat Server, IP: " << inet_ntoa(in) << ":" << world->GetPort() << ", AccID: " << world->GetAccountID() << endl;
  1182. }
  1183. else if (world->GetType() == Login) {
  1184. if (world->IsOutgoingUplink()) {
  1185. if (world->Connected())
  1186. cout << "ID: " << world->GetID() << ", Login Server (out), IP: " << inet_ntoa(in) << ":" << world->GetPort() << ", AccID: " << world->GetAccountID() << endl;
  1187. else
  1188. cout << "ID: " << world->GetID() << ", Login Server (nc), IP: " << inet_ntoa(in) << ":" << world->GetPort() << ", AccID: " << world->GetAccountID() << endl;
  1189. }
  1190. else
  1191. cout << "ID: " << world->GetID() << ", Login Server (in), IP: " << inet_ntoa(in) << ":" << world->GetPort() << " (" << world->GetClientPort() << "), AccID: " << world->GetAccountID() << endl;
  1192. }
  1193. else {
  1194. cout << "ID: " << world->GetID() << ", Unknown Type, Name: " << world->GetName() << ", IP: " << inet_ntoa(in) << ":" << world->GetPort() << ", AccID: " << world->GetAccountID() << endl;
  1195. }
  1196. }
  1197. cout << "============================" << endl;
  1198. }
  1199. void LWorldList::AddServerZoneUpdates(LWorld* world, map<int32, LoginZoneUpdate> updates){
  1200. int32 server_id = world->GetID();
  1201. map<int32, LoginZoneUpdate>::iterator itr;
  1202. for(itr = updates.begin(); itr != updates.end(); itr++){
  1203. if(zone_updates_already_used.size() >= 1500 || zone_updates_already_used[server_id].count(itr->first) > 0){
  1204. world->Kick("Hacking attempt.");
  1205. return;
  1206. }
  1207. zone_updates_already_used[server_id][itr->first] = true;
  1208. }
  1209. server_zone_updates.Put(server_id, updates);
  1210. }
  1211. void LWorldList::RequestServerUpdates(LWorld* world){
  1212. if(world){
  1213. ServerPacket* pack = new ServerPacket(ServerOP_ZoneUpdates, sizeof(ZoneUpdateRequest_Struct));
  1214. ZoneUpdateRequest_Struct* request = (ZoneUpdateRequest_Struct*)pack->pBuffer;
  1215. request->max_per_batch = MAX_UPDATE_COUNT;
  1216. world->SendPacket(pack);
  1217. delete pack;
  1218. zone_update_timeouts.Put(world->GetID(), Timer::GetCurrentTime2() + 30000);
  1219. }
  1220. }
  1221. void LWorldList::ProcessServerUpdates(){
  1222. MutexMap<int32, map<int32, LoginZoneUpdate> >::iterator itr = server_zone_updates.begin();
  1223. while(itr.Next()){
  1224. if(itr->second.size() > 0){
  1225. database.SetServerZoneDescriptions(itr->first, itr->second);
  1226. if(itr->second.size() == MAX_UPDATE_COUNT)
  1227. awaiting_zone_update.Put(itr->first, Timer::GetCurrentTime2() + 10000); //only process 20 updates in a 10 second period to avoid network problems
  1228. server_zone_updates.erase(itr->first);
  1229. }
  1230. if(zone_update_timeouts.count(itr->first) == 0 || zone_update_timeouts.Get(itr->first) <= Timer::GetCurrentTime2()){
  1231. zone_update_timeouts.erase(itr->first);
  1232. server_zone_updates.erase(itr->first);
  1233. }
  1234. }
  1235. LWorld* world = 0;
  1236. MWorldMap.readlock();
  1237. map<int32, LWorld*>::iterator map_itr;
  1238. for(map_itr = worldmap.begin(); map_itr != worldmap.end(); map_itr++){
  1239. world = map_itr->second;
  1240. if(world && world->GetID()){
  1241. if(last_updated.count(world) == 0 || last_updated.Get(world) <= Timer::GetCurrentTime2()){
  1242. zone_updates_already_used[world->GetID()].clear();
  1243. RequestServerUpdates(world);
  1244. last_updated.Put(world, Timer::GetCurrentTime2() + 21600000);
  1245. }
  1246. if(awaiting_zone_update.count(world->GetID()) > 0 && awaiting_zone_update.Get(world->GetID()) <= Timer::GetCurrentTime2()){
  1247. awaiting_zone_update.erase(world->GetID());
  1248. RequestServerUpdates(world);
  1249. }
  1250. }
  1251. }
  1252. MWorldMap.releasereadlock();
  1253. }
  1254. ThreadReturnType ServerUpdateLoop(void* tmp) {
  1255. #ifdef WIN32
  1256. SetThreadPriority(GetCurrentThread(), THREAD_PRIORITY_ABOVE_NORMAL);
  1257. #endif
  1258. if (tmp == 0) {
  1259. ThrowError("ServerUpdateLoop(): tmp = 0!");
  1260. THREAD_RETURN(NULL);
  1261. }
  1262. LWorldList* worldList = (LWorldList*) tmp;
  1263. while (worldList->ContinueServerUpdates()) {
  1264. Sleep(1000);
  1265. worldList->ProcessServerUpdates();
  1266. }
  1267. worldList->ResetServerUpdates();
  1268. THREAD_RETURN(NULL);
  1269. }