Commit | Line | Data |
---|---|---|
7bb4ed43 LOK |
1 | #pragma once |
2 | /* | |
3 | * This file is part of the libCEC(R) library. | |
4 | * | |
5 | * libCEC(R) is Copyright (C) 2011-2012 Pulse-Eight Limited. All rights reserved. | |
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 | ||
4c9b9776 | 34 | #include "../../../include/cectypes.h" |
7bb4ed43 LOK |
35 | #include "../platform/threads/threads.h" |
36 | #include "../platform/util/buffer.h" | |
37 | #include "AdapterCommunication.h" | |
38 | #include "USBCECAdapterMessage.h" | |
39 | ||
40 | namespace PLATFORM | |
41 | { | |
42 | class ISocket; | |
43 | } | |
44 | ||
45 | namespace CEC | |
46 | { | |
47 | class CCECProcessor; | |
56e53c14 | 48 | class CAdapterPingThread; |
a75e3a5a LOK |
49 | class CUSBCECAdapterCommands; |
50 | class CCECAdapterMessageQueue; | |
7bb4ed43 | 51 | |
a75e3a5a | 52 | class CUSBCECAdapterCommunication : public IAdapterCommunication, public PLATFORM::CThread |
7bb4ed43 | 53 | { |
a75e3a5a LOK |
54 | friend class CUSBCECAdapterCommands; |
55 | friend class CCECAdapterMessageQueue; | |
7bb4ed43 | 56 | |
a75e3a5a LOK |
57 | public: |
58 | /*! | |
59 | * @brief Create a new USB-CEC communication handler. | |
60 | * @param callback The callback to use for incoming CEC commands. | |
61 | * @param strPort The name of the com port to use. | |
62 | * @param iBaudRate The baudrate to use on the com port connection. | |
63 | */ | |
b32ffd87 | 64 | CUSBCECAdapterCommunication(IAdapterCommunicationCallback *callback, const char *strPort, uint16_t iBaudRate = CEC_SERIAL_DEFAULT_BAUDRATE); |
a75e3a5a LOK |
65 | virtual ~CUSBCECAdapterCommunication(void); |
66 | ||
67 | /** @name IAdapterCommunication implementation */ | |
68 | ///{ | |
b32ffd87 | 69 | bool Open(uint32_t iTimeoutMs = CEC_DEFAULT_CONNECT_TIMEOUT, bool bSkipChecks = false, bool bStartListening = true); |
a75e3a5a LOK |
70 | void Close(void); |
71 | bool IsOpen(void); | |
72 | CStdString GetError(void) const; | |
33dd87a9 | 73 | cec_adapter_message_state Write(const cec_command &data, bool &bRetry, uint8_t iLineTimeout = 3); |
7bb4ed43 | 74 | |
a75e3a5a LOK |
75 | bool StartBootloader(void); |
76 | bool SetAckMask(uint16_t iMask); | |
77 | bool PingAdapter(void); | |
78 | uint16_t GetFirmwareVersion(void); | |
b2f56d35 | 79 | uint32_t GetFirmwareBuildDate(void); |
a75e3a5a LOK |
80 | bool PersistConfiguration(libcec_configuration *configuration); |
81 | bool GetConfiguration(libcec_configuration *configuration); | |
82 | CStdString GetPortName(void); | |
83 | uint16_t GetPhysicalAddress(void) { return 0; } | |
84 | bool SetControlledMode(bool controlled); | |
85 | ///} | |
7bb4ed43 LOK |
86 | |
87 | void *Process(void); | |
f9e01dac | 88 | |
a75e3a5a LOK |
89 | private: |
90 | /*! | |
91 | * @brief Clear all input bytes. | |
92 | * @param iTimeout Timeout when anything was received. | |
93 | */ | |
b32ffd87 | 94 | void ClearInputBytes(uint32_t iTimeout = CEC_CLEAR_INPUT_DEFAULT_WAIT); |
a75e3a5a LOK |
95 | |
96 | /*! | |
97 | * @brief Change the current CEC line timeout. | |
98 | * @param iTimeout The new timeout. | |
99 | * @return True when acked by the controller, false otherwise. | |
100 | */ | |
101 | bool SetLineTimeout(uint8_t iTimeout); | |
102 | ||
103 | /*! | |
104 | * @brief Send a command to the controller and wait for an ack. | |
105 | * @param msgCode The command to send. | |
106 | * @param params The parameters to the command. | |
107 | * @param bIsRetry True when this command is being retried, false otherwise. | |
108 | * @return The message. Delete when done with it. | |
109 | */ | |
110 | CCECAdapterMessage *SendCommand(cec_adapter_messagecode msgCode, CCECAdapterMessage ¶ms, bool bIsRetry = false); | |
111 | ||
112 | /*! | |
113 | * @brief Change the "initialised" status. | |
114 | * @param bSetTo The new value. | |
115 | */ | |
116 | void SetInitialised(bool bSetTo = true); | |
117 | ||
118 | /*! | |
119 | * @return True when initialised, false otherwise. | |
120 | */ | |
121 | bool IsInitialised(void); | |
122 | ||
123 | /*! | |
124 | * @brief Pings the adapter, checks the firmware version and sets controlled mode. | |
125 | * @param iTimeoutMs The timeout after which this fails if no proper data was received. | |
126 | * @return True when the checks passed, false otherwise. | |
127 | */ | |
b32ffd87 | 128 | bool CheckAdapter(uint32_t iTimeoutMs = CEC_DEFAULT_CONNECT_TIMEOUT); |
a75e3a5a LOK |
129 | |
130 | /*! | |
131 | * @brief Handle a poll message inside the adapter message (checks if one is present). | |
132 | * @param msg The adapter message to parse. | |
133 | * @return True when the message resulted in a CEC error, false otherwise. | |
134 | */ | |
135 | bool HandlePoll(const CCECAdapterMessage &msg); | |
136 | ||
137 | /*! | |
138 | * @brief Read data from the device. | |
139 | * @param iTimeout The read timeout to use. | |
140 | * @param iSize The maximum read size. | |
141 | * @return True when something was read, false otherwise. | |
142 | */ | |
b1f94db1 | 143 | bool ReadFromDevice(uint32_t iTimeout, size_t iSize = 256); |
a75e3a5a LOK |
144 | |
145 | /*! | |
146 | * @brief Writes a message to the serial port. | |
147 | * @param message The message to write. | |
148 | * @return True when written, false otherwise. | |
149 | */ | |
150 | bool WriteToDevice(CCECAdapterMessage *message); | |
151 | ||
152 | /*! | |
153 | * @brief Called before sending a CEC command over the line, so we know we're expecting an ack. | |
154 | * @param dest The destination of the CEC command. | |
155 | */ | |
156 | void MarkAsWaiting(const cec_logical_address dest); | |
157 | ||
158 | PLATFORM::ISocket * m_port; /**< the com port connection */ | |
159 | PLATFORM::CMutex m_mutex; /**< mutex for changes in this class */ | |
160 | uint8_t m_iLineTimeout; /**< the current line timeout on the CEC line */ | |
161 | cec_logical_address m_lastPollDestination; /**< the destination of the last poll message that was received */ | |
162 | bool m_bInitialised; /**< true when the connection is initialised, false otherwise */ | |
163 | bool m_bWaitingForAck[15]; /**< array in which we store from which devices we're expecting acks */ | |
164 | CAdapterPingThread * m_pingThread; /**< ping thread, that pings the adapter every 15 seconds */ | |
165 | CUSBCECAdapterCommands * m_commands; /**< commands that can be sent to the adapter */ | |
166 | CCECAdapterMessageQueue * m_adapterMessageQueue; /**< the incoming and outgoing message queue */ | |
56e53c14 LOK |
167 | }; |
168 | ||
169 | class CAdapterPingThread : public PLATFORM::CThread | |
170 | { | |
171 | public: | |
172 | CAdapterPingThread(CUSBCECAdapterCommunication *com, uint32_t iTimeout) : | |
173 | m_com(com), | |
174 | m_timeout(iTimeout){} | |
175 | virtual ~CAdapterPingThread(void) {} | |
176 | ||
177 | virtual void* Process(void); | |
178 | private: | |
179 | CUSBCECAdapterCommunication *m_com; | |
180 | PLATFORM::CTimeout m_timeout; | |
7bb4ed43 LOK |
181 | }; |
182 | }; |