X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Flib%2FAdapterCommunication.h;h=135b5c2cdadf3947e3d4955b40df7b78632f9b18;hb=2b32d0ab4a65fd7ac86072285e87972e1131b98a;hp=270d96b9f5303746ecc0b7d42d9813f4dc478a69;hpb=828682d35c298ff062422521689258c363ea3579;p=deb_libcec.git diff --git a/src/lib/AdapterCommunication.h b/src/lib/AdapterCommunication.h index 270d96b..135b5c2 100644 --- a/src/lib/AdapterCommunication.h +++ b/src/lib/AdapterCommunication.h @@ -31,46 +31,44 @@ * http://www.pulse-eight.net/ */ -#include -#include #include "../../include/CECExports.h" -#include "../../include/CECTypes.h" -#include "util/buffer.h" -#include "util/threads.h" - -class CSerialPort; +#include "platform/threads.h" +#include namespace CEC { - class CCECParser; + class CSerialPort; + class CLibCEC; - class CAdapterCommunication : CThread + class CAdapterCommunication : private CThread { public: - CAdapterCommunication(CCECParser *parser); + CAdapterCommunication(CLibCEC *controller); virtual ~CAdapterCommunication(); - bool Open(const char *strPort, int iBaudRate = 38400, int iTimeoutMs = 10000); - bool Read(cec_frame &msg, int 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); + + bool StartBootloader(void); + bool SetAckMask(uint16_t iMask); + static void PushEscaped(cec_frame &vec, uint8_t byte); private: - void AddData(uint8_t *data, int iLen); - bool ReadFromDevice(int iTimeout); + void AddData(uint8_t *data, uint8_t iLen); + bool ReadFromDevice(uint32_t iTimeout); CSerialPort * m_port; - CCECParser * m_parser; + 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; }; };