3 * This file is part of the libCEC(R) library.
5 * libCEC(R) is Copyright (C) 2011-2012 Pulse-Eight Limited. All rights reserved.
6 * libCEC(R) is an original work, containing original code.
8 * libCEC(R) is a trademark of Pulse-Eight Limited.
10 * This program is dual-licensed; you can redistribute it and/or modify
11 * it under the terms of the GNU General Public License as published by
12 * the Free Software Foundation; either version 2 of the License, or
13 * (at your option) any later version.
15 * This program is distributed in the hope that it will be useful,
16 * but WITHOUT ANY WARRANTY; without even the implied warranty of
17 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
18 * GNU General Public License for more details.
20 * You should have received a copy of the GNU General Public License
21 * along with this program; if not, write to the Free Software
22 * Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
25 * Alternatively, you can license this library under a commercial license,
26 * please contact Pulse-Eight Licensing for more information.
28 * For more information contact:
29 * Pulse-Eight Licensing <license@pulse-eight.com>
30 * http://www.pulse-eight.com/
31 * http://www.pulse-eight.net/
34 #include "../../../include/cectypes.h"
35 #include "../platform/threads/threads.h"
36 #include "../platform/util/buffer.h"
37 #include "AdapterCommunication.h"
38 #include "USBCECAdapterMessage.h"
49 class CUSBCECAdapterProcessor
: public PLATFORM::CThread
52 CUSBCECAdapterProcessor(IAdapterCommunicationCallback
*cb
) :
54 virtual ~CUSBCECAdapterProcessor(void)
60 void AddCommand(cec_command command
);
62 IAdapterCommunicationCallback
* m_callback
;
63 PLATFORM::SyncedBuffer
<cec_command
> m_inBuffer
;
66 class CUSBCECAdapterCommunication
: public IAdapterCommunication
, private PLATFORM::CThread
69 CUSBCECAdapterCommunication(CCECProcessor
*processor
, const char *strPort
, uint16_t iBaudRate
= 38400);
70 virtual ~CUSBCECAdapterCommunication();
72 virtual bool Open(IAdapterCommunicationCallback
*cb
, uint32_t iTimeoutMs
= 10000, bool bSkipChecks
= false);
73 virtual void Close(void);
74 virtual bool IsOpen(void);
75 virtual CStdString
GetError(void) const;
77 bool Read(cec_command
&command
, uint32_t iTimeout
);
78 cec_adapter_message_state
Write(const cec_command
&data
, uint8_t iMaxTries
, uint8_t iLineTimeout
= 3, uint8_t iRetryLineTimeout
= 3);
80 virtual bool SetLineTimeout(uint8_t iTimeout
);
81 virtual bool StartBootloader(void);
82 virtual bool SetAckMask(uint16_t iMask
);
83 virtual bool PingAdapter(void);
84 virtual uint16_t GetFirmwareVersion(void);
85 virtual bool SetControlledMode(bool controlled
);
86 virtual bool PersistConfiguration(libcec_configuration
*configuration
);
87 virtual bool GetConfiguration(libcec_configuration
*configuration
);
88 virtual CStdString
GetPortName(void);
89 virtual uint16_t GetPhysicalAddress(void) { return 0; }
93 bool SendCommand(cec_adapter_messagecode msgCode
, CCECAdapterMessage
¶ms
, bool bExpectAck
= true, bool bIsTransmission
= false, bool bSendDirectly
= true, bool bIsRetry
= false);
94 cec_datapacket
GetSetting(cec_adapter_messagecode msgCode
, uint8_t iResponseLength
);
96 bool SetSettingAutoEnabled(bool enabled
);
97 bool GetSettingAutoEnabled(bool &enabled
);
99 bool SetSettingDeviceType(cec_device_type type
);
100 bool GetSettingDeviceType(cec_device_type
&type
);
102 bool SetSettingDefaultLogicalAddress(cec_logical_address address
);
103 bool GetSettingDefaultLogicalAddress(cec_logical_address
&address
);
105 bool SetSettingLogicalAddressMask(uint16_t iMask
);
106 bool GetSettingLogicalAddressMask(uint16_t &iMask
);
108 bool SetSettingPhysicalAddress(uint16_t iPhysicalAddress
);
109 bool GetSettingPhysicalAddress(uint16_t &iPhysicalAddress
);
111 bool SetSettingCECVersion(cec_version version
);
112 bool GetSettingCECVersion(cec_version
&version
);
114 bool SetSettingOSDName(const char *strOSDName
);
115 bool GetSettingOSDName(CStdString
&strOSDName
);
117 bool WriteEEPROM(void);
119 bool SetAckMaskInternal(uint16_t iMask
, bool bWriteDirectly
= false);
121 bool CheckAdapter(uint32_t iTimeoutMs
= 10000);
122 bool Write(CCECAdapterMessage
*data
);
123 bool Read(CCECAdapterMessage
&msg
, uint32_t iTimeout
= 1000);
124 bool ParseMessage(const CCECAdapterMessage
&msg
);
125 void SendMessageToAdapter(CCECAdapterMessage
*msg
);
126 void WriteNextCommand(void);
127 void AddData(uint8_t *data
, size_t iLen
);
128 bool ReadFromDevice(uint32_t iTimeout
, size_t iSize
= 256);
129 bool WaitForAck(CCECAdapterMessage
&message
);
131 PLATFORM::ISocket
* m_port
;
132 CCECProcessor
* m_processor
;
133 PLATFORM::SyncedBuffer
<CCECAdapterMessage
*> m_inBuffer
;
134 PLATFORM::SyncedBuffer
<CCECAdapterMessage
*> m_outBuffer
;
135 PLATFORM::CMutex m_mutex
;
136 PLATFORM::CCondition
<volatile bool> m_rcvCondition
;
137 volatile bool m_bHasData
;
138 uint8_t m_iLineTimeout
;
139 uint16_t m_iFirmwareVersion
;
140 cec_command m_currentframe
;
141 cec_logical_address m_lastInitiator
;
142 CCECAdapterMessage m_currentAdapterMessage
;
143 bool m_bNextIsEscaped
;
145 IAdapterCommunicationCallback
* m_callback
;
146 CUSBCECAdapterProcessor
* m_messageProcessor
;