| 12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598159916001601160216031604160516061607160816091610161116121613161416151616161716181619162016211622162316241625162616271628162916301631163216331634163516361637163816391640164116421643164416451646164716481649165016511652165316541655165616571658165916601661166216631664166516661667166816691670167116721673167416751676167716781679168016811682168316841685168616871688168916901691169216931694169516961697169816991700170117021703170417051706170717081709171017111712171317141715171617171718171917201721172217231724172517261727172817291730173117321733173417351736173717381739174017411742174317441745174617471748174917501751175217531754175517561757 |
- /*
- * Connection.h, part of VCMI engine
- *
- * Authors: listed in file AUTHORS in main folder
- *
- * License: GNU General Public License v2.0 or later
- * Full text of license available in license.txt file, in main folder
- *
- */
- #pragma once
- #include <typeinfo>
- #include <type_traits>
- #include <boost/mpl/eval_if.hpp>
- #include <boost/mpl/equal_to.hpp>
- #include <boost/mpl/int.hpp>
- #include <boost/mpl/identity.hpp>
- #include <boost/mpl/for_each.hpp>
- #include <boost/any.hpp>
- #include "ConstTransitivePtr.h"
- #include "CCreatureSet.h" //for CStackInstance
- #include "mapObjects/CGHeroInstance.h"
- #include "mapping/CCampaignHandler.h" //for CCampaignState
- #include "rmg/CMapGenerator.h" // for CMapGenOptions
- const ui32 version = 761;
- const ui32 minSupportedVersion = 753;
- class CISer;
- class COSer;
- class CConnection;
- class CGObjectInstance;
- class CStackInstance;
- class CGameState;
- class CCreature;
- class LibClasses;
- class CHero;
- class FileStream;
- struct CPack;
- extern DLL_LINKAGE LibClasses * VLC;
- namespace mpl = boost::mpl;
- const std::string SAVEGAME_MAGIC = "VCMISVG";
- namespace boost
- {
- namespace asio
- {
- namespace ip
- {
- class tcp;
- }
- class io_service;
- template <typename Protocol> class stream_socket_service;
- template <typename Protocol,typename StreamSocketService>
- class basic_stream_socket;
- template <typename Protocol> class socket_acceptor_service;
- template <typename Protocol,typename SocketAcceptorService>
- class basic_socket_acceptor;
- }
- class mutex;
- }
- enum SerializationLvl
- {
- Wrong=0,
- Boolean,
- Primitive,
- Array,
- Pointer,
- Enum,
- Serializable,
- BooleanVector
- };
- struct TypeComparer
- {
- bool operator()(const std::type_info *a, const std::type_info *b) const
- {
- #ifndef __APPLE__
- return a->before(*b);
- #else
- return strcmp(a->name(), b->name()) < 0;
- #endif
- }
- };
- struct IPointerCaster
- {
- virtual boost::any castRawPtr(const boost::any &ptr) const = 0; // takes From*, performs dynamic cast, returns To*
- virtual boost::any castSharedPtr(const boost::any &ptr) const = 0; // takes std::shared_ptr<From>, performs dynamic cast, returns std::shared_ptr<To>
- virtual boost::any castWeakPtr(const boost::any &ptr) const = 0; // takes std::weak_ptr<From>, performs dynamic cast, returns std::weak_ptr<To>. The object under poitner must live.
- //virtual boost::any castUniquePtr(const boost::any &ptr) const = 0; // takes std::unique_ptr<From>, performs dynamic cast, returns std::unique_ptr<To>
- };
- template <typename From, typename To>
- struct PointerCaster : IPointerCaster
- {
- virtual boost::any castRawPtr(const boost::any &ptr) const override // takes void* pointing to From object, performs dynamic cast, returns void* pointing to To object
- {
- From * from = (From*)boost::any_cast<void*>(ptr);
- To * ret = dynamic_cast<To*>(from);
- if (ret == nullptr)
- {
- // Last resort when RTTI goes mad
- ret = static_cast<To*>(from);
- }
- return (void*)ret;
- }
- // Helper function performing casts between smart pointers using dynamic_pointer_cast
- template<typename SmartPt>
- boost::any castSmartPtr(const boost::any &ptr) const
- {
- try
- {
- auto from = boost::any_cast<SmartPt>(ptr);
- auto ret = std::dynamic_pointer_cast<To>(from);
- if (!ret)
- {
- // Last resort when RTTI goes mad
- ret = std::static_pointer_cast<To>(from);
- }
- return ret;
- }
- catch(std::exception &e)
- {
- THROW_FORMAT("Failed cast %s -> %s. Given argument was %s. Error message: %s", typeid(From).name() % typeid(To).name() % ptr.type().name() % e.what());
- }
- }
- virtual boost::any castSharedPtr(const boost::any &ptr) const override
- {
- return castSmartPtr<std::shared_ptr<From>>(ptr);
- }
- virtual boost::any castWeakPtr(const boost::any &ptr) const override
- {
- auto from = boost::any_cast<std::weak_ptr<From>>(ptr);
- return castSmartPtr<std::shared_ptr<From>>(from.lock());
- }
- // virtual boost::any castUniquePtr(const boost::any &ptr) const override
- // {
- // return castSmartPtr<std::unique_ptr<From>>(ptr);
- // }
- };
- class DLL_LINKAGE CTypeList: public boost::noncopyable
- {
- public:
- struct TypeDescriptor;
- typedef std::shared_ptr<TypeDescriptor> TypeInfoPtr;
- typedef std::weak_ptr<TypeDescriptor> WeakTypeInfoPtr;
- struct TypeDescriptor
- {
- ui16 typeID;
- const char *name;
- std::vector<WeakTypeInfoPtr> children, parents;
- };
- typedef boost::shared_mutex TMutex;
- typedef boost::unique_lock<TMutex> TUniqueLock;
- typedef boost::shared_lock<TMutex> TSharedLock;
- private:
- mutable TMutex mx;
- std::map<const std::type_info *, TypeInfoPtr, TypeComparer> typeInfos;
- std::map<std::pair<TypeInfoPtr, TypeInfoPtr>, std::unique_ptr<const IPointerCaster>> casters; //for each pair <Base, Der> we provide a caster (each registered relations creates a single entry here)
- /// Returns sequence of types starting from "from" and ending on "to". Every next type is derived from the previous.
- /// Throws if there is no link registered.
- std::vector<TypeInfoPtr> castSequence(TypeInfoPtr from, TypeInfoPtr to) const;
- std::vector<TypeInfoPtr> castSequence(const std::type_info *from, const std::type_info *to) const;
- template<boost::any(IPointerCaster::*CastingFunction)(const boost::any &) const>
- boost::any castHelper(boost::any inputPtr, const std::type_info *fromArg, const std::type_info *toArg) const
- {
- TSharedLock lock(mx);
- auto typesSequence = castSequence(fromArg, toArg);
- boost::any ptr = inputPtr;
- for(int i = 0; i < static_cast<int>(typesSequence.size()) - 1; i++)
- {
- auto &from = typesSequence[i];
- auto &to = typesSequence[i + 1];
- auto castingPair = std::make_pair(from, to);
- if(!casters.count(castingPair))
- THROW_FORMAT("Cannot find caster for conversion %s -> %s which is needed to cast %s -> %s", from->name % to->name % fromArg->name() % toArg->name());
- auto &caster = casters.at(castingPair);
- ptr = (*caster.*CastingFunction)(ptr); //Why does std::unique_ptr not have operator->* ..?
- }
- return ptr;
- }
- TypeInfoPtr getTypeDescriptor(const std::type_info *type, bool throws = true) const; //if not throws, failure returns nullptr
- TypeInfoPtr registerType(const std::type_info *type);
- public:
- CTypeList();
- template <typename Base, typename Derived>
- void registerType(const Base * b = nullptr, const Derived * d = nullptr)
- {
- TUniqueLock lock(mx);
- static_assert(std::is_base_of<Base, Derived>::value, "First registerType template parameter needs to ba a base class of the second one.");
- static_assert(std::has_virtual_destructor<Base>::value, "Base class needs to have a virtual destructor.");
- static_assert(!std::is_same<Base, Derived>::value, "Parameters of registerTypes should be two diffrenet types.");
- auto bt = getTypeInfo(b), dt = getTypeInfo(d); //obtain std::type_info
- auto bti = registerType(bt), dti = registerType(dt); //obtain our TypeDescriptor
- // register the relation between classes
- bti->children.push_back(dti);
- dti->parents.push_back(bti);
- casters[std::make_pair(bti, dti)] = make_unique<const PointerCaster<Base, Derived>>();
- casters[std::make_pair(dti, bti)] = make_unique<const PointerCaster<Derived, Base>>();
- }
- ui16 getTypeID(const std::type_info *type, bool throws = false) const;
- template <typename T>
- ui16 getTypeID(const T * t = nullptr, bool throws = false) const
- {
- return getTypeID(getTypeInfo(t), throws);
- }
- template<typename TInput>
- void * castToMostDerived(const TInput * inputPtr) const
- {
- auto &baseType = typeid(typename std::remove_cv<TInput>::type);
- auto derivedType = getTypeInfo(inputPtr);
- if (!strcmp(baseType.name(), derivedType->name()))
- {
- return const_cast<void*>(reinterpret_cast<const void*>(inputPtr));
- }
- return boost::any_cast<void*>(castHelper<&IPointerCaster::castRawPtr>(
- const_cast<void*>(reinterpret_cast<const void*>(inputPtr)), &baseType,
- derivedType));
- }
- template<typename TInput>
- boost::any castSharedToMostDerived(const std::shared_ptr<TInput> inputPtr) const
- {
- auto &baseType = typeid(typename std::remove_cv<TInput>::type);
- auto derivedType = getTypeInfo(inputPtr.get());
- if (!strcmp(baseType.name(), derivedType->name()))
- return inputPtr;
- return castHelper<&IPointerCaster::castSharedPtr>(inputPtr, &baseType, derivedType);
- }
- void * castRaw(void *inputPtr, const std::type_info *from, const std::type_info *to) const
- {
- return boost::any_cast<void*>(castHelper<&IPointerCaster::castRawPtr>(inputPtr, from, to));
- }
- boost::any castShared(boost::any inputPtr, const std::type_info *from, const std::type_info *to) const
- {
- return castHelper<&IPointerCaster::castSharedPtr>(inputPtr, from, to);
- }
- template <typename T> const std::type_info * getTypeInfo(const T * t = nullptr) const
- {
- if(t)
- return &typeid(*t);
- else
- return &typeid(T);
- }
- };
- extern DLL_LINKAGE CTypeList typeList;
- template<typename Variant, typename Source>
- struct VariantLoaderHelper
- {
- Source & source;
- std::vector<std::function<Variant()>> funcs;
- VariantLoaderHelper(Source & source):
- source(source)
- {
- mpl::for_each<typename Variant::types>(std::ref(*this));
- }
- template<typename Type>
- void operator()(Type)
- {
- funcs.push_back([&]() -> Variant
- {
- Type obj;
- source >> obj;
- return Variant(obj);
- });
- }
- };
- template<typename T>
- struct SerializationLevel
- {
- typedef mpl::integral_c_tag tag;
- typedef
- typename mpl::eval_if<
- boost::is_same<T, bool>,
- mpl::int_<Boolean>,
- //else
- typename mpl::eval_if<
- boost::is_same<T, std::vector<bool> >,
- mpl::int_<BooleanVector>,
- //else
- typename mpl::eval_if<
- boost::is_fundamental<T>,
- mpl::int_<Primitive>,
- //else
- typename mpl::eval_if<
- boost::is_enum<T>,
- mpl::int_<Enum>,
- //else
- typename mpl::eval_if<
- boost::is_class<T>,
- mpl::int_<Serializable>,
- //else
- typename mpl::eval_if<
- boost::is_array<T>,
- mpl::int_<Array>,
- //else
- typename mpl::eval_if<
- boost::is_pointer<T>,
- mpl::int_<Pointer>,
- //else
- typename mpl::eval_if<
- boost::is_enum<T>,
- mpl::int_<Primitive>,
- //else
- mpl::int_<Wrong>
- >
- >
- >
- >
- >
- >
- >
- >::type type;
- static const int value = SerializationLevel::type::value;
- };
- template <typename ObjType, typename IdType>
- struct VectorisedObjectInfo
- {
- const std::vector<ConstTransitivePtr<ObjType> > *vector; //pointer to the appropriate vector
- std::function<IdType(const ObjType &)> idRetriever;
- //const IdType ObjType::*idPtr; //pointer to the field representing the position in the vector
- VectorisedObjectInfo(const std::vector< ConstTransitivePtr<ObjType> > *Vector, std::function<IdType(const ObjType &)> IdGetter)
- :vector(Vector), idRetriever(IdGetter)
- {
- }
- };
- template<typename T>
- si32 idToNumber(const T &t, typename boost::enable_if<boost::is_convertible<T,si32> >::type * dummy = 0)
- {
- return t;
- }
- template<typename T, typename NT>
- NT idToNumber(const BaseForID<T, NT> &t)
- {
- return t.getNum();
- }
- /// Class which is responsible for storing and loading data.
- class DLL_LINKAGE CSerializer
- {
- public:
- typedef std::map<const std::type_info *, boost::any, TypeComparer> TTypeVecMap;
- TTypeVecMap vectors; //entry must be a pointer to vector containing pointers to the objects of key type
- bool smartVectorMembersSerialization;
- bool sendStackInstanceByIds;
- CSerializer();
- ~CSerializer();
- virtual void reportState(CLogger * out){};
- template <typename T, typename U>
- void registerVectoredType(const std::vector<T*> *Vector, const std::function<U(const T&)> &idRetriever)
- {
- vectors[&typeid(T)] = VectorisedObjectInfo<T, U>(Vector, idRetriever);
- }
- template <typename T, typename U>
- void registerVectoredType(const std::vector<ConstTransitivePtr<T> > *Vector, const std::function<U(const T&)> &idRetriever)
- {
- vectors[&typeid(T)] = VectorisedObjectInfo<T, U>(Vector, idRetriever);
- }
- template <typename T, typename U>
- const VectorisedObjectInfo<T, U> *getVectorisedTypeInfo()
- {
- const std::type_info *myType = nullptr;
- //
- // 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..
- // myType = &typeid(CGObjectInstance);
- // else
- myType = &typeid(T);
- TTypeVecMap::iterator i = vectors.find(myType);
- if(i == vectors.end())
- return nullptr;
- else
- {
- assert(!i->second.empty());
- assert(i->second.type() == typeid(VectorisedObjectInfo<T, U>));
- VectorisedObjectInfo<T, U> *ret = &(boost::any_cast<VectorisedObjectInfo<T, U>&>(i->second));
- return ret;
- }
- }
- template <typename T, typename U>
- T* getVectorItemFromId(const VectorisedObjectInfo<T, U> &oInfo, U id) const
- {
- /* if(id < 0)
- return nullptr;*/
- si32 idAsNumber = idToNumber(id);
- assert(oInfo.vector);
- assert(static_cast<si32>(oInfo.vector->size()) > idAsNumber);
- return const_cast<T*>((*oInfo.vector)[idAsNumber].get());
- }
- template <typename T, typename U>
- U getIdFromVectorItem(const VectorisedObjectInfo<T, U> &oInfo, const T* obj) const
- {
- if(!obj)
- return U(-1);
- return oInfo.idRetriever(*obj);
- }
- void addStdVecItems(CGameState *gs, LibClasses *lib = VLC);
- };
- class IBinaryWriter : public virtual CSerializer
- {
- public:
- virtual int write(const void * data, unsigned size) = 0;
- };
- class DLL_LINKAGE CSaverBase
- {
- protected:
- IBinaryWriter * writer;
- public:
- CSaverBase(IBinaryWriter * w): writer(w){};
- inline int write(const void * data, unsigned size)
- {
- return writer->write(data, size);
- };
- };
- class CBasicPointerSaver
- {
- public:
- virtual void savePtr(CSaverBase &ar, const void *data) const =0;
- virtual ~CBasicPointerSaver(){}
- };
- template <typename T> //metafunction returning CGObjectInstance if T is its derivate or T elsewise
- struct VectorisedTypeFor
- {
- typedef typename
- //if
- mpl::eval_if<boost::is_same<CGHeroInstance,T>,
- mpl::identity<CGHeroInstance>,
- //else if
- mpl::eval_if<boost::is_base_of<CGObjectInstance,T>,
- mpl::identity<CGObjectInstance>,
- //else
- mpl::identity<T>
- > >::type type;
- };
- template <typename U>
- struct VectorizedIDType
- {
- typedef typename
- //if
- mpl::eval_if<boost::is_same<CArtifact,U>,
- mpl::identity<ArtifactID>,
- //else if
- mpl::eval_if<boost::is_same<CCreature,U>,
- mpl::identity<CreatureID>,
- //else if
- mpl::eval_if<boost::is_same<CHero,U>,
- mpl::identity<HeroTypeID>,
- //else if
- mpl::eval_if<boost::is_same<CArtifactInstance,U>,
- mpl::identity<ArtifactInstanceID>,
- //else if
- mpl::eval_if<boost::is_same<CGHeroInstance,U>,
- mpl::identity<HeroTypeID>,
- //else if
- mpl::eval_if<boost::is_base_of<CGObjectInstance,U>,
- mpl::identity<ObjectInstanceID>,
- //else
- mpl::identity<si32>
- > > > > > >::type type;
- };
- template <typename Handler>
- struct VariantVisitorSaver : boost::static_visitor<>
- {
- Handler &h;
- VariantVisitorSaver(Handler &H):h(H)
- {
- }
- template <typename T>
- void operator()(const T &t)
- {
- h << t;
- }
- };
- template<typename Ser,typename T>
- struct SaveIfStackInstance
- {
- static bool invoke(Ser &s, const T &data)
- {
- return false;
- }
- };
- template<typename Ser>
- struct SaveIfStackInstance<Ser, CStackInstance *>
- {
- static bool invoke(Ser &s, const CStackInstance* const &data)
- {
- assert(data->armyObj);
- SlotID slot;
- if(data->getNodeType() == CBonusSystemNode::COMMANDER)
- slot = SlotID::COMMANDER_SLOT_PLACEHOLDER;
- else
- slot = data->armyObj->findStack(data);
- assert(slot != SlotID());
- s << data->armyObj << slot;
- return true;
- }
- };
- template<typename Ser,typename T>
- struct LoadIfStackInstance
- {
- static bool invoke(Ser &s, T &data)
- {
- return false;
- }
- };
- template<typename Ser>
- struct LoadIfStackInstance<Ser, CStackInstance *>
- {
- static bool invoke(Ser &s, CStackInstance* &data)
- {
- CArmedInstance *armedObj;
- SlotID slot;
- s >> armedObj >> slot;
- if(slot != SlotID::COMMANDER_SLOT_PLACEHOLDER)
- {
- assert(armedObj->hasStackAtSlot(slot));
- data = armedObj->stacks[slot];
- }
- else
- {
- auto hero = dynamic_cast<CGHeroInstance *>(armedObj);
- assert(hero);
- assert(hero->commander);
- data = hero->commander;
- }
- return true;
- }
- };
- /// The class which manages saving objects.
- class DLL_LINKAGE COSer : public CSaverBase
- {
- public:
- struct SaveBoolean
- {
- static void invoke(COSer &s, const bool &data)
- {
- s.saveBoolean(data);
- }
- };
- struct SaveBooleanVector
- {
- static void invoke(COSer &s, const std::vector<bool> &data)
- {
- s.saveBooleanVector(data);
- }
- };
- template<typename T>
- struct SavePrimitive
- {
- static void invoke(COSer &s, const T &data)
- {
- s.savePrimitive(data);
- }
- };
- template<typename T>
- struct SaveSerializable
- {
- static void invoke(COSer &s, const T &data)
- {
- s.saveSerializable(data);
- }
- };
- template<typename T>
- struct SaveEnum
- {
- static void invoke(COSer &s, const T &data)
- {
- s.saveEnum(data);
- }
- };
- template<typename T>
- struct SavePointer
- {
- static void invoke(COSer &s, const T &data)
- {
- s.savePointer(data);
- }
- };
- template<typename T>
- struct SaveArray
- {
- static void invoke(COSer &s, const T &data)
- {
- s.saveArray(data);
- }
- };
- template<typename T>
- struct SaveWrong
- {
- static void invoke(COSer &s, const T &data)
- {
- throw std::runtime_error("Wrong save serialization call!");
- }
- };
- template <typename T>
- class CPointerSaver : public CBasicPointerSaver
- {
- public:
- void savePtr(CSaverBase &ar, const void *data) const override
- {
- COSer &s = static_cast<COSer&>(ar);
- const T *ptr = static_cast<const T*>(data);
- //T is most derived known type, it's time to call actual serialize
- const_cast<T*>(ptr)->serialize(s,version);
- }
- };
- bool saving;
- std::map<ui16,CBasicPointerSaver*> savers; // typeID => CPointerSaver<serializer,type>
- std::map<const void*, ui32> savedPointers;
- bool smartPointerSerialization;
- COSer(IBinaryWriter * w): CSaverBase(w)
- {
- saving=true;
- smartPointerSerialization = true;
- }
- ~COSer()
- {
- std::map<ui16,CBasicPointerSaver*>::iterator iter;
- for(iter = savers.begin(); iter != savers.end(); iter++)
- delete iter->second;
- }
- template<typename T>
- void addSaver(const T * t = nullptr)
- {
- auto ID = typeList.getTypeID(t);
- if(!savers.count(ID))
- savers[ID] = new CPointerSaver<T>;
- }
- template<typename Base, typename Derived> void registerType(const Base * b = nullptr, const Derived * d = nullptr)
- {
- typeList.registerType(b, d);
- addSaver(b);
- addSaver(d);
- }
- template<class T>
- COSer & operator<<(const T &t)
- {
- this->save(t);
- return * this;
- }
- template<class T>
- COSer & operator&(const T & t)
- {
- return * this << t;
- }
- template <typename T>
- void savePrimitive(const T &data)
- {
- this->write(&data,sizeof(data));
- }
- template <typename T>
- void savePointer(const T &data)
- {
- //write if pointer is not nullptr
- ui8 hlp = (data!=nullptr);
- *this << hlp;
- //if pointer is nullptr then we don't need anything more...
- if(!hlp)
- return;
- if(writer->smartVectorMembersSerialization)
- {
- typedef typename boost::remove_const<typename boost::remove_pointer<T>::type>::type TObjectType;
- typedef typename VectorisedTypeFor<TObjectType>::type VType;
- typedef typename VectorizedIDType<TObjectType>::type IDType;
- if(const auto *info = writer->getVectorisedTypeInfo<VType, IDType>())
- {
- IDType id = writer->getIdFromVectorItem<VType>(*info, data);
- *this << id;
- if(id != IDType(-1)) //vector id is enough
- return;
- }
- }
- if(writer->sendStackInstanceByIds)
- {
- const bool gotSaved = SaveIfStackInstance<COSer,T>::invoke(*this, data);
- if(gotSaved)
- return;
- }
- if(smartPointerSerialization)
- {
- // We might have an object that has multiple inheritance and store it via the non-first base pointer.
- // Therefore, all pointers need to be normalized to the actual object address.
- auto actualPointer = typeList.castToMostDerived(data);
- std::map<const void*,ui32>::iterator i = savedPointers.find(actualPointer);
- if(i != savedPointers.end())
- {
- //this pointer has been already serialized - write only it's id
- *this << i->second;
- return;
- }
- //give id to this pointer
- ui32 pid = (ui32)savedPointers.size();
- savedPointers[actualPointer] = pid;
- *this << pid;
- }
- //write type identifier
- ui16 tid = typeList.getTypeID(data);
- *this << tid;
- this->savePointerHlp(tid, data);
- }
- //that part of ptr serialization was extracted to allow customization of its behavior in derived classes
- template <typename T>
- void savePointerHlp(ui16 tid, const T &data)
- {
- if(!tid)
- *this << *data; //if type is unregistered simply write all data in a standard way
- else
- savers[tid]->savePtr(*this, typeList.castToMostDerived(data)); //call serializer specific for our real type
- }
- template <typename T>
- void saveArray(const T &data)
- {
- ui32 size = ARRAY_COUNT(data);
- for(ui32 i=0; i < size; i++)
- *this << data[i];
- }
- template <typename T>
- void save(const T &data)
- {
- typedef
- //if
- typename mpl::eval_if< mpl::equal_to<SerializationLevel<T>,mpl::int_<Boolean> >,
- mpl::identity<SaveBoolean>,
- //else if
- typename mpl::eval_if< mpl::equal_to<SerializationLevel<T>,mpl::int_<BooleanVector> >,
- mpl::identity<SaveBooleanVector>,
- //else if
- typename mpl::eval_if< mpl::equal_to<SerializationLevel<T>,mpl::int_<Primitive> >,
- mpl::identity<SavePrimitive<T> >,
- //else if
- typename mpl::eval_if<mpl::equal_to<SerializationLevel<T>,mpl::int_<Enum> >,
- mpl::identity<SaveEnum<T> >,
- //else if
- typename mpl::eval_if<mpl::equal_to<SerializationLevel<T>,mpl::int_<Pointer> >,
- mpl::identity<SavePointer<T> >,
- //else if
- typename mpl::eval_if<mpl::equal_to<SerializationLevel<T>,mpl::int_<Array> >,
- mpl::identity<SaveArray<T> >,
- //else if
- typename mpl::eval_if<mpl::equal_to<SerializationLevel<T>,mpl::int_<Serializable> >,
- mpl::identity<SaveSerializable<T> >,
- //else
- mpl::identity<SaveWrong<T> >
- >
- >
- >
- >
- >
- >
- >::type typex;
- typex::invoke(* this, data);
- }
- template <typename T>
- void saveSerializable(const T &data)
- {
- const_cast<T&>(data).serialize(*this,version);
- }
- template <typename T>
- void saveSerializable(const std::shared_ptr<T> &data)
- {
- T *internalPtr = data.get();
- *this << internalPtr;
- }
- template <typename T>
- void saveSerializable(const std::unique_ptr<T> &data)
- {
- T *internalPtr = data.get();
- *this << internalPtr;
- }
- template <typename T>
- void saveSerializable(const std::vector<T> &data)
- {
- ui32 length = data.size();
- *this << length;
- for(ui32 i=0;i<length;i++)
- *this << data[i];
- }
- template <typename T, size_t N>
- void saveSerializable(const std::array<T, N> &data)
- {
- for(ui32 i=0; i < N; i++)
- *this << data[i];
- }
- template <typename T>
- void saveSerializable(const std::set<T> &data)
- {
- std::set<T> &d = const_cast<std::set<T> &>(data);
- ui32 length = d.size();
- *this << length;
- for(typename std::set<T>::iterator i=d.begin();i!=d.end();i++)
- *this << *i;
- }
- template <typename T, typename U>
- void saveSerializable(const std::unordered_set<T, U> &data)
- {
- std::unordered_set<T, U> &d = const_cast<std::unordered_set<T, U> &>(data);
- ui32 length = d.size();
- *this << length;
- for(typename std::unordered_set<T, U>::iterator i=d.begin();i!=d.end();i++)
- *this << *i;
- }
- template <typename T>
- void saveSerializable(const std::list<T> &data)
- {
- std::list<T> &d = const_cast<std::list<T> &>(data);
- ui32 length = d.size();
- *this << length;
- for(typename std::list<T>::iterator i=d.begin();i!=d.end();i++)
- *this << *i;
- }
- void saveSerializable(const std::string &data)
- {
- *this << ui32(data.length());
- this->write(data.c_str(),data.size());
- }
- template <typename T1, typename T2>
- void saveSerializable(const std::pair<T1,T2> &data)
- {
- *this << data.first << data.second;
- }
- template <typename T1, typename T2>
- void saveSerializable(const std::map<T1,T2> &data)
- {
- *this << ui32(data.size());
- for(typename std::map<T1,T2>::const_iterator i=data.begin();i!=data.end();i++)
- *this << i->first << i->second;
- }
- template <typename T1, typename T2>
- void saveSerializable(const std::multimap<T1, T2> &data)
- {
- *this << ui32(data.size());
- for(typename std::map<T1, T2>::const_iterator i = data.begin(); i != data.end(); i++)
- *this << i->first << i->second;
- }
- template <BOOST_VARIANT_ENUM_PARAMS(typename T)>
- void saveSerializable(const boost::variant<BOOST_VARIANT_ENUM_PARAMS(T)> &data)
- {
- si32 which = data.which();
- *this << which;
- VariantVisitorSaver<COSer> visitor(*this);
- boost::apply_visitor(visitor, data);
- }
- template <typename T>
- void saveSerializable(const boost::optional<T> &data)
- {
- if(data)
- {
- *this << (ui8)1;
- *this << *data;
- }
- else
- {
- *this << (ui8)0;
- }
- }
- template <typename E>
- void saveEnum(const E &data)
- {
- si32 writ = static_cast<si32>(data);
- *this << writ;
- }
- void saveBoolean(const bool & data)
- {
- ui8 writ = static_cast<ui8>(data);
- *this << writ;
- }
- void saveBooleanVector(const std::vector<bool> & data)
- {
- std::vector<ui8> convData;
- std::copy(data.begin(), data.end(), std::back_inserter(convData));
- saveSerializable(convData);
- }
- };
- class IBinaryReader : public virtual CSerializer
- {
- public:
- virtual int read(void * data, unsigned size) = 0;
- };
- class DLL_LINKAGE CLoaderBase
- {
- protected:
- IBinaryReader * reader;
- public:
- CLoaderBase(IBinaryReader * r): reader(r){};
- inline int read(void * data, unsigned size)
- {
- return reader->read(data, size);
- };
- };
- class CBasicPointerLoader
- {
- public:
- virtual const std::type_info * loadPtr(CLoaderBase &ar, void *data, ui32 pid) const =0; //data is pointer to the ACTUAL POINTER
- virtual ~CBasicPointerLoader(){}
- };
- template <typename T, typename Enable = void>
- struct ClassObjectCreator
- {
- static T *invoke()
- {
- static_assert(!std::is_abstract<T>::value, "Cannot call new upon abstract classes!");
- return new T();
- }
- };
- template<typename T>
- struct ClassObjectCreator<T, typename std::enable_if<std::is_abstract<T>::value>::type>
- {
- static T *invoke()
- {
- throw std::runtime_error("Something went really wrong during deserialization. Attempted creating an object of an abstract class " + std::string(typeid(T).name()));
- }
- };
- /// The class which manages loading of objects.
- class DLL_LINKAGE CISer : public CLoaderBase
- {
- public:
- struct LoadBoolean
- {
- static void invoke(CISer &s, bool &data)
- {
- s.loadBoolean(data);
- }
- };
- struct LoadBooleanVector
- {
- static void invoke(CISer &s, std::vector<bool> &data)
- {
- s.loadBooleanVector(data);
- }
- };
- template<typename T>
- struct LoadEnum
- {
- static void invoke(CISer &s, T &data)
- {
- s.loadEnum(data);
- }
- };
- template<typename T>
- struct LoadPrimitive
- {
- static void invoke(CISer &s, T &data)
- {
- s.loadPrimitive(data);
- }
- };
- template<typename T>
- struct LoadPointer
- {
- static void invoke(CISer &s, T &data)
- {
- s.loadPointer(data);
- }
- };
- template<typename T>
- struct LoadArray
- {
- static void invoke(CISer &s, T &data)
- {
- s.loadArray(data);
- }
- };
- template<typename T>
- struct LoadSerializable
- {
- static void invoke(CISer &s, T &data)
- {
- s.loadSerializable(data);
- }
- };
- template<typename T>
- struct LoadWrong
- {
- static void invoke(CISer &s, const T &data)
- {
- throw std::runtime_error("Wrong load serialization call!");
- }
- };
- template <typename T> class CPointerLoader : public CBasicPointerLoader
- {
- public:
- const std::type_info * loadPtr(CLoaderBase &ar, void *data, ui32 pid) const override //data is pointer to the ACTUAL POINTER
- {
- CISer &s = static_cast<CISer&>(ar);
- T *&ptr = *static_cast<T**>(data);
- //create new object under pointer
- typedef typename boost::remove_pointer<T>::type npT;
- ptr = ClassObjectCreator<npT>::invoke(); //does new npT or throws for abstract classes
- s.ptrAllocated(ptr, pid);
- //T is most derived known type, it's time to call actual serialize
- ptr->serialize(s,s.fileVersion);
- return &typeid(T);
- }
- };
- bool saving;
- std::map<ui16, CBasicPointerLoader*> loaders; // typeID => CPointerSaver<serializer,type>
- si32 fileVersion;
- bool reverseEndianess; //if source has different endianness than us, we reverse bytes
- std::map<ui32, void*> loadedPointers;
- std::map<ui32, const std::type_info*> loadedPointersTypes;
- std::map<const void*, boost::any> loadedSharedPointers;
- bool smartPointerSerialization;
- CISer(IBinaryReader * r): CLoaderBase(r)
- {
- saving = false;
- fileVersion = 0;
- smartPointerSerialization = true;
- reverseEndianess = false;
- }
- ~CISer()
- {
- std::map<ui16,CBasicPointerLoader*>::iterator iter;
- for(iter = loaders.begin(); iter != loaders.end(); iter++)
- delete iter->second;
- }
- template<typename T>
- void addLoader(const T * t = nullptr)
- {
- auto ID = typeList.getTypeID(t);
- if(!loaders.count(ID))
- loaders[ID] = new CPointerLoader<T>;
- }
- template<typename Base, typename Derived> void registerType(const Base * b = nullptr, const Derived * d = nullptr)
- {
- typeList.registerType(b, d);
- addLoader(b);
- addLoader(d);
- }
- template<class T>
- CISer & operator>>(T &t)
- {
- this->load(t);
- return * this;
- }
- template<class T>
- CISer & operator&(T & t)
- {
- return * this >> t;
- }
- int write(const void * data, unsigned size);
- template <typename T>
- void load(T &data)
- {
- typedef
- //if
- typename mpl::eval_if< mpl::equal_to<SerializationLevel<T>,mpl::int_<Boolean> >,
- mpl::identity<LoadBoolean>,
- //else if
- typename mpl::eval_if< mpl::equal_to<SerializationLevel<T>,mpl::int_<BooleanVector> >,
- mpl::identity<LoadBooleanVector>,
- //else if
- typename mpl::eval_if< mpl::equal_to<SerializationLevel<T>,mpl::int_<Primitive> >,
- mpl::identity<LoadPrimitive<T> >,
- //else if
- typename mpl::eval_if<mpl::equal_to<SerializationLevel<T>,mpl::int_<Enum> >,
- mpl::identity<LoadEnum<T> >,
- //else if
- typename mpl::eval_if<mpl::equal_to<SerializationLevel<T>,mpl::int_<Pointer> >,
- mpl::identity<LoadPointer<T> >,
- //else if
- typename mpl::eval_if<mpl::equal_to<SerializationLevel<T>,mpl::int_<Array> >,
- mpl::identity<LoadArray<T> >,
- //else if
- typename mpl::eval_if<mpl::equal_to<SerializationLevel<T>,mpl::int_<Serializable> >,
- mpl::identity<LoadSerializable<T> >,
- //else
- mpl::identity<LoadWrong<T> >
- >
- >
- >
- >
- >
- >
- >::type typex;
- typex::invoke(* this, data);
- }
- template <typename T>
- void loadPrimitive(T &data)
- {
- if(0) //for testing #989
- {
- this->read(&data,sizeof(data));
- }
- else
- {
- unsigned length = sizeof(data);
- char* dataPtr = (char*)&data;
- this->read(dataPtr,length);
- if(reverseEndianess)
- std::reverse(dataPtr, dataPtr + length);
- }
- }
- template <typename T>
- void loadSerializableBySerializeCall(T &data)
- {
- ////that const cast is evil because it allows to implicitly overwrite const objects when deserializing
- typedef typename boost::remove_const<T>::type nonConstT;
- nonConstT &hlp = const_cast<nonConstT&>(data);
- hlp.serialize(*this,fileVersion);
- //data.serialize(*this,myVersion);
- }
- template <typename T>
- void loadSerializable(T &data)
- {
- loadSerializableBySerializeCall(data);
- }
- template <typename T>
- void loadArray(T &data)
- {
- ui32 size = ARRAY_COUNT(data);
- for(ui32 i = 0; i < size; i++)
- *this >> data[i];
- }
- template <typename T>
- void loadPointer(T &data)
- {
- ui8 hlp;
- *this >> hlp;
- if(!hlp)
- {
- data = nullptr;
- return;
- }
- if(reader->smartVectorMembersSerialization)
- {
- typedef typename boost::remove_const<typename boost::remove_pointer<T>::type>::type TObjectType; //eg: const CGHeroInstance * => CGHeroInstance
- typedef typename VectorisedTypeFor<TObjectType>::type VType; //eg: CGHeroInstance -> CGobjectInstance
- typedef typename VectorizedIDType<TObjectType>::type IDType;
- if(const auto *info = reader->getVectorisedTypeInfo<VType, IDType>())
- {
- IDType id;
- *this >> id;
- if(id != IDType(-1))
- {
- data = static_cast<T>(reader->getVectorItemFromId<VType, IDType>(*info, id));
- return;
- }
- }
- }
- if(reader->sendStackInstanceByIds)
- {
- bool gotLoaded = LoadIfStackInstance<CISer,T>::invoke(* this, data);
- if(gotLoaded)
- return;
- }
- ui32 pid = 0xffffffff; //pointer id (or maybe rather pointee id)
- if(smartPointerSerialization)
- {
- *this >> pid; //get the id
- std::map<ui32, void*>::iterator i = loadedPointers.find(pid); //lookup
- if(i != loadedPointers.end())
- {
- // We already got this pointer
- // Cast it in case we are loading it to a non-first base pointer
- assert(loadedPointersTypes.count(pid));
- data = reinterpret_cast<T>(typeList.castRaw(i->second, loadedPointersTypes.at(pid), &typeid(typename boost::remove_const<typename boost::remove_pointer<T>::type>::type)));
- return;
- }
- }
- //get type id
- ui16 tid;
- *this >> tid;
- this->loadPointerHlp(tid, data, pid);
- }
- //that part of ptr deserialization was extracted to allow customization of its behavior in derived classes
- template <typename T>
- void loadPointerHlp( ui16 tid, T & data, ui32 pid )
- {
- if(!tid)
- {
- typedef typename boost::remove_pointer<T>::type npT;
- typedef typename boost::remove_const<npT>::type ncpT;
- data = ClassObjectCreator<ncpT>::invoke();
- ptrAllocated(data, pid);
- *this >> *data;
- }
- else
- {
- auto loader = loaders[tid];
- if (loader == nullptr)
- {
- logGlobal->errorStream() << "loadPointerHlp " << tid << " " << pid << " - no loader exists";
- data = nullptr;
- return;
- }
- auto typeInfo = loader->loadPtr(*this, &data, pid);
- data = reinterpret_cast<T>(typeList.castRaw((void*)data, typeInfo, &typeid(typename boost::remove_const<typename boost::remove_pointer<T>::type>::type)));
- }
- }
- template <typename T>
- void ptrAllocated(const T *ptr, ui32 pid)
- {
- if(smartPointerSerialization && pid != 0xffffffff)
- {
- loadedPointersTypes[pid] = &typeid(T);
- loadedPointers[pid] = (void*)ptr; //add loaded pointer to our lookup map; cast is to avoid errors with const T* pt
- }
- }
- #define READ_CHECK_U32(x) \
- ui32 length; \
- *this >> length; \
- if(length > 500000) \
- { \
- logGlobal->warnStream() << "Warning: very big length: " << length;\
- reader->reportState(logGlobal); \
- };
- template <typename T>
- void loadSerializable(std::shared_ptr<T> &data)
- {
- typedef typename boost::remove_const<T>::type NonConstT;
- NonConstT *internalPtr;
- *this >> internalPtr;
- void *internalPtrDerived = typeList.castToMostDerived(internalPtr);
- if(internalPtr)
- {
- auto itr = loadedSharedPointers.find(internalPtrDerived);
- if(itr != loadedSharedPointers.end())
- {
- // This pointers is already loaded. The "data" needs to be pointed to it,
- // so their shared state is actually shared.
- try
- {
- auto actualType = typeList.getTypeInfo(internalPtr);
- auto typeWeNeedToReturn = typeList.getTypeInfo<T>();
- if(*actualType == *typeWeNeedToReturn)
- {
- // No casting needed, just unpack already stored std::shared_ptr and return it
- data = boost::any_cast<std::shared_ptr<T>>(itr->second);
- }
- else
- {
- // We need to perform series of casts
- auto ret = typeList.castShared(itr->second, actualType, typeWeNeedToReturn);
- data = boost::any_cast<std::shared_ptr<T>>(ret);
- }
- }
- catch(std::exception &e)
- {
- logGlobal->errorStream() << e.what();
- logGlobal->errorStream() << boost::format("Failed to cast stored shared ptr. Real type: %s. Needed type %s. FIXME FIXME FIXME")
- % itr->second.type().name() % typeid(std::shared_ptr<T>).name();
- //TODO scenario with inheritance -> we can have stored ptr to base and load ptr to derived (or vice versa)
- assert(0);
- }
- }
- else
- {
- auto hlp = std::shared_ptr<NonConstT>(internalPtr);
- data = hlp; //possibly adds const
- loadedSharedPointers[internalPtrDerived] = typeList.castSharedToMostDerived(hlp);
- }
- }
- else
- data.reset();
- }
- template <typename T>
- void loadSerializable(std::unique_ptr<T> &data)
- {
- T *internalPtr;
- *this >> internalPtr;
- data.reset(internalPtr);
- }
- template <typename T>
- void loadSerializable(std::vector<T> &data)
- {
- READ_CHECK_U32(length);
- data.resize(length);
- for(ui32 i=0;i<length;i++)
- *this >> data[i];
- }
- template <typename T, size_t N>
- void loadSerializable(std::array<T, N> &data)
- {
- for(ui32 i = 0; i < N; i++)
- *this >> data[i];
- }
- template <typename T>
- void loadSerializable(std::set<T> &data)
- {
- READ_CHECK_U32(length);
- data.clear();
- T ins;
- for(ui32 i=0;i<length;i++)
- {
- *this >> ins;
- data.insert(ins);
- }
- }
- template <typename T, typename U>
- void loadSerializable(std::unordered_set<T, U> &data)
- {
- READ_CHECK_U32(length);
- data.clear();
- T ins;
- for(ui32 i=0;i<length;i++)
- {
- *this >> ins;
- data.insert(ins);
- }
- }
- template <typename T>
- void loadSerializable(std::list<T> &data)
- {
- READ_CHECK_U32(length);
- data.clear();
- T ins;
- for(ui32 i=0;i<length;i++)
- {
- *this >> ins;
- data.push_back(ins);
- }
- }
- template <typename T1, typename T2>
- void loadSerializable(std::pair<T1,T2> &data)
- {
- *this >> data.first >> data.second;
- }
- template <typename T1, typename T2>
- void loadSerializable(std::map<T1,T2> &data)
- {
- READ_CHECK_U32(length);
- data.clear();
- T1 key;
- T2 value;
- for(ui32 i=0;i<length;i++)
- {
- *this >> key >> value;
- data.insert(std::pair<T1, T2>(std::move(key), std::move(value)));
- }
- }
- template <typename T1, typename T2>
- void loadSerializable(std::multimap<T1, T2> &data)
- {
- READ_CHECK_U32(length);
- data.clear();
- T1 key;
- T2 value;
- for(ui32 i = 0; i < length; i++)
- {
- *this >> key >> value;
- data.insert(std::pair<T1, T2>(std::move(key), std::move(value)));
- }
- }
- void loadSerializable(std::string &data)
- {
- READ_CHECK_U32(length);
- data.resize(length);
- this->read((void*)data.c_str(),length);
- }
- template <BOOST_VARIANT_ENUM_PARAMS(typename T)>
- void loadSerializable(boost::variant<BOOST_VARIANT_ENUM_PARAMS(T)> &data)
- {
- typedef boost::variant<BOOST_VARIANT_ENUM_PARAMS(T)> TVariant;
- VariantLoaderHelper<TVariant, CISer> loader(*this);
- si32 which;
- *this >> which;
- assert(which < loader.funcs.size());
- data = loader.funcs.at(which)();
- }
- template <typename T>
- void loadSerializable(boost::optional<T> & data)
- {
- ui8 present;
- *this >> present;
- if(present)
- {
- T t;
- *this >> t;
- data = t;
- }
- else
- {
- data = boost::optional<T>();
- }
- }
- // void loadSerializable(CStackInstance *&s)
- // {
- // if(sendStackInstanceByIds)
- // {
- // CArmedInstance *armed;
- // SlotID slot;
- // *this >> armed >> slot;
- // assert(armed->hasStackAtSlot(slot));
- // s = armed->stacks[slot];
- // }
- // else
- // loadSerializableBySerializeCall(s);
- // }
- template <typename E>
- void loadEnum(E &data)
- {
- si32 read;
- *this >> read;
- data = static_cast<E>(read);
- }
- void loadBoolean(bool &data)
- {
- ui8 read;
- *this >> read;
- data = static_cast<bool>(read);
- }
- void loadBooleanVector(std::vector<bool> & data)
- {
- std::vector<ui8> convData;
- loadSerializable(convData);
- convData.resize(data.size());
- range::copy(convData, data.begin());
- }
- };
- class DLL_LINKAGE CSaveFile
- :public IBinaryWriter
- {
- public:
- COSer serializer;
- boost::filesystem::path fName;
- std::unique_ptr<FileStream> sfile;
- CSaveFile(const boost::filesystem::path &fname); //throws!
- ~CSaveFile();
- int write(const void * data, unsigned size) override;
- void openNextFile(const boost::filesystem::path &fname); //throws!
- void clear();
- void reportState(CLogger * out) override;
- void putMagicBytes(const std::string &text);
- template<class T>
- CSaveFile & operator<<(const T &t)
- {
- serializer << t;
- return * this;
- }
- };
- class DLL_LINKAGE CLoadFile
- : public IBinaryReader
- {
- public:
- CISer serializer;
- boost::filesystem::path fName;
- std::unique_ptr<FileStream> sfile;
- CLoadFile(const boost::filesystem::path & fname, int minimalVersion = version); //throws!
- ~CLoadFile();
- int read(void * data, unsigned size) override; //throws!
- void openNextFile(const boost::filesystem::path & fname, int minimalVersion); //throws!
- void clear();
- void reportState(CLogger * out) override;
- void checkMagicBytes(const std::string & text);
- template<class T>
- CLoadFile & operator>>(T &t)
- {
- serializer >> t;
- return * this;
- }
- };
- class DLL_LINKAGE CLoadIntegrityValidator
- : public IBinaryReader
- {
- public:
- CISer serializer;
- std::unique_ptr<CLoadFile> primaryFile, controlFile;
- bool foundDesync;
- CLoadIntegrityValidator(const boost::filesystem::path &primaryFileName, const boost::filesystem::path &controlFileName, int minimalVersion = version); //throws!
- int read( void * data, unsigned size) override; //throws!
- void checkMagicBytes(const std::string &text);
- std::unique_ptr<CLoadFile> decay(); //returns primary file. CLoadIntegrityValidator stops being usable anymore
- };
- typedef boost::asio::basic_stream_socket < boost::asio::ip::tcp , boost::asio::stream_socket_service<boost::asio::ip::tcp> > TSocket;
- typedef boost::asio::basic_socket_acceptor<boost::asio::ip::tcp, boost::asio::socket_acceptor_service<boost::asio::ip::tcp> > TAcceptor;
- class DLL_LINKAGE CConnection
- : public IBinaryReader, public IBinaryWriter
- {
- //CGameState *gs;
- CConnection(void);
- void init();
- void reportState(CLogger * out) override;
- public:
- CISer iser;
- COSer oser;
- boost::mutex *rmx, *wmx; // read/write mutexes
- TSocket * socket;
- bool logging;
- bool connected;
- bool myEndianess, contactEndianess; //true if little endian, if endianness is different we'll have to revert received multi-byte vars
- boost::asio::io_service *io_service;
- std::string name; //who uses this connection
- int connectionID;
- boost::thread *handler;
- bool receivedStop, sendStop;
- CConnection(std::string host, std::string port, std::string Name);
- CConnection(TAcceptor * acceptor, boost::asio::io_service *Io_service, std::string Name);
- CConnection(TSocket * Socket, std::string Name); //use immediately after accepting connection into socket
- int write(const void * data, unsigned size) override;
- int read(void * data, unsigned size) override;
- void close();
- bool isOpen() const;
- template<class T>
- CConnection &operator&(const T&);
- virtual ~CConnection(void);
- CPack *retreivePack(); //gets from server next pack (allocates it with new)
- void sendPackToServer(const CPack &pack, PlayerColor player, ui32 requestID);
- void disableStackSendingByID();
- void enableStackSendingByID();
- void disableSmartPointerSerialization();
- void enableSmartPointerSerializatoin();
- void disableSmartVectorMemberSerialization();
- void enableSmartVectorMemberSerializatoin();
- void prepareForSendingHeroes(); //disables sending vectorised, enables smart pointer serialization, clears saved/loaded ptr cache
- void enterPregameConnectionMode();
- template<class T>
- CConnection & operator>>(T &t)
- {
- iser >> t;
- return * this;
- }
- template<class T>
- CConnection & operator<<(const T &t)
- {
- oser << t;
- return * this;
- }
- };
- DLL_LINKAGE std::ostream &operator<<(std::ostream &str, const CConnection &cpc);
- // Serializer that stores objects in the dynamic buffer. Allows performing deep object copies.
- class DLL_LINKAGE CMemorySerializer
- : public IBinaryReader, public IBinaryWriter
- {
- std::vector<ui8> buffer;
- size_t readPos; //index of the next byte to be read
- public:
- CISer iser;
- COSer oser;
- int read(void * data, unsigned size) override; //throws!
- int write(const void * data, unsigned size) override;
- CMemorySerializer();
- template <typename T>
- static std::unique_ptr<T> deepCopy(const T &data)
- {
- CMemorySerializer mem;
- mem.oser << &data;
- std::unique_ptr<T> ret;
- mem.iser >> ret;
- return ret;
- }
- };
- template<typename T>
- class CApplier
- {
- public:
- std::map<ui16,T*> apps;
- ~CApplier()
- {
- typename std::map<ui16, T*>::iterator iter;
- for(iter = apps.begin(); iter != apps.end(); iter++)
- delete iter->second;
- }
- template<typename RegisteredType>
- void addApplier(ui16 ID)
- {
- if(!apps.count(ID))
- {
- RegisteredType * rtype = nullptr;
- apps[ID] = T::getApplier(rtype);
- }
- }
- template<typename Base, typename Derived>
- void registerType(const Base * b = nullptr, const Derived * d = nullptr)
- {
- typeList.registerType(b, d);
- addApplier<Base>(typeList.getTypeID(b));
- addApplier<Derived>(typeList.getTypeID(d));
- }
- };
|