00001
00002
00003
00004
00005
00006
00007
00008
00009
00010
00011
00012
00013
00014
00015
00016
00017
00018
00019
00020
00021
00022
00023
00024
00025
00026
00027
00028
00029
00031
00032
00033
00034
00035
00036
00037
00038
00039
00040
00041
00042
00043
00044
00045
00046
00047 #include <QUANTA/QUANTAglobals.hxx>
00048 #include <QUANTA/QUANTAinit.hxx>
00049 #include <QUANTA/QUANTAmisc_debug.hxx>
00050 #include <QUANTA/QUANTAnet_datapack_c.hxx>
00051
00052 #include <QAvatar.h>
00053 #include <QAvatarFactory.h>
00054 #include <QAvatarListener.h>
00055 #include <QAvatarManager.h>
00056
00057 #include <signal.h>
00058
00059 #ifdef USE_STL_NAMESPACE
00060 #include <iostream>
00061 using std::cerr;
00062 using std::cout;
00063 using std::endl;
00064 #else
00065 #include <iostream.h>
00066 #endif
00067
00068 static const int HELLO_SIZE=256;
00069 static const int TRACKER_SIZE=QUANTAnet_datapack_c::sizeof_int()*2;
00070 static const int AUX_SIZE=256;
00071
00072 class DemoFactory : public QAvatarFactory
00073 {
00074 public:
00075 virtual QAvatar* createAvatar(const long& newID)
00076 {
00077
00078
00079
00080
00081
00082 return new QAvatar(newID, HELLO_SIZE, AUX_SIZE, TRACKER_SIZE);
00083 }
00084 };
00085
00086 class DemoListener : public QAvatarListener
00087 {
00088 public:
00089 virtual ~DemoListener() {}
00090 virtual void avatarArrive(QAvatar* avatar)
00091 {
00092 printf("WELCOME!!! AVATAR %i ARRIVED: %s\n",
00093 avatar->getID(), avatar->getHelloData());
00094 }
00095 virtual void avatarAux(QAvatar* avatar)
00096 {
00097 printf("AVATAR %i AUX: %s\n", avatar->getID(), avatar->getAuxData());
00098 }
00099 virtual void avatarBye(QAvatar* avatar)
00100 {
00101 printf("GOODBYE!! AVATAR %i LEFT\n", avatar->getID());
00102 }
00103 virtual void avatarHello(QAvatar* avatar)
00104 {
00105 printf("AVATAR %i HELLO: %s\n",
00106 avatar->getID(), avatar->getHelloData());
00107 }
00108 virtual void avatarTracker(QAvatar* avatar)
00109 {
00110 QUANTAnet_datapack_c unpacker;
00111 int x, y;
00112 unpacker.initUnpack(avatar->getTrackerData(), TRACKER_SIZE);
00113 unpacker.unpackInt(&x);
00114 unpacker.unpackInt(&y);
00115 printf("AVATAR %i TRACKER: %i %i\n", avatar->getID(), x, y);
00116 }
00117 };
00118
00119 volatile bool keepRunning = true;
00120
00121 void interruptHandler(int);
00122
00123 int
00124 main(int argc, char** argv)
00125 {
00126 if (argc < 2) {
00127 cerr << "Usage: server" << endl;
00128 return 1;
00129 }
00130
00131 short hailingPort = 7000;
00132 short trackerPort = 7001;
00133
00134
00135 signal(SIGINT, interruptHandler);
00136
00137 QUANTAinit();
00138
00139 DemoFactory* avatarFactory = new DemoFactory;
00140 QAvatarManager* avatarManager = new QAvatarManager(avatarFactory);
00141 QAvatar* selfAvatar = avatarManager->getSelfAvatar();
00142
00143
00144
00145 DemoListener* avatarListener = new DemoListener;
00146 avatarManager->attach(avatarListener);
00147 avatarManager->setTrackerUpdateDelay(1.0);
00148
00149
00150 if (!avatarManager->connect(argv[1], hailingPort, trackerPort)) {
00151 cerr << "Unable to initialize the avatar manager!" << endl;
00152 delete avatarManager;
00153 return 1;
00154 }
00155
00156
00157 char* helloData = new char[HELLO_SIZE];
00158 strcpy(helloData, "THIS IS HELLO DATA");
00159 selfAvatar->setHelloData(helloData, strlen(helloData)+1);
00160 avatarManager->sendHello();
00161
00162 char* trackerData = new char[TRACKER_SIZE];
00163 char* auxData = new char[AUX_SIZE];
00164
00165 int loops;
00166 if (argc > 2) {
00167 loops = atoi(argv[2]);
00168 } else {
00169 loops = 1000;
00170 }
00171
00172 QUANTAnet_datapack_c packer;
00173 for (int i = 0; (i < loops) && keepRunning; i++) {
00174
00175 cerr << i << endl;
00176
00177
00178
00179
00180 packer.initPack(trackerData, TRACKER_SIZE);
00181 packer.packInt(i);
00182 packer.packInt(loops-i);
00183
00184 selfAvatar->setTrackerData(trackerData, TRACKER_SIZE);
00185
00186 avatarManager->sendTracker();
00187
00188
00189 if ((i % 4) == 0) {
00190 sprintf(auxData, "THIS IS AUX DATA %d", i);
00191 selfAvatar->setAuxData(auxData, strlen(auxData)+1);
00192 avatarManager->sendAux();
00193 }
00194 avatarManager->process();
00195 QUANTAsleep(5);
00196 }
00197
00198
00199
00200 cerr << "\nShutting down..." << endl;
00201 avatarManager->sendBye();
00202
00203 delete avatarManager;
00204 delete avatarFactory;
00205 delete avatarListener;
00206
00207 delete[] helloData;
00208 delete[] trackerData;
00209 delete[] auxData;
00210
00211 return 0;
00212 }
00213
00214 void
00215 interruptHandler(int arg)
00216 {
00217 cout << "Ctrl-C caught..." << endl;
00218 keepRunning = false;
00219 }