cec: fixed - directly process commands that have been received, or all the 'request...

diff --git a/src/lib/CECProcessor.cpp b/src/lib/CECProcessor.cpp
index 54162b92257f9f4e6f1fa9e6517009c46b87c4e2..afe87a979f48cdfb944291575a969f9d5009fcd7 100644 (file)
--- a/src/lib/CECProcessor.cpp
+++ b/src/lib/CECProcessor.cpp
@@ -432,13 +432,12 @@ void CCECProcessor::ReplaceHandlers(void)
 
 bool CCECProcessor::OnCommandReceived(const cec_command &command)
 {
-  m_commandBuffer.Push(command);
+  ParseCommand(command);
   return true;
 }
 
 void *CCECProcessor::Process(void)
 {
-  cec_command command;
   CLibCEC::AddLog(CEC_LOG_DEBUG, "processor thread started");
 
   while (!IsStopped() && m_communication->IsOpen())
@@ -446,8 +445,6 @@ void *CCECProcessor::Process(void)
     if (IsInitialised())
     {
       ReplaceHandlers();
-      if (m_commandBuffer.Pop(command))
-        ParseCommand(command);
 
       m_controller->CheckKeypressTimeout();
     }

diff --git a/src/lib/CECProcessor.h b/src/lib/CECProcessor.h
index 5a657533664c465c4e7e0527fc87c7d35f724c38..49c6eae904db047cff18b6d12a4d77f35094c7a4 100644 (file)
--- a/src/lib/CECProcessor.h
+++ b/src/lib/CECProcessor.h
@@ -168,7 +168,6 @@ namespace CEC
       IAdapterCommunication *             m_communication;
       CLibCEC*                            m_controller;
       bool                                m_bMonitor;
-      PLATFORM::SyncedBuffer<cec_command> m_commandBuffer;
       cec_keypress                        m_previousKey;
       PLATFORM::CThread *                 m_busScan;
       uint8_t                             m_iLineTimeout;