X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Flib%2FAdapterCommunication.cpp;h=8d351f058a49164409bd11380211934aa1d650a7;hb=d0d8b3c000e1aa12feeb555c2240e026c4a3dcf5;hp=54077d6ed776b4b6ef72f0dcc0d76cffd948ab45;hpb=e107f073245c22d58a99d6efc7d2e70a13c82d38;p=deb_libcec.git diff --git a/src/lib/AdapterCommunication.cpp b/src/lib/AdapterCommunication.cpp index 54077d6..8d351f0 100644 --- a/src/lib/AdapterCommunication.cpp +++ b/src/lib/AdapterCommunication.cpp @@ -265,7 +265,11 @@ CAdapterCommunication::~CAdapterCommunication(void) bool CAdapterCommunication::Open(const char *strPort, uint16_t iBaudRate /* = 38400 */, uint32_t iTimeoutMs /* = 10000 */) { + uint64_t iNow = GetTimeMs(); + uint64_t iTimeout = iNow + iTimeoutMs; + CLockObject lock(&m_mutex); + if (!m_port) { m_processor->AddLog(CEC_LOG_ERROR, "port is NULL"); @@ -275,12 +279,23 @@ bool CAdapterCommunication::Open(const char *strPort, uint16_t iBaudRate /* = 38 if (IsOpen()) { m_processor->AddLog(CEC_LOG_ERROR, "port is already open"); + return true; } - if (!m_port->Open(strPort, iBaudRate)) + CStdString strError; + bool bConnected(false); + while (!bConnected && iNow < iTimeout) + { + if ((bConnected = m_port->Open(strPort, iBaudRate)) == false) + { + strError.Format("error opening serial port '%s': %s", strPort, m_port->GetError().c_str()); + Sleep(250); + iNow = GetTimeMs(); + } + } + + if (!bConnected) { - CStdString strError; - strError.Format("error opening serial port '%s': %s", strPort, m_port->GetError().c_str()); m_processor->AddLog(CEC_LOG_ERROR, strError); return false; }