update to bugfix
This commit is contained in:
parent
6d2bfaeb3b
commit
16ed5e3270
@ -17,10 +17,12 @@ QueueMapManager* QueueMapManager::instance() {
|
|||||||
|
|
||||||
ReturnValue_t QueueMapManager::addMessageQueue(QueueHandle_t queue, MessageQueueId_t* id) {
|
ReturnValue_t QueueMapManager::addMessageQueue(QueueHandle_t queue, MessageQueueId_t* id) {
|
||||||
MutexGuard lock(mapLock);
|
MutexGuard lock(mapLock);
|
||||||
uint32_t currentId = queueCounter++;
|
uint32_t currentId = queueCounter;
|
||||||
|
queueCounter++;
|
||||||
if(currentId == MessageQueueIF::NO_QUEUE) {
|
if(currentId == MessageQueueIF::NO_QUEUE) {
|
||||||
// Skip the NO_QUEUE value
|
// Skip the NO_QUEUE value
|
||||||
currentId = queueCounter++;
|
currentId = queueCounter;
|
||||||
|
queueCounter++;
|
||||||
}
|
}
|
||||||
auto returnPair = queueMap.emplace(currentId, queue);
|
auto returnPair = queueMap.emplace(currentId, queue);
|
||||||
if(not returnPair.second) {
|
if(not returnPair.second) {
|
||||||
|
Loading…
Reference in New Issue
Block a user