116 lines
2.4 KiB
C++
116 lines
2.4 KiB
C++
/**
|
|
* PANDA 3D SOFTWARE
|
|
* Copyright (c) Carnegie Mellon University. All rights reserved.
|
|
*
|
|
* All use of this software is subject to the terms of the revised BSD
|
|
* license. You should have received a copy of this license along
|
|
* with this source code in a file named "LICENSE."
|
|
*
|
|
* @file directdServer.cxx
|
|
* @author skyler
|
|
* @date 2002-04-08
|
|
*/
|
|
|
|
#include "directdServer.h"
|
|
|
|
DirectDServer::DirectDServer() {
|
|
}
|
|
|
|
DirectDServer::~DirectDServer() {
|
|
}
|
|
|
|
void
|
|
DirectDServer::handle_command(const string& cmd) {
|
|
nout<<"DirectDServer::handle_command: "<<cmd<<", size="<<cmd.size()<<endl;
|
|
if (cmd.size()==1) {
|
|
switch (cmd[0]) {
|
|
case 'k':
|
|
kill_app(0);
|
|
break;
|
|
case 'q':
|
|
_shutdown=true;
|
|
break;
|
|
default:
|
|
cerr<<"unknown command: "<<cmd<<endl;
|
|
break;
|
|
}
|
|
} else {
|
|
switch (cmd[0]) {
|
|
case 'k':
|
|
if (cmd[1]=='a') {
|
|
kill_all();
|
|
} else {
|
|
int index = atoi(cmd.substr(1, string::npos).c_str());
|
|
kill_app(index);
|
|
}
|
|
break;
|
|
case '!': {
|
|
string c=cmd.substr(1, string::npos);
|
|
// read_command(c);
|
|
start_app(c);
|
|
}
|
|
break;
|
|
default:
|
|
start_app(cmd);
|
|
break;
|
|
}
|
|
}
|
|
}
|
|
|
|
void
|
|
DirectDServer::read_command(string& cmd) {
|
|
try {
|
|
pifstream f;
|
|
f.open("directdCommand", ios::in | ios::binary);
|
|
stringstream ss;
|
|
const int buf_size=512;
|
|
char buf[buf_size];
|
|
f.getline(buf, buf_size);
|
|
if (f.gcount() > 0) {
|
|
cmd = buf;
|
|
cerr<<"read_command "<<cmd<<endl;
|
|
}
|
|
f.close();
|
|
} catch (...) {
|
|
// This could be bad, I suppose. But we're going to throw out any
|
|
// exceptions that happen during the above read.
|
|
cerr<<"DirectD::read_command() exception."<<endl;
|
|
}
|
|
}
|
|
|
|
void
|
|
DirectDServer::run_server(int port) {
|
|
nout<<"server"<<endl;
|
|
|
|
listen_to(port);
|
|
|
|
while (!_shutdown) {
|
|
check_for_new_clients();
|
|
check_for_lost_connection();
|
|
check_for_datagrams();
|
|
|
|
// Yield the timeslice before we poll again.
|
|
// PR_Sleep(PR_MillisecondsToInterval(200));
|
|
Sleep(200);
|
|
}
|
|
}
|
|
|
|
int
|
|
main(int argc, char *argv[]) {
|
|
if (argc > 1 && strcmp(argv[1], "--help")==0) {
|
|
cerr<<"directd [<port>]\n"
|
|
" port default 8001\n";
|
|
return 1;
|
|
}
|
|
|
|
cerr<<"directdServer "<<__DATE__<<" "<<__TIME__<<endl;
|
|
int port=8001;
|
|
if (argc > 1) {
|
|
port=(atoi(argv[argc-1]));
|
|
}
|
|
DirectDServer directd;
|
|
directd.run_server(port);
|
|
|
|
return 0;
|
|
}
|