From 1ce12cfd028d423550a1013ae8edef907398af0e Mon Sep 17 00:00:00 2001 From: Vasily Davydov Date: Thu, 18 May 2023 13:02:43 +0300 Subject: [PATCH] master: add more strict debug to queue send --- source/shoh/src/threads/master/Master.cpp | 17 +++++++++-------- 1 file changed, 9 insertions(+), 8 deletions(-) diff --git a/source/shoh/src/threads/master/Master.cpp b/source/shoh/src/threads/master/Master.cpp index 1a562d2..ea1d38f 100644 --- a/source/shoh/src/threads/master/Master.cpp +++ b/source/shoh/src/threads/master/Master.cpp @@ -40,30 +40,31 @@ Master::~Master() void Master::HandleEventType(Event* e) { EventRawData rd = e->getData(); - switch (e->getType()) + bool send = false; + switch (e->getType()) { case Event::Null: LOG_ERROR("Master recieved Event::Null with data: %d", rd); break; case Event::Rotary: //Comes from rotary, goes to manager - _qm->send(ThreadCommon::QueueManager::manager_event_master, e, 0); + send = _qm->send(ThreadCommon::QueueManager::manager_event_master, e, 0); //LOG_WARNING("Timestamp: %zus, Clock: %zu, Chip freq: %zu", LPC_SCT1->COUNT_U / Chip_Clock_GetMainClockRate(), LPC_SCT1->COUNT_U, Chip_Clock_GetMainClockRate()); - LOG_DEBUG("Rotary: %s has been forwarded to manager", rotary_direction[rd]); + if (send) LOG_DEBUG("Rotary: %s has been forwarded to manager", rotary_direction[rd]); break; case Event::InternalTemp: // TODO remove (deprecated) break; case Event::ExternalTemp: //Comes from sensors, goes to relay & manager - _qm->send(ThreadCommon::QueueManager::relay_event_master, e, 0); - _qm->send(ThreadCommon::QueueManager::manager_event_master, e, 0); - LOG_DEBUG("ExtTemp: %d has been forwarded to manager and relay", rd); + send = _qm->send(ThreadCommon::QueueManager::relay_event_master, e, 0); + send = _qm->send(ThreadCommon::QueueManager::manager_event_master, e, 0); + if (send) LOG_DEBUG("ExtTemp: %d has been forwarded to manager and relay", rd); break; case Event::SetPoint: //Comes from manager, goes to relay - _qm->send(ThreadCommon::QueueManager::relay_event_master, e, 0); - LOG_DEBUG("SetPoint: %d has been forwarded to relay", rd); + send = _qm->send(ThreadCommon::QueueManager::relay_event_master, e, 0); + if (send) LOG_DEBUG("SetPoint: %d has been forwarded to relay", rd); break; default: LOG_ERROR("Unknown EventType");