X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Flib%2Fimplementations%2FCECCommandHandler.cpp;h=561819f3f47d77401c5c00b6fea3f172eafb13e8;hb=7e5a449a3115e69adca77af01fb5daf2c04896ad;hp=44cf477b3507fa0d9073a577e7fbee887514fff1;hpb=960f33c651b2dd1e6331dafe5b21705c11cee1a2;p=deb_libcec.git diff --git a/src/lib/implementations/CECCommandHandler.cpp b/src/lib/implementations/CECCommandHandler.cpp index 44cf477..561819f 100644 --- a/src/lib/implementations/CECCommandHandler.cpp +++ b/src/lib/implementations/CECCommandHandler.cpp @@ -48,7 +48,6 @@ CCECCommandHandler::CCECCommandHandler(CCECBusDevice *busDevice) : m_iTransmitWait(CEC_DEFAULT_TRANSMIT_WAIT), m_iTransmitRetries(CEC_DEFAULT_TRANSMIT_RETRIES), m_bHandlerInited(false), - m_iUseCounter(0), m_expectedResponse(CEC_OPCODE_NONE), m_bOPTSendDeckStatusUpdateOnActiveSource(false), m_vendorId(CEC_VENDOR_UNKNOWN), @@ -58,8 +57,6 @@ CCECCommandHandler::CCECCommandHandler(CCECBusDevice *busDevice) : CCECCommandHandler::~CCECCommandHandler(void) { - CLockObject lock(m_processor->m_transmitMutex); - CLockObject receiveLock(m_receiveMutex); m_condition.Broadcast(); } @@ -67,7 +64,6 @@ bool CCECCommandHandler::HandleCommand(const cec_command &command) { bool bHandled(true); - MarkBusy(); CLibCEC::AddCommand(command); switch(command.opcode) @@ -202,7 +198,6 @@ bool CCECCommandHandler::HandleCommand(const cec_command &command) } } - MarkReady(); return bHandled; } @@ -344,6 +339,7 @@ bool CCECCommandHandler::HandleGivePhysicalAddress(const cec_command &command) { device->SetActiveSource(); return device->TransmitPhysicalAddress() && + device->TransmitImageViewOn() && device->TransmitActiveSource(); } } @@ -511,6 +507,7 @@ bool CCECCommandHandler::HandleSetStreamPath(const cec_command &command) if (device && m_busDevice->MyLogicalAddressContains(device->GetLogicalAddress())) { device->SetActiveSource(); + device->TransmitImageViewOn(); device->TransmitActiveSource(); device->SetMenuState(CEC_MENU_STATE_ACTIVATED); @@ -610,6 +607,7 @@ bool CCECCommandHandler::HandleUserControlPressed(const cec_command &command) if (device->MyLogicalAddressContains(device->GetLogicalAddress())) { device->SetActiveSource(); + device->TransmitImageViewOn(); device->TransmitActiveSource(); if (device->GetType() == CEC_DEVICE_TYPE_PLAYBACK_DEVICE || @@ -951,14 +949,12 @@ bool CCECCommandHandler::TransmitKeyRelease(const cec_logical_address iInitiator bool CCECCommandHandler::Transmit(cec_command &command, bool bExpectResponse /* = true */, cec_opcode expectedResponse /* = CEC_OPCODE_NONE */) { bool bReturn(false); - MarkBusy(); command.transmit_timeout = m_iTransmitTimeout; { uint8_t iTries(0), iMaxTries(command.opcode == CEC_OPCODE_NONE ? 1 : m_iTransmitRetries + 1); CLockObject writeLock(m_processor->m_transmitMutex); CLockObject receiveLock(m_receiveMutex); - ++m_iUseCounter; while (!bReturn && ++iTries <= iMaxTries) { m_expectedResponse = expectedResponse; @@ -967,14 +963,12 @@ bool CCECCommandHandler::Transmit(cec_command &command, bool bExpectResponse /* CLibCEC::AddLog(CEC_LOG_DEBUG, "command transmitted"); if (bExpectResponse) bReturn = m_condition.Wait(m_receiveMutex, m_bRcvSignal, m_iTransmitWait); - if (bReturn) - m_bRcvSignal = false; + m_bRcvSignal = false; + CLibCEC::AddLog(CEC_LOG_DEBUG, bReturn ? "expected response received" : "expected response not received"); } } - --m_iUseCounter; } - MarkReady(); return bReturn; } @@ -995,21 +989,3 @@ bool CCECCommandHandler::ActivateSource(void) } return true; } - -void CCECCommandHandler::MarkBusy(void) -{ - CLockObject receiveLock(m_receiveMutex); - ++m_iUseCounter; -} - -bool CCECCommandHandler::MarkReady(void) -{ - CLockObject receiveLock(m_receiveMutex); - return m_iUseCounter > 0 ? (--m_iUseCounter == 0) : true; -} - -bool CCECCommandHandler::InUse(void) -{ - CLockObject receiveLock(m_receiveMutex); - return m_iUseCounter > 0; -}