Planet
navi homePPSaboutscreenshotsdownloaddevelopmentforum

source: code/trunk/src/network/Server.cc @ 2949

Last change on this file since 2949 was 2896, checked in by landauf, 16 years ago

Merged gui branch back to trunk.

I did 2 small changes in IngameManager.cc on line 777 and 888 (yes, really), because const_reverse_iterator strangely doesn't work on MinGW.

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