Planet
navi homePPSaboutscreenshotsdownloaddevelopmentforum

source: code/branches/objecthierarchy/src/network/Server.cc @ 1941

Last change on this file since 1941 was 1941, checked in by scheusso, 15 years ago

small fix

  • Property svn:eol-style set to native
File size: 11.3 KB
Line 
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) 2007
24 *   Co-authors:
25 *      ...
26 *
27 */
28
29//
30// C++ Implementation: Server
31//
32// Description:
33//
34//
35// Author:  Oliver Scheuss, (C) 2007
36//
37// Copyright: See COPYING file that comes with this distribution
38//
39//
40
41#include "Server.h"
42
43#include <iostream>
44#include <cassert>
45
46
47#include "ConnectionManager.h"
48#include "ClientConnectionListener.h"
49#include "GamestateManager.h"
50#include "ClientInformation.h"
51#include "util/Sleep.h"
52#include "core/ConsoleCommand.h"
53#include "core/CoreIncludes.h"
54#include "core/Iterator.h"
55#include "packet/Chat.h"
56#include "packet/Packet.h"
57#include "packet/Welcome.h"
58#include "packet/DeleteObjects.h"
59#include <util/Convert.h>
60
61namespace network
62{
63  const int MAX_FAILURES = 20;
64  const int NETWORK_FREQUENCY = 30;
65
66  /**
67  * Constructor for default values (bindaddress is set to ENET_HOST_ANY
68  *
69  */
70  Server::Server() {
71    timeSinceLastUpdate_=0;
72    connection = new ConnectionManager();
73    gamestates_ = new GamestateManager();
74  }
75
76  Server::Server(int port){
77    timeSinceLastUpdate_=0;
78    connection = new ConnectionManager(port);
79    gamestates_ = new GamestateManager();
80  }
81
82  /**
83  * Constructor
84  * @param port Port to listen on
85  * @param bindAddress Address to listen on
86  */
87  Server::Server(int port, std::string bindAddress) {
88    timeSinceLastUpdate_=0;
89    connection = new ConnectionManager(port, bindAddress);
90    gamestates_ = new GamestateManager();
91  }
92
93  /**
94  * Constructor
95  * @param port Port to listen on
96  * @param bindAddress Address to listen on
97  */
98  Server::Server(int port, const char *bindAddress) {
99    timeSinceLastUpdate_=0;
100    connection = new ConnectionManager(port, bindAddress);
101    gamestates_ = new GamestateManager();
102  }
103
104  /**
105  * @brief Destructor
106  */
107  Server::~Server(){
108    if(connection)
109      delete connection;
110    if(gamestates_)
111      delete gamestates_;
112  }
113
114  /**
115  * This function opens the server by creating the listener thread
116  */
117  void Server::open() {
118    connection->createListener();
119    return;
120  }
121
122  /**
123  * This function closes the server
124  */
125  void Server::close() {
126    connection->quitListener();
127    return;
128  }
129
130  bool Server::processChat(std::string message, unsigned int playerID){
131    ClientInformation *temp = ClientInformation::getBegin();
132    packet::Chat *chat;
133    while(temp){
134      chat = new packet::Chat(message, playerID);
135      chat->setClientID(temp->getID());
136      if(!chat->send())
137        COUT(3) << "could not send Chat message to client ID: " << temp->getID() << std::endl;
138      temp = temp->next();
139    }
140    COUT(1) << "Player " << playerID << ": " << message << std::endl;
141    return true;
142  }
143
144
145  /**
146  * Run this function once every tick
147  * calls processQueue and updateGamestate
148  * @param time time since last tick
149  */
150  void Server::tick(float time) {
151    processQueue();
152    //this steers our network frequency
153    timeSinceLastUpdate_+=time;
154    if(timeSinceLastUpdate_>=(1./NETWORK_FREQUENCY)){
155      timeSinceLastUpdate_=(float)((int)(timeSinceLastUpdate_*NETWORK_FREQUENCY))/timeSinceLastUpdate_;
156      gamestates_->processGamestates();
157      updateGamestate();
158    }
159  }
160
161  bool Server::queuePacket(ENetPacket *packet, int clientID){
162    return connection->addPacket(packet, clientID);
163  }
164
165  /**
166  * processes all the packets waiting in the queue
167  */
168  void Server::processQueue() {
169    ENetEvent *event;
170    while(!connection->queueEmpty()){
171      //std::cout << "Client " << clientID << " sent: " << std::endl;
172      //clientID here is a reference to grab clientID from ClientInformation
173      event = connection->getEvent();
174      if(!event)
175        continue;
176      assert(event->type != ENET_EVENT_TYPE_NONE);
177      switch( event->type ) {
178      case ENET_EVENT_TYPE_CONNECT:
179        COUT(3) << "processing event_Type_connect" << std::endl;
180        addClient(event);
181        break;
182      case ENET_EVENT_TYPE_DISCONNECT:
183        if(ClientInformation::findClient(&event->peer->address))
184          disconnectClient(event);
185        break;
186      case ENET_EVENT_TYPE_RECEIVE:
187        if(!processPacket(event->packet, event->peer))
188          COUT(3) << "processing incoming packet failed" << std::endl;
189        break;
190      default:
191        break;
192      }
193      delete event;
194      //if statement to catch case that packetbuffer is empty
195    }
196  }
197
198  /**
199  * takes a new snapshot of the gamestate and sends it to the clients
200  */
201  void Server::updateGamestate() {
202    gamestates_->update();
203    COUT(5) << "Server: one gamestate update complete, goig to sendGameState" << std::endl;
204    //std::cout << "updated gamestate, sending it" << std::endl;
205    //if(clients->getGamestateID()!=GAMESTATEID_INITIAL)
206    sendGameState();
207    sendObjectDeletes();
208    COUT(5) << "Server: one sendGameState turn complete, repeat in next tick" << std::endl;
209    //std::cout << "sent gamestate" << std::endl;
210  }
211
212  bool Server::processPacket( ENetPacket *packet, ENetPeer *peer ){
213    packet::Packet *p = packet::Packet::createPacket(packet, peer);
214    return p->process();
215  }
216
217  /**
218  * sends the gamestate
219  */
220  bool Server::sendGameState() {
221    COUT(5) << "Server: starting function sendGameState" << std::endl;
222    ClientInformation *temp = ClientInformation::getBegin();
223    bool added=false;
224    while(temp != NULL){
225      if( !(temp->getSynched()) ){
226        COUT(5) << "Server: not sending gamestate" << std::endl;
227        temp=temp->next();
228        if(!temp)
229          break;
230        //think this works without continue
231        continue;
232      }
233      COUT(4) << "client id: " << temp->getID() << " RTT: " << temp->getRTT() << " loss: " << temp->getPacketLoss() << std::endl;
234      COUT(5) << "Server: doing gamestate gamestate preparation" << std::endl;
235      int gid = temp->getGamestateID(); //get gamestate id
236      int cid = temp->getID(); //get client id
237      COUT(5) << "Server: got acked (gamestate) ID from clientlist: " << gid << std::endl;
238      packet::Gamestate *gs = gamestates_->popGameState(cid);
239      if(gs==NULL){
240        COUT(2) << "Server: could not generate gamestate (NULL from compress)" << std::endl;
241        continue;
242      }
243      //std::cout << "adding gamestate" << std::endl;
244      gs->setClientID(cid);
245      if ( !gs->send() ){
246        COUT(3) << "Server: packet with client id (cid): " << cid << " not sended: " << temp->getFailures() << std::endl;
247        temp->addFailure();
248      }else
249        temp->resetFailures();
250      added=true;
251      temp=temp->next();
252      // gs gets automatically deleted by enet callback
253    }
254    return true;
255  }
256
257  bool Server::sendObjectDeletes(){
258    ClientInformation *temp = ClientInformation::getBegin();
259    packet::DeleteObjects *del = new packet::DeleteObjects();
260    if(!del->fetchIDs())
261      return true;  //everything ok (no deletes this tick)
262//     COUT(3) << "sending DeleteObjects" << std::endl;
263    while(temp != NULL){
264      if( !(temp->getSynched()) ){
265        COUT(5) << "Server: not sending gamestate" << std::endl;
266        temp=temp->next();
267        continue;
268      }
269      int cid = temp->getID(); //get client id
270      packet::DeleteObjects *cd = new packet::DeleteObjects(*del);
271      assert(cd);
272      cd->setClientID(cid);
273      if ( !cd->send() )
274        COUT(3) << "Server: packet with client id (cid): " << cid << " not sended: " << temp->getFailures() << std::endl;
275      temp=temp->next();
276      // gs gets automatically deleted by enet callback
277    }
278    return true;
279  }
280
281
282  bool Server::addClient(ENetEvent *event){
283    unsigned int newid=0;
284   
285    ClientInformation *temp = ClientInformation::insertBack(new ClientInformation);
286    if(!temp){
287      COUT(2) << "Server: could not add client" << std::endl;
288      return false;
289    }
290    if(temp==ClientInformation::getBegin()) { //not good if you use anything else than insertBack
291      newid=1;
292    }
293    else
294      newid=temp->prev()->getID()+1;
295    temp->setID(newid);
296    temp->setPeer(event->peer);
297   
298    // inform all the listeners
299    orxonox::ObjectList<ClientConnectionListener>::iterator listener = orxonox::ObjectList<ClientConnectionListener>::begin();
300    while(listener){
301      listener->clientConnected(newid);
302      listener++;
303    }
304   
305    COUT(3) << "Server: added client id: " << temp->getID() << std::endl;
306    return createClient(temp->getID()); 
307}
308
309  bool Server::createClient(int clientID){
310    ClientInformation *temp = ClientInformation::findClient(clientID);
311    if(!temp){
312      COUT(2) << "Conn.Man. could not create client with id: " << clientID << std::endl;
313      return false;
314    }
315    COUT(4) << "Con.Man: creating client id: " << temp->getID() << std::endl;
316    connection->syncClassid(temp->getID());
317    temp->setSynched(true);
318    COUT(3) << "sending welcome" << std::endl;
319    packet::Welcome *w = new packet::Welcome(temp->getID(), temp->getShipID());
320    w->setClientID(temp->getID());
321    bool b = w->send();
322    assert(b);
323    packet::Gamestate *g = new packet::Gamestate();
324    g->setClientID(temp->getID());
325    b = g->collectData(0);
326    assert(b);
327    b = g->compressData();
328    assert(b);
329    b = g->send();
330    assert(b);
331    return true;
332  }
333
334  bool Server::disconnectClient(ENetEvent *event){
335    COUT(4) << "removing client from list" << std::endl;
336    //return removeClient(head_->findClient(&(peer->address))->getID());
337
338    //boost::recursive_mutex::scoped_lock lock(head_->mutex_);
339    ClientInformation *client = ClientInformation::findClient(&event->peer->address);
340    if(!client)
341      return false;
342    gamestates_->removeClient(client);
343
344// inform all the listeners
345    orxonox::ObjectList<ClientConnectionListener>::iterator listener = orxonox::ObjectList<ClientConnectionListener>::begin();
346    while(listener){
347      listener->clientDisconnected(client->getID());
348    }
349
350    return ClientInformation::removeClient(event->peer);
351  }
352
353  void Server::disconnectClient(int clientID){
354    ClientInformation *client = ClientInformation::findClient(clientID);
355    if(client)
356      disconnectClient(client);
357  }
358  void Server::disconnectClient( ClientInformation *client){
359    connection->disconnectClient(client);
360    gamestates_->removeClient(client);
361  }
362
363  bool Server::chat(std::string message){
364    ClientInformation *temp = ClientInformation::getBegin();
365    packet::Chat *chat;
366    while(temp){
367      chat = new packet::Chat(message, Host::getPlayerID());
368      chat->setClientID(temp->getID());
369      if(!chat->send())
370        COUT(3) << "could not send Chat message to client ID: " << temp->getID() << std::endl;
371      temp = temp->next();
372    }
373    COUT(1) << "Player " << Host::getPlayerID() << ": " << message << std::endl;
374    return true;
375  }
376
377}
Note: See TracBrowser for help on using the repository browser.