tweak shutdown

This commit is contained in:
ZappoMan 2014-03-31 17:05:31 -07:00
parent dc302e7126
commit ef68f164c9
3 changed files with 19 additions and 1 deletions

View file

@ -107,8 +107,13 @@ void OctreeQueryNode::nodeKilled() {
void OctreeQueryNode::initializeOctreeSendThread(const SharedAssignmentPointer& myAssignment, const SharedNodePointer& node) {
// Create octree sending thread...
qDebug() << "OctreeQueryNode::initializeOctreeSendThread()... BEFORE new OctreeSendThread(myAssignment, node);";
_octreeSendThread = new OctreeSendThread(myAssignment, node);
qDebug() << "OctreeQueryNode::initializeOctreeSendThread()... AFTER new OctreeSendThread(myAssignment, node);";
qDebug() << "OctreeQueryNode::initializeOctreeSendThread()... BEFORE _octreeSendThread->initialize(true)";
_octreeSendThread->initialize(true);
qDebug() << "OctreeQueryNode::initializeOctreeSendThread()... AFTER _octreeSendThread->initialize(true)";
}
bool OctreeQueryNode::packetIsDuplicate() const {

View file

@ -28,10 +28,19 @@ OctreeSendThread::OctreeSendThread(const SharedAssignmentPointer& myAssignment,
_nodeMissingCount(0),
_isShuttingDown(false)
{
qDebug() << qPrintable(_myServer->getMyServerName()) << "server [" << _myServer << "]: client connected "
qDebug() << "OctreeSendThread::OctreeSendThread()... START";
QString serverName("Octree");
if (_myServer) {
serverName = _myServer->getMyServerName();
}
qDebug() << qPrintable(serverName) << "server [" << _myServer << "]: client connected "
"- starting sending thread [" << this << "]";
qDebug() << "OctreeSendThread::OctreeSendThread()... before OctreeServer::clientConnected()";
OctreeServer::clientConnected();
qDebug() << "OctreeSendThread::OctreeSendThread()... AFTER OctreeServer::clientConnected()";
qDebug() << "OctreeSendThread::OctreeSendThread()... DONE";
}
OctreeSendThread::~OctreeSendThread() {

View file

@ -842,8 +842,12 @@ void OctreeServer::readPendingDatagrams() {
if (debug) {
qDebug() << "calling initializeOctreeSendThread()... node:" << *matchingNode;
}
qDebug() << "OctreeServer::readPendingDatagrams()... BEFORE nodeData->initializeOctreeSendThread()";
SharedAssignmentPointer sharedAssignment = AssignmentClient::getCurrentAssignment();
nodeData->initializeOctreeSendThread(sharedAssignment, matchingNode);
qDebug() << "OctreeServer::readPendingDatagrams()... AFTER nodeData->initializeOctreeSendThread()";
}
}
} else if (packetType == PacketTypeJurisdictionRequest) {