repositories
/
deb_libcec.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
cec: process messages that were received async, or all incoming requests will time out
[deb_libcec.git]
/
src
/
lib
/
CECProcessor.cpp
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)
{
bool CCECProcessor::OnCommandReceived(const cec_command &command)
{
-
m_commandBuffer.Push
(command);
+
ParseCommand
(command);
return true;
}
void *CCECProcessor::Process(void)
{
return true;
}
void *CCECProcessor::Process(void)
{
- cec_command command;
CLibCEC::AddLog(CEC_LOG_DEBUG, "processor thread started");
while (!IsStopped() && m_communication->IsOpen())
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 (IsInitialised())
{
ReplaceHandlers();
- if (m_commandBuffer.Pop(command))
- ParseCommand(command);
m_controller->CheckKeypressTimeout();
}
m_controller->CheckKeypressTimeout();
}