|
|
|
@ -12,7 +12,6 @@
|
|
|
|
#include "network/udp/Socket.h"
|
|
|
|
#include "network/udp/Socket.h"
|
|
|
|
#include "Log.h"
|
|
|
|
#include "Log.h"
|
|
|
|
#include "Utils.h"
|
|
|
|
#include "Utils.h"
|
|
|
|
#include "Thread.h"
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
using namespace network;
|
|
|
|
using namespace network;
|
|
|
|
|
|
|
|
|
|
|
|
@ -119,8 +118,7 @@ void RawFrameQueue::enqueueMessage(const uint8_t* message, uint32_t length, sock
|
|
|
|
// if the queue is flushing -- don't attempt to enqueue any messages
|
|
|
|
// if the queue is flushing -- don't attempt to enqueue any messages
|
|
|
|
if (m_queueFlushing) {
|
|
|
|
if (m_queueFlushing) {
|
|
|
|
LogWarning(LOG_NET, "RawFrameQueue::enqueueMessage() -- queue is flushing, waiting to enqueue message");
|
|
|
|
LogWarning(LOG_NET, "RawFrameQueue::enqueueMessage() -- queue is flushing, waiting to enqueue message");
|
|
|
|
while (m_queueFlushing)
|
|
|
|
std::lock_guard<std::mutex> lock(m_queueMutex);
|
|
|
|
Thread::sleep(1U);
|
|
|
|
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
uint8_t* buffer = new uint8_t[length];
|
|
|
|
uint8_t* buffer = new uint8_t[length];
|
|
|
|
|