Update framework #6
@ -18,6 +18,10 @@ 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++;
|
||||||
|
if(currentId == MessageQueueIF::NO_QUEUE) {
|
||||||
|
// Skip the NO_QUEUE value
|
||||||
|
queueCounter++;
|
||||||
|
}
|
||||||
auto returnPair = queueMap.emplace(currentId, queue);
|
auto returnPair = queueMap.emplace(currentId, queue);
|
||||||
if(not returnPair.second) {
|
if(not returnPair.second) {
|
||||||
#if FSFW_CPP_OSTREAM_ENABLED == 1
|
#if FSFW_CPP_OSTREAM_ENABLED == 1
|
||||||
|
Loading…
Reference in New Issue
Block a user