WIP: somethings wrong.. #19
@ -61,6 +61,7 @@ ReturnValue_t MessageQueue::receiveMessage(MessageQueueMessage* message) {
|
|||||||
}
|
}
|
||||||
// not sure this will work..
|
// not sure this will work..
|
||||||
//*message = std::move(messageQueue.front());
|
//*message = std::move(messageQueue.front());
|
||||||
|
MutexHelper mutexLock(queueLock, 20);
|
||||||
MessageQueueMessage* currentMessage = &messageQueue.front();
|
MessageQueueMessage* currentMessage = &messageQueue.front();
|
||||||
std::copy(currentMessage->getBuffer(),
|
std::copy(currentMessage->getBuffer(),
|
||||||
currentMessage->getBuffer() + messageSize, message->getBuffer());
|
currentMessage->getBuffer() + messageSize, message->getBuffer());
|
||||||
|
Loading…
Reference in New Issue
Block a user