Commit | Line | Data |
---|---|---|
7bb4ed43 LOK |
1 | #pragma once |
2 | /* | |
3 | * This file is part of the libCEC(R) library. | |
4 | * | |
16f47961 | 5 | * libCEC(R) is Copyright (C) 2011-2013 Pulse-Eight Limited. All rights reserved. |
7bb4ed43 LOK |
6 | * libCEC(R) is an original work, containing original code. |
7 | * | |
8 | * libCEC(R) is a trademark of Pulse-Eight Limited. | |
9 | * | |
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. | |
14 | * | |
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. | |
19 | * | |
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. | |
23 | * | |
24 | * | |
25 | * Alternatively, you can license this library under a commercial license, | |
26 | * please contact Pulse-Eight Licensing for more information. | |
27 | * | |
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/ | |
32 | */ | |
33 | ||
2b44051c LOK |
34 | #include "lib/platform/threads/threads.h" |
35 | #include "lib/adapter/AdapterCommunication.h" | |
cb8feb41 | 36 | #include "USBCECAdapterMessage.h" |
7bb4ed43 LOK |
37 | |
38 | namespace PLATFORM | |
39 | { | |
40 | class ISocket; | |
41 | } | |
42 | ||
43 | namespace CEC | |
44 | { | |
45 | class CCECProcessor; | |
56e53c14 | 46 | class CAdapterPingThread; |
3ead056c | 47 | class CAdapterEepromWriteThread; |
a75e3a5a LOK |
48 | class CUSBCECAdapterCommands; |
49 | class CCECAdapterMessageQueue; | |
2b44051c | 50 | class CCECAdapterMessage; |
7bb4ed43 | 51 | |
a75e3a5a | 52 | class CUSBCECAdapterCommunication : public IAdapterCommunication, public PLATFORM::CThread |
7bb4ed43 | 53 | { |
a75e3a5a LOK |
54 | friend class CUSBCECAdapterCommands; |
55 | friend class CCECAdapterMessageQueue; | |
3ead056c | 56 | friend class CAdapterEepromWriteThread; |
7bb4ed43 | 57 | |
a75e3a5a LOK |
58 | public: |
59 | /*! | |
60 | * @brief Create a new USB-CEC communication handler. | |
61 | * @param callback The callback to use for incoming CEC commands. | |
62 | * @param strPort The name of the com port to use. | |
63 | * @param iBaudRate The baudrate to use on the com port connection. | |
64 | */ | |
b32ffd87 | 65 | CUSBCECAdapterCommunication(IAdapterCommunicationCallback *callback, const char *strPort, uint16_t iBaudRate = CEC_SERIAL_DEFAULT_BAUDRATE); |
a75e3a5a LOK |
66 | virtual ~CUSBCECAdapterCommunication(void); |
67 | ||
68 | /** @name IAdapterCommunication implementation */ | |
69 | ///{ | |
b32ffd87 | 70 | bool Open(uint32_t iTimeoutMs = CEC_DEFAULT_CONNECT_TIMEOUT, bool bSkipChecks = false, bool bStartListening = true); |
a75e3a5a LOK |
71 | void Close(void); |
72 | bool IsOpen(void); | |
2b44051c LOK |
73 | std::string GetError(void) const; |
74 | cec_adapter_message_state Write(const cec_command &data, bool &bRetry, uint8_t iLineTimeout, bool bIsReply); | |
7bb4ed43 | 75 | |
a75e3a5a | 76 | bool StartBootloader(void); |
2b44051c LOK |
77 | bool SetLogicalAddresses(const cec_logical_addresses &addresses); |
78 | cec_logical_addresses GetLogicalAddresses(void); | |
a75e3a5a LOK |
79 | bool PingAdapter(void); |
80 | uint16_t GetFirmwareVersion(void); | |
b2f56d35 | 81 | uint32_t GetFirmwareBuildDate(void); |
5daed059 | 82 | bool IsRunningLatestFirmware(void); |
c0152c09 LOK |
83 | bool PersistConfiguration(const libcec_configuration &configuration); |
84 | bool GetConfiguration(libcec_configuration &configuration); | |
2b44051c | 85 | std::string GetPortName(void); |
200322e5 | 86 | uint16_t GetPhysicalAddress(void); |
a75e3a5a | 87 | bool SetControlledMode(bool controlled); |
2b44051c LOK |
88 | cec_vendor_id GetVendorId(void) { return CEC_VENDOR_UNKNOWN; } |
89 | bool SupportsSourceLogicalAddress(const cec_logical_address UNUSED(address)) { return true; } | |
2d418322 | 90 | cec_adapter_type GetAdapterType(void); |
8768aeca LOK |
91 | uint16_t GetAdapterVendorId(void) const; |
92 | uint16_t GetAdapterProductId(void) const; | |
a582c2bb | 93 | void SetActiveSource(bool bSetTo, bool bClientUnregistered); |
a75e3a5a | 94 | ///} |
7bb4ed43 | 95 | |
3ead056c LOK |
96 | bool ProvidesExtendedResponse(void); |
97 | ||
7bb4ed43 | 98 | void *Process(void); |
f9e01dac | 99 | |
a75e3a5a LOK |
100 | private: |
101 | /*! | |
102 | * @brief Clear all input bytes. | |
103 | * @param iTimeout Timeout when anything was received. | |
104 | */ | |
b32ffd87 | 105 | void ClearInputBytes(uint32_t iTimeout = CEC_CLEAR_INPUT_DEFAULT_WAIT); |
a75e3a5a LOK |
106 | |
107 | /*! | |
108 | * @brief Change the current CEC line timeout. | |
109 | * @param iTimeout The new timeout. | |
110 | * @return True when acked by the controller, false otherwise. | |
111 | */ | |
112 | bool SetLineTimeout(uint8_t iTimeout); | |
113 | ||
114 | /*! | |
115 | * @brief Send a command to the controller and wait for an ack. | |
116 | * @param msgCode The command to send. | |
117 | * @param params The parameters to the command. | |
118 | * @param bIsRetry True when this command is being retried, false otherwise. | |
119 | * @return The message. Delete when done with it. | |
120 | */ | |
121 | CCECAdapterMessage *SendCommand(cec_adapter_messagecode msgCode, CCECAdapterMessage ¶ms, bool bIsRetry = false); | |
122 | ||
123 | /*! | |
124 | * @brief Change the "initialised" status. | |
125 | * @param bSetTo The new value. | |
126 | */ | |
127 | void SetInitialised(bool bSetTo = true); | |
128 | ||
129 | /*! | |
130 | * @return True when initialised, false otherwise. | |
131 | */ | |
132 | bool IsInitialised(void); | |
133 | ||
134 | /*! | |
135 | * @brief Pings the adapter, checks the firmware version and sets controlled mode. | |
136 | * @param iTimeoutMs The timeout after which this fails if no proper data was received. | |
137 | * @return True when the checks passed, false otherwise. | |
138 | */ | |
b32ffd87 | 139 | bool CheckAdapter(uint32_t iTimeoutMs = CEC_DEFAULT_CONNECT_TIMEOUT); |
a75e3a5a LOK |
140 | |
141 | /*! | |
142 | * @brief Handle a poll message inside the adapter message (checks if one is present). | |
143 | * @param msg The adapter message to parse. | |
144 | * @return True when the message resulted in a CEC error, false otherwise. | |
145 | */ | |
146 | bool HandlePoll(const CCECAdapterMessage &msg); | |
147 | ||
148 | /*! | |
149 | * @brief Read data from the device. | |
150 | * @param iTimeout The read timeout to use. | |
151 | * @param iSize The maximum read size. | |
152 | * @return True when something was read, false otherwise. | |
153 | */ | |
b1f94db1 | 154 | bool ReadFromDevice(uint32_t iTimeout, size_t iSize = 256); |
a75e3a5a LOK |
155 | |
156 | /*! | |
157 | * @brief Writes a message to the serial port. | |
158 | * @param message The message to write. | |
159 | * @return True when written, false otherwise. | |
160 | */ | |
161 | bool WriteToDevice(CCECAdapterMessage *message); | |
162 | ||
163 | /*! | |
164 | * @brief Called before sending a CEC command over the line, so we know we're expecting an ack. | |
165 | * @param dest The destination of the CEC command. | |
166 | */ | |
167 | void MarkAsWaiting(const cec_logical_address dest); | |
168 | ||
c6f01e11 LOK |
169 | /*! |
170 | * @brief Clear and reset the message queue. | |
171 | */ | |
172 | void ResetMessageQueue(void); | |
173 | ||
a75e3a5a LOK |
174 | PLATFORM::ISocket * m_port; /**< the com port connection */ |
175 | PLATFORM::CMutex m_mutex; /**< mutex for changes in this class */ | |
176 | uint8_t m_iLineTimeout; /**< the current line timeout on the CEC line */ | |
177 | cec_logical_address m_lastPollDestination; /**< the destination of the last poll message that was received */ | |
178 | bool m_bInitialised; /**< true when the connection is initialised, false otherwise */ | |
179 | bool m_bWaitingForAck[15]; /**< array in which we store from which devices we're expecting acks */ | |
180 | CAdapterPingThread * m_pingThread; /**< ping thread, that pings the adapter every 15 seconds */ | |
3ead056c | 181 | CAdapterEepromWriteThread * m_eepromWriteThread; /**< eeprom writes are done async */ |
a75e3a5a LOK |
182 | CUSBCECAdapterCommands * m_commands; /**< commands that can be sent to the adapter */ |
183 | CCECAdapterMessageQueue * m_adapterMessageQueue; /**< the incoming and outgoing message queue */ | |
2b44051c | 184 | cec_logical_addresses m_logicalAddresses; /**< the logical address list that this instance is using */ |
3ead056c LOK |
185 | }; |
186 | ||
187 | class CAdapterEepromWriteThread : public PLATFORM::CThread | |
188 | { | |
189 | public: | |
190 | CAdapterEepromWriteThread(CUSBCECAdapterCommunication *com) : | |
191 | m_com(com), | |
192 | m_bWrite(false), | |
193 | m_iLastEepromWrite(0), | |
194 | m_iScheduleEepromWrite(0) {} | |
195 | virtual ~CAdapterEepromWriteThread(void) {} | |
196 | ||
197 | bool Write(void); | |
198 | void* Process(void); | |
199 | void Stop(void); | |
200 | private: | |
201 | CUSBCECAdapterCommunication *m_com; | |
202 | bool m_bWrite; | |
203 | PLATFORM::CCondition<bool> m_condition; | |
204 | PLATFORM::CMutex m_mutex; | |
205 | int64_t m_iLastEepromWrite; /**< last time that this instance did an eeprom write */ | |
206 | int64_t m_iScheduleEepromWrite; /**< in case there were more than 2 changes within 30 seconds, do another write at this time */ | |
56e53c14 LOK |
207 | }; |
208 | ||
209 | class CAdapterPingThread : public PLATFORM::CThread | |
210 | { | |
211 | public: | |
212 | CAdapterPingThread(CUSBCECAdapterCommunication *com, uint32_t iTimeout) : | |
213 | m_com(com), | |
214 | m_timeout(iTimeout){} | |
215 | virtual ~CAdapterPingThread(void) {} | |
216 | ||
3ead056c | 217 | void* Process(void); |
56e53c14 LOK |
218 | private: |
219 | CUSBCECAdapterCommunication *m_com; | |
220 | PLATFORM::CTimeout m_timeout; | |
7bb4ed43 LOK |
221 | }; |
222 | }; |