X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Flib%2FAdapterCommunication.h;h=31de379e1350ac131529590e095ae2dd7bac2ee6;hb=04437dcf953eb9bf3accaceb4dab0fe06d935264;hp=21a775dbc6b8739b87f0982041fbdd168182b300;hpb=b8c9190697f79d21df7207f1799654de9325c5a3;p=deb_libcec.git diff --git a/src/lib/AdapterCommunication.h b/src/lib/AdapterCommunication.h index 21a775d..31de379 100644 --- a/src/lib/AdapterCommunication.h +++ b/src/lib/AdapterCommunication.h @@ -36,8 +36,6 @@ #include "util/buffer.h" #include "util/StdString.h" #include -#include -#include namespace CEC { @@ -51,7 +49,7 @@ namespace CEC } cec_adapter_message_state; - class CCECAdapterMessage : public boost::enable_shared_from_this + class CCECAdapterMessage { public: CCECAdapterMessage(void) { clear(); } @@ -64,7 +62,7 @@ namespace CEC uint8_t operator[](uint8_t pos) const { return packet[pos]; } uint8_t at(uint8_t pos) const { return packet[pos]; } uint8_t size(void) const { return packet.size; } - void clear(void) { state = ADAPTER_MESSAGE_STATE_UNKNOWN; packet.clear(); } + void clear(void) { state = ADAPTER_MESSAGE_STATE_UNKNOWN; transmit_timeout = 0; packet.clear(); } void shift(uint8_t iShiftBy) { packet.shift(iShiftBy); } void push_back(uint8_t add) { packet.push_back(add); } cec_adapter_messagecode message(void) const { return packet.size >= 1 ? (cec_adapter_messagecode) (packet.at(0) & ~(MSGCODE_FRAME_EOM | MSGCODE_FRAME_ACK)) : MSGCODE_NOTHING; } @@ -77,10 +75,10 @@ namespace CEC cec_datapacket packet; cec_adapter_message_state state; + int32_t transmit_timeout; CMutex mutex; CCondition condition; }; - typedef boost::shared_ptr CCECAdapterMessagePtr; class CSerialPort; class CLibCEC; @@ -93,7 +91,7 @@ namespace CEC bool Open(const char *strPort, uint16_t iBaudRate = 38400, uint32_t iTimeoutMs = 10000); bool Read(CCECAdapterMessage &msg, uint32_t iTimeout = 1000); - bool Write(CCECAdapterMessagePtr data); + bool Write(CCECAdapterMessage *data); bool PingAdapter(void); void Close(void); bool IsOpen(void) const; @@ -102,7 +100,6 @@ namespace CEC void *Process(void); bool StartBootloader(void); - bool SetAckMask(uint16_t iMask); private: void WriteNextCommand(void); @@ -112,7 +109,7 @@ namespace CEC CSerialPort * m_port; CLibCEC * m_controller; CecBuffer m_inBuffer; - CecBuffer m_outBuffer; + CecBuffer m_outBuffer; CMutex m_mutex; CCondition m_rcvCondition; CCondition m_startCondition;