cec: fix background polling and libcec exit
[deb_libcec.git] / src / lib / implementations / SLCommandHandler.cpp
1 /*
2 * This file is part of the libCEC(R) library.
3 *
4 * libCEC(R) is Copyright (C) 2011 Pulse-Eight Limited. All rights reserved.
5 * libCEC(R) is an original work, containing original code.
6 *
7 * libCEC(R) is a trademark of Pulse-Eight Limited.
8 *
9 * This program is dual-licensed; you can redistribute it and/or modify
10 * it under the terms of the GNU General Public License as published by
11 * the Free Software Foundation; either version 2 of the License, or
12 * (at your option) any later version.
13 *
14 * This program is distributed in the hope that it will be useful,
15 * but WITHOUT ANY WARRANTY; without even the implied warranty of
16 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
17 * GNU General Public License for more details.
18 *
19 * You should have received a copy of the GNU General Public License
20 * along with this program; if not, write to the Free Software
21 * Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
22 *
23 *
24 * Alternatively, you can license this library under a commercial license,
25 * please contact Pulse-Eight Licensing for more information.
26 *
27 * For more information contact:
28 * Pulse-Eight Licensing <license@pulse-eight.com>
29 * http://www.pulse-eight.com/
30 * http://www.pulse-eight.net/
31 */
32
33 #include "SLCommandHandler.h"
34 #include "../devices/CECBusDevice.h"
35 #include "../devices/CECPlaybackDevice.h"
36 #include "../CECProcessor.h"
37 #include "../platform/timeutils.h"
38
39 using namespace CEC;
40
41 #define SL_COMMAND_UNKNOWN_01 0x01
42 #define SL_COMMAND_UNKNOWN_02 0x02
43 #define SL_COMMAND_UNKNOWN_03 0x05
44
45 #define SL_COMMAND_REQUEST_POWER_STATUS 0xa0
46 #define SL_COMMAND_POWER_ON 0x0300
47 #define SL_COMMAND_CONNECT_REQUEST 0x04
48 #define SL_COMMAND_CONNECT_ACCEPT 0x05
49
50 CSLCommandHandler::CSLCommandHandler(CCECBusDevice *busDevice) :
51 CCECCommandHandler(busDevice),
52 m_bAwaitingReceiveFailed(false),
53 m_bSLEnabled(false),
54 m_bVendorIdSent(false)
55 {
56 }
57
58 bool CSLCommandHandler::HandleVendorCommand(const cec_command &command)
59 {
60 if (command.parameters.size == 1 &&
61 command.parameters[0] == SL_COMMAND_UNKNOWN_01)
62 {
63 HandleVendorCommand01(command);
64 return true;
65 }
66 else if (command.parameters.size == 2 &&
67 command.parameters[0] == SL_COMMAND_CONNECT_REQUEST)
68 {
69 HandleVendorCommand04(command);
70 return true;
71 }
72 else if (command.parameters.size == 1 &&
73 command.parameters[0] == SL_COMMAND_REQUEST_POWER_STATUS)
74 {
75 HandleVendorCommandA0(command);
76 return true;
77 }
78
79 return false;
80 }
81
82 bool CSLCommandHandler::HandleGiveDeckStatus(const cec_command &command)
83 {
84 if (command.parameters.size == 1)
85 {
86 if (command.parameters[0] == CEC_STATUS_REQUEST_ONCE ||
87 command.parameters[0] == CEC_STATUS_REQUEST_ON)
88 {
89 TransmitDeckStatus(command.initiator);
90 }
91 else
92 {
93 CCECCommandHandler::HandleGiveDeckStatus(command);
94 }
95 }
96 return true;
97 }
98
99 void CSLCommandHandler::HandleVendorCommand01(const cec_command &command)
100 {
101 cec_command response;
102 cec_command::Format(response, command.destination, command.initiator, CEC_OPCODE_VENDOR_COMMAND);
103 response.PushBack(SL_COMMAND_UNKNOWN_02);
104 response.PushBack(SL_COMMAND_UNKNOWN_03);
105
106 Transmit(response);
107
108 /* transmit power status */
109 if (command.destination != CECDEVICE_BROADCAST)
110 m_processor->m_busDevices[command.destination]->TransmitPowerState(command.initiator);
111 }
112
113 void CSLCommandHandler::HandleVendorCommand04(const cec_command &command)
114 {
115 cec_command response;
116 cec_command::Format(response, command.destination, command.initiator, CEC_OPCODE_VENDOR_COMMAND);
117 response.PushBack(SL_COMMAND_CONNECT_ACCEPT);
118 response.PushBack((uint8_t)m_processor->GetLogicalAddresses().primary);
119 Transmit(response);
120
121 TransmitDeckStatus(command.initiator);
122 }
123
124 void CSLCommandHandler::HandleVendorCommandA0(const cec_command &command)
125 {
126 if (command.destination != CECDEVICE_BROADCAST)
127 {
128 CCECBusDevice *device = m_processor->m_busDevices[m_processor->GetLogicalAddresses().primary];
129 device->SetPowerStatus(CEC_POWER_STATUS_IN_TRANSITION_STANDBY_TO_ON);
130 device->TransmitPowerState(command.initiator);
131 device->SetPowerStatus(CEC_POWER_STATUS_ON);
132 }
133 }
134
135 void CSLCommandHandler::TransmitDeckStatus(const cec_logical_address iDestination)
136 {
137 /* set deck status for the playback device */
138 CCECBusDevice *primary = m_processor->m_busDevices[m_processor->GetLogicalAddresses().primary];
139 if (primary->GetType() == CEC_DEVICE_TYPE_PLAYBACK_DEVICE || primary->GetType() == CEC_DEVICE_TYPE_RECORDING_DEVICE)
140 {
141 ((CCECPlaybackDevice *)primary)->SetDeckStatus(CEC_DECK_INFO_OTHER_STATUS_LG);
142 ((CCECPlaybackDevice *)primary)->TransmitDeckStatus(iDestination);
143 }
144 }
145
146 bool CSLCommandHandler::TransmitLGVendorId(const cec_logical_address iInitiator, const cec_logical_address iDestination)
147 {
148 cec_command response;
149 cec_command::Format(response, iInitiator, iDestination, CEC_OPCODE_DEVICE_VENDOR_ID);
150 response.parameters.PushBack((uint8_t) (((uint64_t)CEC_VENDOR_LG >> 16) & 0xFF));
151 response.parameters.PushBack((uint8_t) (((uint64_t)CEC_VENDOR_LG >> 8) & 0xFF));
152 response.parameters.PushBack((uint8_t) ((uint64_t)CEC_VENDOR_LG & 0xFF));
153
154 Transmit(response);
155 return true;
156 }
157
158 bool CSLCommandHandler::HandleGiveDeviceVendorId(const cec_command &command)
159 {
160 /* imitate LG devices */
161 CCECBusDevice *device = GetDevice(command.destination);
162 if (device)
163 device->SetVendorId(CEC_VENDOR_LG);
164
165 return CCECCommandHandler::HandleGiveDeviceVendorId(command);
166 }
167
168 bool CSLCommandHandler::HandleCommand(const cec_command &command)
169 {
170 bool bHandled(false);
171
172 if (m_processor->IsStarted() && m_busDevice->MyLogicalAddressContains(command.destination) ||
173 command.destination == CECDEVICE_BROADCAST)
174 {
175 switch(command.opcode)
176 {
177 case CEC_OPCODE_VENDOR_COMMAND:
178 bHandled = HandleVendorCommand(command);
179 break;
180 case CEC_OPCODE_FEATURE_ABORT:
181 {
182 if (!m_bVendorIdSent)
183 {
184 m_bVendorIdSent = true;
185 TransmitLGVendorId(m_processor->GetLogicalAddresses().primary, CECDEVICE_BROADCAST);
186 }
187 m_bSLEnabled = false;
188 }
189 bHandled = true;
190 default:
191 break;
192 }
193 }
194
195 if (!bHandled)
196 bHandled = CCECCommandHandler::HandleCommand(command);
197
198 return bHandled;
199 }
200
201 void CSLCommandHandler::HandlePoll(const cec_logical_address iInitiator, const cec_logical_address iDestination)
202 {
203 CCECCommandHandler::HandlePoll(iInitiator, iDestination);
204 m_bAwaitingReceiveFailed = true;
205 }
206
207 bool CSLCommandHandler::HandleReceiveFailed(void)
208 {
209 if (m_bAwaitingReceiveFailed)
210 {
211 m_bAwaitingReceiveFailed = false;
212 return false;
213 }
214
215 return true;
216 }
217
218 bool CSLCommandHandler::InitHandler(void)
219 {
220 if (m_bSLEnabled)
221 return true;
222 m_bSLEnabled = true;
223
224 m_processor->SetStandardLineTimeout(3);
225 m_processor->SetRetryLineTimeout(3);
226
227 /* increase the number of retries because the tv is keeping the bus busy at times */
228 m_iTransmitWait = 2000;
229 m_iTransmitRetries = 4;
230 m_iTransmitTimeout = 500;
231
232 CCECBusDevice *primary = m_processor->m_busDevices[m_processor->GetLogicalAddresses().primary];
233 if (m_busDevice->GetLogicalAddress() != primary->GetLogicalAddress())
234 primary->SetVendorId(CEC_VENDOR_LG, false);
235
236 if (m_busDevice->GetLogicalAddress() == CECDEVICE_TV)
237 {
238 primary->TransmitVendorID(CECDEVICE_TV);
239 primary->TransmitPhysicalAddress();
240
241 /* LG TVs don't always reply to CEC version requests, so just set it to 1.3a */
242 m_busDevice->SetCecVersion(CEC_VERSION_1_3A);
243 }
244
245 /* LG devices always return "korean" as language */
246 cec_menu_language lang;
247 lang.device = m_busDevice->GetLogicalAddress();
248 snprintf(lang.language, 4, "eng");
249 m_busDevice->SetMenuLanguage(lang);
250
251 if (m_busDevice->GetLogicalAddress() == CECDEVICE_TV)
252 {
253 m_processor->SetActiveSource(m_processor->GetLogicalAddresses().primary);
254 /* LG TVs only route keypresses when the deck status is set to 0x20 */
255 cec_logical_addresses addr = m_processor->GetLogicalAddresses();
256 for (uint8_t iPtr = 0; iPtr < 15; iPtr++)
257 {
258 CCECBusDevice *device = m_processor->m_busDevices[iPtr];
259
260 if (addr[iPtr])
261 {
262 if (device && (device->GetType() == CEC_DEVICE_TYPE_PLAYBACK_DEVICE ||
263 device->GetType() == CEC_DEVICE_TYPE_RECORDING_DEVICE))
264 {
265 ((CCECPlaybackDevice *)device)->SetDeckStatus(CEC_DECK_INFO_OTHER_STATUS_LG);
266 TransmitDeckStatus(CECDEVICE_TV);
267 }
268 }
269 }
270 }
271
272 return true;
273 }
274
275 bool CSLCommandHandler::TransmitPowerOn(const cec_logical_address iInitiator, const cec_logical_address iDestination)
276 {
277 if (iDestination != CECDEVICE_BROADCAST &&
278 m_processor->m_busDevices[iDestination]->GetVendorId(false) == CEC_VENDOR_LG);
279 {
280 cec_command command;
281 cec_command::Format(command, iInitiator, iDestination, CEC_OPCODE_VENDOR_COMMAND);
282 command.parameters.PushBack((uint8_t) (((uint16_t)SL_COMMAND_POWER_ON >> 8) & 0xFF));
283 command.parameters.PushBack((uint8_t) ((uint16_t)SL_COMMAND_POWER_ON & 0xFF));
284 return Transmit(command);
285 }
286
287 return CCECCommandHandler::TransmitPowerOn(iInitiator, iDestination);
288 }