X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Flib%2FAdapterCommunication.h;h=135b5c2cdadf3947e3d4955b40df7b78632f9b18;hb=370757d1da5f6111c0f2ca3995515549b26b0cd1;hp=c95f729998d75d5505323125011397229599422b;hpb=8bca69de10349c3cfb7ea3ba4ab5f7ebbb34a740;p=deb_libcec.git diff --git a/src/lib/AdapterCommunication.h b/src/lib/AdapterCommunication.h index c95f729..135b5c2 100644 --- a/src/lib/AdapterCommunication.h +++ b/src/lib/AdapterCommunication.h @@ -33,24 +33,25 @@ #include "../../include/CECExports.h" #include "platform/threads.h" +#include namespace CEC { class CSerialPort; class CLibCEC; - class CAdapterCommunication : CThread + class CAdapterCommunication : private CThread { public: CAdapterCommunication(CLibCEC *controller); virtual ~CAdapterCommunication(); - bool Open(const char *strPort, uint16_t iBaudRate = 38400, uint64_t iTimeoutMs = 10000); - bool Read(cec_frame &msg, uint64_t iTimeout = 1000); + bool Open(const char *strPort, uint16_t iBaudRate = 38400, uint32_t iTimeoutMs = 10000); + bool Read(cec_frame &msg, uint32_t iTimeout = 1000); bool Write(const cec_frame &frame); bool PingAdapter(void); void Close(void); - bool IsOpen(void) const { return !m_bStop && m_bStarted; } + bool IsOpen(void) const; std::string GetError(void) const; void *Process(void); @@ -60,17 +61,14 @@ namespace CEC static void PushEscaped(cec_frame &vec, uint8_t byte); private: void AddData(uint8_t *data, uint8_t iLen); - bool ReadFromDevice(uint64_t iTimeout); + bool ReadFromDevice(uint32_t iTimeout); CSerialPort * m_port; CLibCEC * m_controller; uint8_t* m_inbuf; - int m_iInbufSize; - int m_iInbufUsed; - bool m_bStarted; - bool m_bStop; - CMutex m_commMutex; - CMutex m_bufferMutex; - CCondition m_condition; + int16_t m_iInbufSize; + int16_t m_iInbufUsed; + CMutex m_mutex; + CCondition m_rcvCondition; }; };