7 #include <sys/select.h>
23 #ifdef NEED_HDHOMERUN_DEVICE_SELECTOR_LOAD_FROM_STR
24 static int hdhomerun_device_selector_load_from_str(
struct hdhomerun_device_selector_t *hds,
char *device_str);
27 #define LOC QString("HDHRSH[%1](%2): ").arg(m_inputId).arg(m_device)
34 int inputid,
int majorid)
38 QMap<int,HDHRStreamHandler*>::iterator it =
s_handlers.find(majorid);
47 LOG(VB_RECORD, LOG_INFO,
48 QString(
"HDHRSH[%1]: Creating new stream handler %2 for %3")
49 .arg(inputid).arg(majorid).arg(devname));
55 LOG(VB_RECORD, LOG_INFO,
56 QString(
"HDHRSH[%1]: Using existing stream handler %2 for %3")
57 .arg(inputid).arg(majorid)
58 .arg(devname) + QString(
" (%1 in use)").arg(rcount));
74 QMap<int,HDHRStreamHandler*>::iterator it =
s_handlers.find(majorid);
84 LOG(VB_RECORD, LOG_INFO, QString(
"HDHRSH[%1]: Closing handler for %2")
85 .arg(inputid).arg(majorid));
92 LOG(VB_GENERAL, LOG_ERR,
93 QString(
"HDHRSH[%1] Error: Couldn't find handler for %2")
94 .arg(inputid).arg(majorid));
122 LOG(VB_GENERAL, LOG_ERR,
LOC +
123 "Starting recording (set target failed). Aborting.");
133 LOG(VB_RECORD, LOG_INFO,
LOC +
"RunTS(): begin");
136 QElapsedTimer last_update;
139 auto elapsed = !last_update.isValid()
140 ? -1ms : std::chrono::milliseconds(last_update.elapsed());
141 elapsed = (elapsed < 0ms) ? 1s : elapsed;
147 last_update.restart();
150 size_t read_size = VIDEO_DATA_BUFFER_SIZE_1S / 8;
151 read_size /= VIDEO_DATA_PACKET_SIZE;
152 read_size *= VIDEO_DATA_PACKET_SIZE;
154 size_t data_length = 0;
155 unsigned char *data_buffer = hdhomerun_device_stream_recv(
160 std::this_thread::sleep_for(20ms);
175 remainder = sit.key()->ProcessData(data_buffer, data_length);
177 WriteMPTS(data_buffer, data_length - remainder);
182 LOG(VB_RECORD, LOG_INFO,
LOC +
183 QString(
"RunTS(): data_length = %1 remainder = %2")
184 .arg(data_length).arg(remainder));
187 LOG(VB_RECORD, LOG_INFO,
LOC +
"RunTS(): " +
"shutdown");
198 struct hdhomerun_video_sock_t* vs =
nullptr;
199 struct hdhomerun_video_stats_t stats {};
203 hdhomerun_video_get_stats(vs, &stats);
204 LOG(VB_RECORD, LOG_INFO,
LOC +
205 QString(
"stream stats: packet_count=%1 "
207 "transport_errors=%3 "
208 "sequence_errors=%4 "
209 "overflow_errors=%5")
210 .arg(stats.packet_count)
211 .arg(stats.network_error_count)
212 .arg(stats.transport_error_count)
213 .arg(stats.sequence_error_count)
214 .arg(stats.overflow_error_count));
218 LOG(VB_RECORD, LOG_INFO,
LOC +
"RunTS(): " +
"end");
227 uint pid0 = (pid / (16*16*16)) % 16;
228 uint pid1 = (pid / (16*16)) % 16;
229 uint pid2 = (pid / (16)) % 16;
230 uint pid3 = pid % 16;
231 return QString(
"0x%1%2%3%4")
232 .arg(pid0,0,16).arg(pid1,0,16)
233 .arg(pid2,0,16).arg(pid3,0,16);
243 LOG(VB_GENERAL, LOG_ERR,
LOC +
244 "UpdateFilters called in wrong tune mode");
248 #ifdef DEBUG_PID_FILTERS
249 LOG(VB_RECORD, LOG_DEBUG,
LOC +
"UpdateFilters()");
250 #endif // DEBUG_PID_FILTERS
260 std::vector<uint> range_min;
261 std::vector<uint> range_max;
265 range_min.push_back(it.key());
266 PIDInfoMap::const_iterator eit = it;
268 (eit !=
m_pidInfo.cend()) && (it.key() + 1 == eit.key());
270 range_max.push_back(it.key());
272 if (range_min.size() > 16)
274 range_min.resize(16);
275 uint pid_max = range_max.back();
276 range_max.resize(15);
277 range_max.push_back(pid_max);
280 for (
size_t i = 0; i < range_min.size(); i++)
283 if (range_min[i] != range_max[i])
284 filter += QString(
"-%1").arg(
filt_str(range_max[i]));
288 filter = filter.trimmed();
290 QString new_filter =
TunerSet(
"filter", filter);
292 #ifdef DEBUG_PID_FILTERS
293 QString msg = QString(
"Filter: '%1'").arg(filter);
294 if (filter != new_filter)
295 msg += QString(
"\n\t\t\t\t'%2'").arg(new_filter);
297 LOG(VB_RECORD, LOG_DEBUG,
LOC + msg);
298 #endif // DEBUG_PID_FILTERS
302 return filter == new_filter;
311 if (QString(model).contains(
"cablecard", Qt::CaseInsensitive))
313 QString status_channel =
"none";
314 hdhomerun_tuner_status_t t_status {};
316 if (hdhomerun_device_get_oob_status(
319 LOG(VB_GENERAL, LOG_ERR,
LOC +
320 "Failed to query Cable card OOB channel");
324 status_channel = QString(t_status.channel);
325 LOG(VB_RECORD, LOG_INFO,
LOC +
326 QString(
"Cable card OOB channel is '%1'")
327 .arg(status_channel));
330 if (status_channel ==
"none")
332 LOG(VB_RECORD, LOG_INFO,
LOC +
"Cable card is not present");
337 LOG(VB_RECORD, LOG_INFO,
LOC +
"Cable card is present");
341 else if (QString(model).endsWith(
"dvbt", Qt::CaseInsensitive))
345 else if (QString(model).endsWith(
"dvbc", Qt::CaseInsensitive))
349 else if (QString(model).endsWith(
"dvbtc", Qt::CaseInsensitive))
384 LOG(VB_GENERAL, LOG_ERR,
LOC +
"Unable to create device selector");
388 QStringList devices =
m_device.split(
",");
389 for (
const QString& device : qAsConst(devices))
391 QByteArray ba = device.toUtf8();
392 int n = hdhomerun_device_selector_load_from_str(
394 LOG(VB_GENERAL, LOG_INFO,
LOC + QString(
"Added %1 devices from %3")
395 .arg(n).arg(device));
402 LOG(VB_GENERAL, LOG_ERR,
LOC +
403 QString(
"Unable to find a free device"));
411 LOG(VB_GENERAL, LOG_INFO,
LOC +
412 QString(
"Connected to device(%1)")
419 const QString &name,
bool report_error_return,
bool print_error)
const
425 LOG(VB_GENERAL, LOG_ERR,
LOC +
"Get request failed (not connected)");
429 QString valname = QString(
"/tuner%1/%2").arg(
m_tuner).arg(name);
430 char *value =
nullptr;
431 char *
error =
nullptr;
432 if (hdhomerun_device_get_var(
436 LOG(VB_GENERAL, LOG_ERR,
LOC +
437 QString(
"Get %1 request failed").arg(valname) +
ENO);
441 if (report_error_return &&
error)
445 LOG(VB_GENERAL, LOG_ERR,
LOC + QString(
"DeviceGet(%1): %2")
456 const QString &name,
const QString &val,
457 bool report_error_return,
bool print_error)
463 LOG(VB_GENERAL, LOG_ERR,
LOC +
"Set request failed (not connected)");
468 QString valname = QString(
"/tuner%1/%2").arg(
m_tuner).arg(name);
469 char *value =
nullptr;
470 char *
error =
nullptr;
473 LOG(VB_CHANSCAN, LOG_DEBUG,
LOC + valname +
" " + val);
475 if (hdhomerun_device_set_var(
477 val.toLocal8Bit().constData(), &value, &
error) < 0)
479 LOG(VB_GENERAL, LOG_ERR,
LOC +
480 QString(
"Set %1 to '%2' request failed").arg(valname, val) +
486 if (report_error_return &&
error)
491 if (!(val.contains(
"0x2000") && strstr(
error,
"ERROR: invalid pid filter")))
493 LOG(VB_GENERAL, LOG_ERR,
LOC + QString(
"DeviceSet(%1 %2): %3")
494 .arg(name, val,
error));
523 LOG(VB_RECORD, LOG_INFO,
LOC + QString(
"Not Re-Tuning channel %1")
528 LOG(VB_RECORD, LOG_INFO,
LOC + QString(
"Tuning channel %1 (was %2)")
530 return !
TunerSet(
"channel", chanid).isEmpty();
540 LOG(VB_GENERAL, LOG_ERR,
LOC +
"TuneProgram called in wrong tune mode");
544 LOG(VB_RECORD, LOG_INFO,
LOC + QString(
"Tuning program %1")
545 .arg(mpeg_prog_num));
547 "program", QString::number(mpeg_prog_num),
false).isEmpty();
557 LOG(VB_RECORD, LOG_INFO,
LOC + QString(
"Not Re-Tuning channel %1")
561 LOG(VB_RECORD, LOG_INFO,
LOC + QString(
"TuneVChannel(%1) from (%2)")
564 LOG(VB_RECORD, LOG_INFO,
LOC + QString(
"Tuning vchannel %1").arg(vchn));
565 return !
TunerSet(
"vchannel", vchn).isEmpty();
568 #ifdef NEED_HDHOMERUN_DEVICE_SELECTOR_LOAD_FROM_STR
574 struct hdhomerun_device_selector_t {
575 struct hdhomerun_device_t **hd_list;
577 struct hdhomerun_debug_t *dbg;
580 static int hdhomerun_device_selector_load_from_str_discover(
struct hdhomerun_device_selector_t *hds, uint32_t target_ip, uint32_t device_id)
582 struct hdhomerun_discover_device_t result;
583 int discover_count = hdhomerun_discover_find_devices_custom(target_ip, HDHOMERUN_DEVICE_TYPE_TUNER, device_id, &result, 1);
584 if (discover_count != 1) {
589 unsigned int tuner_index;
590 for (tuner_index = 0; tuner_index < result.tuner_count; tuner_index++) {
591 struct hdhomerun_device_t *hd = hdhomerun_device_create(result.device_id, result.ip_addr, tuner_index, hds->dbg);
596 hdhomerun_device_selector_add_device(hds, hd);
603 static int hdhomerun_device_selector_load_from_str(
struct hdhomerun_device_selector_t *hds,
char *device_str)
609 if (sscanf(device_str,
"%u.%u.%u.%u", &a[0], &a[1], &a[2], &a[3]) == 4) {
610 uint32_t ip_addr = (uint32_t)((a[0] << 24) | (a[1] << 16) | (a[2] << 8) | (a[3] << 0));
616 if (sscanf(device_str,
"%u.%u.%u.%u-%u", &a[0], &a[1], &a[2], &a[3], &tuner) == 5) {
617 struct hdhomerun_device_t *hd = hdhomerun_device_create(HDHOMERUN_DEVICE_ID_WILDCARD, ip_addr, tuner, hds->dbg);
622 hdhomerun_device_selector_add_device(hds, hd);
629 return hdhomerun_device_selector_load_from_str_discover(hds, ip_addr, HDHOMERUN_DEVICE_ID_WILDCARD);
636 uint32_t device_id = (uint32_t)strtoul(device_str, &end, 16);
637 if ((end == device_str + 8) && hdhomerun_discover_validate_device_id(device_id)) {
642 unsigned int tuner = (
unsigned int)strtoul(end + 1, NULL, 10);
643 struct hdhomerun_device_t *hd = hdhomerun_device_create(device_id, 0, tuner, hds->dbg);
648 hdhomerun_device_selector_add_device(hds, hd);
655 return hdhomerun_device_selector_load_from_str_discover(hds, 0, device_id);