cec: add 'txn' command to cec-client. same as 'tx', but doesn't wait for ACK before...
[deb_libcec.git] / src / testclient / main.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 <cec.h>
34
35 #include <cstdio>
36 #include <fcntl.h>
37 #include <iostream>
38 #include <string>
39 #include <sstream>
40 #include "../lib/platform/threads.h"
41 #include "../lib/util/StdString.h"
42
43 using namespace CEC;
44 using namespace std;
45
46 #define CEC_TEST_CLIENT_VERSION 7
47
48 #include <cecloader.h>
49
50 inline bool HexStrToInt(const std::string& data, uint8_t& value)
51 {
52 int iTmp(0);
53 if (sscanf(data.c_str(), "%x", &iTmp) == 1)
54 {
55 if (iTmp > 256)
56 value = 255;
57 else if (iTmp < 0)
58 value = 0;
59 else
60 value = (uint8_t) iTmp;
61
62 return true;
63 }
64
65 return false;
66 }
67
68 //get the first word (separated by whitespace) from string data and place that in word
69 //then remove that word from string data
70 bool GetWord(string& data, string& word)
71 {
72 stringstream datastream(data);
73 string end;
74
75 datastream >> word;
76 if (datastream.fail())
77 {
78 data.clear();
79 return false;
80 }
81
82 size_t pos = data.find(word) + word.length();
83
84 if (pos >= data.length())
85 {
86 data.clear();
87 return true;
88 }
89
90 data = data.substr(pos);
91
92 datastream.clear();
93 datastream.str(data);
94
95 datastream >> end;
96 if (datastream.fail())
97 data.clear();
98
99 return true;
100 }
101
102 void flush_log(ICECAdapter *cecParser)
103 {
104 cec_log_message message;
105 while (cecParser && cecParser->GetNextLogMessage(&message))
106 {
107 switch (message.level)
108 {
109 case CEC_LOG_ERROR:
110 cout << "ERROR: ";
111 break;
112 case CEC_LOG_WARNING:
113 cout << "WARNING: ";
114 break;
115 case CEC_LOG_NOTICE:
116 cout << "NOTICE: ";
117 break;
118 case CEC_LOG_DEBUG:
119 cout << "DEBUG: ";
120 break;
121 }
122
123 CStdString strMessageTmp;
124 strMessageTmp.Format("[%16lld]\t%s", message.time, message.message);
125 cout << strMessageTmp.c_str() << endl;
126 }
127 }
128
129 void list_devices(ICECAdapter *parser)
130 {
131 cec_adapter *devices = new cec_adapter[10];
132 uint8_t iDevicesFound = parser->FindAdapters(devices, 10, NULL);
133 if (iDevicesFound <= 0)
134 {
135 cout << "Found devices: NONE" << endl;
136 }
137 else
138 {
139 CStdString strLog;
140 strLog.Format("Found devices: %d", iDevicesFound);
141 cout << strLog.c_str() << endl;
142 for (unsigned int iDevicePtr = 0; iDevicePtr < iDevicesFound; iDevicePtr++)
143 {
144 CStdString strDevice;
145 strDevice.Format("device: %d\npath: %s\ncom port: %s", iDevicePtr + 1, devices[iDevicePtr].path, devices[iDevicePtr].comm);
146 cout << endl << strDevice.c_str() << endl;
147 }
148 }
149 }
150
151 void show_help(const char* strExec)
152 {
153 cout << endl <<
154 strExec << " {-h|--help|-l|--list-devices|[COM PORT]}" << endl <<
155 endl <<
156 "parameters:" << endl <<
157 "\t-h --help Shows this help text" << endl <<
158 "\t-l --list-devices List all devices on this system" << endl <<
159 "\t[COM PORT] The com port to connect to. If no COM port is given, the client tries to connect to the first device that is detected" << endl <<
160 endl <<
161 "Type 'h' or 'help' and press enter after starting the client to display all available commands" << endl;
162 }
163
164 void show_console_help(void)
165 {
166 cout << endl <<
167 "================================================================================" << endl <<
168 "Available commands:" << endl <<
169 endl <<
170 "tx {bytes} transfer bytes over the CEC line." << endl <<
171 "txn {bytes} transfer bytes and don't wait for an ACK reply." << endl <<
172 "[tx 40 00 FF 11 22 33] sends bytes 0x40 0x00 0xFF 0x11 0x22 0x33" << endl <<
173 endl <<
174 "on {address} power on the device with the given logical address." << endl <<
175 "[on 5] power on a connected audio system" << endl <<
176 endl <<
177 "standby {address} put the device with the given address in standby mode." << endl <<
178 "[standby 0] powers off the TV" << endl <<
179 endl <<
180 "la {logical_address} change the logical address of the CEC adapter." << endl <<
181 "[la 4] logical address 4" << endl <<
182 endl <<
183 "[ping] send a ping command to the CEC adapter." << endl <<
184 "[bl] to let the adapter enter the bootloader, to upgrade" << endl <<
185 " the flash rom." << endl <<
186 "[r] reconnect to the CEC adapter." << endl <<
187 "[h] or [help] show this help." << endl <<
188 "[q] or [quit] to quit the CEC test client and switch off all" << endl <<
189 " connected CEC devices." << endl <<
190 "================================================================================" << endl;
191 }
192
193 int main (int argc, char *argv[])
194 {
195 ICECAdapter *parser = LoadLibCec("CECTester");
196 if (!parser || parser->GetMinVersion() > CEC_TEST_CLIENT_VERSION)
197 {
198 #ifdef __WINDOWS__
199 cout << "Cannot load libcec.dll" << endl;
200 #else
201 cout << "Cannot load libcec.so" << endl;
202 #endif
203 return 1;
204 }
205 CStdString strLog;
206 strLog.Format("CEC Parser created - libcec version %d", parser->GetLibVersion());
207 cout << strLog.c_str() << endl;
208
209 //make stdin non-blocking
210 #ifndef __WINDOWS__
211 int flags = fcntl(0, F_GETFL, 0);
212 flags |= O_NONBLOCK;
213 fcntl(0, F_SETFL, flags);
214 #endif
215
216 string strPort;
217 if (argc < 2)
218 {
219 cout << "no serial port given. trying autodetect: ";
220 cec_adapter devices[10];
221 uint8_t iDevicesFound = parser->FindAdapters(devices, 10, NULL);
222 if (iDevicesFound <= 0)
223 {
224 cout << "FAILED" << endl;
225 UnloadLibCec(parser);
226 return 1;
227 }
228 else
229 {
230 cout << endl << " path: " << devices[0].path << endl <<
231 " com port: " << devices[0].comm << endl << endl;
232 strPort = devices[0].comm;
233 }
234 }
235 else if (!strcmp(argv[1], "--list-devices") || !strcmp(argv[1], "-l"))
236 {
237 list_devices(parser);
238 UnloadLibCec(parser);
239 return 0;
240 }
241 else if (!strcmp(argv[1], "--help") || !strcmp(argv[1], "-h"))
242 {
243 show_help(argv[0]);
244 return 0;
245 }
246 else
247 {
248 strPort = argv[1];
249 }
250
251 if (!parser->Open(strPort.c_str()))
252 {
253 cout << "unable to open the device on port " << strPort << endl;
254 flush_log(parser);
255 UnloadLibCec(parser);
256 return 1;
257 }
258
259 cout << "cec device opened" << endl;
260
261 parser->PowerOnDevices(CECDEVICE_TV);
262 flush_log(parser);
263
264 parser->SetActiveView();
265 flush_log(parser);
266
267 bool bContinue(true);
268 cout << "waiting for input" << endl;
269 while (bContinue)
270 {
271 flush_log(parser);
272
273 string input;
274 getline(cin, input);
275 cin.clear();
276
277 if (!input.empty())
278 {
279 string command;
280 if (GetWord(input, command))
281 {
282 if (command == "tx" || command == "txn")
283 {
284 string strvalue;
285 uint8_t ivalue;
286 cec_command bytes;
287 bytes.clear();
288
289 while (GetWord(input, strvalue) && HexStrToInt(strvalue, ivalue))
290 bytes.push_back(ivalue);
291
292 parser->Transmit(bytes, command == "tx");
293 }
294 else if (command == "on")
295 {
296 string strValue;
297 uint8_t iValue = 0;
298 if (GetWord(input, strValue) && HexStrToInt(strValue, iValue) && iValue <= 0xF)
299 {
300 parser->PowerOnDevices((cec_logical_address) iValue);
301 }
302 else
303 {
304 cout << "invalid destination" << endl;
305 }
306 }
307 else if (command == "standby")
308 {
309 string strValue;
310 uint8_t iValue = 0;
311 if (GetWord(input, strValue) && HexStrToInt(strValue, iValue) && iValue <= 0xF)
312 {
313 parser->StandbyDevices((cec_logical_address) iValue);
314 }
315 else
316 {
317 cout << "invalid destination" << endl;
318 }
319 }
320 else if (command == "la")
321 {
322 string strvalue;
323 if (GetWord(input, strvalue))
324 {
325 parser->SetLogicalAddress((cec_logical_address) atoi(strvalue.c_str()));
326 }
327 }
328 else if (command == "ping")
329 {
330 parser->PingAdapter();
331 }
332 else if (command == "bl")
333 {
334 parser->StartBootloader();
335 }
336 else if (command == "r")
337 {
338 cout << "closing the connection" << endl;
339 parser->Close();
340 flush_log(parser);
341
342 cout << "opening a new connection" << endl;
343 parser->Open(strPort.c_str());
344 flush_log(parser);
345
346 cout << "setting active view" << endl;
347 parser->SetActiveView();
348 }
349 else if (command == "h" || command == "help")
350 {
351 show_console_help();
352 }
353 else if (command == "q" || command == "quit")
354 {
355 bContinue = false;
356 }
357 }
358 if (bContinue)
359 cout << "waiting for input" << endl;
360 }
361 CCondition::Sleep(50);
362 }
363
364 parser->StandbyDevices(CECDEVICE_BROADCAST);
365 parser->Close();
366 flush_log(parser);
367 UnloadLibCec(parser);
368 return 0;
369 }