Planet
navi homePPSaboutscreenshotsdownloaddevelopmentforum

source: code/branches/presentation/src/network/packet/Gamestate.cc @ 2474

Last change on this file since 2474 was 2464, checked in by rgrieder, 16 years ago

Bugfix in network: When checking for other objectIDs, it was possible that within the constructor of one Synchronisable, another one was created. In the check then, both have objectID == OBJECTID_UNKNOWN because the objectID of the first object was not yet set (done after construction).

  • Moved the check to Gamestate, after ALL objects of one packet have been created.
  • Property svn:eol-style set to native
File size: 21.2 KB
RevLine 
[1711]1/*
2 *   ORXONOX - the hottest 3D action shooter ever to exist
3 *                    > www.orxonox.net <
4 *
5 *
6 *   License notice:
7 *
8 *   This program is free software; you can redistribute it and/or
9 *   modify it under the terms of the GNU General Public License
10 *   as published by the Free Software Foundation; either version 2
11 *   of the License, or (at your option) any later version.
12 *
13 *   This program is distributed in the hope that it will be useful,
14 *   but WITHOUT ANY WARRANTY; without even the implied warranty of
15 *   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
16 *   GNU General Public License for more details.
17 *
18 *   You should have received a copy of the GNU General Public License
19 *   along with this program; if not, write to the Free Software
20 *   Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA  02110-1301, USA.
21 *
22 *   Author:
23 *      Oliver Scheuss, (C) 2008
24 *   Co-authors:
25 *      ...
26 *
27 */
28
[1701]29#include "Gamestate.h"
[2371]30#include "../GamestateHandler.h"
31#include "../synchronisable/Synchronisable.h"
32#include "../TrafficControl.h"
[1763]33#include "core/CoreIncludes.h"
[1751]34#include "core/Iterator.h"
[1701]35
36#include <zlib.h>
37#include <assert.h>
38
39
40
[2171]41namespace orxonox {
[1701]42
43namespace packet {
44
[1751]45#define GAMESTATE_START(data) (data + sizeof(GamestateHeader))
[1701]46#define GAMESTATE_HEADER(data) ((GamestateHeader *)data)
47#define HEADER GAMESTATE_HEADER(data_)
[1740]48
[2087]49
[1907]50#define PACKET_FLAG_GAMESTATE  ENET_PACKET_FLAG_RELIABLE
[2087]51
[1701]52Gamestate::Gamestate()
53{
[1907]54  flags_ = flags_ | PACKET_FLAG_GAMESTATE;
[1701]55}
56
[1907]57Gamestate::Gamestate(uint8_t *data, unsigned int clientID):
[1711]58    Packet(data, clientID)
[1701]59{
[1907]60  flags_ = flags_ | PACKET_FLAG_GAMESTATE;
[1701]61}
62
[1907]63Gamestate::Gamestate(uint8_t *data)
64{
65  flags_ = flags_ | PACKET_FLAG_GAMESTATE;
66  data_=data;
67}
[1701]68
[1907]69
[1701]70Gamestate::~Gamestate()
71{
72}
73
[2171]74bool Gamestate::collectData(int id, uint8_t mode)
[1701]75{
[2371]76  uint32_t tempsize=0, currentsize=0;
[1751]77  assert(data_==0);
[2371]78  uint32_t size = calcGamestateSize(id, mode);
[1740]79
[1701]80  COUT(4) << "G.ST.Man: producing gamestate with id: " << id << std::endl;
81  if(size==0)
82    return false;
83  data_ = new unsigned char[size + sizeof(GamestateHeader)];
84  if(!data_){
85    COUT(2) << "GameStateManager: could not allocate memory" << std::endl;
86    return false;
87  }
[2087]88
[1701]89  //start collect data synchronisable by synchronisable
[1907]90  uint8_t *mem=data_;
[1701]91  mem+=sizeof(GamestateHeader);
[2171]92  ObjectList<Synchronisable>::iterator it;
93  for(it = ObjectList<Synchronisable>::begin(); it; ++it){
[1907]94    tempsize=it->getSize(id, mode);
[1740]95
[1701]96    if(currentsize+tempsize > size){
[2171]97      assert(0); // if we don't use multithreading this part shouldn't be neccessary
[1701]98      // start allocate additional memory
99      COUT(3) << "G.St.Man: need additional memory" << std::endl;
[2171]100      ObjectList<Synchronisable>::iterator temp = it;
[1701]101      int addsize=tempsize;
102      while(++temp)
[1907]103        addsize+=temp->getSize(id, mode);
104      data_ = (uint8_t *)realloc(data_, sizeof(GamestateHeader) + currentsize + addsize);
[1701]105      if(!data_)
106        return false;
107      size = currentsize+addsize;
108    }// stop allocate additional memory
109
[2087]110
[1907]111    //if(it->doSelection(id))
[2371]112    if(tempsize!=0)
113      dataMap_.push_back( obj(it->getObjectID(), it->getCreatorID(), tempsize, mem-data_) );
114//     dataMap_[mem-data_]=(*it);  // save the mem location of the synchronisable data
[1751]115    if(!it->getData(mem, id, mode))
[1701]116      return false; // mem pointer gets automatically increased because of call by reference
117    // increase size counter by size of current synchronisable
118    currentsize+=tempsize;
119  }
[1740]120
121
[1701]122  //start write gamestate header
[1710]123  HEADER->packetType = ENUM::Gamestate;
[1907]124  HEADER->datasize = currentsize;
[1701]125  HEADER->id = id;
126  HEADER->diffed = false;
127  HEADER->complete = true;
[1715]128  HEADER->compressed = false;
[1701]129  //stop write gamestate header
[1740]130
[1701]131  COUT(5) << "G.ST.Man: Gamestate size: " << currentsize << std::endl;
132  COUT(5) << "G.ST.Man: 'estimated' (and corrected) Gamestate size: " << size << std::endl;
133  return true;
134}
135
[2171]136bool Gamestate::spreadData(uint8_t mode)
[1701]137{
[1751]138  assert(data_);
139  assert(!HEADER->compressed);
140  assert(!HEADER->diffed);
[1907]141  uint8_t *mem=data_+sizeof(GamestateHeader);
[1701]142    // get the start of the Synchronisable list
[2171]143  //ObjectList<Synchronisable>::iterator it=ObjectList<Synchronisable>::begin();
[1907]144  Synchronisable *s;
[1740]145
[1907]146  // update the data of the objects we received
147  while(mem < data_+sizeof(GamestateHeader)+HEADER->datasize){
148    synchronisableHeader *objectheader = (synchronisableHeader*)mem;
[1701]149
[1907]150    s = Synchronisable::getSynchronisable( objectheader->objectID );
151    if(!s)
[1701]152    {
[2417]153      Synchronisable::fabricate(mem, mode);
[2371]154//         COUT(0) << "could not fabricate synchronisable: " << objectheader->objectID << " classid: " << objectheader->classID << " creator: " << objectheader->creatorID << endl;
155//       else
156//         COUT(0) << "fabricated: " << objectheader->objectID << " classid: " << objectheader->classID << " creator: "  << objectheader->creatorID << endl;
[1701]157    }
[1907]158    else
159    {
160      bool b = s->updateData(mem, mode);
161      assert(b);
162    }
[1701]163  }
164
[2464]165   // In debug mode, check first, whether there are no duplicate objectIDs
166#ifndef NDEBUG
167  ObjectList<Synchronisable>::iterator it;
168  for (it = ObjectList<Synchronisable>::begin(); it != ObjectList<Synchronisable>::end(); ++it) {
169    if (it->getObjectID() == OBJECTID_UNKNOWN) {
170      if (it->objectMode_ != 0x0) {
171        COUT(0) << "Found object with OBJECTID_UNKNOWN on the client with objectMode != 0x0!" << std::endl;
172        assert(false);
173      }
174    }
175    else {
176      ObjectList<Synchronisable>::iterator it2;
177      for (it2 = ObjectList<Synchronisable>::begin(); it2 != ObjectList<Synchronisable>::end(); ++it2) {
178        if (it->getObjectID() == it2->getObjectID() && *it != *it2) {
179           COUT(0) << "Found duplicate objectIDs on the client!" << std::endl
180                   << "Are you sure you don't create a Sychnronisable objcect with 'new' \
181                       that doesn't have objectMode = 0x0?" << std::endl;
182           assert(false);
183        }
184      }
185    }
186  }
187#endif
188
[1701]189  return true;
190}
191
[1907]192
193
[1705]194int Gamestate::getID(){
195  return HEADER->id;
196}
197
[2371]198uint32_t Gamestate::getSize() const
[1701]199{
[1711]200  assert(data_);
[1715]201  if(HEADER->compressed)
[1701]202    return HEADER->compsize+sizeof(GamestateHeader);
203  else
204  {
[1907]205    return HEADER->datasize+sizeof(GamestateHeader);
[1701]206  }
207}
208
[1751]209bool Gamestate::operator==(packet::Gamestate gs){
[1907]210  uint8_t *d1 = data_+sizeof(GamestateHeader);
211  uint8_t *d2 = gs.data_+sizeof(GamestateHeader);
[1751]212  assert(!isCompressed());
213  assert(!gs.isCompressed());
[1907]214  while(d1<data_+HEADER->datasize)
[1751]215  {
216    if(*d1!=*d2)
217      return false;
218    d1++;
219    d2++;
220  }
221  return true;
222}
223
[1701]224bool Gamestate::process()
225{
[1705]226  return GamestateHandler::addGamestate(this, getClientID());
[1701]227}
228
[1907]229
230
[1701]231bool Gamestate::compressData()
232{
233  assert(HEADER);
[1751]234  assert(!HEADER->compressed);
[1907]235  uLongf buffer = (uLongf)(((HEADER->datasize + 12)*1.01)+1);
[1701]236  if(buffer==0)
237    return false;
[1740]238
[1907]239  uint8_t *ndata = new uint8_t[buffer+sizeof(GamestateHeader)];
240  uint8_t *dest = GAMESTATE_START(ndata);
[1751]241  //unsigned char *dest = new unsigned char[buffer];
[1907]242  uint8_t *source = GAMESTATE_START(data_);
[1701]243  int retval;
[1907]244  retval = compress( dest, &buffer, source, (uLong)(HEADER->datasize) );
[1701]245  switch ( retval ) {
246    case Z_OK: COUT(5) << "G.St.Man: compress: successfully compressed" << std::endl; break;
[1751]247    case Z_MEM_ERROR: COUT(1) << "G.St.Man: compress: not enough memory available in gamestate.compress" << std::endl; return false;
248    case Z_BUF_ERROR: COUT(2) << "G.St.Man: compress: not enough memory available in the buffer in gamestate.compress" << std::endl; return false;
249    case Z_DATA_ERROR: COUT(2) << "G.St.Man: compress: data corrupted in gamestate.compress" << std::endl; return false;
[1701]250  }
[1751]251#ifndef NDEBUG
252  //decompress and compare the start and the decompressed data
[1907]253  uint8_t *rdata = new uint8_t[HEADER->datasize+sizeof(GamestateHeader)];
254  uint8_t *d2 = GAMESTATE_START(rdata);
255  uLongf length2 = HEADER->datasize;
[1751]256  uncompress(d2, &length2, dest, buffer);
[1907]257  for(unsigned int i=0; i<HEADER->datasize; i++){
[1751]258    assert(*(source+i)==*(d2+i));
259  }
260  delete[] rdata;
261#endif
[1701]262
263  //copy and modify header
[1751]264#ifndef NDEBUG
[1907]265  HEADER->crc32 = calcCRC(data_+sizeof(GamestateHeader), HEADER->datasize);
[1751]266#endif
[1701]267  *GAMESTATE_HEADER(ndata) = *HEADER;
268  //delete old data
269  delete[] data_;
270  //save new data
271  data_ = ndata;
[1751]272  HEADER->compsize = buffer;
273  HEADER->compressed = true;
[1730]274  assert(HEADER->compressed);
[2087]275  COUT(4) << "gamestate compress datasize: " << HEADER->datasize << " compsize: " << HEADER->compsize << std::endl;
[1701]276  return true;
277}
278bool Gamestate::decompressData()
279{
[1751]280  assert(HEADER);
[1715]281  assert(HEADER->compressed);
[2087]282  COUT(4) << "GameStateClient: uncompressing gamestate. id: " << HEADER->id << ", baseid: " << HEADER->base_id << ", datasize: " << HEADER->datasize << ", compsize: " << HEADER->compsize << std::endl;
[2371]283  uint32_t datasize = HEADER->datasize;
284  uint32_t compsize = HEADER->compsize;
285  uint32_t bufsize;
[2087]286//  assert(compsize<=datasize);
[1907]287  bufsize = datasize;
[1751]288  assert(bufsize!=0);
[1907]289  uint8_t *ndata = new uint8_t[bufsize + sizeof(GamestateHeader)];
290  uint8_t *dest = ndata + sizeof(GamestateHeader);
291  uint8_t *source = data_ + sizeof(GamestateHeader);
[1701]292  int retval;
[1751]293  uLongf length=bufsize;
294  retval = uncompress( dest, &length, source, (uLong)compsize );
[1701]295  switch ( retval ) {
296    case Z_OK: COUT(5) << "successfully decompressed" << std::endl; break;
297    case Z_MEM_ERROR: COUT(1) << "not enough memory available" << std::endl; return false;
298    case Z_BUF_ERROR: COUT(2) << "not enough memory available in the buffer" << std::endl; return false;
299    case Z_DATA_ERROR: COUT(2) << "data corrupted (zlib)" << std::endl; return false;
300  }
[1751]301#ifndef NDEBUG
[1907]302  assert(HEADER->crc32==calcCRC(ndata+sizeof(GamestateHeader), HEADER->datasize));
[1751]303#endif
[1752]304
[1701]305  //copy over the header
306  *GAMESTATE_HEADER(ndata) = *HEADER;
[2087]307
308  if (this->bDataENetAllocated_){
309    // Memory was allocated by ENet. --> We let it be since enet_packet_destroy will
310    // deallocated it anyway. So data and packet stay together.
311    this->bDataENetAllocated_ = false;
312  }
313  else{
314    // We allocated the memory in the first place (unlikely). So we destroy the old data
315    // and overwrite it with the new decompressed data.
316    delete[] this->data_;
317  }
318
[1751]319  //set new pointers
[1701]320  data_ = ndata;
[1751]321  HEADER->compressed = false;
[1907]322  assert(HEADER->datasize==datasize);
[1751]323  assert(HEADER->compsize==compsize);
[1701]324  return true;
325}
326
327Gamestate *Gamestate::diff(Gamestate *base)
328{
[1751]329  assert(HEADER);
330  assert(!HEADER->compressed);
331  assert(!HEADER->diffed);
[1701]332  //unsigned char *basep = base->getGs()/*, *gs = getGs()*/;
[1907]333  uint8_t *basep = GAMESTATE_START(base->data_), *gs = GAMESTATE_START(this->data_);
[2371]334  uint32_t of=0; // pointers offset
335  uint32_t dest_length=0;
[1907]336  dest_length=HEADER->datasize;
[1701]337  if(dest_length==0)
338    return NULL;
[1907]339  uint8_t *ndata = new uint8_t[dest_length*sizeof(uint8_t)+sizeof(GamestateHeader)];
340  uint8_t *dest = ndata + sizeof(GamestateHeader);
341  while(of < GAMESTATE_HEADER(base->data_)->datasize && of < HEADER->datasize){
[1701]342    *(dest+of)=*(basep+of)^*(gs+of); // do the xor
343    ++of;
344  }
[1907]345  if(GAMESTATE_HEADER(base->data_)->datasize!=HEADER->datasize){
346    uint8_t n=0;
347    if(GAMESTATE_HEADER(base->data_)->datasize < HEADER->datasize){
[1701]348      while(of<dest_length){
349        *(dest+of)=n^*(gs+of);
350        of++;
351      }
352    }
353  }
354
[1715]355  *GAMESTATE_HEADER(ndata) = *HEADER;
356  GAMESTATE_HEADER(ndata)->diffed = true;
[1751]357  GAMESTATE_HEADER(ndata)->base_id = base->getID();
358  Gamestate *g = new Gamestate(ndata, getClientID());
359  g->flags_=flags_;
360  g->packetDirection_ = packetDirection_;
[1701]361  return g;
362}
363
[2371]364Gamestate* Gamestate::doSelection(unsigned int clientID, unsigned int targetSize){
[1907]365  assert(data_);
[2371]366  std::list<obj>::iterator it;
[2087]367
[1907]368  // allocate memory for new data
369  uint8_t *gdata = new uint8_t[HEADER->datasize+sizeof(GamestateHeader)];
370  // create a gamestate out of it
371  Gamestate *gs = new Gamestate(gdata);
372  uint8_t *newdata = gdata + sizeof(GamestateHeader);
[2417]373  uint8_t *origdata = GAMESTATE_START(data_);
[2087]374
[1907]375  //copy the GamestateHeader
376  *(GamestateHeader*)gdata = *HEADER;
[2087]377
[1907]378  synchronisableHeader *oldobjectheader, *newobjectheader;
[2371]379  uint32_t objectOffset;
380  unsigned int objectsize, destsize=0;
[2435]381  // TODO: Why is this variable not used?
382  //Synchronisable *object;
[2087]383
[2371]384  //call TrafficControl
[2382]385  TrafficControl::getInstance()->processObjectList( clientID, HEADER->id, &dataMap_ );
[2371]386 
[1907]387  //copy in the zeros
[2419]388  for(it=dataMap_.begin(); it!=dataMap_.end();){
[2459]389//    if((*it).objSize==0)
390//      continue;
[2417]391    oldobjectheader = (synchronisableHeader*)origdata;
[1907]392    newobjectheader = (synchronisableHeader*)newdata;
[2417]393//     object = Synchronisable::getSynchronisable( (*it).objID );
394//     assert(object->objectID == oldobjectheader->objectID);
[2371]395    objectsize = oldobjectheader->size;
[2171]396    objectOffset=sizeof(synchronisableHeader); //skip the size and the availableData variables in the objectheader
[2417]397    if ( (*it).objID == oldobjectheader->objectID ){
398      memcpy(newdata, origdata, objectsize);
[2171]399      assert(newobjectheader->dataAvailable==true);
[2419]400      ++it;
[1907]401    }else{
[2417]402      *newobjectheader = *oldobjectheader;
[1907]403      newobjectheader->dataAvailable=false;
[2171]404      memset(newdata+objectOffset, 0, objectsize-objectOffset);
[1907]405    }
406    newdata += objectsize;
[2417]407    origdata += objectsize;
[2371]408    destsize += objectsize;
409//     origdata += objectsize;
[1907]410  }
[2371]411  ((GamestateHeader*)gdata)->datasize = destsize;
[2419]412  assert(destsize==HEADER->datasize);
[2371]413  assert(destsize!=0);
[1907]414  return gs;
415}
416
417
418Gamestate* Gamestate::intelligentDiff(Gamestate *base, unsigned int clientID){
419  // asserts
420  assert(data_);
421  assert(base->data_);
422  assert(!GAMESTATE_HEADER(base->data_)->diffed);
423  assert(!GAMESTATE_HEADER(base->data_)->compressed);
424  assert(!HEADER->compressed);
425  assert(!HEADER->diffed);
[2087]426
[1907]427  //preparations
[2371]428  std::list<obj>::iterator it;
[1907]429  uint8_t *origdata, *basedata, *destdata, *ndata;
[2371]430  uint32_t objectOffset, streamOffset=0;    //data offset
431  uint32_t minsize = (HEADER->datasize < GAMESTATE_HEADER(base->data_)->datasize) ? HEADER->datasize : GAMESTATE_HEADER(base->data_)->datasize;
[1907]432  synchronisableHeader *origheader;
433  synchronisableHeader *destheader;
[2371]434  Synchronisable *object;
[2087]435
[1907]436  origdata = GAMESTATE_START(this->data_);
437  basedata = GAMESTATE_START(base->data_);
438  ndata = new uint8_t[HEADER->datasize + sizeof(GamestateHeader)];
439  destdata = ndata + sizeof(GamestateHeader);
[2087]440
[1907]441  // do the diff
442  for(it=dataMap_.begin(); it!=dataMap_.end(); it++){
443    assert(streamOffset<HEADER->datasize);
444    origheader = (synchronisableHeader *)(origdata+streamOffset);
445    destheader = (synchronisableHeader *)(destdata+streamOffset);
[2371]446    object = Synchronisable::getSynchronisable(origheader->objectID);
447    bool sendData = object->doSelection(HEADER->id);
[2087]448
[1907]449    //copy and partially diff the object header
[2371]450    assert(sizeof(synchronisableHeader)==3*sizeof(uint32_t)+sizeof(bool));
[1907]451    *(uint32_t*)destdata = *(uint32_t*)origdata; //size (do not diff)
452    *(bool*)(destdata+sizeof(uint32_t)) = sendData;
453    if(sendData){
454      *(uint32_t*)(destdata+sizeof(uint32_t)+sizeof(bool)) = *(uint32_t*)(basedata+sizeof(uint32_t)+sizeof(bool)) ^ *(uint32_t*)(origdata+sizeof(uint32_t)+sizeof(bool)); //objectid (diff it)
455      *(uint32_t*)(destdata+2*sizeof(uint32_t)+sizeof(bool)) = *(uint32_t*)(basedata+2*sizeof(uint32_t)+sizeof(bool)) ^ *(uint32_t*)(origdata+2*sizeof(uint32_t)+sizeof(bool)); //classid (diff it)
456    }else{
457      *(uint32_t*)(destdata+sizeof(uint32_t)+sizeof(bool)) = 0;
[2087]458      *(uint32_t*)(destdata+2*sizeof(uint32_t)+sizeof(bool)) = 0;
[1907]459    }
460    objectOffset=sizeof(synchronisableHeader);
461    streamOffset+=sizeof(synchronisableHeader);
[2087]462
[1907]463    //now handle the object data or fill with zeros
464    while(objectOffset<origheader->size ){
[2087]465
[1907]466      if(sendData && streamOffset<minsize)
467        *(destdata+objectOffset)=*(basedata+objectOffset)^*(origdata+objectOffset); // do the xor
468      else if(sendData)
469        *(destdata+objectOffset)=((uint8_t)0)^*(origdata+objectOffset); // xor with 0 (basestream is too short)
470      else
471        *(destdata+objectOffset)=0; // set to 0 because this object should not be transfered
[2087]472
[1907]473      objectOffset++;
474      streamOffset++;
475    }
476    destdata+=objectOffset;
477    origdata+=objectOffset;
478    basedata+=objectOffset;
479  }
[2087]480
[1907]481  //copy over the gamestate header and set the diffed flag
482  *(GamestateHeader *)ndata = *HEADER; //copy over the header
483  Gamestate *gs = new Gamestate(ndata);
484  GAMESTATE_HEADER(ndata)->diffed=true;
485  return gs;
486}
487
488Gamestate* Gamestate::intelligentUnDiff(Gamestate *base){
489  // asserts
490  assert(data_);
491  assert(base->data_);
492  assert(!GAMESTATE_HEADER(base->data_)->diffed);
493  assert(!GAMESTATE_HEADER(base->data_)->compressed);
494  assert(!HEADER->compressed);
495  assert(HEADER->diffed);
[2087]496
[1907]497  //preparations
[2371]498  std::list<obj>::iterator it;
[1907]499  uint8_t *origdata, *basedata, *destdata, *ndata;
[2371]500  uint32_t objectOffset, streamOffset=0;    //data offset
501  uint32_t minsize = (HEADER->datasize < GAMESTATE_HEADER(base->data_)->datasize) ? HEADER->datasize : GAMESTATE_HEADER(base->data_)->datasize;
[1907]502  synchronisableHeader *origheader;
503  synchronisableHeader *destheader;
[2371]504  Synchronisable *object;
[2087]505
[1907]506  origdata = GAMESTATE_START(this->data_);
507  basedata = GAMESTATE_START(base->data_);
508  ndata = new uint8_t[HEADER->datasize + sizeof(GamestateHeader)];
509  destdata = ndata + sizeof(GamestateHeader);
[2087]510
[1907]511  // do the undiff
512  for(it=dataMap_.begin(); it!=dataMap_.end(); it++){
513    assert(streamOffset<HEADER->datasize);
514    origheader = (synchronisableHeader *)(origdata+streamOffset);
515    destheader = (synchronisableHeader *)(destdata+streamOffset);
[2371]516    object = Synchronisable::getSynchronisable( origheader->objectID );
[1907]517    bool sendData;
[2087]518
[1907]519    //copy and partially diff the object header
[2371]520    assert(sizeof(synchronisableHeader)==3*sizeof(uint32_t)+sizeof(bool));
521    *(uint32_t*)destdata = *(uint32_t*)origdata; //size (do not diff)
522    *(bool*)(destdata+sizeof(uint32_t)) = *(bool*)(origdata+sizeof(uint32_t));
523    sendData = *(bool*)(origdata+sizeof(uint32_t));
[1907]524    if(sendData){
[2371]525      *(uint32_t*)(destdata+sizeof(uint32_t)+sizeof(bool)) = *(uint32_t*)(basedata+sizeof(uint32_t)+sizeof(bool)) ^ *(uint32_t*)(origdata+sizeof(uint32_t)+sizeof(bool)); //objectid (diff it)
526      *(uint32_t*)(destdata+2*sizeof(uint32_t)+sizeof(bool)) = *(uint32_t*)(basedata+2*sizeof(uint32_t)+sizeof(bool)) ^ *(uint32_t*)(origdata+2*sizeof(uint32_t)+sizeof(bool)); //classid (diff it)
[1907]527    }else{
[2371]528      *(uint32_t*)(destdata+sizeof(uint32_t)+sizeof(bool)) = 0;
529      *(uint32_t*)(destdata+2*sizeof(uint32_t)+sizeof(bool)) = 0;
[1907]530    }
531    objectOffset=sizeof(synchronisableHeader);
532    streamOffset+=sizeof(synchronisableHeader);
[2087]533
[1907]534    //now handle the object data or fill with zeros
535    while(objectOffset<origheader->size ){
[2087]536
[1907]537      if(sendData && streamOffset<minsize)
538        *(destdata+objectOffset)=*(basedata+objectOffset)^*(origdata+objectOffset); // do the xor
539      else if(sendData)
540        *(destdata+objectOffset)=((unsigned char)0)^*(origdata+objectOffset); // xor with 0 (basestream is too short)
541      else
542        *(destdata+objectOffset)=0; // set to 0 because this object should not be transfered
[2087]543
[1907]544      objectOffset++;
545      streamOffset++;
546    }
547    destdata+=objectOffset;
548    origdata+=objectOffset;
549    basedata+=objectOffset;
550  }
[2087]551
[1907]552  //copy over the gamestate header and set the diffed flag
553  *(GamestateHeader *)ndata = *HEADER; //copy over the header
554  Gamestate *gs = new Gamestate(ndata);
555  GAMESTATE_HEADER(ndata)->diffed=false;
556  return gs;
557}
558
[1701]559Gamestate *Gamestate::undiff(Gamestate *base)
560{
[1751]561  assert(this && base);assert(HEADER);
562  assert(HEADER->diffed);
[1715]563  assert(!HEADER->compressed && !GAMESTATE_HEADER(base->data_)->compressed);
[1701]564  //unsigned char *basep = base->getGs()/*, *gs = getGs()*/;
[1907]565  uint8_t *basep = GAMESTATE_START(base->data_);
566  uint8_t *gs = GAMESTATE_START(this->data_);
[2371]567  uint32_t of=0; // pointers offset
568  uint32_t dest_length=0;
[1907]569  dest_length=HEADER->datasize;
[1701]570  if(dest_length==0)
571    return NULL;
[1907]572  uint8_t *ndata = new uint8_t[dest_length*sizeof(uint8_t)+sizeof(GamestateHeader)];
573  uint8_t *dest = ndata + sizeof(GamestateHeader);
574  while(of < GAMESTATE_HEADER(base->data_)->datasize && of < HEADER->datasize){
[1701]575    *(dest+of)=*(basep+of)^*(gs+of); // do the xor
576    ++of;
577  }
[1907]578  if(GAMESTATE_HEADER(base->data_)->datasize!=HEADER->datasize){
579    uint8_t n=0;
580    if(GAMESTATE_HEADER(base->data_)->datasize < HEADER->datasize){
[1701]581      while(of < dest_length){
582        *(dest+of)=n^*(gs+of);
583        of++;
584      }
585    }
586  }
[1715]587  *GAMESTATE_HEADER(ndata) = *HEADER;
588  GAMESTATE_HEADER(ndata)->diffed = false;
[1751]589  Gamestate *g = new Gamestate(ndata, getClientID());
590  g->flags_=flags_;
591  g->packetDirection_ = packetDirection_;
592  assert(!g->isDiffed());
593  assert(!g->isCompressed());
[1701]594  return g;
595}
596
597
[2371]598uint32_t Gamestate::calcGamestateSize(int32_t id, uint8_t mode)
[1701]599{
[2371]600  uint32_t size=0;
[1701]601    // get the start of the Synchronisable list
[2171]602  ObjectList<Synchronisable>::iterator it;
[1701]603    // get total size of gamestate
[2171]604  for(it = ObjectList<Synchronisable>::begin(); it; ++it)
[1907]605    size+=it->getSize(id, mode); // size of the actual data of the synchronisable
[1701]606//  size+=sizeof(GamestateHeader);
607  return size;
608}
609
610/**
611 * This function removes a Synchronisable out of the universe
612 * @param it iterator of the list pointing to the object
613 * @return iterator pointing to the next object in the list
614 */
[2171]615  void Gamestate::removeObject(ObjectList<Synchronisable>::iterator &it) {
616    ObjectList<Synchronisable>::iterator temp=it;
[1701]617    ++it;
618    delete  *temp;
619  }
620
[1712]621  bool Gamestate::isDiffed(){
622    return HEADER->diffed;
623  }
[1740]624
[1751]625  bool Gamestate::isCompressed(){
626    return HEADER->compressed;
627  }
[1752]628
[1712]629  int Gamestate::getBaseID(){
630    return HEADER->base_id;
631  }
[1701]632}
633
634}
Note: See TracBrowser for help on using the repository browser.