7 #include <sys/select.h>
22 #ifdef NEED_HDHOMERUN_DEVICE_SELECTOR_LOAD_FROM_STR
23 static int hdhomerun_device_selector_load_from_str(
struct hdhomerun_device_selector_t *hds,
char *device_str);
26 #define LOC QString("HDHRSH[%1](%2): ").arg(m_inputId).arg(m_device)
33 int inputid,
int majorid)
37 QMap<int,HDHRStreamHandler*>::iterator it =
s_handlers.find(majorid);
46 LOG(VB_RECORD, LOG_INFO,
47 QString(
"HDHRSH[%1]: Creating new stream handler %2 for %3")
54 LOG(VB_RECORD, LOG_INFO,
55 QString(
"HDHRSH[%1]: Using existing stream handler %2 for %3")
57 .
arg(devname) + QString(
" (%1 in use)").
arg(rcount));
73 QMap<int,HDHRStreamHandler*>::iterator it =
s_handlers.find(majorid);
83 LOG(VB_RECORD, LOG_INFO, QString(
"HDHRSH[%1]: Closing handler for %2")
84 .
arg(inputid).
arg(majorid));
91 LOG(VB_GENERAL, LOG_ERR,
92 QString(
"HDHRSH[%1] Error: Couldn't find handler for %2")
93 .
arg(inputid).
arg(majorid));
121 LOG(VB_GENERAL, LOG_ERR,
LOC +
122 "Starting recording (set target failed). Aborting.");
132 LOG(VB_RECORD, LOG_INFO,
LOC +
"RunTS(): begin");
135 QElapsedTimer last_update;
138 int elapsed = !last_update.isValid() ? -1 : last_update.elapsed();
139 elapsed = (elapsed < 0) ? 1000 : elapsed;
145 last_update.restart();
148 size_t read_size = VIDEO_DATA_BUFFER_SIZE_1S / 8;
149 read_size /= VIDEO_DATA_PACKET_SIZE;
150 read_size *= VIDEO_DATA_PACKET_SIZE;
152 size_t data_length = 0;
153 unsigned char *data_buffer = hdhomerun_device_stream_recv(
158 std::this_thread::sleep_for(std::chrono::milliseconds(20));
173 remainder = sit.key()->ProcessData(data_buffer, data_length);
175 WriteMPTS(data_buffer, data_length - remainder);
180 LOG(VB_RECORD, LOG_INFO,
LOC +
181 QString(
"RunTS(): data_length = %1 remainder = %2")
182 .
arg(data_length).
arg(remainder));
185 LOG(VB_RECORD, LOG_INFO,
LOC +
"RunTS(): " +
"shutdown");
196 struct hdhomerun_video_sock_t* vs =
nullptr;
197 struct hdhomerun_video_stats_t stats {};
201 hdhomerun_video_get_stats(vs, &stats);
202 LOG(VB_RECORD, LOG_INFO,
LOC +
203 QString(
"stream stats: packet_count=%1 "
205 "transport_errors=%3 "
206 "sequence_errors=%4 "
207 "overflow_errors=%5")
208 .
arg(stats.packet_count)
209 .arg(stats.network_error_count)
210 .arg(stats.transport_error_count)
211 .arg(stats.sequence_error_count)
212 .arg(stats.overflow_error_count));
216 LOG(VB_RECORD, LOG_INFO,
LOC +
"RunTS(): " +
"end");
225 uint pid0 = (pid / (16*16*16)) % 16;
226 uint pid1 = (pid / (16*16)) % 16;
227 uint pid2 = (pid / (16)) % 16;
228 uint pid3 = pid % 16;
229 return QString(
"0x%1%2%3%4")
230 .arg(pid0,0,16).arg(pid1,0,16)
231 .arg(pid2,0,16).arg(pid3,0,16);
241 LOG(VB_GENERAL, LOG_ERR,
LOC +
242 "UpdateFilters called in wrong tune mode");
246 #ifdef DEBUG_PID_FILTERS
247 LOG(VB_RECORD, LOG_DEBUG,
LOC +
"UpdateFilters()");
248 #endif // DEBUG_PID_FILTERS
253 std::vector<uint> range_min;
254 std::vector<uint> range_max;
258 range_min.push_back(it.key());
259 PIDInfoMap::const_iterator eit = it;
261 (eit !=
m_pidInfo.cend()) && (it.key() + 1 == eit.key());
263 range_max.push_back(it.key());
265 if (range_min.size() > 16)
267 range_min.resize(16);
268 uint pid_max = range_max.back();
269 range_max.resize(15);
270 range_max.push_back(pid_max);
273 for (
size_t i = 0; i < range_min.size(); i++)
276 if (range_min[i] != range_max[i])
277 filter += QString(
"-%1").arg(
filt_str(range_max[i]));
281 filter = filter.trimmed();
283 QString new_filter =
TunerSet(
"filter", filter);
285 #ifdef DEBUG_PID_FILTERS
286 QString msg = QString(
"Filter: '%1'").arg(filter);
287 if (filter != new_filter)
288 msg += QString(
"\n\t\t\t\t'%2'").arg(new_filter);
290 LOG(VB_RECORD, LOG_DEBUG,
LOC + msg);
291 #endif // DEBUG_PID_FILTERS
293 return filter == new_filter;
302 if (QString(model).contains(
"cablecard", Qt::CaseInsensitive))
304 QString status_channel =
"none";
305 hdhomerun_tuner_status_t t_status {};
307 if (hdhomerun_device_get_oob_status(
310 LOG(VB_GENERAL, LOG_ERR,
LOC +
311 "Failed to query Cable card OOB channel");
315 status_channel = QString(t_status.channel);
316 LOG(VB_RECORD, LOG_INFO,
LOC +
317 QString(
"Cable card OOB channel is '%1'")
318 .
arg(status_channel));
321 if (status_channel ==
"none")
323 LOG(VB_RECORD, LOG_INFO,
LOC +
"Cable card is not present");
328 LOG(VB_RECORD, LOG_INFO,
LOC +
"Cable card is present");
332 else if (QString(model).endsWith(
"dvbt", Qt::CaseInsensitive))
336 else if (QString(model).endsWith(
"dvbc", Qt::CaseInsensitive))
340 else if (QString(model).endsWith(
"dvbtc", Qt::CaseInsensitive))
375 LOG(VB_GENERAL, LOG_ERR,
LOC +
"Unable to create device selector");
379 QStringList devices =
m_device.split(
",");
380 for (
int i = 0; i < devices.size(); ++i)
382 QByteArray ba = devices[i].toUtf8();
383 int n = hdhomerun_device_selector_load_from_str(
385 LOG(VB_GENERAL, LOG_INFO,
LOC + QString(
"Added %1 devices from %3")
393 LOG(VB_GENERAL, LOG_ERR,
LOC +
394 QString(
"Unable to find a free device"));
402 LOG(VB_GENERAL, LOG_INFO,
LOC +
403 QString(
"Connected to device(%1)")
410 const QString &name,
bool report_error_return,
bool print_error)
const
416 LOG(VB_GENERAL, LOG_ERR,
LOC +
"Get request failed (not connected)");
420 QString valname = QString(
"/tuner%1/%2").arg(
m_tuner).arg(name);
421 char *value =
nullptr;
422 char *
error =
nullptr;
423 if (hdhomerun_device_get_var(
427 LOG(VB_GENERAL, LOG_ERR,
LOC +
428 QString(
"Get %1 request failed").
arg(valname) +
ENO);
432 if (report_error_return &&
error)
436 LOG(VB_GENERAL, LOG_ERR,
LOC + QString(
"DeviceGet(%1): %2")
443 return QString(value);
447 const QString &name,
const QString &val,
448 bool report_error_return,
bool print_error)
454 LOG(VB_GENERAL, LOG_ERR,
LOC +
"Set request failed (not connected)");
459 QString valname = QString(
"/tuner%1/%2").arg(
m_tuner).arg(name);
460 char *value =
nullptr;
461 char *
error =
nullptr;
464 LOG(VB_CHANSCAN, LOG_DEBUG,
LOC + valname +
" " + val);
466 if (hdhomerun_device_set_var(
468 val.toLocal8Bit().constData(), &value, &
error) < 0)
470 LOG(VB_GENERAL, LOG_ERR,
LOC +
471 QString(
"Set %1 to '%2' request failed").
arg(valname).
arg(val) +
477 if (report_error_return &&
error)
482 if (!(val.contains(
"0x2000") && strstr(
error,
"ERROR: invalid pid filter")))
484 LOG(VB_GENERAL, LOG_ERR,
LOC + QString(
"DeviceSet(%1 %2): %3")
492 return QString(value);
514 LOG(VB_RECORD, LOG_INFO,
LOC + QString(
"Not Re-Tuning channel %1")
519 LOG(VB_RECORD, LOG_INFO,
LOC + QString(
"Tuning channel %1 (was %2)")
521 return !
TunerSet(
"channel", chanid).isEmpty();
531 LOG(VB_GENERAL, LOG_ERR,
LOC +
"TuneProgram called in wrong tune mode");
535 LOG(VB_RECORD, LOG_INFO,
LOC + QString(
"Tuning program %1")
536 .
arg(mpeg_prog_num));
538 "program", QString::number(mpeg_prog_num),
false).isEmpty();
548 LOG(VB_RECORD, LOG_INFO,
LOC + QString(
"Not Re-Tuning channel %1")
552 LOG(VB_RECORD, LOG_INFO,
LOC + QString(
"TuneVChannel(%1) from (%2)")
555 LOG(VB_RECORD, LOG_INFO,
LOC + QString(
"Tuning vchannel %1").
arg(vchn));
556 return !
TunerSet(
"vchannel", vchn).isEmpty();
559 #ifdef NEED_HDHOMERUN_DEVICE_SELECTOR_LOAD_FROM_STR
565 struct hdhomerun_device_selector_t {
566 struct hdhomerun_device_t **hd_list;
568 struct hdhomerun_debug_t *dbg;
571 static int hdhomerun_device_selector_load_from_str_discover(
struct hdhomerun_device_selector_t *hds, uint32_t target_ip, uint32_t device_id)
573 struct hdhomerun_discover_device_t result;
574 int discover_count = hdhomerun_discover_find_devices_custom(target_ip, HDHOMERUN_DEVICE_TYPE_TUNER, device_id, &result, 1);
575 if (discover_count != 1) {
580 unsigned int tuner_index;
581 for (tuner_index = 0; tuner_index < result.tuner_count; tuner_index++) {
582 struct hdhomerun_device_t *hd = hdhomerun_device_create(result.device_id, result.ip_addr, tuner_index, hds->dbg);
587 hdhomerun_device_selector_add_device(hds, hd);
594 static int hdhomerun_device_selector_load_from_str(
struct hdhomerun_device_selector_t *hds,
char *device_str)
600 if (sscanf(device_str,
"%u.%u.%u.%u", &a[0], &a[1], &a[2], &a[3]) == 4) {
601 uint32_t ip_addr = (uint32_t)((a[0] << 24) | (a[1] << 16) | (a[2] << 8) | (a[3] << 0));
607 if (sscanf(device_str,
"%u.%u.%u.%u-%u", &a[0], &a[1], &a[2], &a[3], &tuner) == 5) {
608 struct hdhomerun_device_t *hd = hdhomerun_device_create(HDHOMERUN_DEVICE_ID_WILDCARD, ip_addr, tuner, hds->dbg);
613 hdhomerun_device_selector_add_device(hds, hd);
620 return hdhomerun_device_selector_load_from_str_discover(hds, ip_addr, HDHOMERUN_DEVICE_ID_WILDCARD);
627 uint32_t device_id = (uint32_t)strtoul(device_str, &end, 16);
628 if ((end == device_str + 8) && hdhomerun_discover_validate_device_id(device_id)) {
633 unsigned int tuner = (
unsigned int)strtoul(end + 1,
NULL, 10);
634 struct hdhomerun_device_t *hd = hdhomerun_device_create(device_id, 0, tuner, hds->dbg);
639 hdhomerun_device_selector_add_device(hds, hd);
646 return hdhomerun_device_selector_load_from_str_discover(hds, 0, device_id);