Connection.h 23 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943
  1. #pragma once
  2. #include <typeinfo> //XXX this is in namespace std if you want w/o use typeinfo.h?
  3. #include <boost/type_traits/is_fundamental.hpp>
  4. #include <boost/type_traits/is_enum.hpp>
  5. #include <boost/type_traits/is_pointer.hpp>
  6. #include <boost/type_traits/is_class.hpp>
  7. #include <boost/type_traits/is_base_of.hpp>
  8. #include <boost/type_traits/is_array.hpp>
  9. #include <boost/type_traits/remove_pointer.hpp>
  10. #include <boost/type_traits/remove_const.hpp>
  11. #include <boost/mpl/eval_if.hpp>
  12. #include <boost/mpl/equal_to.hpp>
  13. #include <boost/mpl/int.hpp>
  14. #include <boost/mpl/identity.hpp>
  15. #include <boost/any.hpp>
  16. #include "ConstTransitivePtr.h"
  17. const ui32 version = 730;
  18. class CConnection;
  19. class CGObjectInstance;
  20. class CGameState;
  21. class CCreature;
  22. class LibClasses;
  23. class CHero;
  24. struct CPack;
  25. extern DLL_LINKAGE LibClasses * VLC;
  26. namespace mpl = boost::mpl;
  27. /*
  28. * Connection.h, part of VCMI engine
  29. *
  30. * Authors: listed in file AUTHORS in main folder
  31. *
  32. * License: GNU General Public License v2.0 or later
  33. * Full text of license available in license.txt file, in main folder
  34. *
  35. */
  36. namespace boost
  37. {
  38. namespace asio
  39. {
  40. namespace ip
  41. {
  42. class tcp;
  43. }
  44. class io_service;
  45. template <typename Protocol> class stream_socket_service;
  46. template <typename Protocol,typename StreamSocketService>
  47. class basic_stream_socket;
  48. template <typename Protocol> class socket_acceptor_service;
  49. template <typename Protocol,typename SocketAcceptorService>
  50. class basic_socket_acceptor;
  51. }
  52. class mutex;
  53. };
  54. enum SerializationLvl
  55. {
  56. Wrong=0,
  57. Primitive,
  58. Array,
  59. Pointer,
  60. Serializable
  61. };
  62. struct TypeComparer
  63. {
  64. bool operator()(const std::type_info *a, const std::type_info *b) const
  65. {
  66. return a->before(*b);
  67. }
  68. };
  69. class DLL_LINKAGE CTypeList
  70. {
  71. typedef std::multimap<const std::type_info *,ui16,TypeComparer> TTypeMap;
  72. TTypeMap types;
  73. public:
  74. CTypeList();
  75. ui16 registerType(const std::type_info *type);
  76. template <typename T> ui16 registerType(const T * t = NULL)
  77. {
  78. return registerType(getTypeInfo(t));
  79. }
  80. ui16 getTypeID(const std::type_info *type);
  81. template <typename T> ui16 getTypeID(const T * t = NULL)
  82. {
  83. return getTypeID(getTypeInfo(t));
  84. }
  85. template <typename T> const std::type_info * getTypeInfo(const T * t = NULL)
  86. {
  87. if(t)
  88. return &typeid(*t);
  89. else
  90. return &typeid(T);
  91. }
  92. };
  93. extern DLL_LINKAGE CTypeList typeList;
  94. template<typename Ser,typename T>
  95. struct SavePrimitive
  96. {
  97. static void invoke(Ser &s, const T &data)
  98. {
  99. s.savePrimitive(data);
  100. }
  101. };
  102. template<typename Ser,typename T>
  103. struct SaveSerializable
  104. {
  105. static void invoke(Ser &s, const T &data)
  106. {
  107. s.saveSerializable(data);
  108. }
  109. };
  110. template<typename Ser,typename T>
  111. struct LoadPrimitive
  112. {
  113. static void invoke(Ser &s, T &data)
  114. {
  115. s.loadPrimitive(data);
  116. }
  117. };
  118. template<typename Ser,typename T>
  119. struct SavePointer
  120. {
  121. static void invoke(Ser &s, const T &data)
  122. {
  123. s.savePointer(data);
  124. }
  125. };
  126. template<typename Ser,typename T>
  127. struct LoadPointer
  128. {
  129. static void invoke(Ser &s, T &data)
  130. {
  131. s.loadPointer(data);
  132. }
  133. };
  134. template<typename Ser,typename T>
  135. struct SaveArray
  136. {
  137. static void invoke(Ser &s, const T &data)
  138. {
  139. s.saveArray(data);
  140. }
  141. };
  142. template<typename Ser,typename T>
  143. struct LoadArray
  144. {
  145. static void invoke(Ser &s, T &data)
  146. {
  147. s.loadArray(data);
  148. }
  149. };
  150. template<typename Ser,typename T>
  151. struct LoadSerializable
  152. {
  153. static void invoke(Ser &s, T &data)
  154. {
  155. s.loadSerializable(data);
  156. }
  157. };
  158. template<typename Ser,typename T>
  159. struct SaveWrong
  160. {
  161. static void invoke(Ser &s, const T &data)
  162. {
  163. throw std::string("Wrong save serialization call!");
  164. }
  165. };
  166. template<typename Ser,typename T>
  167. struct LoadWrong
  168. {
  169. static void invoke(Ser &s, const T &data)
  170. {
  171. throw std::string("Wrong load serialization call!");
  172. }
  173. };
  174. template<typename T>
  175. struct SerializationLevel
  176. {
  177. typedef mpl::integral_c_tag tag;
  178. typedef
  179. typename mpl::eval_if<
  180. boost::is_fundamental<T>,
  181. mpl::int_<Primitive>,
  182. //else
  183. typename mpl::eval_if<
  184. boost::is_class<T>,
  185. mpl::int_<Serializable>,
  186. //else
  187. typename mpl::eval_if<
  188. boost::is_array<T>,
  189. mpl::int_<Array>,
  190. //else
  191. typename mpl::eval_if<
  192. boost::is_pointer<T>,
  193. mpl::int_<Pointer>,
  194. //else
  195. typename mpl::eval_if<
  196. boost::is_enum<T>,
  197. mpl::int_<Primitive>,
  198. //else
  199. mpl::int_<Wrong>
  200. >
  201. >
  202. >
  203. >
  204. >::type type;
  205. static const int value = SerializationLevel::type::value;
  206. };
  207. template <typename T>
  208. struct VectorisedObjectInfo
  209. {
  210. const std::vector<ConstTransitivePtr<T> > *vector; //pointer to the appropriate vector
  211. const si32 T::*idPtr; //pointer to the field representing the position in the vector
  212. VectorisedObjectInfo(const std::vector< ConstTransitivePtr<T> > *Vector, const si32 T::*IdPtr)
  213. :vector(Vector), idPtr(IdPtr)
  214. {
  215. }
  216. };
  217. /// Class which is responsible for storing and loading data.
  218. class DLL_LINKAGE CSerializer
  219. {
  220. public:
  221. typedef std::map<const std::type_info *, boost::any, TypeComparer> TTypeVecMap;
  222. TTypeVecMap vectors; //entry must be a pointer to vector containing pointers to the objects of key type
  223. bool smartVectorMembersSerialization;
  224. CSerializer();
  225. ~CSerializer();
  226. virtual void reportState(CLogger &out){};
  227. template <typename T>
  228. void registerVectoredType(const std::vector<T*> *Vector, const si32 T::*IdPtr)
  229. {
  230. vectors[&typeid(T)] = VectorisedObjectInfo<T>(Vector, IdPtr);
  231. }
  232. template <typename T>
  233. void registerVectoredType(const std::vector<ConstTransitivePtr<T> > *Vector, const si32 T::*IdPtr)
  234. {
  235. vectors[&typeid(T)] = VectorisedObjectInfo<T>(Vector, IdPtr);
  236. }
  237. template <typename T>
  238. const VectorisedObjectInfo<T> *getVectorisedTypeInfo()
  239. {
  240. const std::type_info *myType = NULL;
  241. //
  242. // if(boost::is_base_of<CGObjectInstance, T>::value) //ugly workaround to support also types derived from CGObjectInstance -> if we encounter one, treat it aas CGObj..
  243. // myType = &typeid(CGObjectInstance);
  244. // else
  245. myType = &typeid(T);
  246. TTypeVecMap::iterator i = vectors.find(myType);
  247. if(i == vectors.end())
  248. return NULL;
  249. else
  250. {
  251. assert(!i->second.empty());
  252. assert(i->second.type() == typeid(VectorisedObjectInfo<T>));
  253. VectorisedObjectInfo<T> *ret = &(boost::any_cast<VectorisedObjectInfo<T>&>(i->second));
  254. return ret;
  255. }
  256. }
  257. template <typename T>
  258. T* getVectorItemFromId(const VectorisedObjectInfo<T> &oInfo, ui32 id) const
  259. {
  260. /* if(id < 0)
  261. return NULL;*/
  262. assert(oInfo.vector);
  263. assert(oInfo.vector->size() > id);
  264. return const_cast<T*>((*oInfo.vector)[id].get());
  265. }
  266. template <typename T>
  267. si32 getIdFromVectorItem(const VectorisedObjectInfo<T> &oInfo, const T* obj) const
  268. {
  269. if(!obj)
  270. return -1;
  271. return obj->*oInfo.idPtr;
  272. }
  273. void addStdVecItems(CGameState *gs, LibClasses *lib = VLC);
  274. };
  275. class DLL_LINKAGE CSaverBase : public virtual CSerializer
  276. {
  277. };
  278. class CBasicPointerSaver
  279. {
  280. public:
  281. virtual void savePtr(CSaverBase &ar, const void *data) const =0;
  282. ~CBasicPointerSaver(){}
  283. };
  284. template <typename Serializer, typename T> class CPointerSaver : public CBasicPointerSaver
  285. {
  286. public:
  287. void savePtr(CSaverBase &ar, const void *data) const
  288. {
  289. Serializer &s = static_cast<Serializer&>(ar);
  290. const T *ptr = static_cast<const T*>(data);
  291. //T is most derived known type, it's time to call actual serialize
  292. const_cast<T&>(*ptr).serialize(s,version);
  293. }
  294. };
  295. template <typename T> //metafunction returning CGObjectInstance if T is its derivate or T elsewise
  296. struct VectorisedTypeFor
  297. {
  298. typedef typename
  299. //if
  300. mpl::eval_if<boost::is_base_of<CGObjectInstance,T>,
  301. mpl::identity<CGObjectInstance>,
  302. //else
  303. mpl::identity<T>
  304. >::type type;
  305. };
  306. /// The class which manages saving objects.
  307. template <typename Serializer> class DLL_LINKAGE COSer : public CSaverBase
  308. {
  309. public:
  310. bool saving;
  311. std::map<ui16,CBasicPointerSaver*> savers; // typeID => CPointerSaver<serializer,type>
  312. std::map<const void*, ui32> savedPointers;
  313. bool smartPointerSerialization;
  314. COSer()
  315. {
  316. saving=true;
  317. smartPointerSerialization = true;
  318. }
  319. ~COSer()
  320. {
  321. std::map<ui16,CBasicPointerSaver*>::iterator iter;
  322. for(iter = savers.begin(); iter != savers.end(); iter++)
  323. delete iter->second;
  324. }
  325. template<typename T> void registerType(const T * t=NULL)
  326. {
  327. ui16 ID = typeList.registerType(t);
  328. savers[ID] = new CPointerSaver<COSer<Serializer>,T>;
  329. }
  330. Serializer * This()
  331. {
  332. return static_cast<Serializer*>(this);
  333. }
  334. template<class T>
  335. Serializer & operator<<(const T &t)
  336. {
  337. this->This()->save(t);
  338. return * this->This();
  339. }
  340. template<class T>
  341. COSer & operator&(const T & t)
  342. {
  343. return * this->This() << t;
  344. }
  345. int write(const void * data, unsigned size);
  346. template <typename T>
  347. void savePrimitive(const T &data)
  348. {
  349. this->This()->write(&data,sizeof(data));
  350. }
  351. template <typename T>
  352. void savePointer(const T &data)
  353. {
  354. //write if pointer is not NULL
  355. ui8 hlp = (data!=NULL);
  356. *this << hlp;
  357. //if pointer is NULL then we don't need anything more...
  358. if(!hlp)
  359. return;
  360. if(smartVectorMembersSerialization)
  361. {
  362. typedef typename boost::remove_const<typename boost::remove_pointer<T>::type>::type TObjectType;
  363. typedef typename VectorisedTypeFor<TObjectType>::type VType;
  364. if(const VectorisedObjectInfo<VType> *info = getVectorisedTypeInfo<VType>())
  365. {
  366. si32 id = getIdFromVectorItem<VType>(*info, data);
  367. *this << id;
  368. if(id != -1) //vector id is enough
  369. return;
  370. }
  371. }
  372. if(smartPointerSerialization)
  373. {
  374. std::map<const void*,ui32>::iterator i = savedPointers.find(data);
  375. if(i != savedPointers.end())
  376. {
  377. //this pointer has been already serialized - write only it's id
  378. *this << i->second;
  379. return;
  380. }
  381. //give id to this pointer
  382. ui32 pid = (ui32)savedPointers.size();
  383. savedPointers[data] = pid;
  384. *this << pid;
  385. }
  386. //write type identifier
  387. ui16 tid = typeList.getTypeID(data);
  388. *this << tid;
  389. This()->savePointerHlp(tid, data);
  390. }
  391. //that part of ptr serialization was extracted to allow customization of its behavior in derived classes
  392. template <typename T>
  393. void savePointerHlp(ui16 tid, const T &data)
  394. {
  395. if(!tid)
  396. *this << *data; //if type is unregistered simply write all data in a standard way
  397. else
  398. savers[tid]->savePtr(*this,data); //call serializer specific for our real type
  399. }
  400. template <typename T>
  401. void saveArray(const T &data)
  402. {
  403. ui32 size = ARRAY_COUNT(data);
  404. for(ui32 i=0; i < size; i++)
  405. *this << data[i];
  406. }
  407. template <typename T>
  408. void save(const T &data)
  409. {
  410. typedef
  411. //if
  412. typename mpl::eval_if< mpl::equal_to<SerializationLevel<T>,mpl::int_<Primitive> >,
  413. mpl::identity<SavePrimitive<Serializer,T> >,
  414. //else if
  415. typename mpl::eval_if<mpl::equal_to<SerializationLevel<T>,mpl::int_<Pointer> >,
  416. mpl::identity<SavePointer<Serializer,T> >,
  417. //else if
  418. typename mpl::eval_if<mpl::equal_to<SerializationLevel<T>,mpl::int_<Array> >,
  419. mpl::identity<SaveArray<Serializer,T> >,
  420. //else if
  421. typename mpl::eval_if<mpl::equal_to<SerializationLevel<T>,mpl::int_<Serializable> >,
  422. mpl::identity<SaveSerializable<Serializer,T> >,
  423. //else
  424. mpl::identity<SaveWrong<Serializer,T> >
  425. >
  426. >
  427. >
  428. >::type typex;
  429. typex::invoke(* this->This(), data);
  430. }
  431. template <typename T>
  432. void saveSerializable(const T &data)
  433. {
  434. const_cast<T&>(data).serialize(*this,version);
  435. }
  436. template <typename T>
  437. void saveSerializable(const boost::shared_ptr<T> &data)
  438. {
  439. T *internalPtr = data.get();
  440. *this << internalPtr;
  441. }
  442. template <typename T>
  443. void saveSerializable(const std::vector<T> &data)
  444. {
  445. ui32 length = data.size();
  446. *this << length;
  447. for(ui32 i=0;i<length;i++)
  448. *this << data[i];
  449. }
  450. template <typename T>
  451. void saveSerializable(const std::set<T> &data)
  452. {
  453. std::set<T> &d = const_cast<std::set<T> &>(data);
  454. ui32 length = d.size();
  455. *this << length;
  456. for(typename std::set<T>::iterator i=d.begin();i!=d.end();i++)
  457. *this << *i;
  458. }
  459. template <typename T, typename U>
  460. void saveSerializable(const boost::unordered_set<T, U> &data)
  461. {
  462. boost::unordered_set<T, U> &d = const_cast<boost::unordered_set<T, U> &>(data);
  463. ui32 length = d.size();
  464. *this << length;
  465. for(typename boost::unordered_set<T, U>::iterator i=d.begin();i!=d.end();i++)
  466. *this << *i;
  467. }
  468. template <typename T>
  469. void saveSerializable(const std::list<T> &data)
  470. {
  471. std::list<T> &d = const_cast<std::list<T> &>(data);
  472. ui32 length = d.size();
  473. *this << length;
  474. for(typename std::list<T>::iterator i=d.begin();i!=d.end();i++)
  475. *this << *i;
  476. }
  477. void saveSerializable(const std::string &data)
  478. {
  479. *this << ui32(data.length());
  480. this->This()->write(data.c_str(),data.size());
  481. }
  482. template <typename T1, typename T2>
  483. void saveSerializable(const std::pair<T1,T2> &data)
  484. {
  485. *this << data.first << data.second;
  486. }
  487. template <typename T1, typename T2>
  488. void saveSerializable(const std::map<T1,T2> &data)
  489. {
  490. *this << ui32(data.size());
  491. for(typename std::map<T1,T2>::const_iterator i=data.begin();i!=data.end();i++)
  492. *this << i->first << i->second;
  493. }
  494. };
  495. class DLL_LINKAGE CLoaderBase : public virtual CSerializer
  496. {};
  497. class CBasicPointerLoader
  498. {
  499. public:
  500. virtual void loadPtr(CLoaderBase &ar, void *data, ui32 pid) const =0; //data is pointer to the ACTUAL POINTER
  501. virtual ~CBasicPointerLoader(){}
  502. };
  503. template <typename Serializer, typename T> class CPointerLoader : public CBasicPointerLoader
  504. {
  505. public:
  506. void loadPtr(CLoaderBase &ar, void *data, ui32 pid) const //data is pointer to the ACTUAL POINTER
  507. {
  508. Serializer &s = static_cast<Serializer&>(ar);
  509. T *&ptr = *static_cast<T**>(data);
  510. //create new object under pointer
  511. typedef typename boost::remove_pointer<T>::type npT;
  512. ptr = new npT;
  513. s.ptrAllocated(ptr, pid);
  514. //T is most derived known type, it's time to call actual serialize
  515. ptr->serialize(s,version);
  516. }
  517. };
  518. /// The class which manages loading of objects.
  519. template <typename Serializer> class DLL_LINKAGE CISer : public CLoaderBase
  520. {
  521. public:
  522. bool saving;
  523. std::map<ui16,CBasicPointerLoader*> loaders; // typeID => CPointerSaver<serializer,type>
  524. ui32 myVersion;
  525. std::map<ui32, void*> loadedPointers;
  526. bool smartPointerSerialization;
  527. CISer()
  528. {
  529. saving = false;
  530. myVersion = version;
  531. smartPointerSerialization = true;
  532. }
  533. ~CISer()
  534. {
  535. std::map<ui16,CBasicPointerLoader*>::iterator iter;
  536. for(iter = loaders.begin(); iter != loaders.end(); iter++)
  537. delete iter->second;
  538. }
  539. template<typename T> void registerType(const T * t=NULL)
  540. {
  541. ui16 ID = typeList.registerType(t);
  542. loaders[ID] = new CPointerLoader<CISer<Serializer>,T>;
  543. }
  544. Serializer * This()
  545. {
  546. return static_cast<Serializer*>(this);
  547. }
  548. template<class T>
  549. Serializer & operator>>(T &t)
  550. {
  551. this->This()->load(t);
  552. return * this->This();
  553. }
  554. template<class T>
  555. CISer & operator&(T & t)
  556. {
  557. return * this->This() >> t;
  558. }
  559. int write(const void * data, unsigned size);
  560. template <typename T>
  561. void load(T &data)
  562. {
  563. typedef
  564. //if
  565. typename mpl::eval_if< mpl::equal_to<SerializationLevel<T>,mpl::int_<Primitive> >,
  566. mpl::identity<LoadPrimitive<Serializer,T> >,
  567. //else if
  568. typename mpl::eval_if<mpl::equal_to<SerializationLevel<T>,mpl::int_<Pointer> >,
  569. mpl::identity<LoadPointer<Serializer,T> >,
  570. //else if
  571. typename mpl::eval_if<mpl::equal_to<SerializationLevel<T>,mpl::int_<Array> >,
  572. mpl::identity<LoadArray<Serializer,T> >,
  573. //else if
  574. typename mpl::eval_if<mpl::equal_to<SerializationLevel<T>,mpl::int_<Serializable> >,
  575. mpl::identity<LoadSerializable<Serializer,T> >,
  576. //else
  577. mpl::identity<LoadWrong<Serializer,T> >
  578. >
  579. >
  580. >
  581. >::type typex;
  582. typex::invoke(* this->This(), data);
  583. }
  584. template <typename T>
  585. void loadPrimitive(T &data)
  586. {
  587. this->This()->read(&data,sizeof(data));
  588. }
  589. template <typename T>
  590. void loadSerializable(T &data)
  591. {
  592. ////that const cast is evil because it allows to implicitly overwrite const objects when deserializing
  593. typedef typename boost::remove_const<T>::type nonConstT;
  594. nonConstT &hlp = const_cast<nonConstT&>(data);
  595. hlp.serialize(*this,myVersion);
  596. //data.serialize(*this,myVersion);
  597. }
  598. template <typename T>
  599. void loadArray(T &data)
  600. {
  601. ui32 size = ARRAY_COUNT(data);
  602. for(ui32 i = 0; i < size; i++)
  603. *this >> data[i];
  604. }
  605. template <typename T>
  606. void loadPointer(T &data)
  607. {
  608. ui8 hlp;
  609. *this >> hlp;
  610. if(!hlp)
  611. {
  612. data = NULL;
  613. return;
  614. }
  615. if(smartVectorMembersSerialization)
  616. {
  617. typedef typename boost::remove_const<typename boost::remove_pointer<T>::type>::type TObjectType; //eg: const CGHeroInstance * => CGHeroInstance
  618. typedef typename VectorisedTypeFor<TObjectType>::type VType; //eg: CGHeroInstance -> CGobjectInstance
  619. if(const VectorisedObjectInfo<VType> *info = getVectorisedTypeInfo<VType>())
  620. {
  621. si32 id;
  622. *this >> id;
  623. if(id != -1)
  624. {
  625. data = static_cast<T>(getVectorItemFromId(*info, id));
  626. return;
  627. }
  628. }
  629. }
  630. ui32 pid = 0xffffffff; //pointer id (or maybe rather pointee id)
  631. if(smartPointerSerialization)
  632. {
  633. *this >> pid; //get the id
  634. std::map<ui32, void*>::iterator i = loadedPointers.find(pid); //lookup
  635. if(i != loadedPointers.end())
  636. {
  637. //we already got this pointer
  638. data = static_cast<T>(i->second);
  639. return;
  640. }
  641. }
  642. //get type id
  643. ui16 tid;
  644. *this >> tid;
  645. This()->loadPointerHlp(tid, data, pid);
  646. }
  647. //that part of ptr deserialization was extracted to allow customization of its behavior in derived classes
  648. template <typename T>
  649. void loadPointerHlp( ui16 tid, T & data, ui32 pid )
  650. {
  651. if(!tid)
  652. {
  653. typedef typename boost::remove_pointer<T>::type npT;
  654. typedef typename boost::remove_const<npT>::type ncpT;
  655. data = new ncpT;
  656. ptrAllocated(data, pid);
  657. *this >> *data;
  658. }
  659. else
  660. {
  661. loaders[tid]->loadPtr(*this,&data, pid);
  662. }
  663. }
  664. template <typename T>
  665. void ptrAllocated(const T *ptr, ui32 pid)
  666. {
  667. if(smartPointerSerialization && pid != 0xffffffff)
  668. loadedPointers[pid] = (void*)ptr; //add loaded pointer to our lookup map; cast is to avoid errors with const T* pt
  669. }
  670. #define READ_CHECK_U32(x) \
  671. ui32 length; \
  672. *this >> length; \
  673. if(length > 500000) \
  674. { \
  675. tlog2 << "Warning: very big length: " << length << "\n" ;\
  676. reportState(tlog2); \
  677. };
  678. template <typename T>
  679. void loadSerializable(boost::shared_ptr<T> &data)
  680. {
  681. T *internalPtr;
  682. *this >> internalPtr;
  683. data.reset(internalPtr);
  684. }
  685. template <typename T>
  686. void loadSerializable(std::vector<T> &data)
  687. {
  688. READ_CHECK_U32(length);
  689. data.resize(length);
  690. for(ui32 i=0;i<length;i++)
  691. *this >> data[i];
  692. }
  693. template <typename T>
  694. void loadSerializable(std::set<T> &data)
  695. {
  696. READ_CHECK_U32(length);
  697. T ins;
  698. for(ui32 i=0;i<length;i++)
  699. {
  700. *this >> ins;
  701. data.insert(ins);
  702. }
  703. }
  704. template <typename T, typename U>
  705. void loadSerializable(boost::unordered_set<T, U> &data)
  706. {
  707. READ_CHECK_U32(length);
  708. T ins;
  709. for(ui32 i=0;i<length;i++)
  710. {
  711. *this >> ins;
  712. data.insert(ins);
  713. }
  714. }
  715. template <typename T>
  716. void loadSerializable(std::list<T> &data)
  717. {
  718. READ_CHECK_U32(length);
  719. T ins;
  720. for(ui32 i=0;i<length;i++)
  721. {
  722. *this >> ins;
  723. data.push_back(ins);
  724. }
  725. }
  726. template <typename T1, typename T2>
  727. void loadSerializable(std::pair<T1,T2> &data)
  728. {
  729. *this >> data.first >> data.second;
  730. }
  731. template <typename T1, typename T2>
  732. void loadSerializable(std::map<T1,T2> &data)
  733. {
  734. READ_CHECK_U32(length);
  735. T1 t;
  736. for(ui32 i=0;i<length;i++)
  737. {
  738. *this >> t;
  739. *this >> data[t];
  740. }
  741. }
  742. void loadSerializable(std::string &data)
  743. {
  744. READ_CHECK_U32(length);
  745. data.resize(length);
  746. this->This()->read((void*)data.c_str(),length);
  747. }
  748. };
  749. class DLL_LINKAGE CSaveFile
  750. : public COSer<CSaveFile>
  751. {
  752. void dummyMagicFunction()
  753. {
  754. *this << std::string("This function makes stuff working.");
  755. }
  756. public:
  757. std::string fName;
  758. std::ofstream *sfile;
  759. CSaveFile(const std::string &fname);
  760. ~CSaveFile();
  761. int write(const void * data, unsigned size);
  762. void close();
  763. void openNextFile(const std::string &fname);
  764. void reportState(CLogger &out);
  765. };
  766. class DLL_LINKAGE CLoadFile
  767. : public CISer<CLoadFile>
  768. {
  769. void dummyMagicFunction()
  770. {
  771. std::string dummy = "This function makes stuff working.";
  772. *this >> dummy;
  773. }
  774. public:
  775. std::string fName;
  776. std::ifstream *sfile;
  777. CLoadFile(const std::string &fname, int minimalVersion = version);
  778. ~CLoadFile();
  779. int read(const void * data, unsigned size);
  780. void close();
  781. void openNextFile(const std::string &fname, int minimalVersion);
  782. void reportState(CLogger &out);
  783. };
  784. typedef boost::asio::basic_stream_socket < boost::asio::ip::tcp , boost::asio::stream_socket_service<boost::asio::ip::tcp> > TSocket;
  785. typedef boost::asio::basic_socket_acceptor<boost::asio::ip::tcp, boost::asio::socket_acceptor_service<boost::asio::ip::tcp> > TAcceptor;
  786. class DLL_LINKAGE CConnection
  787. :public CISer<CConnection>, public COSer<CConnection>
  788. {
  789. //CGameState *gs;
  790. CConnection(void);
  791. void init();
  792. void reportState(CLogger &out);
  793. public:
  794. boost::mutex *rmx, *wmx; // read/write mutexes
  795. TSocket * socket;
  796. bool logging;
  797. bool connected;
  798. bool myEndianess, contactEndianess; //true if little endian, if endianess is different we'll have to revert received multi-byte vars
  799. boost::asio::io_service *io_service;
  800. std::string name; //who uses this connection
  801. int connectionID;
  802. CConnection *c;
  803. boost::thread *handler;
  804. bool receivedStop, sendStop;
  805. CConnection(std::string host, std::string port, std::string Name);
  806. CConnection(TAcceptor * acceptor, boost::asio::io_service *Io_service, std::string Name);
  807. CConnection(TSocket * Socket, std::string Name); //use immediately after accepting connection into socket
  808. int write(const void * data, unsigned size);
  809. int read(void * data, unsigned size);
  810. void close();
  811. bool isOpen() const;
  812. template<class T>
  813. CConnection &operator&(const T&);
  814. ~CConnection(void);
  815. CPack *retreivePack(); //gets from server next pack (allocates it with new)
  816. void sendPackToServer(const CPack &pack, ui8 player);
  817. };
  818. DLL_LINKAGE std::ostream &operator<<(std::ostream &str, const CConnection &cpc);
  819. template<typename T>
  820. class CApplier
  821. {
  822. public:
  823. std::map<ui16,T*> apps;
  824. ~CApplier()
  825. {
  826. typename std::map<ui16, T*>::iterator iter;
  827. for(iter = apps.begin(); iter != apps.end(); iter++)
  828. delete iter->second;
  829. }
  830. template<typename U> void registerType(const U * t=NULL)
  831. {
  832. ui16 ID = typeList.registerType(t);
  833. apps[ID] = T::getApplier(t);
  834. }
  835. };