| [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 | */ | 
|---|
| [1701] | 28 |  | 
|---|
| [1711] | 29 |  | 
|---|
| [1760] | 30 | #include "Packet.h" | 
|---|
|  | 31 |  | 
|---|
|  | 32 | #include <cassert> | 
|---|
| [1701] | 33 | #include <enet/enet.h> | 
|---|
| [1711] | 34 | #include <boost/bind.hpp> | 
|---|
| [1701] | 35 |  | 
|---|
|  | 36 | #include "network/ConnectionManager.h" | 
|---|
|  | 37 | #include "network/ClientInformation.h" | 
|---|
|  | 38 |  | 
|---|
|  | 39 | #include "Acknowledgement.h" | 
|---|
|  | 40 | #include "Chat.h" | 
|---|
|  | 41 | #include "ClassID.h" | 
|---|
| [1709] | 42 | #include "Gamestate.h" | 
|---|
| [1711] | 43 | #include "Welcome.h" | 
|---|
| [1907] | 44 | #include "DeleteObjects.h" | 
|---|
| [1701] | 45 | #include "network/Host.h" | 
|---|
| [1705] | 46 | #include "core/CoreIncludes.h" | 
|---|
| [1701] | 47 |  | 
|---|
|  | 48 | namespace network{ | 
|---|
|  | 49 |  | 
|---|
|  | 50 | namespace packet{ | 
|---|
| [1940] | 51 |  | 
|---|
| [1711] | 52 | #define PACKET_FLAG_DEFAULT ENET_PACKET_FLAG_NO_ALLOCATE | 
|---|
| [1701] | 53 | #define _PACKETID           0 | 
|---|
| [1940] | 54 |  | 
|---|
| [1711] | 55 | std::map<ENetPacket *, Packet *> Packet::packetMap_; | 
|---|
| [1940] | 56 |  | 
|---|
| [1701] | 57 | Packet::Packet(){ | 
|---|
| [1711] | 58 | flags_ = PACKET_FLAG_DEFAULT; | 
|---|
| [1701] | 59 | packetDirection_ = ENUM::Outgoing; | 
|---|
|  | 60 | clientID_=0; | 
|---|
| [1711] | 61 | data_=0; | 
|---|
| [1701] | 62 | enetPacket_=0; | 
|---|
|  | 63 | } | 
|---|
|  | 64 |  | 
|---|
| [1712] | 65 | void blub(ENetPacket *packet){ | 
|---|
| [1713] | 66 | COUT(4) << "blubb" << std::endl; | 
|---|
| [1712] | 67 | } | 
|---|
|  | 68 |  | 
|---|
| [1907] | 69 | Packet::Packet(uint8_t *data, unsigned int clientID){ | 
|---|
| [1711] | 70 | flags_ = PACKET_FLAG_DEFAULT; | 
|---|
| [1713] | 71 | packetDirection_ = ENUM::Incoming; | 
|---|
| [1711] | 72 | clientID_=clientID; | 
|---|
|  | 73 | data_=data; | 
|---|
| [1701] | 74 | enetPacket_=0; | 
|---|
|  | 75 | } | 
|---|
|  | 76 |  | 
|---|
|  | 77 |  | 
|---|
| [1711] | 78 | Packet::Packet(const Packet &p){ | 
|---|
| [1712] | 79 | enetPacket_=p.enetPacket_; | 
|---|
| [1711] | 80 | flags_=p.flags_; | 
|---|
| [1730] | 81 | packetDirection_ = p.packetDirection_; | 
|---|
|  | 82 | clientID_ = p.clientID_; | 
|---|
| [1711] | 83 | if(p.data_){ | 
|---|
| [1907] | 84 | data_ = new uint8_t[p.getSize()]; | 
|---|
| [1711] | 85 | memcpy(data_, p.data_, p.getSize()); | 
|---|
|  | 86 | }else | 
|---|
|  | 87 | data_=0; | 
|---|
| [1701] | 88 | } | 
|---|
|  | 89 |  | 
|---|
| [1711] | 90 | Packet::~Packet(){ | 
|---|
| [1751] | 91 | if(enetPacket_){ | 
|---|
|  | 92 | assert(enetPacket_->freeCallback==0); | 
|---|
| [1705] | 93 | enet_packet_destroy(enetPacket_); | 
|---|
| [1751] | 94 | } | 
|---|
| [1711] | 95 | if(data_) | 
|---|
|  | 96 | delete[] data_; | 
|---|
| [1705] | 97 | } | 
|---|
| [1701] | 98 |  | 
|---|
|  | 99 | bool Packet::send(){ | 
|---|
| [1730] | 100 | if(packetDirection_ != ENUM::Outgoing && packetDirection_ != ENUM::Bidirectional ){ | 
|---|
| [1712] | 101 | assert(0); | 
|---|
| [1701] | 102 | return false; | 
|---|
| [1730] | 103 | } | 
|---|
| [1701] | 104 | if(!enetPacket_){ | 
|---|
| [1712] | 105 | if(!data_){ | 
|---|
|  | 106 | assert(0); | 
|---|
| [1701] | 107 | return false; | 
|---|
| [1712] | 108 | } | 
|---|
| [1711] | 109 | enetPacket_ = enet_packet_create(getData(), getSize(), getFlags()); | 
|---|
| [1751] | 110 | enetPacket_->freeCallback = &Packet::deletePacket; | 
|---|
|  | 111 | //     enetPacket_->freeCallback = &blub; | 
|---|
| [1711] | 112 | packetMap_[enetPacket_] = this; | 
|---|
| [1701] | 113 | } | 
|---|
| [1940] | 114 | #ifndef NDEBUG | 
|---|
| [1751] | 115 | switch( *(ENUM::Type *)(data_ + _PACKETID) ) | 
|---|
| [1715] | 116 | { | 
|---|
|  | 117 | case ENUM::Acknowledgement: | 
|---|
|  | 118 | case ENUM::Chat: | 
|---|
|  | 119 | case ENUM::ClassID: | 
|---|
|  | 120 | case ENUM::Gamestate: | 
|---|
|  | 121 | case ENUM::Welcome: | 
|---|
| [1907] | 122 | case ENUM::DeleteObjects: | 
|---|
| [1751] | 123 | break; | 
|---|
| [1715] | 124 | default: | 
|---|
| [1751] | 125 | assert(0); //there was some error, if this is the case | 
|---|
| [1715] | 126 | break; | 
|---|
| [1751] | 127 | } | 
|---|
|  | 128 | #endif | 
|---|
|  | 129 | ENetPacket *temp = enetPacket_; | 
|---|
| [1705] | 130 | enetPacket_ = 0; // otherwise we have a double free because enet already handles the deallocation of the packet | 
|---|
| [1751] | 131 | network::Host::addPacket( temp, clientID_); | 
|---|
| [1701] | 132 | return true; | 
|---|
|  | 133 | } | 
|---|
|  | 134 |  | 
|---|
| [1711] | 135 | Packet *Packet::createPacket(ENetPacket *packet, ENetPeer *peer){ | 
|---|
| [1907] | 136 | uint8_t *data = packet->data; | 
|---|
| [1960] | 137 | assert(ClientInformation::findClient(&peer->address)->getID() != (unsigned int)-2 || !Host::isServer()); | 
|---|
| [1711] | 138 | unsigned int clientID = ClientInformation::findClient(&peer->address)->getID(); | 
|---|
|  | 139 | Packet *p; | 
|---|
| [1907] | 140 | COUT(5) << "packet type: " << *(ENUM::Type *)&data[_PACKETID] << std::endl; | 
|---|
| [1715] | 141 | switch( *(ENUM::Type *)(data + _PACKETID) ) | 
|---|
| [1701] | 142 | { | 
|---|
|  | 143 | case ENUM::Acknowledgement: | 
|---|
| [1907] | 144 | COUT(4) << "ack" << std::endl; | 
|---|
| [1711] | 145 | p = new Acknowledgement( data, clientID ); | 
|---|
| [1701] | 146 | break; | 
|---|
|  | 147 | case ENUM::Chat: | 
|---|
| [1907] | 148 | COUT(4) << "chat" << std::endl; | 
|---|
| [1711] | 149 | p = new Chat( data, clientID ); | 
|---|
| [1701] | 150 | break; | 
|---|
|  | 151 | case ENUM::ClassID: | 
|---|
| [1907] | 152 | COUT(4) << "classid" << std::endl; | 
|---|
| [1711] | 153 | p = new ClassID( data, clientID ); | 
|---|
| [1701] | 154 | break; | 
|---|
|  | 155 | case ENUM::Gamestate: | 
|---|
| [1907] | 156 | COUT(4) << "gamestate" << std::endl; | 
|---|
| [1701] | 157 | // TODO: remove brackets | 
|---|
| [1715] | 158 | p = new Gamestate( data, clientID ); | 
|---|
| [1701] | 159 | break; | 
|---|
| [1711] | 160 | case ENUM::Welcome: | 
|---|
| [1907] | 161 | COUT(4) << "welcome" << std::endl; | 
|---|
| [1711] | 162 | p = new Welcome( data, clientID ); | 
|---|
| [1715] | 163 | break; | 
|---|
| [1907] | 164 | case ENUM::DeleteObjects: | 
|---|
|  | 165 | COUT(4) << "deleteobjects" << std::endl; | 
|---|
|  | 166 | p = new DeleteObjects( data, clientID ); | 
|---|
|  | 167 | break; | 
|---|
| [1701] | 168 | default: | 
|---|
| [1710] | 169 | assert(0); //TODO: repair this | 
|---|
|  | 170 | break; | 
|---|
| [1701] | 171 | } | 
|---|
| [1711] | 172 | return p; | 
|---|
| [1701] | 173 | } | 
|---|
|  | 174 |  | 
|---|
| [1711] | 175 | void Packet::deletePacket(ENetPacket *packet){ | 
|---|
|  | 176 | assert(packetMap_[packet]); | 
|---|
| [1751] | 177 | assert(packetMap_[packet]->enetPacket_==0); | 
|---|
| [1711] | 178 | delete packetMap_[packet]; | 
|---|
|  | 179 | } | 
|---|
|  | 180 |  | 
|---|
| [1701] | 181 | } // namespace packet | 
|---|
|  | 182 |  | 
|---|
|  | 183 | } // namespace network | 
|---|
|  | 184 |  | 
|---|