Client.cpp 22 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790
  1. #include "../CCallback.h"
  2. #include "../CConsoleHandler.h"
  3. #include "../CGameInfo.h"
  4. #include "../CGameState.h"
  5. #include "../CPlayerInterface.h"
  6. #include "../StartInfo.h"
  7. #include "../hch/CArtHandler.h"
  8. #include "../hch/CDefObjInfoHandler.h"
  9. #include "../hch/CGeneralTextHandler.h"
  10. #include "../hch/CHeroHandler.h"
  11. #include "../hch/CTownHandler.h"
  12. #include "../hch/CObjectHandler.h"
  13. #include "../hch/CBuildingHandler.h"
  14. #include "../hch/CSpellHandler.h"
  15. #include "../lib/Connection.h"
  16. #include "../lib/Interprocess.h"
  17. #include "../lib/NetPacks.h"
  18. #include "../lib/VCMI_Lib.h"
  19. #include "../map.h"
  20. #include "../mapHandler.h"
  21. #include "CConfigHandler.h"
  22. #include "Client.h"
  23. #include <boost/bind.hpp>
  24. #include <boost/foreach.hpp>
  25. #include <boost/thread.hpp>
  26. #include <boost/thread/shared_mutex.hpp>
  27. #include <sstream>
  28. CSharedCond<std::set<IPack*> > mess(new std::set<IPack*>);
  29. extern std::string NAME;
  30. namespace intpr = boost::interprocess;
  31. SharedMem sm;
  32. CClient::CClient(void)
  33. {
  34. IObjectInterface::cb = this;
  35. serv = NULL;
  36. gs = NULL;
  37. cb = NULL;
  38. }
  39. CClient::CClient(CConnection *con, StartInfo *si)
  40. {
  41. IObjectInterface::cb = this;
  42. newGame(con,si);
  43. }
  44. CClient::~CClient(void)
  45. {
  46. }
  47. void CClient::process(int what)
  48. {
  49. static BattleAction curbaction;
  50. switch (what)
  51. {
  52. case 100: //one of our interfaces has turn
  53. {
  54. ui8 player;
  55. *serv >> player;//who?
  56. tlog5 << "It's turn of "<<(unsigned)player<<" player."<<std::endl;
  57. gs->currentPlayer = player;
  58. boost::thread(boost::bind(&CGameInterface::yourTurn,playerint[player]));
  59. break;
  60. }
  61. case 101:
  62. {
  63. NewTurn n;
  64. *serv >> n;
  65. tlog5 << "New day: "<<(unsigned)n.day<<". Applying changes... ";
  66. gs->apply(&n);
  67. tlog5 << "done!"<<std::endl;
  68. break;
  69. }
  70. case 102: //set resource amount
  71. {
  72. SetResource sr;
  73. *serv >> sr;
  74. tlog5 << "Set amount of "<<CGI->generaltexth->restypes[sr.resid]
  75. << " of player "<<(unsigned)sr.player <<" to "<<sr.val<<std::endl;
  76. gs->apply(&sr);
  77. playerint[sr.player]->receivedResource(sr.resid,sr.val);
  78. break;
  79. }
  80. case 103: //show info dialog
  81. {
  82. InfoWindow iw;
  83. *serv >> iw;
  84. std::vector<Component*> comps;
  85. for(size_t i=0;i<iw.components.size();i++) {
  86. comps.push_back(&iw.components[i]);
  87. }
  88. std::string str = toString(iw.text);
  89. playerint[iw.player]->showInfoDialog(str,comps);
  90. break;
  91. }
  92. case 104:
  93. {
  94. SetResources sr;
  95. *serv >> sr;
  96. tlog5 << "Set amount of resources of player "<<(unsigned)sr.player<<std::endl;
  97. gs->apply(&sr);
  98. playerint[sr.player]->receivedResource(-1,-1);
  99. break;
  100. }
  101. case 105:
  102. {
  103. SetPrimSkill sps;
  104. *serv >> sps;
  105. tlog5 << "Changing hero primary skill"<<std::endl;
  106. gs->apply(&sps);
  107. playerint[gs->getHero(sps.id)->tempOwner]->heroPrimarySkillChanged(gs->getHero(sps.id),sps.which,sps.val);
  108. break;
  109. }
  110. case 106:
  111. {
  112. SetSecSkill sr;
  113. *serv >> sr;
  114. tlog5 << "Changing hero secondary skill"<<std::endl;
  115. gs->apply(&sr);
  116. //TODO? - maybe inform interfaces
  117. break;
  118. }
  119. case 107:
  120. {
  121. ShowInInfobox sii;
  122. *serv >> sii;
  123. SComponent sc(sii.c);
  124. sc.description = toString(sii.text);
  125. if(playerint[sii.player]->human)
  126. static_cast<CPlayerInterface*>(playerint[sii.player])->showComp(sc);
  127. break;
  128. }
  129. case 108:
  130. {
  131. HeroVisitCastle vc;
  132. *serv >> vc;
  133. gs->apply(&vc);
  134. if(vc.start() && !vc.garrison() && vstd::contains(playerint,gs->getHero(vc.hid)->tempOwner))
  135. {
  136. playerint[gs->getHero(vc.hid)->tempOwner]->heroVisitsTown(gs->getHero(vc.hid),gs->getTown(vc.tid));
  137. }
  138. break;
  139. }
  140. case 109:
  141. {
  142. ChangeSpells vc;
  143. *serv >> vc;
  144. tlog5 << "Changing spells of hero "<<vc.hid<<std::endl;
  145. gs->apply(&vc);
  146. break;
  147. }
  148. case 110:
  149. {
  150. SetMana sm;
  151. *serv >> sm;
  152. tlog5 << "Setting mana value of hero "<<sm.hid<<" to "<<sm.val<<std::endl;
  153. gs->apply(&sm);
  154. CGHeroInstance *h = gs->getHero(sm.hid);
  155. if(vstd::contains(playerint,h->tempOwner))
  156. playerint[h->tempOwner]->heroManaPointsChanged(h);
  157. break;
  158. }
  159. case 111:
  160. {
  161. SetMovePoints smp;
  162. *serv >> smp;
  163. tlog5 << "Setting movement points of hero "<<smp.hid<<" to "<<smp.val<<std::endl;
  164. gs->apply(&smp);
  165. CGHeroInstance *h = gs->getHero(smp.hid);
  166. if(vstd::contains(playerint,h->tempOwner))
  167. playerint[h->tempOwner]->heroMovePointsChanged(h);
  168. break;
  169. }
  170. case 112:
  171. {
  172. FoWChange fc;
  173. *serv >> fc;
  174. tlog5 << "Changing FoW of player "<<(int)fc.player<<std::endl;
  175. gs->apply(&fc);
  176. if(!vstd::contains(playerint,fc.player))
  177. break;
  178. if(fc.mode)
  179. playerint[fc.player]->tileRevealed(fc.tiles);
  180. else
  181. playerint[fc.player]->tileHidden(fc.tiles);
  182. break;
  183. }
  184. case 113:
  185. {
  186. SetAvailableHeroes sav;
  187. *serv >> sav;
  188. tlog5 << "Setting available heroes for player "<<(int)sav.player<<std::endl;
  189. gs->apply(&sav);
  190. break;
  191. }
  192. case 500:
  193. {
  194. RemoveObject rh;
  195. *serv >> rh;
  196. CGObjectInstance *obj = gs->map->objects[rh.id];
  197. CGI->mh->removeObject(obj);
  198. gs->apply(&rh);
  199. if(obj->ID == 34)
  200. {
  201. CGHeroInstance *h = static_cast<CGHeroInstance*>(obj);
  202. tlog5 << "Removing hero with id = "<<(unsigned)rh.id<<std::endl;
  203. playerint[h->tempOwner]->heroKilled(h);
  204. }
  205. break;
  206. }
  207. case 501: //hero movement response - we have to notify interfaces and callback
  208. {
  209. TryMoveHero *th = new TryMoveHero; //will be deleted by callback after processing
  210. *serv >> *th;
  211. tlog5 << "HeroMove: id="<<th->id<<"\tResult: "<<(unsigned)th->result<<"\tPosition "<<th->end<<std::endl;
  212. HeroMoveDetails hmd(th->start,th->end,static_cast<CGHeroInstance*>(gs->map->objects[th->id]));
  213. hmd.style = th->result-1;
  214. hmd.successful = th->result;
  215. if(th->result>1)
  216. CGI->mh->removeObject(hmd.ho);
  217. gs->apply(th);
  218. if(th->result>1)
  219. CGI->mh->printObject(hmd.ho);
  220. int player = gs->map->objects[th->id]->getOwner();
  221. if(playerint[player])
  222. {
  223. playerint[player]->tileRevealed(th->fowRevealed);
  224. //std::for_each(th->fowRevealed.begin(),th->fowRevealed.end(),boost::bind(&CGameInterface::tileRevealed,playerint[player],_1));
  225. }
  226. //notify interfaces about move
  227. for(std::map<ui8, CGameInterface*>::iterator i=playerint.begin();i!=playerint.end();i++)
  228. {
  229. if(i->first >= PLAYER_LIMIT) continue;
  230. if(gs->players[i->first].fogOfWarMap[th->start.x-1][th->start.y][th->start.z] || gs->players[i->first].fogOfWarMap[th->end.x-1][th->end.y][th->end.z])
  231. {
  232. i->second->heroMoved(hmd);
  233. }
  234. }
  235. //add info for callback
  236. if(th->result<2)
  237. {
  238. mess.mx->lock();
  239. mess.res->insert(th);
  240. mess.mx->unlock();
  241. mess.cv->notify_all();
  242. }
  243. break;
  244. }
  245. case 502:
  246. {
  247. SetGarrisons sg;
  248. *serv >> sg;
  249. tlog5 << "Setting garrisons." << std::endl;
  250. gs->apply(&sg);
  251. for(std::map<ui32,CCreatureSet>::iterator i = sg.garrs.begin(); i!=sg.garrs.end(); i++)
  252. playerint[gs->map->objects[i->first]->tempOwner]->garrisonChanged(gs->map->objects[i->first]);
  253. break;
  254. }
  255. case 503:
  256. {
  257. //SetStrInfo ssi;
  258. //*serv >> ssi;
  259. //gs->apply(&ssi);
  260. //TODO: notify interfaces
  261. break;
  262. }
  263. case 504:
  264. {
  265. NewStructures ns;
  266. *serv >> ns;
  267. CGTownInstance *town = static_cast<CGTownInstance*>(gs->map->objects[ns.tid]);
  268. tlog5 << "New structure(s) in " << ns.tid <<" " << town->name << " - " << *ns.bid.begin() << std::endl;
  269. gs->apply(&ns);
  270. BOOST_FOREACH(si32 bid, ns.bid)
  271. {
  272. if(bid==13) //for or capitol
  273. {
  274. town->defInfo = gs->capitols[town->subID];
  275. }
  276. if(bid ==7)
  277. {
  278. town->defInfo = gs->forts[town->subID];
  279. }
  280. playerint[town->tempOwner]->buildChanged(town,bid,1);
  281. }
  282. break;
  283. }
  284. case 506:
  285. {
  286. SetAvailableCreatures ns;
  287. *serv >> ns;
  288. tlog5 << "Setting available creatures in " << ns.tid << std::endl;
  289. gs->apply(&ns);
  290. CGTownInstance *t = gs->getTown(ns.tid);
  291. if(vstd::contains(playerint,t->tempOwner))
  292. playerint[t->tempOwner]->availableCreaturesChanged(t);
  293. break;
  294. }
  295. case 508:
  296. {
  297. SetHeroesInTown inTown;
  298. *serv >> inTown;
  299. tlog5 << "Setting heroes in town " << inTown.tid << std::endl;
  300. gs->apply(&inTown);
  301. CGTownInstance *t = gs->getTown(inTown.tid);
  302. if(vstd::contains(playerint,t->tempOwner))
  303. playerint[t->tempOwner]->heroInGarrisonChange(t);
  304. break;
  305. }
  306. case 509:
  307. {
  308. SetHeroArtifacts sha;
  309. *serv >> sha;
  310. tlog5 << "Setting artifacts of hero " << sha.hid << std::endl;
  311. gs->apply(&sha);
  312. CGHeroInstance *t = gs->getHero(sha.hid);
  313. if(vstd::contains(playerint,t->tempOwner))
  314. playerint[t->tempOwner]->heroArtifactSetChanged(t);
  315. break;
  316. }
  317. case 513:
  318. {
  319. ui8 color;
  320. std::string message;
  321. *serv >> color >> message;
  322. tlog4 << "Player "<<(int)color<<" sends a message: " << message << std::endl;
  323. break;
  324. }
  325. case 514:
  326. {
  327. SetSelection ss;
  328. *serv >> ss;
  329. tlog5 << "Selection of player " << (int)ss.player << " set to " << ss.id << std::endl;
  330. gs->apply(&ss);
  331. break;
  332. }
  333. case 515:
  334. {
  335. HeroRecruited hr;
  336. *serv >> hr;
  337. tlog5 << "New hero bought\n";
  338. CGHeroInstance *h = gs->hpool.heroesPool[hr.hid];
  339. gs->apply(&hr);
  340. CGI->mh->initHeroDef(h);
  341. //CGI->mh->printObject(h);
  342. playerint[h->tempOwner]->heroCreated(h);
  343. playerint[h->tempOwner]->heroInGarrisonChange(gs->getTown(hr.tid));
  344. break;
  345. }
  346. case 1001:
  347. {
  348. SetObjectProperty sop;
  349. *serv >> sop;
  350. tlog5 << "Setting " << (unsigned)sop.what << " property of " << sop.id <<" object to "<<sop.val<<std::endl;
  351. gs->apply(&sop);
  352. break;
  353. }
  354. case 1002:
  355. {
  356. SetHoverName shn;
  357. *serv >> shn;
  358. tlog5 << "Setting a name of " << shn.id <<" object to "<< toString(shn.name) <<std::endl;
  359. gs->apply(&shn);
  360. break;
  361. }
  362. case 2000:
  363. {
  364. HeroLevelUp bs;
  365. *serv >> bs;
  366. tlog5 << "Hero levels up!" <<std::endl;
  367. gs->apply(&bs);
  368. CGHeroInstance *h = gs->getHero(bs.heroid);
  369. if(vstd::contains(playerint,h->tempOwner))
  370. {
  371. boost::function<void(ui32)> callback = boost::function<void(ui32)>(boost::bind(&CCallback::selectionMade,LOCPLINT->cb,_1,bs.id));
  372. playerint[h->tempOwner]->heroGotLevel((const CGHeroInstance *)h,(int)bs.primskill,bs.skills, callback);
  373. }
  374. break;
  375. }
  376. case 2001:
  377. {
  378. SelectionDialog sd;
  379. *serv >> sd;
  380. tlog5 << "Showing selection dialog " <<std::endl;
  381. std::vector<Component*> comps;
  382. for(size_t i=0; i < sd.components.size(); ++i) {
  383. comps.push_back(&sd.components[i]);
  384. }
  385. std::string str = toString(sd.text);
  386. playerint[sd.player]->showSelDialog(str,comps,sd.id);
  387. break;
  388. }
  389. case 2002:
  390. {
  391. YesNoDialog ynd;
  392. *serv >> ynd;
  393. tlog5 << "Showing yes/no dialog " <<std::endl;
  394. std::vector<Component*> comps;
  395. for(size_t i=0; i < ynd.components.size(); ++i) {
  396. comps.push_back(&ynd.components[i]);
  397. }
  398. std::string str = toString(ynd.text);
  399. playerint[ynd.player]->showYesNoDialog(str,comps,ynd.id);
  400. break;
  401. }
  402. case 3000:
  403. {
  404. BattleStart bs;
  405. *serv >> bs; //uses new to allocate memory for battleInfo - must be deleted when battle is over
  406. tlog5 << "Starting battle!" <<std::endl;
  407. gs->apply(&bs);
  408. if(playerint.find(gs->curB->side1) != playerint.end())
  409. playerint[gs->curB->side1]->battleStart(&gs->curB->army1, &gs->curB->army2, gs->curB->tile, gs->getHero(gs->curB->hero1), gs->getHero(gs->curB->hero2), 0);
  410. if(playerint.find(gs->curB->side2) != playerint.end())
  411. playerint[gs->curB->side2]->battleStart(&gs->curB->army1, &gs->curB->army2, gs->curB->tile, gs->getHero(gs->curB->hero1), gs->getHero(gs->curB->hero2), 1);
  412. break;
  413. }
  414. case 3001:
  415. {
  416. BattleNextRound bnr;
  417. *serv >> bnr;
  418. tlog5 << "Round nr " << bnr.round <<std::endl;
  419. gs->apply(&bnr);
  420. //tell players about next round
  421. if(playerint.find(gs->curB->side1) != playerint.end())
  422. playerint[gs->curB->side1]->battleNewRound(bnr.round);
  423. if(playerint.find(gs->curB->side2) != playerint.end())
  424. playerint[gs->curB->side2]->battleNewRound(bnr.round);
  425. break;
  426. }
  427. case 3002:
  428. {
  429. BattleSetActiveStack sas;
  430. *serv >> sas;
  431. tlog5 << "Active stack: " << sas.stack <<std::endl;
  432. gs->apply(&sas);
  433. int owner = gs->curB->getStack(sas.stack)->owner;
  434. boost::thread(boost::bind(&CClient::waitForMoveAndSend,this,owner));
  435. break;
  436. }
  437. case 3003:
  438. {
  439. BattleResult br;
  440. *serv >> br;
  441. tlog5 << "Battle ends. Winner: " << (unsigned)br.winner<< ". Type of end: "<< (unsigned)br.result <<std::endl;
  442. if(playerint.find(gs->curB->side1) != playerint.end())
  443. playerint[gs->curB->side1]->battleEnd(&br);
  444. if(playerint.find(gs->curB->side2) != playerint.end())
  445. playerint[gs->curB->side2]->battleEnd(&br);
  446. gs->apply(&br);
  447. break;
  448. }
  449. case 3004:
  450. {
  451. BattleStackMoved br;
  452. *serv >> br;
  453. tlog5 << "Stack "<<br.stack <<" moves to the tile "<<br.tile<<std::endl;
  454. if(playerint.find(gs->curB->side1) != playerint.end())
  455. playerint[gs->curB->side1]->battleStackMoved(br.stack,br.tile);
  456. if(playerint.find(gs->curB->side2) != playerint.end())
  457. playerint[gs->curB->side2]->battleStackMoved(br.stack,br.tile);
  458. gs->apply(&br);
  459. break;
  460. }
  461. case 3005:
  462. {
  463. BattleStackAttacked bsa;
  464. *serv >> bsa;
  465. gs->apply(&bsa);
  466. if(playerint.find(gs->curB->side1) != playerint.end())
  467. playerint[gs->curB->side1]->battleStackAttacked(&bsa);
  468. if(playerint.find(gs->curB->side2) != playerint.end())
  469. playerint[gs->curB->side2]->battleStackAttacked(&bsa);
  470. break;
  471. }
  472. case 3006:
  473. {
  474. BattleAttack ba;
  475. *serv >> ba;
  476. tlog5 << "Stack: " << ba.stackAttacking << " is attacking stack "<< ba.bsa.stackAttacked <<std::endl;
  477. if(playerint.find(gs->curB->side1) != playerint.end())
  478. playerint[gs->curB->side1]->battleAttack(&ba);
  479. if(playerint.find(gs->curB->side2) != playerint.end())
  480. playerint[gs->curB->side2]->battleAttack(&ba);
  481. gs->apply(&ba);
  482. if(playerint.find(gs->curB->side1) != playerint.end())
  483. playerint[gs->curB->side1]->battleStackAttacked(&ba.bsa);
  484. if(playerint.find(gs->curB->side2) != playerint.end())
  485. playerint[gs->curB->side2]->battleStackAttacked(&ba.bsa);
  486. break;
  487. }
  488. case 3007:
  489. {
  490. *serv >> curbaction;
  491. tlog5 << "Action started. ID: " << (int)curbaction.actionType << ". Destination: "<< curbaction.destinationTile <<std::endl;
  492. if(playerint.find(gs->curB->side1) != playerint.end())
  493. playerint[gs->curB->side1]->actionStarted(&curbaction);
  494. if(playerint.find(gs->curB->side2) != playerint.end())
  495. playerint[gs->curB->side2]->actionStarted(&curbaction);
  496. gs->apply(&StartAction(curbaction));
  497. break;
  498. }
  499. case 3008:
  500. {
  501. tlog5 << "Action ended!\n";
  502. if(!gs->curB)
  503. {
  504. tlog2 << "There is no battle state!\n";
  505. break;
  506. }
  507. if(playerint.find(gs->curB->side1) != playerint.end())
  508. playerint[gs->curB->side1]->actionFinished(&curbaction);
  509. if(playerint.find(gs->curB->side2) != playerint.end())
  510. playerint[gs->curB->side2]->actionFinished(&curbaction);
  511. break;
  512. }
  513. case 3009:
  514. {
  515. tlog5 << "Spell casted!\n";
  516. SpellCasted sc;
  517. *serv >> sc;
  518. gs->apply(&sc);
  519. if(playerint.find(gs->curB->side1) != playerint.end())
  520. playerint[gs->curB->side1]->battleSpellCasted(&sc);
  521. if(playerint.find(gs->curB->side2) != playerint.end())
  522. playerint[gs->curB->side2]->battleSpellCasted(&sc);
  523. break;
  524. }
  525. case 3010:
  526. {
  527. tlog5 << "Effect set!\n";
  528. SetStackEffect sse;
  529. *serv >> sse;
  530. gs->apply(&sse);
  531. SpellCasted sc;
  532. sc.id = sse.stack;
  533. sc.side = 3; //doesn't matter
  534. sc.skill = sse.effect.level;
  535. sc.tile = gs->curB->getStack(sse.stack)->position;
  536. if(playerint.find(gs->curB->side1) != playerint.end())
  537. playerint[gs->curB->side1]->battleSpellCasted(&sc);
  538. if(playerint.find(gs->curB->side2) != playerint.end())
  539. playerint[gs->curB->side2]->battleSpellCasted(&sc);
  540. break;
  541. }
  542. case 9999:
  543. break;
  544. default:
  545. {
  546. std::ostringstream ex;
  547. ex << "Not supported server message (type=" << what <<")";
  548. throw ex.str();
  549. }
  550. }
  551. }
  552. void CClient::waitForMoveAndSend(int color)
  553. {
  554. try
  555. {
  556. BattleAction ba = playerint[color]->activeStack(gs->curB->activeStack);
  557. *serv << ui16(3002) << ba;
  558. return;
  559. }HANDLE_EXCEPTION
  560. tlog1 << "We should not be here!" << std::endl;
  561. }
  562. void CClient::run()
  563. {
  564. try
  565. {
  566. ui16 typ;
  567. while(1)
  568. {
  569. *serv >> typ;
  570. process(typ);
  571. }
  572. } HANDLE_EXCEPTION
  573. }
  574. void CClient::close()
  575. {
  576. if(!serv)
  577. return;
  578. tlog3 << "Connection has been requested to be closed.\n";
  579. boost::unique_lock<boost::mutex>(*serv->wmx);
  580. *serv << ui16(99);
  581. tlog3 << "Sent closing signal to the server\n";
  582. serv->close();
  583. tlog3 << "Our socket has been closed.\n";
  584. }
  585. void CClient::save(const std::string & fname)
  586. {
  587. *serv << ui16(98) << fname;
  588. }
  589. void CClient::load( const std::string & fname )
  590. {
  591. tlog0 <<"\n\nLoading procedure started!\n\n";
  592. timeHandler tmh;
  593. close(); //kill server
  594. tlog0 <<"Sent kill signal to the server: "<<tmh.getDif()<<std::endl;
  595. VLC->clear(); //delete old handlers
  596. delete CGI->mh;
  597. delete CGI->state;
  598. //TODO: del callbacks
  599. for(std::map<ui8,CGameInterface *>::iterator i = playerint.begin(); i!=playerint.end(); i++)
  600. {
  601. delete i->second; //delete player interfaces
  602. }
  603. tlog0 <<"Deleting old data: "<<tmh.getDif()<<std::endl;
  604. char portc[10];
  605. SDL_itoa(conf.cc.port,portc,10);
  606. runServer(portc); //create new server
  607. tlog0 <<"Restarting server: "<<tmh.getDif()<<std::endl;
  608. {
  609. char sig[8];
  610. CMapHeader dum;
  611. CGI->mh = new CMapHandler();
  612. CLoadFile lf(fname + ".vlgm1");
  613. lf >> sig >> dum;
  614. tlog0 <<"Reading save signature: "<<tmh.getDif()<<std::endl;
  615. lf >> *VLC;
  616. CGI->setFromLib();
  617. tlog0 <<"Reading handlers: "<<tmh.getDif()<<std::endl;
  618. lf >> gs;
  619. tlog0 <<"Reading gamestate: "<<tmh.getDif()<<std::endl;
  620. CGI->state = gs;
  621. CGI->mh->map = gs->map;
  622. CGI->mh->init();
  623. tlog0 <<"Initing maphandler: "<<tmh.getDif()<<std::endl;
  624. }
  625. waitForServer();
  626. tlog0 <<"Waiting for server: "<<tmh.getDif()<<std::endl;
  627. serv = new CConnection(conf.cc.server,portc,NAME);
  628. tlog0 <<"Setting up connection: "<<tmh.getDif()<<std::endl;
  629. ui8 pom8;
  630. *serv << ui8(3) << ui8(1); //load game; one client
  631. *serv << fname;
  632. *serv >> pom8;
  633. if(pom8)
  634. throw "Server cannot open the savegame!";
  635. else
  636. tlog0 << "Server opened savegame properly.\n";
  637. *serv << ui8(gs->scenarioOps->playerInfos.size()+1); //number of players + neutral
  638. for(size_t i=0;i<gs->scenarioOps->playerInfos.size();i++)
  639. {
  640. *serv << ui8(gs->scenarioOps->playerInfos[i].color); //players
  641. }
  642. *serv << ui8(255); // neutrals
  643. tlog0 <<"Sent info to server: "<<tmh.getDif()<<std::endl;
  644. for (size_t i=0; i<gs->scenarioOps->playerInfos.size();++i) //initializing interfaces for players
  645. {
  646. ui8 color = gs->scenarioOps->playerInfos[i].color;
  647. CCallback *cb = new CCallback(gs,color,this);
  648. if(!gs->scenarioOps->playerInfos[i].human) {
  649. playerint[color] = static_cast<CGameInterface*>(CAIHandler::getNewAI(cb,conf.cc.defaultAI));
  650. }
  651. else {
  652. playerint[color] = new CPlayerInterface(color,i);
  653. }
  654. gs->currentPlayer = color;
  655. playerint[color]->init(cb);
  656. tlog0 <<"Setting up interface for player "<< (int)color <<": "<<tmh.getDif()<<std::endl;
  657. }
  658. playerint[255] = CAIHandler::getNewAI(cb,conf.cc.defaultAI);
  659. playerint[255]->init(new CCallback(gs,255,this));
  660. tlog0 <<"Setting up interface for neutral \"player\"" << tmh.getDif() << std::endl;
  661. }
  662. int CClient::getCurrentPlayer()
  663. {
  664. return gs->currentPlayer;
  665. }
  666. int CClient::getSelectedHero()
  667. {
  668. return IGameCallback::getSelectedHero(getCurrentPlayer())->id;
  669. }
  670. void CClient::newGame( CConnection *con, StartInfo *si )
  671. {
  672. timeHandler tmh;
  673. CGI->state = new CGameState();
  674. tlog0 <<"\tGamestate: "<<tmh.getDif()<<std::endl;
  675. serv = con;
  676. CConnection &c(*con);
  677. ////////////////////////////////////////////////////
  678. ui8 pom8;
  679. c << ui8(2) << ui8(1); //new game; one client
  680. c << *si;
  681. c >> pom8;
  682. if(pom8)
  683. throw "Server cannot open the map!";
  684. else
  685. tlog0 << "Server opened map properly.\n";
  686. c << ui8(si->playerInfos.size()+1); //number of players + neutral
  687. for(size_t i=0;i<si->playerInfos.size();i++)
  688. {
  689. c << ui8(si->playerInfos[i].color); //players
  690. }
  691. c << ui8(255); // neutrals
  692. ui32 seed, sum;
  693. std::string mapname;
  694. c >> mapname >> sum >> seed;
  695. tlog0 <<"\tSending/Getting info to/from the server: "<<tmh.getDif()<<std::endl;
  696. Mapa * mapa = new Mapa(mapname);
  697. tlog0 <<"Reading and detecting map file (together): "<<tmh.getDif()<<std::endl;
  698. tlog0 << "\tServer checksum for "<<mapname <<": "<<sum << std::endl;
  699. tlog0 << "\tOur checksum for the map: "<< mapa->checksum << std::endl;
  700. if(mapa->checksum != sum)
  701. {
  702. tlog1 << "Wrong map checksum!!!" << std::endl;
  703. throw std::string("Wrong checksum");
  704. }
  705. tlog0 << "\tUsing random seed: "<<seed << std::endl;
  706. gs = CGI->state;
  707. gs->scenarioOps = si;
  708. gs->init(si,mapa,seed);
  709. CGI->mh = new CMapHandler();
  710. tlog0 <<"Initializing GameState (together): "<<tmh.getDif()<<std::endl;
  711. CGI->mh->map = mapa;
  712. tlog0 <<"Creating mapHandler: "<<tmh.getDif()<<std::endl;
  713. CGI->mh->init();
  714. tlog0 <<"Initializing mapHandler (together): "<<tmh.getDif()<<std::endl;
  715. for (size_t i=0; i<CGI->state->scenarioOps->playerInfos.size();++i) //initializing interfaces for players
  716. {
  717. ui8 color = gs->scenarioOps->playerInfos[i].color;
  718. CCallback *cb = new CCallback(gs,color,this);
  719. if(!gs->scenarioOps->playerInfos[i].human) {
  720. playerint[color] = static_cast<CGameInterface*>(CAIHandler::getNewAI(cb,conf.cc.defaultAI));
  721. }
  722. else {
  723. playerint[color] = new CPlayerInterface(color,i);
  724. }
  725. gs->currentPlayer = color;
  726. playerint[color]->init(cb);
  727. }
  728. playerint[255] = CAIHandler::getNewAI(cb,conf.cc.defaultAI);
  729. playerint[255]->init(new CCallback(gs,255,this));
  730. }
  731. void CClient::runServer(const char * portc)
  732. {
  733. static std::string comm = std::string(SERVER_NAME) + " " + portc + " > server_log.txt"; //needs to be static, if not - will be probably destroyed before new thread reads it
  734. boost::thread servthr(boost::bind(system,comm.c_str())); //runs server executable; //TODO: will it work on non-windows platforms?
  735. }
  736. void CClient::waitForServer()
  737. {
  738. {
  739. intpr::scoped_lock<intpr::interprocess_mutex> slock(sm.sr->mutex);
  740. while(!sm.sr->ready)
  741. {
  742. sm.sr->cond.wait(slock);
  743. }
  744. }
  745. intpr::shared_memory_object::remove("vcmi_memory");
  746. }