Planet
navi homePPSaboutscreenshotsdownloaddevelopmentforum

source: orxonox.OLD/trunk/src/lib/network/network_game_manager.cc @ 9567

Last change on this file since 9567 was 9494, checked in by bensch, 18 years ago

merged the proxy back

File size: 10.6 KB
Line 
1/*
2   orxonox - the future of 3D-vertical-scrollers
3
4   Copyright (C) 2004 orx
5
6   This program is free software; you can redistribute it and/or modify
7   it under the terms of the GNU General Public License as published by
8   the Free Software Foundation; either version 2, or (at your option)
9   any later version.
10
11### File Specific:
12   main-programmer: Christoph Renner rennerc@ee.ethz.ch
13   co-programmer:   Patrick Boenzli  boenzlip@orxonox.ethz.ch
14
15     June 2006: finishing work on the network stream for pps presentation (rennerc@ee.ethz.ch)
16     July 2006: some code rearangement and integration of the proxy server mechanism (boenzlip@ee.ethz.ch)
17*/
18
19
20
21#define DEBUG_MODULE_NETWORK
22
23#include "util/loading/factory.h"
24#include "state.h"
25#include "class_list.h"
26#include "debug.h"
27
28#include "network_stream.h"
29#include "shared_network_data.h"
30#include "converter.h"
31#include "message_manager.h"
32
33#include "playable.h"
34#include "player.h"
35
36#include "game_world.h"
37
38#include "game_rules.h"
39#include "network_game_rules.h"
40
41#include "network_game_manager.h"
42
43#include "multiplayer_team_deathmatch.h"
44
45#include "preferences.h"
46
47
48
49
50NetworkGameManager* NetworkGameManager::singletonRef = NULL;
51
52/*!
53 * Standard constructor
54 */
55NetworkGameManager::NetworkGameManager()
56  : Synchronizeable()
57{
58  PRINTF(0)("START\n");
59
60  /* set the class id for the base object */
61  this->setClassID(CL_NETWORK_GAME_MANAGER, "NetworkGameManager");
62
63  this->setSynchronized(true);
64
65  MessageManager::getInstance()->registerMessageHandler( MSGID_DELETESYNCHRONIZEABLE, delSynchronizeableHandler, NULL );
66  MessageManager::getInstance()->registerMessageHandler( MSGID_PREFEREDTEAM, preferedTeamHandler, NULL );
67  MessageManager::getInstance()->registerMessageHandler( MSGID_CHATMESSAGE, chatMessageHandler, NULL );
68
69  this->gameState = 0;
70  registerVar( new SynchronizeableInt( &gameState, &gameState, "gameState" ) );
71}
72
73/*!
74 * Standard destructor
75 */
76NetworkGameManager::~NetworkGameManager()
77{
78  delete MessageManager::getInstance();
79
80  PlayerStats::deleteAllPlayerStats();
81
82  NetworkGameManager::singletonRef = NULL;
83}
84
85
86/**
87 * insert new player into game
88 * @param userId
89 * @return
90 */
91bool NetworkGameManager::signalNewPlayer( int userId )
92{
93  assert( SharedNetworkData::getInstance()->isMasterServer() ||  SharedNetworkData::getInstance()->isProxyServerActive());
94  assert( State::getGameRules() );
95  assert( State::getGameRules()->isA( CL_NETWORK_GAME_RULES ) );
96
97  NetworkGameRules & rules = *(dynamic_cast<NetworkGameRules*>(State::getGameRules()));
98
99  int team = rules.getTeamForNewUser();
100  ClassID playableClassId = rules.getPlayableClassId( userId, team );
101  std::string playableModel = rules.getPlayableModelFileName( userId, team, playableClassId );
102  std::string playableTexture = rules.getPlayableModelFileName( userId, team, playableClassId );
103  float       playableScale = rules.getPlayableScale( userId, team, playableClassId );
104
105  BaseObject * bo = Factory::fabricate( playableClassId );
106
107  assert( bo != NULL );
108  assert( bo->isA( CL_PLAYABLE ) );
109
110  Playable & playable = *(dynamic_cast<Playable*>(bo));
111
112  playable.loadMD2Texture( playableTexture );
113
114  playable.loadModel( playableModel, 100.0f );
115  playable.setOwner( userId );
116  playable.setUniqueID( SharedNetworkData::getInstance()->getNewUniqueID() );
117  playable.setSynchronized( true );
118
119  PlayerStats * stats = rules.getNewPlayerStats( userId );
120
121  stats->setUniqueID( SharedNetworkData::getInstance()->getNewUniqueID() );
122  stats->setSynchronized( true );
123  stats->setOwner( SharedNetworkData::getInstance()->getHostID() );
124
125  stats->setTeamId( team );
126  stats->setPlayableClassId( playableClassId );
127  stats->setPlayableUniqueId( playable.getUniqueID() );
128  stats->setModelFileName( playableModel );
129
130  if ( userId == 0 )
131    stats->setNickName( Preferences::getInstance()->getString( "multiplayer", "nickname", "Server" ) );
132
133  if ( rules.isA( CL_MULTIPLAYER_TEAM_DEATHMATCH ) )
134    dynamic_cast<MultiplayerTeamDeathmatch*>(&rules)->respawnPlayable( &playable, team, 0.0f );
135
136  return true;
137}
138
139
140/**
141 * remove player from game
142 * @param userID
143 * @return
144 */
145bool NetworkGameManager::signalLeftPlayer(int userID)
146{
147  if ( PlayerStats::getStats( userID ) )
148  {
149    if ( PlayerStats::getStats( userID )->getPlayable() )
150      delete PlayerStats::getStats( userID )->getPlayable();
151    delete PlayerStats::getStats( userID );
152  }
153
154  return true;
155}
156
157
158
159/**
160 * handler for remove synchronizeable messages
161 * @param messageId
162 * @param data
163 * @param dataLength
164 * @param someData
165 * @param userId
166 * @return true on successfull handling else handler will be called again
167 */
168bool NetworkGameManager::delSynchronizeableHandler( MessageId messageId, byte * data, int dataLength, void * someData, int userId )
169{
170
171  PRINTF(0)(" del synchronizeable\n");
172
173  if ( SharedNetworkData::getInstance()->isMasterServer() ||
174       SharedNetworkData::getInstance()->isProxyServerActive() && SharedNetworkData::getInstance()->isUserClient(userId))
175  {
176    PRINTF(0)("Recieved DeleteSynchronizeable message from client %d!\n", userId);
177    return true;
178  }
179
180  int uniqueId = 0;
181  int len = Converter::byteArrayToInt( data, &uniqueId );
182
183  if ( len != dataLength )
184  {
185    PRINTF(2)("Recieved DeleteSynchronizeable message with incorrect size (%d) from client %d!\n", dataLength, userId);
186    return true;
187  }
188
189  const std::list<BaseObject*> * list = ClassList::getList( CL_SYNCHRONIZEABLE );
190
191  for ( std::list<BaseObject*>::const_iterator it = list->begin(); it != list->end(); it++ )
192  {
193    if ( dynamic_cast<Synchronizeable*>(*it)->getUniqueID() == uniqueId )
194    {
195      if ( (*it)->isA(CL_PLAYABLE) )
196      {
197        getInstance()->playablesToDelete.push_back( dynamic_cast<Playable*>(*it) );
198        return true;
199      }
200
201      delete dynamic_cast<Synchronizeable*>(*it);
202      return true;
203    }
204  }
205
206  return true;
207}
208
209/**
210 * removes synchronizeable (also on clients)
211 * @param uniqueId uniqueid to delete
212 */
213void NetworkGameManager::removeSynchronizeable( int uniqueId )
214{
215  byte buf[INTSIZE];
216
217  assert( Converter::intToByteArray( uniqueId, buf, INTSIZE ) == INTSIZE );
218
219  MessageManager::getInstance()->sendMessage( MSGID_DELETESYNCHRONIZEABLE, buf, INTSIZE, RT_ALL_BUT_ME, 0, MP_HIGHBANDWIDTH );
220}
221
222
223
224/**
225 * handler for MSGID_PREFEREDTEAM message
226 * @param messageId
227 * @param data
228 * @param dataLength
229 * @param someData
230 * @param userId
231 * @return
232 */
233bool NetworkGameManager::preferedTeamHandler( MessageId messageId, byte * data, int dataLength, void * someData, int userId )
234{
235  assert( SharedNetworkData::getInstance()->isMasterServer() ||  SharedNetworkData::getInstance()->isProxyServerActive());
236
237  int teamId = 0;
238  int len = Converter::byteArrayToInt( data, &teamId );
239
240  if ( len != dataLength )
241  {
242    PRINTF(2)("Recieved DeleteSynchronizeable message with incorrect size (%d) from client %d!\n", dataLength, userId);
243    return true;
244  }
245
246  NetworkGameManager::getInstance()->setPreferedTeam( userId, teamId );
247
248  return true;
249}
250
251void NetworkGameManager::setPreferedTeam( int userId, int teamId )
252{
253  if ( !PlayerStats::getStats( userId ) )
254    return;
255
256  PlayerStats & stats = *(PlayerStats::getStats( userId ));
257
258  stats.setPreferedTeamId( teamId );
259}
260
261/**
262 * set prefered team for this host
263 * @param teamId
264 */
265void NetworkGameManager::prefereTeam( int teamId )
266{
267  if ( SharedNetworkData::getInstance()->isMasterServer() /*|| SharedNetworkData::getInstance()->isProxyServerActive()*/)
268    setPreferedTeam( SharedNetworkData::getInstance()->getHostID(), teamId );
269  else
270  {
271    byte buf[INTSIZE];
272
273    assert( Converter::intToByteArray( teamId, buf, INTSIZE) == INTSIZE );
274
275    MessageManager::getInstance()->sendMessage( MSGID_PREFEREDTEAM, buf, INTSIZE, RT_USER, 0, MP_HIGHBANDWIDTH );
276  }
277}
278
279/**
280 * this function will be called periodically by networkManager
281 * @param ds time elapsed since last call of tick
282 */
283void NetworkGameManager::tick( float ds )
284{
285  //delete playables if they are not assigned to local player anymore
286  for ( std::list<Playable*>::iterator it = playablesToDelete.begin(); it != playablesToDelete.end();  )
287  {
288    if ( State::getPlayer()->getPlayable() != *it )
289    {
290      const std::list<BaseObject*> * list = ClassList::getList( CL_PLAYABLE );
291
292      if ( list && std::find( list->begin(), list->end(), *it ) != list->end() )
293      {
294        PRINTF(0)("Delete unused playable: %s owner: %d\n", (*it)->getClassCName(), (*it)->getOwner() );
295        std::list<Playable*>::iterator delit = it;
296        it++;
297        delete *delit;
298        playablesToDelete.erase( delit );
299        continue;
300      }
301    }
302    it++;
303  }
304}
305
306
307
308bool NetworkGameManager::chatMessageHandler( MessageId messageId, byte * data, int dataLength, void * someData, int userId )
309{
310  PRINTF(0)("NetworkGameManager::chatMessageHandler %d %d\n", userId, SharedNetworkData::getInstance()->getHostID() );
311  if ( (SharedNetworkData::getInstance()->isMasterServer() /*|| SharedNetworkData::getInstance()->isProxyServerActive()*/) && userId !=  SharedNetworkData::getInstance()->getHostID() )
312  {
313    MessageManager::getInstance()->sendMessage( messageId, data, dataLength, RT_ALL_BUT_ME, 0, MP_HIGHBANDWIDTH );
314  }
315
316  assert( State::getGameRules() );
317  assert( State::getGameRules()->isA( CL_NETWORK_GAME_RULES ) );
318
319  NetworkGameRules & rules = *(dynamic_cast<NetworkGameRules*>(State::getGameRules()));
320
321  if ( dataLength < 3*INTSIZE )
322  {
323    PRINTF(2)("got too small chatmessage from client %d\n", userId);
324
325    return true;
326  }
327
328  int messageType = 0;
329  Converter::byteArrayToInt( data, &messageType );
330  int senderUserId = 0;
331  Converter::byteArrayToInt( data+INTSIZE, &senderUserId );
332  std::string message;
333  Converter::byteArrayToString( data+2*INTSIZE, message, dataLength-2*INTSIZE );
334
335  rules.handleChatMessage( senderUserId, message, messageType );
336
337  return true;
338}
339
340/**
341 * send chat message
342 * @param message message text
343 * @param messageType some int
344 */
345void NetworkGameManager::sendChatMessage( const std::string & message, int messageType )
346{
347  byte * buf = new byte[message.length()+3*INTSIZE];
348
349  assert( Converter::intToByteArray( messageType, buf, INTSIZE ) == INTSIZE );
350  assert( Converter::intToByteArray( SharedNetworkData::getInstance()->getHostID(), buf+INTSIZE, INTSIZE ) == INTSIZE );
351  assert( Converter::stringToByteArray(message, buf+2*INTSIZE, message.length()+INTSIZE) == message.length()+INTSIZE );
352
353  if ( SharedNetworkData::getInstance()->isMasterServer() /*|| SharedNetworkData::getInstance()->isProxyServerActive()*/)
354    MessageManager::getInstance()->sendMessage( MSGID_CHATMESSAGE, buf, message.length()+3*INTSIZE, RT_ALL_ME, 0, MP_HIGHBANDWIDTH );
355  else
356    MessageManager::getInstance()->sendMessage( MSGID_CHATMESSAGE, buf, message.length()+3*INTSIZE, RT_ALL_BUT_ME, 0, MP_HIGHBANDWIDTH );
357
358
359  delete [] buf;
360}
361
362
363
Note: See TracBrowser for help on using the repository browser.