forked from oerkki/voxelands
parent
4565caabea
commit
c2900aa9fc
|
@ -543,6 +543,7 @@ Connection::~Connection()
|
|||
|
||||
void * Connection::Thread()
|
||||
{
|
||||
printf("Connection::Thread()\n");
|
||||
log_register_thread("Connection");
|
||||
|
||||
dout_con<<"Connection thread started"<<std::endl;
|
||||
|
@ -565,6 +566,7 @@ void * Connection::Thread()
|
|||
runTimeouts(dtime);
|
||||
|
||||
while(m_command_queue.size() != 0){
|
||||
printf("m_command_queue.size() = %u\n",m_command_queue.size());
|
||||
ConnectionCommand c = m_command_queue.pop_front();
|
||||
processCommand(c);
|
||||
}
|
||||
|
@ -575,6 +577,7 @@ void * Connection::Thread()
|
|||
|
||||
END_DEBUG_EXCEPTION_HANDLER(derr_con);
|
||||
}
|
||||
printf("Connection::Thread() exit\n");
|
||||
|
||||
return NULL;
|
||||
}
|
||||
|
|
|
@ -73,6 +73,7 @@ private:
|
|||
|
||||
void * ServerThread::Thread()
|
||||
{
|
||||
printf("ServerThread::Thread()\n");
|
||||
log_register_thread("ServerThread");
|
||||
|
||||
DSTACK(__FUNCTION_NAME);
|
||||
|
@ -103,6 +104,8 @@ void * ServerThread::Thread()
|
|||
|
||||
END_DEBUG_EXCEPTION_HANDLER(errorstream)
|
||||
|
||||
printf("ServerThread::Thread() exit\n");
|
||||
|
||||
return NULL;
|
||||
}
|
||||
|
||||
|
@ -1074,8 +1077,10 @@ void Server::start(unsigned short port)
|
|||
// Initialize connection
|
||||
m_con.SetTimeoutMs(30);
|
||||
m_con.Serve(port);
|
||||
if (!m_con.getRun())
|
||||
if (!m_con.getRun()) {
|
||||
printf("no con run\n");
|
||||
return;
|
||||
}
|
||||
|
||||
// Start thread
|
||||
m_thread.start();
|
||||
|
|
Loading…
Reference in New Issue