Planet
navi homePPSaboutscreenshotsdownloaddevelopmentforum

source: code/trunk/src/libraries/network/ServerConnection.cc @ 8206

Last change on this file since 8206 was 7801, checked in by dafrick, 14 years ago

Merging presentation2 branch back to trunk.

  • Property svn:eol-style set to native
File size: 4.3 KB
RevLine 
[3214]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
24 *   Co-authors:
25 *      ...
26 *
27 */
28
29#include "ServerConnection.h"
30
31#include <cassert>
32#include <string>
[5929]33#define WIN32_LEAN_AND_MEAN
[3214]34#include <enet/enet.h>
35
36#include "util/Debug.h"
37#include "ClientInformation.h"
38
39namespace orxonox
40{
41
42  ServerConnection::ServerConnection():
43    bListening_(false)
44  {
45    this->bindAddress_ = new ENetAddress();
[7459]46    memset(this->bindAddress_, 0, sizeof(ENetAddress));
[3214]47    this->bindAddress_->host = ENET_HOST_ANY;
48    this->bindAddress_->port = NETWORK_PORT;
49  }
50
[7801]51  ServerConnection::~ServerConnection()
52  {
[3214]53    if ( this->bListening_ )
54      closeListener();
55    delete this->bindAddress_;
56  }
57
[7801]58  void ServerConnection::setBindAddress( const std::string& bindAddress )
59  {
[7459]60    if (enet_address_set_host (this->bindAddress_, bindAddress.c_str()) < 0)
61        COUT(1) << "Error: Could not resolve \"" << bindAddress << "\"." << std::endl;
[3214]62  }
63
64  void ServerConnection::setPort( unsigned int port ) {
65      this->bindAddress_->port = port;
66  }
67
[7801]68  bool ServerConnection::openListener()
69  {
70    // create host
71    this->host_ = enet_host_create(this->bindAddress_, NETWORK_MAX_CONNECTIONS, NETWORK_CHANNEL_COUNT, 0, 0);
72   
[3214]73    if ( this->host_ == NULL )
[7459]74    {
75        COUT(1) << "ServerConnection: host_ == NULL" << std::endl;
76        return false;
77    }
[7801]78   
79    // enable compression
80    this->enableCompression();
[7459]81    assert( this->host_->socket4 != ENET_SOCKET_NULL || this->host_->socket6 != ENET_SOCKET_NULL );
82    if (this->host_->socket4 == ENET_SOCKET_NULL)
83        COUT(2) << "Warning: IPv4 Socket failed." << std::endl;
84    else if (this->host_->socket6 == ENET_SOCKET_NULL)
85        COUT(2) << "Warning: IPv6 Socket failed." << std::endl;
[3214]86    else
[7459]87        COUT(3) << "Info: Using IPv4 and IPv6 Sockets." << std::endl;
[7801]88   
89    // start communication thread
90    Connection::startCommunicationThread();
[7459]91
92    return true;
[3214]93  }
94
[7801]95  bool ServerConnection::closeListener()
96  {
[3214]97    this->bListening_=false;
98    disconnectClients();
[7801]99    Connection::stopCommunicationThread();
[3214]100    enet_host_destroy(this->host_);
101    return true;
102  }
103
[7801]104  void ServerConnection::addPacket(ENetPacket *packet, unsigned int clientID, uint8_t channelID)
105  {
[3214]106    if ( clientID == CLIENTID_UNKNOWN )
107    {
[7801]108      broadcastPacket(packet, channelID);
[3214]109    }
110    else
111    {
112      ClientInformation *temp = ClientInformation::findClient(clientID);
113      if(!temp){
114        COUT(3) << "C.Man: addPacket findClient failed" << std::endl;
115      }
[7801]116      Connection::addPacket(packet, temp->getPeer(), channelID);
[3214]117    }
118  }
119
120  void ServerConnection::disconnectClient(ClientInformation *client)
121  {
122    Connection::disconnectPeer( client->getPeer() );
123  }
[6417]124
[7801]125  void ServerConnection::disconnectClient(int clientID)
126  {
[3214]127    ClientInformation *client = ClientInformation::findClient(clientID);
128    if(client)
[5929]129      ServerConnection::disconnectClient(client);
[3214]130  }
131
[7801]132  void ServerConnection::disconnectClients()
133  {
[3214]134    ClientInformation *temp = ClientInformation::getBegin();
[7801]135    while(temp!=0)
136    {
[5929]137      ServerConnection::disconnectClient( temp );
[3214]138      temp = temp->next();
139    }
140    return;
141  }
142
143
[7801]144  int ServerConnection::getClientID(ENetPeer* peer)
145  {
[3214]146    return getClientID(&(peer->address));
147  }
148
[7801]149  int ServerConnection::getClientID(ENetAddress* address)
150  {
[3214]151    return ClientInformation::findClient(address)->getID();
152  }
153
[7801]154  ENetPeer *ServerConnection::getClientPeer(int clientID)
155  {
[3214]156    return ClientInformation::findClient(clientID)->getPeer();
157  }
158
159
160}
Note: See TracBrowser for help on using the repository browser.