1. // vim:ts=8 sw=4
2. #ifndef __INC_CLIENTMANAGER_H__
3. #define __INC_CLIENTMANAGER_H__
5. #include <boost/unordered_map.hpp>
6. #include <boost/unordered_set.hpp>
8. #include "../../common/stl.h"
9. #include "../../common/building.h"
11. #include "Peer.h"
12. #include "DBManager.h"
13. #include "LoginData.h"
15. class CPlayerTableCache;
16. class CItemCache;
17. class CItemPriceListTableCache;
19. class CPacketInfo
20. {
21. public:
22. void Add(int header);
23. void Reset();
25. std::map<int, int> m_map_info;
26. };
28. size_t CreatePlayerSaveQuery(char * pszQuery, size_t querySize, TPlayerTable * pkTab);
30. class CClientManager : public CNetBase, public singleton<CClientManager>
31. {
32. public:
33. typedef std::list<CPeer *> TPeerList;
34. typedef boost::unordered_map<DWORD, CPlayerTableCache *> TPlayerTableCacheMap;
35. typedef boost::unordered_map<DWORD, CItemCache *> TItemCacheMap;
36. typedef boost::unordered_set<CItemCache *, boost::hash<CItemCache*> > TItemCacheSet;
37. typedef boost::unordered_map<DWORD, TItemCacheSet *> TItemCacheSetPtrMap;
38. typedef boost::unordered_map<DWORD, CItemPriceListTableCache*> TItemPriceListCacheMap;
39. typedef boost::unordered_map<short, BYTE> TChannelStatusMap;
41. // MYSHOP_PRICE_LIST
42. /// ¾ÆÀÌÅÛ °¡°İÁ¤º¸ ¸®½ºÆ® ¿äû Á¤º¸
43. /**
44. * first: Peer handle
45. * second: ¿äûÇÑ Ç÷¹À̾îÀÇ ID
46. */
47. typedef std::pair< DWORD, DWORD > TItemPricelistReqInfo;
48. // END_OF_MYSHOP_PRICE_LIST
50. class ClientHandleInfo
51. {
52. public:
53. DWORD dwHandle;
54. DWORD account_id;
55. DWORD player_id;
56. BYTE account_index;
57. char login[LOGIN_MAX_LEN + 1];
58. char safebox_password[SAFEBOX_PASSWORD_MAX_LEN + 1];
59. char ip[MAX_HOST_LENGTH + 1];
61. TAccountTable * pAccountTable;
62. TSafeboxTable * pSafebox;
64. ClientHandleInfo(DWORD argHandle, DWORD dwPID = 0)
65. {
66. dwHandle = argHandle;
67. pSafebox = NULL;
68. pAccountTable = NULL;
69. player_id = dwPID;
70. };
71. //µ¶Àϼ±¹°±â´É¿ë »ı¼ºÀÚ
72. ClientHandleInfo(DWORD argHandle, DWORD dwPID, DWORD accountId)
73. {
74. dwHandle = argHandle;
75. pSafebox = NULL;
76. pAccountTable = NULL;
77. player_id = dwPID;
78. account_id = accountId;
79. };
81. ~ClientHandleInfo()
82. {
83. if (pSafebox)
84. {
85. delete pSafebox;
86. pSafebox = NULL;
87. }
88. }
89. };
91. public:
92. CClientManager();
93. ~CClientManager();
95. bool Initialize();
96. time_t GetCurrentTime();
98. #ifdef OFFLINE_SHOP
99. void ShopName(CPeer * peer, TPacketShopName * p);
100. void ShopClose(CPeer * peer, TPacketShopClose *p);
101. void ShopUpdateItem(CPeer * peer, TPacketShopUpdateItem *p);
102. #endif
104. void MainLoop();
105. void Quit();
107. void SetTablePostfix(const char* c_pszTablePostfix);
108. void SetPlayerIDStart(int iIDStart);
109. int GetPlayerIDStart() { return m_iPlayerIDStart; }
111. int GetPlayerDeleteLevelLimit() { return m_iPlayerDeleteLevelLimit; }
113. void SetChinaEventServer(bool flag) { m_bChinaEventServer = flag; }
114. bool IsChinaEventServer() { return m_bChinaEventServer; }
116. DWORD GetUserCount(); // Á¢¼ÓµÈ »ç¿ëÀÚ ¼ö¸¦ ¸®ÅÏ ÇÑ´Ù.
118. void SendAllGuildSkillRechargePacket();
119. void SendTime();
121. CPlayerTableCache * GetPlayerCache(DWORD id);
122. void PutPlayerCache(TPlayerTable * pNew);
124. void CreateItemCacheSet(DWORD dwID);
125. TItemCacheSet * GetItemCacheSet(DWORD dwID);
126. void FlushItemCacheSet(DWORD dwID);
128. CItemCache * GetItemCache(DWORD id);
129. void PutItemCache(TPlayerItem * pNew, bool bSkipQuery = false);
130. bool DeleteItemCache(DWORD id);
132. void UpdatePlayerCache();
133. void UpdateItemCache();
135. // MYSHOP_PRICE_LIST
136. /// °¡°İÁ¤º¸ ¸®½ºÆ® ij½Ã¸¦ °¡Á®¿Â´Ù.
137. /**
138. * @param [in] dwID °¡°İÁ¤º¸ ¸®½ºÆ®ÀÇ ¼ÒÀ¯ÀÚ.(Ç÷¹À̾î ID)
139. * @return °¡°İÁ¤º¸ ¸®½ºÆ® ij½ÃÀÇ Æ÷ÀÎÅÍ
140. */
141. CItemPriceListTableCache* GetItemPriceListCache(DWORD dwID);
143. /// °¡°İÁ¤º¸ ¸®½ºÆ® ij½Ã¸¦ ³Ö´Â´Ù.
144. /**
145. * @param [in] pItemPriceList ij½Ã¿¡ ³ÖÀ» ¾ÆÀÌÅÛ °¡°İÁ¤º¸ ¸®½ºÆ®
146. *
147. * ij½Ã°¡ ÀÌ¹Ì ÀÖÀ¸¸é Update °¡ ¾Æ´Ñ replace ÇÑ´Ù.
148. */
149. void PutItemPriceListCache(const TItemPriceListTable* pItemPriceList);
152. /// Flush ½Ã°£ÀÌ ¸¸·áµÈ ¾ÆÀÌÅÛ °¡°İÁ¤º¸ ¸®½ºÆ® ij½Ã¸¦ Flush ÇØÁÖ°í ij½Ã¿¡¼­ »èÁ¦ÇÑ´Ù.
153. void UpdateItemPriceListCache(void);
154. // END_OF_MYSHOP_PRICE_LIST
157. void SendGuildSkillUsable(DWORD guild_id, DWORD dwSkillVnum, bool bUsable);
159. void SetCacheFlushCountLimit(int iLimit);
161. template <class Func>
162. Func for_each_peer(Func f);
164. CPeer * GetAnyPeer();
166. void ForwardPacket(BYTE header, const void* data, int size, BYTE bChannel = 0, CPeer * except = NULL);
168. void SendNotice(const char * c_pszFormat, ...);
170. char* GetCommand(char* str); //µ¶Àϼ±¹°±â´É¿¡¼­ ¸í·É¾î ¾ò´Â ÇÔ¼ö
171. void ItemAward(CPeer * peer, char* login); //µ¶ÀÏ ¼±¹° ±â´É
173. protected:
174. void Destroy();
176. private:
177. bool InitializeTables();
178. bool InitializeShopTable();
179. bool InitializeMobTable();
180. bool InitializeItemTable();
181. bool InitializeQuestItemTable();
182. bool InitializeSkillTable();
183. bool InitializeRefineTable();
184. bool InitializeBanwordTable();
185. bool InitializeItemAttrTable();
186. bool InitializeItemRareTable();
187. bool InitializeLandTable();
188. bool InitializeObjectProto();
189. bool InitializeObjectTable();
191. bool MirrorMobTableIntoDB();
192. bool MirrorItemTableIntoDB();
194. void AddPeer(socket_t fd);
195. void RemovePeer(CPeer * pPeer);
196. CPeer * GetPeer(IDENT ident);
198. int AnalyzeQueryResult(SQLMsg * msg);
199. int AnalyzeErrorMsg(CPeer * peer, SQLMsg * msg);
201. int Process();
203. void ProcessPackets(CPeer * peer);
205. CLoginData * GetLoginData(DWORD dwKey);
206. CLoginData * GetLoginDataByLogin(const char * c_pszLogin);
207. CLoginData * GetLoginDataByAID(DWORD dwAID);
209. void InsertLoginData(CLoginData * pkLD);
210. void DeleteLoginData(CLoginData * pkLD);
212. bool InsertLogonAccount(const char * c_pszLogin, DWORD dwHandle, const char * c_pszIP);
213. bool DeleteLogonAccount(const char * c_pszLogin, DWORD dwHandle);
214. bool FindLogonAccount(const char * c_pszLogin);
216. void GuildCreate(CPeer * peer, DWORD dwGuildID);
217. void GuildSkillUpdate(CPeer * peer, TPacketGuildSkillUpdate* p);
218. void GuildExpUpdate(CPeer * peer, TPacketGuildExpUpdate* p);
219. void GuildAddMember(CPeer * peer, TPacketGDGuildAddMember* p);
220. void GuildChangeGrade(CPeer * peer, TPacketGuild* p);
221. void GuildRemoveMember(CPeer * peer, TPacketGuild* p);
222. void GuildChangeMemberData(CPeer * peer, TPacketGuildChangeMemberData* p);
223. void GuildDisband(CPeer * peer, TPacketGuild * p);
224. void GuildWar(CPeer * peer, TPacketGuildWar * p);
225. void GuildWarScore(CPeer * peer, TPacketGuildWarScore * p);
226. void GuildChangeLadderPoint(TPacketGuildLadderPoint* p);
227. void GuildUseSkill(TPacketGuildUseSkill* p);
228. void GuildDepositMoney(TPacketGDGuildMoney* p);
229. void GuildWithdrawMoney(CPeer* peer, TPacketGDGuildMoney* p);
230. void GuildWithdrawMoneyGiveReply(TPacketGDGuildMoneyWithdrawGiveReply* p);
231. void GuildWarBet(TPacketGDGuildWarBet * p);
232. void GuildChangeMaster(TPacketChangeGuildMaster* p);
234. void SetGuildWarEndTime(DWORD guild_id1, DWORD guild_id2, time_t tEndTime);
236. void QUERY_BOOT(CPeer * peer, TPacketGDBoot * p);
238. void QUERY_LOGIN(CPeer * peer, DWORD dwHandle, SLoginPacket* data);
239. void QUERY_LOGOUT(CPeer * peer, DWORD dwHandle, const char *);
241. void RESULT_LOGIN(CPeer * peer, SQLMsg *msg);
243. void QUERY_PLAYER_LOAD(CPeer * peer, DWORD dwHandle, TPlayerLoadPacket*);
244. void RESULT_COMPOSITE_PLAYER(CPeer * peer, SQLMsg * pMsg, DWORD dwQID);
245. void RESULT_PLAYER_LOAD(CPeer * peer, MYSQL_RES * pRes, ClientHandleInfo * pkInfo);
246. void RESULT_ITEM_LOAD(CPeer * peer, MYSQL_RES * pRes, DWORD dwHandle, DWORD dwPID);
247. void RESULT_QUEST_LOAD(CPeer * pkPeer, MYSQL_RES * pRes, DWORD dwHandle, DWORD dwPID);
248. void RESULT_AFFECT_LOAD(CPeer * pkPeer, MYSQL_RES * pRes, DWORD dwHandle);
250. // PLAYER_INDEX_CREATE_BUG_FIX
251. void RESULT_PLAYER_INDEX_CREATE(CPeer *pkPeer, SQLMsg *msg);
252. // END_PLAYER_INDEX_CREATE_BUG_FIX
254. // MYSHOP_PRICE_LIST
255. /// °¡°İÁ¤º¸ ·Îµå Äõ¸®¿¡ ´ëÇÑ Result ó¸®
256. /**
257. * @param peer °¡°İÁ¤º¸¸¦ ¿äûÇÑ Game server ÀÇ peer °´Ã¼ Æ÷ÀÎÅÍ
258. * @param pMsg Äõ¸®ÀÇ Result ·Î ¹ŞÀº °´Ã¼ÀÇ Æ÷ÀÎÅÍ
259. *
260. * ·ÎµåµÈ °¡°İÁ¤º¸ ¸®½ºÆ®¸¦ ij½Ã¿¡ ÀúÀåÇÏ°í peer ¿¡°Ô ¸®½ºÆ®¸¦ º¸³»ÁØ´Ù.
261. */
262. void RESULT_PRICELIST_LOAD(CPeer* peer, SQLMsg* pMsg);
264. /// °¡°İÁ¤º¸ ¾÷µ¥ÀÌÆ®¸¦ À§ÇÑ ·Îµå Äõ¸®¿¡ ´ëÇÑ Result ó¸®
265. /**
266. * @param pMsg Äõ¸®ÀÇ Result ·Î ¹ŞÀº °´Ã¼ÀÇ Æ÷ÀÎÅÍ
267. *
268. * ·ÎµåµÈ Á¤º¸·Î °¡°İÁ¤º¸ ¸®½ºÆ® ij½Ã¸¦ ¸¸µé°í ¾÷µ¥ÀÌÆ® ¹ŞÀº °¡°İÁ¤º¸·Î ¾÷µ¥ÀÌÆ® ÇÑ´Ù.
269. */
270. void RESULT_PRICELIST_LOAD_FOR_UPDATE(SQLMsg* pMsg);
271. // END_OF_MYSHOP_PRICE_LIST
273. void QUERY_PLAYER_SAVE(CPeer * peer, DWORD dwHandle, TPlayerTable*);
275. void __QUERY_PLAYER_CREATE(CPeer * peer, DWORD dwHandle, TPlayerCreatePacket *);
276. void __QUERY_PLAYER_DELETE(CPeer * peer, DWORD dwHandle, TPlayerDeletePacket *);
277. void __RESULT_PLAYER_DELETE(CPeer * peer, SQLMsg* msg);
279. void QUERY_PLAYER_COUNT(CPeer * pkPeer, TPlayerCountPacket *);
281. void QUERY_ITEM_SAVE(CPeer * pkPeer, const char * c_pData);
282. void QUERY_ITEM_DESTROY(CPeer * pkPeer, const char * c_pData);
283. void QUERY_ITEM_FLUSH(CPeer * pkPeer, const char * c_pData);
286. void QUERY_QUEST_SAVE(CPeer * pkPeer, TQuestTable *, DWORD dwLen);
287. void QUERY_ADD_AFFECT(CPeer * pkPeer, TPacketGDAddAffect * p);
288. void QUERY_REMOVE_AFFECT(CPeer * pkPeer, TPacketGDRemoveAffect * p);
290. void QUERY_SAFEBOX_LOAD(CPeer * pkPeer, DWORD dwHandle, TSafeboxLoadPacket *, bool bMall);
291. void QUERY_SAFEBOX_SAVE(CPeer * pkPeer, TSafeboxTable * pTable);
292. void QUERY_SAFEBOX_CHANGE_SIZE(CPeer * pkPeer, DWORD dwHandle, TSafeboxChangeSizePacket * p);
293. void QUERY_SAFEBOX_CHANGE_PASSWORD(CPeer * pkPeer, DWORD dwHandle, TSafeboxChangePasswordPacket * p);
295. void RESULT_SAFEBOX_LOAD(CPeer * pkPeer, SQLMsg * msg);
296. void RESULT_SAFEBOX_CHANGE_SIZE(CPeer * pkPeer, SQLMsg * msg);
297. void RESULT_SAFEBOX_CHANGE_PASSWORD(CPeer * pkPeer, SQLMsg * msg);
298. void RESULT_SAFEBOX_CHANGE_PASSWORD_SECOND(CPeer * pkPeer, SQLMsg * msg);
300. void QUERY_EMPIRE_SELECT(CPeer * pkPeer, DWORD dwHandle, TEmpireSelectPacket * p);
301. void QUERY_SETUP(CPeer * pkPeer, DWORD dwHandle, const char * c_pData);
303. void SendPartyOnSetup(CPeer * peer);
305. void QUERY_HIGHSCORE_REGISTER(CPeer * peer, TPacketGDHighscore* data);
306. void RESULT_HIGHSCORE_REGISTER(CPeer * pkPeer, SQLMsg * msg);
308. void QUERY_FLUSH_CACHE(CPeer * pkPeer, const char * c_pData);
310. void QUERY_PARTY_CREATE(CPeer * peer, TPacketPartyCreate* p);
311. void QUERY_PARTY_DELETE(CPeer * peer, TPacketPartyDelete* p);
312. void QUERY_PARTY_ADD(CPeer * peer, TPacketPartyAdd* p);
313. void QUERY_PARTY_REMOVE(CPeer * peer, TPacketPartyRemove* p);
314. void QUERY_PARTY_STATE_CHANGE(CPeer * peer, TPacketPartyStateChange* p);
315. void QUERY_PARTY_SET_MEMBER_LEVEL(CPeer * peer, TPacketPartySetMemberLevel* p);
317. void QUERY_RELOAD_PROTO();
319. void QUERY_CHANGE_NAME(CPeer * peer, DWORD dwHandle, TPacketGDChangeName * p);
320. void GetPlayerFromRes(TPlayerTable * player_table, MYSQL_RES* res);
322. void QUERY_SMS(CPeer * pkPeer, TPacketGDSMS * p);
323. void QUERY_LOGIN_KEY(CPeer * pkPeer, TPacketGDLoginKey * p);
325. void AddGuildPriv(TPacketGiveGuildPriv* p);
326. void AddEmpirePriv(TPacketGiveEmpirePriv* p);
327. void AddCharacterPriv(TPacketGiveCharacterPriv* p);
329. void MoneyLog(TPacketMoneyLog* p);
331. void QUERY_AUTH_LOGIN(CPeer * pkPeer, DWORD dwHandle, TPacketGDAuthLogin * p);
333. void QUERY_LOGIN_BY_KEY(CPeer * pkPeer, DWORD dwHandle, TPacketGDLoginByKey * p);
334. void RESULT_LOGIN_BY_KEY(CPeer * peer, SQLMsg * msg);
336. void ChargeCash(const TRequestChargeCash * p);
338. void LoadEventFlag();
339. void SetEventFlag(TPacketSetEventFlag* p);
340. void SendEventFlagsOnSetup(CPeer* peer);
342. // °áÈ¥
343. void MarriageAdd(TPacketMarriageAdd * p);
344. void MarriageUpdate(TPacketMarriageUpdate * p);
345. void MarriageRemove(TPacketMarriageRemove * p);
347. void WeddingRequest(TPacketWeddingRequest * p);
348. void WeddingReady(TPacketWeddingReady * p);
349. void WeddingEnd(TPacketWeddingEnd * p);
351. // MYSHOP_PRICE_LIST
352. // °³ÀλóÁ¡ °¡°İÁ¤º¸
354. /// ¾ÆÀÌÅÛ °¡°İÁ¤º¸ ¸®½ºÆ® ¾÷µ¥ÀÌÆ® ÆĞŶ(HEADER_GD_MYSHOP_PRICELIST_UPDATE) ó¸®ÇÔ¼ö
355. /**
356. * @param [in] pPacket ÆĞŶ µ¥ÀÌÅÍÀÇ Æ÷ÀÎÅÍ
357. */
358. void MyshopPricelistUpdate(const TPacketMyshopPricelistHeader* pPacket);
360. /// ¾ÆÀÌÅÛ °¡°İÁ¤º¸ ¸®½ºÆ® ¿äû ÆĞŶ(HEADER_GD_MYSHOP_PRICELIST_REQ) ó¸®ÇÔ¼ö
361. /**
362. * @param peer ÆĞŶÀ» º¸³½ Game server ÀÇ peer °´Ã¼ÀÇ Æ÷ÀÎÅÍ
363. * @param [in] dwHandle °¡°İÁ¤º¸¸¦ ¿äûÇÑ peer ÀÇ ÇÚµé
364. * @param [in] dwPlayerID °¡°İÁ¤º¸ ¸®½ºÆ®¸¦ ¿äûÇÑ Ç÷¹À̾îÀÇ ID
365. */
366. void MyshopPricelistRequest(CPeer* peer, DWORD dwHandle, DWORD dwPlayerID);
367. // END_OF_MYSHOP_PRICE_LIST
369. // Building
370. void CreateObject(TPacketGDCreateObject * p);
371. void DeleteObject(DWORD dwID);
372. void UpdateLand(DWORD * pdw);
374. // BLOCK_CHAT
375. void BlockChat(TPacketBlockChat * p);
376. // END_OF_BLOCK_CHAT
378. private:
379. int m_looping;
380. socket_t m_fdAccept; // Á¢¼Ó ¹Ş´Â ¼ÒÄÏ
381. TPeerList m_peerList;
383. CPeer * m_pkAuthPeer;
385. // LoginKey, LoginData pair
386. typedef boost::unordered_map<DWORD, CLoginData *> TLoginDataByLoginKey;
387. TLoginDataByLoginKey m_map_pkLoginData;
389. // Login LoginData pair
390. typedef boost::unordered_map<std::string, CLoginData *> TLoginDataByLogin;
391. TLoginDataByLogin m_map_pkLoginDataByLogin;
393. // AccountID LoginData pair
394. typedef boost::unordered_map<DWORD, CLoginData *> TLoginDataByAID;
395. TLoginDataByAID m_map_pkLoginDataByAID;
397. // Login LoginData pair (½ÇÁ¦ ·Î±×ÀÎ µÇ¾îÀÖ´Â °èÁ¤)
398. typedef boost::unordered_map<std::string, CLoginData *> TLogonAccountMap;
399. TLogonAccountMap m_map_kLogonAccount;
401. int m_iPlayerIDStart;
402. int m_iPlayerDeleteLevelLimit;
403. int m_iPlayerDeleteLevelLimitLower;
404. bool m_bChinaEventServer;
406. std::vector<TMobTable> m_vec_mobTable;
407. std::vector<TItemTable> m_vec_itemTable;
408. std::map<DWORD, TItemTable *> m_map_itemTableByVnum;
410. int m_iShopTableSize;
411. TShopTable * m_pShopTable;
413. int m_iRefineTableSize;
414. TRefineTable* m_pRefineTable;
416. std::vector<TSkillTable> m_vec_skillTable;
417. std::vector<TBanwordTable> m_vec_banwordTable;
418. std::vector<TItemAttrTable> m_vec_itemAttrTable;
419. std::vector<TItemAttrTable> m_vec_itemRareTable;
421. std::vector<building::TLand> m_vec_kLandTable;
422. std::vector<building::TObjectProto> m_vec_kObjectProto;
423. std::map<DWORD, building::TObject *> m_map_pkObjectTable;
426. bool m_bShutdowned;
428. TPlayerTableCacheMap m_map_playerCache; // Ç÷¹À̾î id°¡ key
430. TItemCacheMap m_map_itemCache; // ¾ÆÀÌÅÛ id°¡ key
431. TItemCacheSetPtrMap m_map_pkItemCacheSetPtr; // Ç÷¹À̾î id°¡ key, ÀÌ Ç÷¹À̾ ¾î¶² ¾ÆÀÌÅÛ Ä³½¬¸¦ °¡Áö°í ÀÖ³ª?
433. // MYSHOP_PRICE_LIST
434. /// Ç÷¹À̾ ¾ÆÀÌÅÛ °¡°İÁ¤º¸ ¸®½ºÆ® map. key: Ç÷¹À̾î ID, value: °¡°İÁ¤º¸ ¸®½ºÆ® ij½Ã
435. TItemPriceListCacheMap m_mapItemPriceListCache; ///< Ç÷¹À̾ ¾ÆÀÌÅÛ °¡°İÁ¤º¸ ¸®½ºÆ®
436. // END_OF_MYSHOP_PRICE_LIST
438. TChannelStatusMap m_mChannelStatus;
440. struct TPartyInfo
441. {
442. BYTE bRole;
443. BYTE bLevel;
445. TPartyInfo() :bRole(0), bLevel(0)
446. {
447. }
448. };
450. typedef std::map<DWORD, TPartyInfo> TPartyMember;
451. typedef std::map<DWORD, TPartyMember> TPartyMap;
452. typedef std::map<BYTE, TPartyMap> TPartyChannelMap;
453. TPartyChannelMap m_map_pkChannelParty;
455. typedef std::map<std::string, long> TEventFlagMap;
456. TEventFlagMap m_map_lEventFlag;
458. BYTE m_bLastHeader;
459. int m_iCacheFlushCount;
460. int m_iCacheFlushCountLimit;
462. private :
463. TItemIDRangeTable m_itemRange;
465. public :
466. bool InitializeNowItemID();
467. DWORD GetItemID();
468. DWORD GainItemID();
469. TItemIDRangeTable GetItemRange() { return m_itemRange; }
471. //BOOT_LOCALIZATION
472. public:
473. /* ·ÎÄà Á¤º¸ ÃʱâÈ­
474. **/
475. bool InitializeLocalization();
477. private:
478. std::vector<tLocale> m_vec_Locale;
479. //END_BOOT_LOCALIZATION
480. //ADMIN_MANAGER
482. bool __GetAdminInfo(const char *szIP, std::vector<tAdminInfo> & rAdminVec);
483. bool __GetHostInfo(std::vector<std::string> & rIPVec);
484. //END_ADMIN_MANAGER
487. //RELOAD_ADMIN
488. void ReloadAdmin(CPeer * peer, TPacketReloadAdmin * p);
489. //END_RELOAD_ADMIN
490. void BreakMarriage(CPeer * peer, const char * data);
492. struct TLogoutPlayer
493. {
494. DWORD pid;
495. time_t time;
497. bool operator < (const TLogoutPlayer & r)
498. {
499. return (pid < r.pid);
500. }
501. };
503. typedef boost::unordered_map<DWORD, TLogoutPlayer*> TLogoutPlayerMap;
504. TLogoutPlayerMap m_map_logout;
505. void InsertLogoutPlayer(DWORD pid);
506. void DeleteLogoutPlayer(DWORD pid);
507. void UpdateLogoutPlayer();
508. void UpdateItemCacheSet(DWORD pid);
509. void FlushPlayerCacheSet(DWORD pid);
510. void SendSpareItemIDRange(CPeer* peer);
511. void UpdateHorseName(TPacketUpdateHorseName* data, CPeer* peer);
512. void AckHorseName(DWORD dwPID, CPeer* peer);
513. void DeleteLoginKey(TPacketDC *data);
514. void ResetLastPlayerID(const TPacketNeedLoginLogInfo* data);
515. void DeleteAwardId(TPacketDeleteAwardID* data);
516. void UpdateChannelStatus(TChannelStatus* pData);
517. void RequestChannelStatus(CPeer* peer, DWORD dwHandle);
519. };
521. template<class Func>
522. Func CClientManager::for_each_peer(Func f)
523. {
524. TPeerList::iterator it;
525. for (it = m_peerList.begin(); it!=m_peerList.end();++it)
526. {
527. f(*it);
528. }
529. return f;
530. }
531. #endif