X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Flib%2FAdapterCommunication.cpp;h=00fa87e408615828cf0615dd045d1e1df74f5bc8;hb=28352a04776bccbcdf79945528808af27d2a5c0a;hp=e94e8c01b1880095887df982bc6b0c93fe046cab;hpb=06bfd4d72adaaf83d211f1104e71fe5f2b196442;p=deb_libcec.git diff --git a/src/lib/AdapterCommunication.cpp b/src/lib/AdapterCommunication.cpp index e94e8c0..00fa87e 100644 --- a/src/lib/AdapterCommunication.cpp +++ b/src/lib/AdapterCommunication.cpp @@ -353,7 +353,7 @@ void CAdapterCommunication::AddData(uint8_t *data, uint8_t iLen) void CAdapterCommunication::WriteNextCommand(void) { - CCECAdapterMessagePtr msg; + CCECAdapterMessage *msg; if (m_outBuffer.Pop(msg)) { CLockObject lock(&msg->mutex); @@ -367,14 +367,14 @@ void CAdapterCommunication::WriteNextCommand(void) else { m_controller->AddLog(CEC_LOG_DEBUG, "command sent"); - CCondition::Sleep((uint32_t) msg->size() * (uint32_t)24 /*data*/ + (uint32_t)5 /*start bit (4.5 ms)*/); + CCondition::Sleep((uint32_t) msg->size() * 24 /*data*/ + 5 /*start bit (4.5 ms)*/ + 10); msg->state = ADAPTER_MESSAGE_STATE_SENT; } msg->condition.Signal(); } } -bool CAdapterCommunication::Write(CCECAdapterMessagePtr data) +bool CAdapterCommunication::Write(CCECAdapterMessage *data) { data->state = ADAPTER_MESSAGE_STATE_WAITING; m_outBuffer.Push(data); @@ -442,47 +442,45 @@ std::string CAdapterCommunication::GetError(void) const bool CAdapterCommunication::StartBootloader(void) { + bool bReturn(false); if (!IsRunning()) - return false; + return bReturn; m_controller->AddLog(CEC_LOG_DEBUG, "starting the bootloader"); - CCECAdapterMessagePtr output(new CCECAdapterMessage); + CCECAdapterMessage *output = new CCECAdapterMessage; output->push_back(MSGSTART); output->push_escaped(MSGCODE_START_BOOTLOADER); output->push_back(MSGEND); - if (!Write(output)) - { + if ((bReturn = Write(output)) == false) m_controller->AddLog(CEC_LOG_ERROR, "could not start the bootloader"); - return false; - } - m_controller->AddLog(CEC_LOG_DEBUG, "bootloader start command transmitted"); - return true; + + delete output; + + return bReturn; } bool CAdapterCommunication::PingAdapter(void) { + bool bReturn(false); if (!IsRunning()) - return false; + return bReturn; m_controller->AddLog(CEC_LOG_DEBUG, "sending ping"); - CCECAdapterMessagePtr output(new CCECAdapterMessage); + CCECAdapterMessage *output = new CCECAdapterMessage; output->push_back(MSGSTART); output->push_escaped(MSGCODE_PING); output->push_back(MSGEND); - if (!Write(output)) - { + if ((bReturn = Write(output)) == false) m_controller->AddLog(CEC_LOG_ERROR, "could not send ping command"); - return false; - } - - m_controller->AddLog(CEC_LOG_DEBUG, "ping tranmitted"); // TODO check for pong - return true; + delete output; + + return bReturn; } bool CAdapterCommunication::IsOpen(void) const