Mirrors/overte
3
0
Fork 0
mirror of https://github.com/overte-org/overte.git synced 2025-08-08 07:17:43 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions

Start thread right away

Browse source
This commit is contained in:
Atlante45 2015-10-06 16:12:50 -07:00
parent 81b88cb096
commit 5ee966261d
1 changed files with 6 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
libraries/networking/src/udt/SendQueue.cpp
View file

@ -69,7 +69,9 @@ std::unique_ptr<SendQueue> SendQueue::create(Socket* socket, HifiSockAddr destin
// Move queue to private thread and start it // Move queue to private thread and start it
queue->moveToThread(thread); queue->moveToThread(thread);
return std::move(queue); thread->start();
return queue;
} }
SendQueue::SendQueue(Socket* socket, HifiSockAddr dest) : SendQueue::SendQueue(Socket* socket, HifiSockAddr dest) :
@ -191,9 +193,6 @@ void SendQueue::sendHandshake() {
// we wait for the ACK or the re-send interval to expire // we wait for the ACK or the re-send interval to expire
static const auto HANDSHAKE_RESEND_INTERVAL = std::chrono::milliseconds(100); static const auto HANDSHAKE_RESEND_INTERVAL = std::chrono::milliseconds(100);
_handshakeACKCondition.wait_for(handshakeLock, HANDSHAKE_RESEND_INTERVAL); _handshakeACKCondition.wait_for(handshakeLock, HANDSHAKE_RESEND_INTERVAL);
// Once we're here we've either received the handshake ACK or it's going to be time to re-send a handshake.
// Either way let's continue processing - no packets will be sent if no handshake ACK has been received.
} }
} }
@ -254,6 +253,9 @@ void SendQueue::run() {
// Keep processing events // Keep processing events
QCoreApplication::sendPostedEvents(this); QCoreApplication::sendPostedEvents(this);
// Once we're here we've either received the handshake ACK or it's going to be time to re-send a handshake.
// Either way let's continue processing - no packets will be sent if no handshake ACK has been received.
} }
while (_state == State::Running) { while (_state == State::Running) {