// *************************************************************************** // // Reality - The Matrix Online Server Emulator // Copyright (C) 2006-2010 Rajko Stojadinovic // http://mxoemu.info // // --------------------------------------------------------------------------- // // This program is free software: you can redistribute it and/or modify // it under the terms of the GNU Affero General Public License as // published by the Free Software Foundation, either version 3 of the // License, or (at your option) any later version. // // This program is distributed in the hope that it will be useful, // but WITHOUT ANY WARRANTY; without even the implied warranty of // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the // GNU Affero General Public License for more details. // // You should have received a copy of the GNU Affero General Public License // along with this program. If not, see . // // --------------------------------------------------------------------------- // // *************************************************************************** #include "SequencedPacket.h" void SequencedPacket::Construct(ByteBuffer withHeader) { uint32 packedSeqs; //FL CC CS SS withHeader.rpos(0); withHeader >> packedSeqs; uint32 packed = swap32(packedSeqs); localSeq = packed&0xFFF; remoteSeq = (packed>>12)&0xFFF; ackBits = (packed>>24)&0xFF; vector restOfPacket; restOfPacket.resize(withHeader.size() - withHeader.rpos()); withHeader.read(&restOfPacket[0],restOfPacket.size()); this->clear(); this->append(&restOfPacket[0],restOfPacket.size()); } SequencedPacket::SequencedPacket( ByteBuffer withHeader ) { Construct(withHeader); } SequencedPacket::SequencedPacket( const string &withHeader ) { ByteBuffer simulation; simulation.append((const byte*)withHeader.data(),withHeader.size()); Construct(simulation); } ByteBuffer SequencedPacket::getDataWithHeader() const { uint32 packedSeqs = swap32((ackBits << 24) | ((remoteSeq & 0xFFF) << 12) | (localSeq & 0xFFF)); // FL CC CS SS ByteBuffer returnMe; returnMe << packedSeqs; returnMe.append(this->contents(),this->count()); return returnMe; }