Planet
navi homePPSaboutscreenshotsdownloaddevelopmentforum

source: orxonox.OLD/trunk/src/lib/network/handshake.cc @ 9745

Last change on this file since 9745 was 9656, checked in by bensch, 18 years ago

orxonox/trunk: merged the proxy bache back with no conflicts

File size: 5.1 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: Patirck Boenzli (boenzlip@orxonox.ethz.ch)
14*/
15
16
17#define DEBUG_MODULE_NETWORK
18
19#include "handshake.h"
20
21#include <cassert>
22#include "debug.h"
23
24
25
26
27
28 Handshake::Handshake( int nodeType, int clientId, int networkGameManagerId, int messageManagerId )
29  : Synchronizeable()
30{
31  /* set the class id for the base object */
32  this->setClassID(CL_HANDSHAKE, "Handshake");
33
34
35  // register all variable handlers
36  orxId_handler = registerVarId( new SynchronizeableInt( &localState.orxId, &remoteState.orxId, "orxonoxId", PERMISSION_ALL ) );
37  version_handler = registerVarId( new SynchronizeableInt( &localState.version, &remoteState.version, "version", PERMISSION_ALL ) );
38  netManId_handler = registerVarId( new SynchronizeableInt( &localState.networkManagerId, &remoteState.networkManagerId, "networkManagerId", PERMISSION_ALL ) );
39  msgManId_handler = registerVarId( new SynchronizeableInt( &localState.messageManagerId, &remoteState.messageManagerId, "messageManagerId", PERMISSION_ALL ) );
40  hostId_handler = registerVarId( new SynchronizeableInt( &localState.hostId, &remoteState.hostId, "hostId", PERMISSION_ALL ) );
41  completed_handler = registerVarId( new SynchronizeableInt( &localState.completed, &remoteState.completed, "completed", PERMISSION_ALL ) );
42  error_handler = registerVarId( new SynchronizeableInt( &localState.error, &remoteState.error, "error", PERMISSION_ALL ) );
43  errorString_handler = registerVarId( new SynchronizeableString( &localState.errorString, &remoteState.errorString, "errorString", PERMISSION_ALL ) );
44
45  this->nodeTypeHandler = registerVarId( new SynchronizeableInt( &localState.nodeType, &remoteState.nodeType, "nodeType", PERMISSION_ALL ) );
46
47  candel_id = registerVarId( new SynchronizeableInt( &localState.canDel, &remoteState.canDel, "canDel", PERMISSION_ALL ) );
48
49  registerVar( new SynchronizeableString( &localState.preferedNickName, &remoteState.preferedNickName, "preferedNickName", PERMISSION_ALL ) );
50  // now synchronize only two of the available proxy server addresses
51  registerVar( new SynchronizeableIP( &this->proxy1, &this->proxy1, "proxy server 1", PERMISSION_MASTER_SERVER ) );
52  registerVar( new SynchronizeableIP( &this->proxy2, &this->proxy2, "proxy server 2", PERMISSION_MASTER_SERVER ) );
53  registerVar( new SynchronizeableInt( &this->redirectProxy, &this->redirectProxy, "proxy server redirection flag", PERMISSION_MASTER_SERVER ) );
54
55
56  // init the local state
57  localState.completed = 0;
58  localState.error = 0;
59  localState.errorString = "";
60  localState.hostId = clientId;
61  localState.networkManagerId = networkGameManagerId;
62  this->localState.messageManagerId = messageManagerId;
63  localState.orxId = _ORXONOX_ID;
64  localState.version = _ORXONOX_VERSION;
65  localState.nodeType = nodeType;
66  localState.canDel = 0;
67
68
69  // init the remote state
70  remoteState.completed = 0;
71  remoteState.error = 0;
72  remoteState.errorString = "";
73  remoteState.hostId = NET_ID_UNASSIGNED;
74  remoteState.networkManagerId = -1;
75  remoteState.messageManagerId = -1;
76  remoteState.orxId = 0;
77  remoteState.version = 0;
78  remoteState.nodeType = NET_UNASSIGNED;
79  remoteState.canDel = 0;
80
81
82  this->proxy1 = IP(0, 0);
83  this->proxy2 = IP(0, 0);
84  this->redirectProxy = 0;
85
86
87  // activate the synchronization process
88  this->setSynchronized(true);
89  PRINTF(0)("Handshake created clientId = %d\n", clientId);
90}
91
92
93/**
94 * handler for changes in synced vars
95 * @param id id's which have changed
96 */
97void Handshake::varChangeHandler( std::list< int > & id )
98{
99  for ( std::list<int>::iterator it = id.begin(); it != id.end(); it++ )
100  {
101    // orxonox id handler
102    if ( *it == this->orxId_handler )
103    {
104      if ( remoteState.orxId != _ORXONOX_ID )
105      {
106        localState.error = 1;
107        localState.completed = 1;
108        localState.errorString = "Seems not to be orxonox!";
109        continue;
110      }
111    }
112
113    // orxonox version handler
114    if ( *it == this->version_handler )
115    {
116      if ( remoteState.version != _ORXONOX_VERSION )
117      {
118        localState.error = 2;
119        localState.completed = 1;
120        localState.errorString = "Versions of server and client do not match!";
121        continue;
122      }
123    }
124
125    // node type handler: for each node type there is a specific action to be taken
126    if ( *it == this->nodeTypeHandler)
127    {
128      if ( remoteState.nodeType == NET_MASTER_SERVER )
129      {
130        continue;
131      }
132      else if( remoteState.nodeType == NET_PROXY_SERVER_ACTIVE)
133      {
134        continue;
135      }
136      else if( remoteState.nodeType == NET_CLIENT)
137      {
138        continue;
139      }
140    }
141
142    // cancel
143    if ( *it == candel_id )
144    {
145      PRINTF(0)("handshake finished candel changed\n");
146    }
147  }
148
149  // handshake completed
150  if ( remoteState.orxId == _ORXONOX_ID &&
151       remoteState.version == _ORXONOX_VERSION )
152  {
153    localState.completed = 1;
154  }
155}
156
Note: See TracBrowser for help on using the repository browser.