This commit is contained in:
@ -170,7 +170,7 @@ void ScexUartReader::foundDlePacketHandler(const DleParser::Context &ctx) {
|
||||
void ScexUartReader::handleFoundDlePacket(uint8_t *packet, size_t len) {
|
||||
// TODO: insert data into IPC ring buffer here
|
||||
sif::info << "Detected DLE encoded packet with decoded size " << len << std::endl;
|
||||
//MutexGuard mg(lock);
|
||||
MutexGuard mg(lock);
|
||||
ReturnValue_t result = ipcQueue.insert(len);
|
||||
if(result != RETURN_OK){
|
||||
sif::warning<< "IPCQueue error" << std::endl;
|
||||
@ -184,7 +184,7 @@ void ScexUartReader::handleFoundDlePacket(uint8_t *packet, size_t len) {
|
||||
|
||||
ReturnValue_t ScexUartReader::readReceivedMessage(CookieIF *cookie, uint8_t **buffer,
|
||||
size_t *size) {
|
||||
//MutexGuard mg(lock);
|
||||
MutexGuard mg(lock);
|
||||
if (ipcQueue.empty()) {
|
||||
*size = 0;
|
||||
return RETURN_OK;
|
||||
|
Reference in New Issue
Block a user