With this change to the source I was able to run properly "SIGNAL STRENGTH."

Using the device Netsystem TechniSat SkyStar 2 DVB-S rev 2.3P.

Great as a solution ...

Modified Source -> /usr/local/src/vdr-2.0.3/dvbdevice.c

/* * dvbdevice.c: The DVB device tuner interface * * See the main source file 'vdr.c' for copyright information and * how to reach the author. * * $Id: dvbdevice.c 2.88.1.2 2013/08/23 09:52:14 kls Exp $ */

#include "dvbdevice.h" #include <ctype.h> #include <errno.h> #include <limits.h> #include <linux/dvb/dmx.h> #include <linux/dvb/frontend.h> #include <sys/ioctl.h> #include <sys/mman.h> #include "channels.h" #include "diseqc.h" #include "dvbci.h" #include "menuitems.h" #include "sourceparams.h"

static int DvbApiVersion = 0x0000; // the version of the DVB driver actually in use (will be determined by the first device created)

#define DVBS_TUNE_TIMEOUT 9000 //ms #define DVBS_LOCK_TIMEOUT 2000 //ms #define DVBC_TUNE_TIMEOUT 9000 //ms #define DVBC_LOCK_TIMEOUT 2000 //ms #define DVBT_TUNE_TIMEOUT 9000 //ms #define DVBT_LOCK_TIMEOUT 2000 //ms #define ATSC_TUNE_TIMEOUT 9000 //ms #define ATSC_LOCK_TIMEOUT 2000 //ms

#define SCR_RANDOM_TIMEOUT 500 // ms (add random value up to this when tuning SCR device to avoid lockups)

// --- DVB Parameter Maps ----------------------------------------------------

const tDvbParameterMap InversionValues[] = { { 0, INVERSION_OFF, trNOOP("off") }, { 1, INVERSION_ON, trNOOP("on") }, { 999, INVERSION_AUTO, trNOOP("auto") }, { -1, 0, NULL } };

const tDvbParameterMap BandwidthValues[] = { { 5, 5000000, "5 MHz" }, { 6, 6000000, "6 MHz" }, { 7, 7000000, "7 MHz" }, { 8, 8000000, "8 MHz" }, { 10, 10000000, "10 MHz" }, { 1712, 1712000, "1.712 MHz" }, { -1, 0, NULL } };

const tDvbParameterMap CoderateValues[] = { { 0, FEC_NONE, trNOOP("none") }, { 12, FEC_1_2, "1/2" }, { 23, FEC_2_3, "2/3" }, { 34, FEC_3_4, "3/4" }, { 35, FEC_3_5, "3/5" }, { 45, FEC_4_5, "4/5" }, { 56, FEC_5_6, "5/6" }, { 67, FEC_6_7, "6/7" }, { 78, FEC_7_8, "7/8" }, { 89, FEC_8_9, "8/9" }, { 910, FEC_9_10, "9/10" }, { 999, FEC_AUTO, trNOOP("auto") }, { -1, 0, NULL } };

const tDvbParameterMap ModulationValues[] = { { 16, QAM_16, "QAM16" }, { 32, QAM_32, "QAM32" }, { 64, QAM_64, "QAM64" }, { 128, QAM_128, "QAM128" }, { 256, QAM_256, "QAM256" }, { 2, QPSK, "QPSK" }, { 5, PSK_8, "8PSK" }, { 6, APSK_16, "16APSK" }, { 7, APSK_32, "32APSK" }, { 10, VSB_8, "VSB8" }, { 11, VSB_16, "VSB16" }, { 12, DQPSK, "DQPSK" }, { 999, QAM_AUTO, trNOOP("auto") }, { -1, 0, NULL } };

#define DVB_SYSTEM_1 0 // see also nit.c #define DVB_SYSTEM_2 1

const tDvbParameterMap SystemValuesSat[] = { { 0, DVB_SYSTEM_1, "DVB-S" }, { 1, DVB_SYSTEM_2, "DVB-S2" }, { -1, 0, NULL } };

const tDvbParameterMap SystemValuesTerr[] = { { 0, DVB_SYSTEM_1, "DVB-T" }, { 1, DVB_SYSTEM_2, "DVB-T2" }, { -1, 0, NULL } };

const tDvbParameterMap TransmissionValues[] = { { 1, TRANSMISSION_MODE_1K, "1K" }, { 2, TRANSMISSION_MODE_2K, "2K" }, { 4, TRANSMISSION_MODE_4K, "4K" }, { 8, TRANSMISSION_MODE_8K, "8K" }, { 16, TRANSMISSION_MODE_16K, "16K" }, { 32, TRANSMISSION_MODE_32K, "32K" }, { 999, TRANSMISSION_MODE_AUTO, trNOOP("auto") }, { -1, 0, NULL } };

const tDvbParameterMap GuardValues[] = { { 4, GUARD_INTERVAL_1_4, "1/4" }, { 8, GUARD_INTERVAL_1_8, "1/8" }, { 16, GUARD_INTERVAL_1_16, "1/16" }, { 32, GUARD_INTERVAL_1_32, "1/32" }, { 128, GUARD_INTERVAL_1_128, "1/128" }, { 19128, GUARD_INTERVAL_19_128, "19/128" }, { 19256, GUARD_INTERVAL_19_256, "19/256" }, { 999, GUARD_INTERVAL_AUTO, trNOOP("auto") }, { -1, 0, NULL } };

const tDvbParameterMap HierarchyValues[] = { { 0, HIERARCHY_NONE, trNOOP("none") }, { 1, HIERARCHY_1, "1" }, { 2, HIERARCHY_2, "2" }, { 4, HIERARCHY_4, "4" }, { 999, HIERARCHY_AUTO, trNOOP("auto") }, { -1, 0, NULL } };

const tDvbParameterMap RollOffValues[] = { { 0, ROLLOFF_AUTO, trNOOP("auto") }, { 20, ROLLOFF_20, "0.20" }, { 25, ROLLOFF_25, "0.25" }, { 35, ROLLOFF_35, "0.35" }, { -1, 0, NULL } };

int UserIndex(int Value, const tDvbParameterMap *Map) { const tDvbParameterMap *map = Map; while (map && map->userValue != -1) { if (map->userValue == Value) return map - Map; map++; } return -1; }

int DriverIndex(int Value, const tDvbParameterMap *Map) { const tDvbParameterMap *map = Map; while (map && map->userValue != -1) { if (map->driverValue == Value) return map - Map; map++; } return -1; }

int MapToUser(int Value, const tDvbParameterMap *Map, const char **String) { int n = DriverIndex(Value, Map); if (n >= 0) { if (String) *String = tr(Map[n].userString); return Map[n].userValue; } return -1; }

const char *MapToUserString(int Value, const tDvbParameterMap *Map) { int n = DriverIndex(Value, Map); if (n >= 0) return Map[n].userString; return "???"; }

int MapToDriver(int Value, const tDvbParameterMap *Map) { int n = UserIndex(Value, Map); if (n >= 0) return Map[n].driverValue; return -1; }

// --- cDvbTransponderParameters ---------------------------------------------

cDvbTransponderParameters::cDvbTransponderParameters(const char *Parameters) { polarization = 0; inversion = INVERSION_AUTO; bandwidth = 8000000; coderateH = FEC_AUTO; coderateL = FEC_AUTO; modulation = QPSK; system = DVB_SYSTEM_1; transmission = TRANSMISSION_MODE_AUTO; guard = GUARD_INTERVAL_AUTO; hierarchy = HIERARCHY_AUTO; rollOff = ROLLOFF_AUTO; streamId = 0; Parse(Parameters); }

int cDvbTransponderParameters::PrintParameter(char *p, char Name, int Value) const { return Value >= 0 && Value != 999 ? sprintf(p, "%c%d", Name, Value) : 0; }

cString cDvbTransponderParameters::ToString(char Type) const { #define ST(s) if (strchr(s, Type) && (strchr(s, '0' + system + 1) || strchr(s, '*'))) char buffer[64]; char *q = buffer; *q = 0; ST(" S *") q += sprintf(q, "%c", polarization); ST(" T*") q += PrintParameter(q, 'B', MapToUser(bandwidth, BandwidthValues)); ST(" CST*") q += PrintParameter(q, 'C', MapToUser(coderateH, CoderateValues)); ST(" T*") q += PrintParameter(q, 'D', MapToUser(coderateL, CoderateValues)); ST(" T*") q += PrintParameter(q, 'G', MapToUser(guard, GuardValues)); ST("ACST*") q += PrintParameter(q, 'I', MapToUser(inversion, InversionValues)); ST("ACST*") q += PrintParameter(q, 'M', MapToUser(modulation, ModulationValues)); ST(" S 2") q += PrintParameter(q, 'O', MapToUser(rollOff, RollOffValues)); ST(" ST2") q += PrintParameter(q, 'P', streamId); ST(" ST*") q += PrintParameter(q, 'S', MapToUser(system, SystemValuesSat)); // we only need the numerical value, so Sat or Terr doesn't matter ST(" T*") q += PrintParameter(q, 'T', MapToUser(transmission, TransmissionValues)); ST(" T*") q += PrintParameter(q, 'Y', MapToUser(hierarchy, HierarchyValues)); return buffer; }

const char *cDvbTransponderParameters::ParseParameter(const char *s, int &Value, const tDvbParameterMap *Map) { if (*++s) { char *p = NULL; errno = 0; int n = strtol(s, &p, 10); if (!errno && p != s) { Value = Map ? MapToDriver(n, Map) : n; if (Value >= 0) return p; } } esyslog("ERROR: invalid value for parameter '%c'", *(s - 1)); return NULL; }

bool cDvbTransponderParameters::Parse(const char *s) { while (s && *s) { switch (toupper(*s)) { case 'B': s = ParseParameter(s, bandwidth, BandwidthValues); break; case 'C': s = ParseParameter(s, coderateH, CoderateValues); break; case 'D': s = ParseParameter(s, coderateL, CoderateValues); break; case 'G': s = ParseParameter(s, guard, GuardValues); break; case 'H': polarization = 'H'; s++; break; case 'I': s = ParseParameter(s, inversion, InversionValues); break; case 'L': polarization = 'L'; s++; break; case 'M': s = ParseParameter(s, modulation, ModulationValues); break; case 'O': s = ParseParameter(s, rollOff, RollOffValues); break; case 'P': s = ParseParameter(s, streamId); break; case 'R': polarization = 'R'; s++; break; case 'S': s = ParseParameter(s, system, SystemValuesSat); break; // we only need the numerical value, so Sat or Terr doesn't matter case 'T': s = ParseParameter(s, transmission, TransmissionValues); break; case 'V': polarization = 'V'; s++; break; case 'Y': s = ParseParameter(s, hierarchy, HierarchyValues); break; default: esyslog("ERROR: unknown parameter key '%c'", *s); return false; } } return true; }

// --- cDvbTuner -------------------------------------------------------------

#define TUNER_POLL_TIMEOUT 10 // ms

class cDvbTuner : public cThread { private: static cMutex bondMutex; enum eTunerStatus { tsIdle, tsSet, tsTuned, tsLocked }; bool SendDiseqc; int frontendType; const cDvbDevice *device; mutable int fd_frontend; int adapter, frontend; uint32_t subsystemId; int tuneTimeout; int lockTimeout; time_t lastTimeoutReport; cChannel channel; const cDiseqc *lastDiseqc; const cScr *scr; bool lnbPowerTurnedOn; eTunerStatus tunerStatus; mutable cMutex mutex; cCondVar locked; cCondVar newSet; dvb_diseqc_master_cmd diseqc_cmd; cDvbTuner *bondedTuner; bool bondedMaster; bool SetFrontendType(const cChannel *Channel); cString GetBondingParams(const cChannel *Channel = NULL) const; cDvbTuner *GetBondedMaster(void); bool IsBondedMaster(void) const { return !bondedTuner || bondedMaster; } void ClearEventQueue(void) const; bool GetFrontendStatus(fe_status_t &Status) const; void ExecuteDiseqc(const cDiseqc *Diseqc, unsigned int *Frequency); void ResetToneAndVoltage(void); bool SetFrontend(void); virtual void Action(void);

mutable bool isIdle; bool OpenFrontend(void) const; bool CloseFrontend(void); public: cDvbTuner(const cDvbDevice *Device, int Fd_Frontend, int Adapter, int Frontend); virtual ~cDvbTuner(); int FrontendType(void) const { return frontendType; } bool Bond(cDvbTuner *Tuner); void UnBond(void); bool BondingOk(const cChannel *Channel, bool ConsiderOccupied = false) const; const cChannel *GetTransponder(void) const { return &channel; } uint32_t SubsystemId(void) const { return subsystemId; } bool IsTunedTo(const cChannel *Channel) const; void SetChannel(const cChannel *Channel); bool Locked(int TimeoutMs = 0); int GetSignalStrength(void) const; int GetSignalQuality(void) const; bool SetIdle(bool Idle); bool IsIdle(void) const { return isIdle; } bool SendDiseqcCmd(dvb_diseqc_master_cmd cmd); private: int GetCurrentDeliverySystem(void); };

cMutex cDvbTuner::bondMutex;

cDvbTuner::cDvbTuner(const cDvbDevice *Device, int Fd_Frontend, int Adapter, int Frontend) { SendDiseqc = false; frontendType = SYS_UNDEFINED; device = Device; fd_frontend = Fd_Frontend; adapter = Adapter; frontend = Frontend; subsystemId = cDvbDeviceProbe::GetSubsystemId(adapter, frontend); tuneTimeout = 0; lockTimeout = 0; lastTimeoutReport = 0; lastDiseqc = NULL; scr = NULL; lnbPowerTurnedOn = false; tunerStatus = tsIdle; bondedTuner = NULL; bondedMaster = false; isIdle = false; SetDescription("tuner on frontend %d/%d", adapter, frontend); Start(); }

cDvbTuner::~cDvbTuner() { tunerStatus = tsIdle; newSet.Broadcast(); locked.Broadcast(); Cancel(3); UnBond(); /* looks like this irritates the SCR switch, so let's leave it out for now if (lastDiseqc && lastDiseqc->IsScr()) { unsigned int Frequency = 0; ExecuteDiseqc(lastDiseqc, &Frequency); } */ if (device && device->IsSubDevice()) CloseFrontend(); }

bool cDvbTuner::Bond(cDvbTuner *Tuner) { cMutexLock MutexLock(&bondMutex); if (!bondedTuner) { ResetToneAndVoltage(); bondedMaster = false; // makes sure we don't disturb an existing master bondedTuner = Tuner->bondedTuner ? Tuner->bondedTuner : Tuner; Tuner->bondedTuner = this; dsyslog("tuner %d/%d bonded with tuner %d/%d", adapter, frontend, bondedTuner->adapter, bondedTuner->frontend); return true; } else esyslog("ERROR: tuner %d/%d already bonded with tuner %d/%d, can't bond with tuner %d/%d", adapter, frontend, bondedTuner->adapter, bondedTuner->frontend, Tuner->adapter, Tuner->frontend); return false; }

void cDvbTuner::UnBond(void) { cMutexLock MutexLock(&bondMutex); if (cDvbTuner *t = bondedTuner) { dsyslog("tuner %d/%d unbonded from tuner %d/%d", adapter, frontend, bondedTuner->adapter, bondedTuner->frontend); while (t->bondedTuner != this) t = t->bondedTuner; if (t == bondedTuner) t->bondedTuner = NULL; else t->bondedTuner = bondedTuner; bondedMaster = false; // another one will automatically become master whenever necessary bondedTuner = NULL; } }

cString cDvbTuner::GetBondingParams(const cChannel *Channel) const { if (!Channel) Channel = &channel; cDvbTransponderParameters dtp(Channel->Parameters()); if (Setup.DiSEqC) { if (const cDiseqc *diseqc = Diseqcs.Get(device->CardIndex() + 1, Channel->Source(), Channel->Frequency(), dtp.Polarization(), NULL)) return diseqc->Commands(); } else { bool ToneOff = Channel->Frequency() < Setup.LnbSLOF; bool VoltOff = dtp.Polarization() == 'V' || dtp.Polarization() == 'R'; return cString::sprintf("%c %c", ToneOff ? 't' : 'T', VoltOff ? 'v' : 'V'); } return ""; }

bool cDvbTuner::BondingOk(const cChannel *Channel, bool ConsiderOccupied) const { cMutexLock MutexLock(&bondMutex); if (cDvbTuner *t = bondedTuner) { cString BondingParams = GetBondingParams(Channel); do { if (t->device->Priority() > IDLEPRIORITY || ConsiderOccupied && t->device->Occupied()) { if (strcmp(BondingParams, t->GetBondedMaster()->GetBondingParams()) != 0) return false; } t = t->bondedTuner; } while (t != bondedTuner); } return true; }

cDvbTuner *cDvbTuner::GetBondedMaster(void) { if (!bondedTuner) return this; // an unbonded tuner is always "master" cMutexLock MutexLock(&bondMutex); if (bondedMaster) return this; // This tuner is bonded, but it's not the master, so let's see if there is a master at all: if (cDvbTuner *t = bondedTuner) { while (t != this) { if (t->bondedMaster) return t; t = t->bondedTuner; } } // None of the other bonded tuners is master, so make this one the master: bondedMaster = true; dsyslog("tuner %d/%d is now bonded master", adapter, frontend); return this; }

bool cDvbTuner::IsTunedTo(const cChannel *Channel) const { if (tunerStatus == tsIdle) return false; // not tuned to if (channel.Source() != Channel->Source() || channel.Transponder() != Channel->Transponder()) return false; // sufficient mismatch // Polarization is already checked as part of the Transponder. return strcmp(channel.Parameters(), Channel->Parameters()) == 0; }

void cDvbTuner::SetChannel(const cChannel *Channel) { if (Channel) { if (bondedTuner) { cMutexLock MutexLock(&bondMutex); cDvbTuner *BondedMaster = GetBondedMaster(); if (BondedMaster == this) { if (strcmp(GetBondingParams(Channel), GetBondingParams()) != 0) { // switching to a completely different band, so set all others to idle: for (cDvbTuner *t = bondedTuner; t && t != this; t = t->bondedTuner) t->SetChannel(NULL); } } else if (strcmp(GetBondingParams(Channel), BondedMaster->GetBondingParams()) != 0) BondedMaster->SetChannel(Channel); } cMutexLock MutexLock(&mutex); if (!IsTunedTo(Channel)) tunerStatus = tsSet; channel = *Channel; lastTimeoutReport = 0; newSet.Broadcast(); } else { cMutexLock MutexLock(&mutex); tunerStatus = tsIdle; ResetToneAndVoltage(); } if (bondedTuner && device->IsPrimaryDevice()) cDevice::PrimaryDevice()->DelLivePids(); // 'device' is const, so we must do it this way }

bool cDvbTuner::Locked(int TimeoutMs) { bool isLocked = (tunerStatus >= tsLocked); if (isLocked || !TimeoutMs) return isLocked;

cMutexLock MutexLock(&mutex); if (TimeoutMs && tunerStatus < tsLocked) locked.TimedWait(mutex, TimeoutMs); return tunerStatus >= tsLocked; }

void cDvbTuner::ClearEventQueue(void) const { if (!OpenFrontend()) return; cPoller Poller(fd_frontend); if (Poller.Poll(TUNER_POLL_TIMEOUT)) { dvb_frontend_event Event; while (ioctl(fd_frontend, FE_GET_EVENT, &Event) == 0) ; // just to clear the event queue - we'll read the actual status below } }

bool cDvbTuner::GetFrontendStatus(fe_status_t &Status) const { ClearEventQueue(); while (1) { if (ioctl(fd_frontend, FE_READ_STATUS, &Status) != -1) return true; if (errno != EINTR) break; } return false; }

//#define DEBUG_SIGNALSTRENGTH //#define DEBUG_SIGNALQUALITY #define LOCK_THRESHOLD 5 // indicates that all 5 FE_HAS_* flags are set // Inizio Modifica int cDvbTuner::GetSignalStrength(void) const { fe_status_t Status; if (GetFrontendStatus(Status)) { // Actually one would expect these checks to be done from FE_HAS_SIGNAL to FE_HAS_LOCK, but some drivers (like the stb0899) are broken, so FE_HAS_LOCK is the only one that (hopefully) is generally reliable... if ((Status & FE_HAS_LOCK) == 0) { if ((Status & FE_HAS_SIGNAL) == 0) return 0; if ((Status & FE_HAS_CARRIER) == 0) return 1; if ((Status & FE_HAS_VITERBI) == 0) return 2; if ((Status & FE_HAS_SYNC) == 0) return 3; return 4; } #ifdef DEBUG_SIGNALSTRENGTH bool HasSignal = true; #endif uint16_t Signal; while (1) { if (ioctl(fd_frontend, FE_READ_SIGNAL_STRENGTH, &Signal) != -1) break; if (errno != EINTR) { Signal = 0xFFFF; #ifdef DEBUG_SIGNALSTRENGTH HasSignal = false; #endif break; } } #ifdef DEBUG_SIGNALSTRENGTH bool HasBer = true; #endif uint32_t Ber; while (1) { if (ioctl(fd_frontend, FE_READ_BER, &Ber) != -1) break; if (errno != EINTR) { Ber = 0; #ifdef DEBUG_SIGNALSTRENGTH HasBer = false; #endif break; } } #ifdef DEBUG_SIGNALSTRENGTH bool HasUnc = true; #endif uint32_t Unc; while (1) { if (ioctl(fd_frontend, FE_READ_UNCORRECTED_BLOCKS, &Unc) != -1) break; if (errno != EINTR) { Unc = 0; #ifdef DEBUG_SIGNALSTRENGTH HasUnc = false; #endif break; } } uint16_t MinSignal = 0x0000; uint16_t MaxSignal = 0xFFFF; // Let's assume the default is using the entire range. // Use the subsystemId to identify individual devices in case they need // special treatment to map their Snr value into the range 0...0xFFFF. switch (subsystemId) { case 0x13C21019: // TT-budget S2-3200 (DVB-S/DVB-S2) case 0x1AE40001: // TechniSat SkyStar HD2 (DVB-S/DVB-S2) if (frontendType == SYS_DVBS2) { MinSignal = 10; MaxSignal = 70; } else // MaxSignal = 200; MaxSignal = 670;

break; case 0x20130245: // PCTV Systems PCTV 73ESE case 0x2013024F: // PCTV Systems nanoStick T2 290e // MaxSignal = 255; break; MaxSignal = 670;

} int a = int(constrain(Signal, MinSignal, MaxSignal)) * 350 / (MaxSignal - MinSignal); int b = 100 - (Unc * 10 + (Ber / 256) * 5); if (b < 0) b = 0; int s = LOCK_THRESHOLD + a * b * (100 - LOCK_THRESHOLD) / 100 / 100; if (s > 100) s = 100; #ifdef DEBUG_SIGNALSTRENGTH fprintf(stderr, "FE %d/%d: %08X S = %04X %04X %d %5d %5d %3d%%\n", adapter, frontend, subsystemId, MaxSignal, Signal, HasSignal, HasBer ? int(Ber) : -1, HasUnc ? int(Unc) : -1, s); #endif return s; } return -1; }

#define LOCK_THRESHOLD 5 // indicates that all 5 FE_HAS_* flags are set

int cDvbTuner::GetSignalQuality(void) const { fe_status_t Status; if (GetFrontendStatus(Status)) { // Actually one would expect these checks to be done from FE_HAS_SIGNAL to FE_HAS_LOCK, but some drivers (like the stb0899) are broken, so FE_HAS_LOCK is the only one that (hopefully) is generally reliable... if ((Status & FE_HAS_LOCK) == 0) { if ((Status & FE_HAS_SIGNAL) == 0) return 0; if ((Status & FE_HAS_CARRIER) == 0) return 1; if ((Status & FE_HAS_VITERBI) == 0) return 2; if ((Status & FE_HAS_SYNC) == 0) return 3; return 4; } #ifdef DEBUG_SIGNALQUALITY bool HasSnr = true; #endif uint16_t Snr; while (1) { if (ioctl(fd_frontend, FE_READ_SNR, &Snr) != -1) break; if (errno != EINTR) { Snr = 0xFFFF; #ifdef DEBUG_SIGNALQUALITY HasSnr = false; #endif break; } } #ifdef DEBUG_SIGNALQUALITY bool HasBer = true; #endif uint32_t Ber; while (1) { if (ioctl(fd_frontend, FE_READ_BER, &Ber) != -1) break; if (errno != EINTR) { Ber = 0; #ifdef DEBUG_SIGNALQUALITY HasBer = false; #endif break; } } #ifdef DEBUG_SIGNALQUALITY bool HasUnc = true; #endif uint32_t Unc; while (1) { if (ioctl(fd_frontend, FE_READ_UNCORRECTED_BLOCKS, &Unc) != -1) break; if (errno != EINTR) { Unc = 0; #ifdef DEBUG_SIGNALQUALITY HasUnc = false; #endif break; } } uint16_t MinSnr = 0x0000; uint16_t MaxSnr = 0xFFFF; // Let's assume the default is using the entire range. // Use the subsystemId to identify individual devices in case they need // special treatment to map their Snr value into the range 0...0xFFFF. switch (subsystemId) { case 0x13C21019: // TT-budget S2-3200 (DVB-S/DVB-S2) case 0x1AE40001: // TechniSat SkyStar HD2 (DVB-S/DVB-S2) if (frontendType == SYS_DVBS2) { MinSnr = 10; MaxSnr = 70; } else MaxSnr = 200; break; case 0x20130245: // PCTV Systems PCTV 73ESE case 0x2013024F: // PCTV Systems nanoStick T2 290e MaxSnr = 255; break; } int a = int(constrain(Snr, MinSnr, MaxSnr)) * 100 / (MaxSnr - MinSnr); int b = 100 - (Unc * 10 + (Ber / 256) * 5); if (b < 0) b = 0; int q = LOCK_THRESHOLD + a * b * (100 - LOCK_THRESHOLD) / 100 / 100; if (q > 100) q = 100; #ifdef DEBUG_SIGNALQUALITY fprintf(stderr, "FE %d/%d: %08X Q = %04X %04X %d %5d %5d %3d%%\n", adapter, frontend, subsystemId, MaxSnr, Snr, HasSnr, HasBer ? int(Ber) : -1, HasUnc ? int(Unc) : -1, q); #endif return q; } return -1; }

int cDvbTuner::GetCurrentDeliverySystem() { dtv_property Frontend[1]; memset(&Frontend, 0, sizeof(Frontend)); dtv_properties CmdSeq; memset(&CmdSeq, 0, sizeof(CmdSeq)); CmdSeq.props = Frontend; Frontend[0].cmd = DTV_DELIVERY_SYSTEM; Frontend[0].u.data = 0; if (ioctl(fd_frontend, FE_GET_PROPERTY, &CmdSeq) < 0) { esyslog("ERROR: frontend %d/%d: %m", adapter, frontend); return SYS_UNDEFINED; } return Frontend[0].u.data; }

bool cDvbTuner::SendDiseqcCmd(dvb_diseqc_master_cmd cmd) { cMutexLock MutexLock(&mutex); int frontendType = GetCurrentDeliverySystem(); if ((frontendType != SYS_DVBS && frontendType != SYS_DVBS2) || SendDiseqc) return false; diseqc_cmd=cmd; SendDiseqc=true; newSet.Broadcast(); return true; }

static unsigned int FrequencyToHz(unsigned int f) { while (f && f < 1000000) f *= 1000; return f; }

void cDvbTuner::ExecuteDiseqc(const cDiseqc *Diseqc, unsigned int *Frequency) { if (!lnbPowerTurnedOn) { CHECK(ioctl(fd_frontend, FE_SET_VOLTAGE, SEC_VOLTAGE_13)); // must explicitly turn on LNB power lnbPowerTurnedOn = true; } static cMutex Mutex; if (Diseqc->IsScr()) Mutex.Lock(); struct dvb_diseqc_master_cmd cmd; const char *CurrentAction = NULL; for (;;) { cmd.msg_len = sizeof(cmd.msg); cDiseqc::eDiseqcActions da = Diseqc->Execute(&CurrentAction, cmd.msg, &cmd.msg_len, scr, Frequency); if (da == cDiseqc::daNone) break; switch (da) { case cDiseqc::daToneOff: CHECK(ioctl(fd_frontend, FE_SET_TONE, SEC_TONE_OFF)); break; case cDiseqc::daToneOn: CHECK(ioctl(fd_frontend, FE_SET_TONE, SEC_TONE_ON)); break; case cDiseqc::daVoltage13: CHECK(ioctl(fd_frontend, FE_SET_VOLTAGE, SEC_VOLTAGE_13)); break; case cDiseqc::daVoltage18: CHECK(ioctl(fd_frontend, FE_SET_VOLTAGE, SEC_VOLTAGE_18)); break; case cDiseqc::daMiniA: CHECK(ioctl(fd_frontend, FE_DISEQC_SEND_BURST, SEC_MINI_A)); break; case cDiseqc::daMiniB: CHECK(ioctl(fd_frontend, FE_DISEQC_SEND_BURST, SEC_MINI_B)); break; case cDiseqc::daCodes: CHECK(ioctl(fd_frontend, FE_DISEQC_SEND_MASTER_CMD, &cmd)); break; default: esyslog("ERROR: unknown diseqc command %d", da); } } if (scr) ResetToneAndVoltage(); // makes sure we don't block the bus! if (Diseqc->IsScr()) Mutex.Unlock(); }

void cDvbTuner::ResetToneAndVoltage(void) { CHECK(ioctl(fd_frontend, FE_SET_VOLTAGE, bondedTuner ? SEC_VOLTAGE_OFF : SEC_VOLTAGE_13)); CHECK(ioctl(fd_frontend, FE_SET_TONE, SEC_TONE_OFF)); }

static int GetRequiredDeliverySystem(const cChannel *Channel, const cDvbTransponderParameters *Dtp) { int ds = SYS_UNDEFINED; if (Channel->IsAtsc()) ds = SYS_ATSC; else if (Channel->IsCable()) ds = SYS_DVBC_ANNEX_AC; else if (Channel->IsSat()) ds = Dtp->System() == DVB_SYSTEM_1 ? SYS_DVBS : SYS_DVBS2; else if (Channel->IsTerr()) ds = Dtp->System() == DVB_SYSTEM_1 ? SYS_DVBT : SYS_DVBT2; else esyslog("ERROR: can't determine frontend type for channel %d", Channel->Number()); return ds; }

bool cDvbTuner::SetFrontend(void) { if (!OpenFrontend()) return false; #define MAXFRONTENDCMDS 16 #define SETCMD(c, d) { Frontend[CmdSeq.num].cmd = (c);\ Frontend[CmdSeq.num].u.data = (d);\ if (CmdSeq.num++ > MAXFRONTENDCMDS) {\ esyslog("ERROR: too many tuning commands on frontend %d/%d", adapter, frontend);\ return false;\ }\ } dtv_property Frontend[MAXFRONTENDCMDS]; memset(&Frontend, 0, sizeof(Frontend)); dtv_properties CmdSeq; memset(&CmdSeq, 0, sizeof(CmdSeq)); CmdSeq.props = Frontend; SETCMD(DTV_CLEAR, 0); if (ioctl(fd_frontend, FE_SET_PROPERTY, &CmdSeq) < 0) { esyslog("ERROR: frontend %d/%d: %m", adapter, frontend); return false; } CmdSeq.num = 0;

cDvbTransponderParameters dtp(channel.Parameters());

// Determine the required frontend type: frontendType = GetRequiredDeliverySystem(&channel, &dtp); if (frontendType == SYS_UNDEFINED) return false;

SETCMD(DTV_DELIVERY_SYSTEM, frontendType); if (frontendType == SYS_DVBS || frontendType == SYS_DVBS2) { unsigned int frequency = channel.Frequency(); if (Setup.DiSEqC) { if (const cDiseqc *diseqc = Diseqcs.Get(device->CardIndex() + 1, channel.Source(), frequency, dtp.Polarization(), &scr)) { frequency -= diseqc->Lof(); if (diseqc != lastDiseqc || diseqc->IsScr()) { if (IsBondedMaster()) { ExecuteDiseqc(diseqc, &frequency); if (frequency == 0) return false; } else ResetToneAndVoltage(); lastDiseqc = diseqc; } } else { esyslog("ERROR: no DiSEqC parameters found for channel %d", channel.Number()); return false; } } else { int tone = SEC_TONE_OFF; if (frequency < (unsigned int)Setup.LnbSLOF) { frequency -= Setup.LnbFrequLo; tone = SEC_TONE_OFF; } else { frequency -= Setup.LnbFrequHi; tone = SEC_TONE_ON; } int volt = (dtp.Polarization() == 'V' || dtp.Polarization() == 'R') ? SEC_VOLTAGE_13 : SEC_VOLTAGE_18; if (!IsBondedMaster()) { tone = SEC_TONE_OFF; volt = SEC_VOLTAGE_13; } CHECK(ioctl(fd_frontend, FE_SET_VOLTAGE, volt)); CHECK(ioctl(fd_frontend, FE_SET_TONE, tone)); } frequency = abs(frequency); // Allow for C-band, where the frequency is less than the LOF

// DVB-S/DVB-S2 (common parts) SETCMD(DTV_FREQUENCY, frequency * 1000UL); SETCMD(DTV_MODULATION, dtp.Modulation()); SETCMD(DTV_SYMBOL_RATE, channel.Srate() * 1000UL); SETCMD(DTV_INNER_FEC, dtp.CoderateH()); SETCMD(DTV_INVERSION, dtp.Inversion()); if (frontendType == SYS_DVBS2) { // DVB-S2 SETCMD(DTV_PILOT, PILOT_AUTO); SETCMD(DTV_ROLLOFF, dtp.RollOff()); if (DvbApiVersion >= 0x0508) SETCMD(DTV_STREAM_ID, dtp.StreamId()); } else { // DVB-S SETCMD(DTV_ROLLOFF, ROLLOFF_35); // DVB-S always has a ROLLOFF of 0.35 }

tuneTimeout = DVBS_TUNE_TIMEOUT; lockTimeout = DVBS_LOCK_TIMEOUT; } else if (frontendType == SYS_DVBC_ANNEX_AC || frontendType == SYS_DVBC_ANNEX_B) { // DVB-C SETCMD(DTV_FREQUENCY, FrequencyToHz(channel.Frequency())); SETCMD(DTV_INVERSION, dtp.Inversion()); SETCMD(DTV_SYMBOL_RATE, channel.Srate() * 1000UL); SETCMD(DTV_INNER_FEC, dtp.CoderateH()); SETCMD(DTV_MODULATION, dtp.Modulation());

tuneTimeout = DVBC_TUNE_TIMEOUT; lockTimeout = DVBC_LOCK_TIMEOUT; } else if (frontendType == SYS_DVBT || frontendType == SYS_DVBT2) { // DVB-T/DVB-T2 (common parts) SETCMD(DTV_FREQUENCY, FrequencyToHz(channel.Frequency())); SETCMD(DTV_INVERSION, dtp.Inversion()); SETCMD(DTV_BANDWIDTH_HZ, dtp.Bandwidth()); SETCMD(DTV_CODE_RATE_HP, dtp.CoderateH()); SETCMD(DTV_CODE_RATE_LP, dtp.CoderateL()); SETCMD(DTV_MODULATION, dtp.Modulation()); SETCMD(DTV_TRANSMISSION_MODE, dtp.Transmission()); SETCMD(DTV_GUARD_INTERVAL, dtp.Guard()); SETCMD(DTV_HIERARCHY, dtp.Hierarchy()); if (frontendType == SYS_DVBT2) { // DVB-T2 if (DvbApiVersion >= 0x0508) { SETCMD(DTV_STREAM_ID, dtp.StreamId()); } else if (DvbApiVersion >= 0x0503) SETCMD(DTV_DVBT2_PLP_ID_LEGACY, dtp.StreamId()); }

tuneTimeout = DVBT_TUNE_TIMEOUT; lockTimeout = DVBT_LOCK_TIMEOUT; } else if (frontendType == SYS_ATSC) { // ATSC SETCMD(DTV_FREQUENCY, FrequencyToHz(channel.Frequency())); SETCMD(DTV_INVERSION, dtp.Inversion()); SETCMD(DTV_MODULATION, dtp.Modulation());

tuneTimeout = ATSC_TUNE_TIMEOUT; lockTimeout = ATSC_LOCK_TIMEOUT; } else { esyslog("ERROR: attempt to set channel with unknown DVB frontend type"); return false; } SETCMD(DTV_TUNE, 0); if (ioctl(fd_frontend, FE_SET_PROPERTY, &CmdSeq) < 0) { esyslog("ERROR: frontend %d/%d: %m", adapter, frontend); return false; } return true; }

void cDvbTuner::Action(void) { cTimeMs Timer; bool LostLock = false; fe_status_t Status = (fe_status_t)0; while (Running()) { if (!isIdle) { fe_status_t NewStatus; if (GetFrontendStatus(NewStatus)) Status = NewStatus; } cMutexLock MutexLock(&mutex); if (SendDiseqc) { CHECK(ioctl(fd_frontend, FE_DISEQC_SEND_MASTER_CMD, &diseqc_cmd)); SendDiseqc=false; } int WaitTime = 1000; switch (tunerStatus) { case tsIdle: break; case tsSet: tunerStatus = SetFrontend() ? tsTuned : tsIdle; Timer.Set(tuneTimeout + (scr ? rand() % SCR_RANDOM_TIMEOUT : 0)); continue; case tsTuned: if (Timer.TimedOut()) { tunerStatus = tsSet; lastDiseqc = NULL; if (time(NULL) - lastTimeoutReport > 60) { // let's not get too many of these isyslog("frontend %d/%d timed out while tuning to channel %d, tp %d", adapter, frontend, channel.Number(), channel.Transponder()); lastTimeoutReport = time(NULL); } continue; } WaitTime = 100; // allows for a quick change from tsTuned to tsLocked case tsLocked: if (Status & FE_REINIT) { tunerStatus = tsSet; lastDiseqc = NULL; isyslog("frontend %d/%d was reinitialized", adapter, frontend); lastTimeoutReport = 0; continue; } else if (Status & FE_HAS_LOCK) { if (LostLock) { isyslog("frontend %d/%d regained lock on channel %d, tp %d", adapter, frontend, channel.Number(), channel.Transponder()); LostLock = false; } tunerStatus = tsLocked; locked.Broadcast(); lastTimeoutReport = 0; } else if (tunerStatus == tsLocked) { LostLock = true; isyslog("frontend %d/%d lost lock on channel %d, tp %d", adapter, frontend, channel.Number(), channel.Transponder()); tunerStatus = tsTuned; Timer.Set(lockTimeout); lastTimeoutReport = 0; continue; } break; default: esyslog("ERROR: unknown tuner status %d", tunerStatus); } newSet.TimedWait(mutex, WaitTime); } }

bool cDvbTuner::SetIdle(bool Idle) { if (isIdle == Idle) return true; isIdle = Idle; if (Idle) return CloseFrontend(); return OpenFrontend(); }

bool cDvbTuner::OpenFrontend(void) const { if (fd_frontend >= 0) return true; cMutexLock MutexLock(&mutex); fd_frontend = cDvbDevice::DvbOpen(DEV_DVB_FRONTEND, adapter, frontend, O_RDWR | O_NONBLOCK); if (fd_frontend < 0) return false; isIdle = false; return true; }

bool cDvbTuner::CloseFrontend(void) { if (fd_frontend < 0) return true; cMutexLock MutexLock(&mutex); tunerStatus = tsIdle; newSet.Broadcast(); close(fd_frontend); fd_frontend = -1; return true; }

// --- cDvbSourceParam -------------------------------------------------------

class cDvbSourceParam : public cSourceParam { private: int param; int srate; cDvbTransponderParameters dtp; public: cDvbSourceParam(char Source, const char *Description); virtual void SetData(cChannel *Channel); virtual void GetData(cChannel *Channel); virtual cOsdItem *GetOsdItem(void); };

cDvbSourceParam::cDvbSourceParam(char Source, const char *Description) :cSourceParam(Source, Description) { param = 0; srate = 0; }

void cDvbSourceParam::SetData(cChannel *Channel) { srate = Channel->Srate(); dtp.Parse(Channel->Parameters()); param = 0; }

void cDvbSourceParam::GetData(cChannel *Channel) { Channel->SetTransponderData(Channel->Source(), Channel->Frequency(), srate, dtp.ToString(Source()), true); }

cOsdItem *cDvbSourceParam::GetOsdItem(void) { char type = Source(); const tDvbParameterMap *SystemValues = type == 'S' ? SystemValuesSat : SystemValuesTerr; #undef ST #define ST(s) if (strchr(s, type)) switch (param++) { case 0: ST(" S ") return new cMenuEditChrItem( tr("Polarization"), &dtp.polarization, "HVLR"); else return GetOsdItem(); case 1: ST(" ST") return new cMenuEditMapItem( tr("System"), &dtp.system, SystemValues); else return GetOsdItem(); case 2: ST(" CS ") return new cMenuEditIntItem( tr("Srate"), &srate); else return GetOsdItem(); case 3: ST("ACST") return new cMenuEditMapItem( tr("Inversion"), &dtp.inversion, InversionValues); else return GetOsdItem(); case 4: ST(" CST") return new cMenuEditMapItem( tr("CoderateH"), &dtp.coderateH, CoderateValues); else return GetOsdItem(); case 5: ST(" T") return new cMenuEditMapItem( tr("CoderateL"), &dtp.coderateL, CoderateValues); else return GetOsdItem(); case 6: ST("ACST") return new cMenuEditMapItem( tr("Modulation"), &dtp.modulation, ModulationValues); else return GetOsdItem(); case 7: ST(" T") return new cMenuEditMapItem( tr("Bandwidth"), &dtp.bandwidth, BandwidthValues); else return GetOsdItem(); case 8: ST(" T") return new cMenuEditMapItem( tr("Transmission"), &dtp.transmission, TransmissionValues); else return GetOsdItem(); case 9: ST(" T") return new cMenuEditMapItem( tr("Guard"), &dtp.guard, GuardValues); else return GetOsdItem(); case 10: ST(" T") return new cMenuEditMapItem( tr("Hierarchy"), &dtp.hierarchy, HierarchyValues); else return GetOsdItem(); case 11: ST(" S ") return new cMenuEditMapItem( tr("Rolloff"), &dtp.rollOff, RollOffValues); else return GetOsdItem(); case 12: ST(" ST") return new cMenuEditIntItem( tr("StreamId"), &dtp.streamId, 0, 255); else return GetOsdItem(); default: return NULL; } return NULL; }

// --- cDvbDevice ------------------------------------------------------------

int cDvbDevice::setTransferModeForDolbyDigital = 1; cMutex cDvbDevice::bondMutex;

const char *DeliverySystemNames[] = { "", "DVB-C", "DVB-C", "DVB-T", "DSS", "DVB-S", "DVB-S2", "DVB-H", "ISDBT", "ISDBS", "ISDBC", "ATSC", "ATSCMH", "DMBTH", "CMMB", "DAB", "DVB-T2", "TURBO", NULL };

cDvbDevice::cDvbDevice(int Adapter, int Frontend, cDevice *ParentDevice) :cDevice(ParentDevice) { adapter = Adapter; frontend = Frontend; ciAdapter = NULL; dvbTuner = NULL; numDeliverySystems = 0; numModulations = 0; bondedDevice = NULL; needsDetachBondedReceivers = false; tsBuffer = NULL;

// Devices that are present on all card types:

int fd_frontend = DvbOpen(DEV_DVB_FRONTEND, adapter, frontend, O_RDWR | O_NONBLOCK);

// Common Interface:

int fd_ca = DvbOpen(DEV_DVB_CA, adapter, frontend, O_RDWR); ciAdapter = cDvbCiAdapter::CreateCiAdapter(parentDevice ? parentDevice : this, fd_ca, adapter, frontend);

// The DVR device (will be opened and closed as needed):

fd_dvr = -1;

// We only check the devices that must be present - the others will be checked before accessing them://XXX

if (fd_frontend >= 0) { if (QueryDeliverySystems(fd_frontend)) dvbTuner = new cDvbTuner(this, fd_frontend, adapter, frontend); } else esyslog("ERROR: can't open DVB device %d/%d", adapter, frontend);

StartSectionHandler(); }

cDvbDevice::~cDvbDevice() { StopSectionHandler(); delete dvbTuner; delete ciAdapter; UnBond(); // We're not explicitly closing any device files here, since this sometimes // caused segfaults. Besides, the program is about to terminate anyway... }

cString cDvbDevice::DvbName(const char *Name, int Adapter, int Frontend) { return cString::sprintf("%s/%s%d/%s%d", DEV_DVB_BASE, DEV_DVB_ADAPTER, Adapter, Name, Frontend); }

int cDvbDevice::DvbOpen(const char *Name, int Adapter, int Frontend, int Mode, bool ReportError) { cString FileName = DvbName(Name, Adapter, Frontend); int fd = open(FileName, Mode); if (fd < 0 && ReportError) LOG_ERROR_STR(*FileName); return fd; }

bool cDvbDevice::Exists(int Adapter, int Frontend) { cString FileName = DvbName(DEV_DVB_FRONTEND, Adapter, Frontend); if (access(FileName, F_OK) == 0) { int f = open(FileName, O_RDONLY); if (f >= 0) { close(f); return true; } else if (errno != ENODEV && errno != EINVAL) LOG_ERROR_STR(*FileName); } else if (errno != ENOENT) LOG_ERROR_STR(*FileName); return false; }

bool cDvbDevice::Probe(int Adapter, int Frontend) { cString FileName = DvbName(DEV_DVB_FRONTEND, Adapter, Frontend); dsyslog("probing %s", *FileName); for (cDvbDeviceProbe *dp = DvbDeviceProbes.First(); dp; dp = DvbDeviceProbes.Next(dp)) { if (dp->Probe(Adapter, Frontend)) return true; // a plugin has created the actual device } dsyslog("creating cDvbDevice"); new cDvbDevice(Adapter, Frontend); // it's a "budget" device return true; }

cString cDvbDevice::DeviceType(void) const { if (dvbTuner) { if (dvbTuner->FrontendType() != SYS_UNDEFINED) return DeliverySystemNames[dvbTuner->FrontendType()]; if (numDeliverySystems) return DeliverySystemNames[deliverySystems[0]]; // to have some reasonable default } return ""; }

cString cDvbDevice::DeviceName(void) const { return frontendInfo.name; }

bool cDvbDevice::Initialize(void) { new cDvbSourceParam('A', "ATSC"); new cDvbSourceParam('C', "DVB-C"); new cDvbSourceParam('S', "DVB-S"); new cDvbSourceParam('T', "DVB-T"); cStringList Nodes; cReadDir DvbDir(DEV_DVB_BASE); if (DvbDir.Ok()) { struct dirent *a; while ((a = DvbDir.Next()) != NULL) { if (strstr(a->d_name, DEV_DVB_ADAPTER) == a->d_name) { int Adapter = strtol(a->d_name + strlen(DEV_DVB_ADAPTER), NULL, 10); cReadDir AdapterDir(AddDirectory(DEV_DVB_BASE, a->d_name)); if (AdapterDir.Ok()) { struct dirent *f; while ((f = AdapterDir.Next()) != NULL) { if (strstr(f->d_name, DEV_DVB_FRONTEND) == f->d_name) { int Frontend = strtol(f->d_name + strlen(DEV_DVB_FRONTEND), NULL, 10); Nodes.Append(strdup(cString::sprintf("%2d %2d", Adapter, Frontend))); } } } } } } int Checked = 0; int Found = 0; if (Nodes.Size() > 0) { Nodes.Sort(); for (int i = 0; i < Nodes.Size(); i++) { int Adapter; int Frontend; if (2 == sscanf(Nodes[i], "%d %d", &Adapter, &Frontend)) { if (Exists(Adapter, Frontend)) { if (Checked++ < MAXDVBDEVICES) { if (UseDevice(NextCardIndex())) { if (Probe(Adapter, Frontend)) Found++; } else NextCardIndex(1); // skips this one } } } } } NextCardIndex(MAXDVBDEVICES - Checked); // skips the rest if (Found > 0) isyslog("found %d DVB device%s", Found, Found > 1 ? "s" : ""); else isyslog("no DVB device found"); return Found > 0; }

bool cDvbDevice::QueryDeliverySystems(int fd_frontend) { numDeliverySystems = 0; if (ioctl(fd_frontend, FE_GET_INFO, &frontendInfo) < 0) { LOG_ERROR; return false; } dtv_property Frontend[1]; dtv_properties CmdSeq; // Determine the version of the running DVB API: if (!DvbApiVersion) { memset(&Frontend, 0, sizeof(Frontend)); memset(&CmdSeq, 0, sizeof(CmdSeq)); CmdSeq.props = Frontend; SETCMD(DTV_API_VERSION, 0); if (ioctl(fd_frontend, FE_GET_PROPERTY, &CmdSeq) != 0) { LOG_ERROR; return false; } DvbApiVersion = Frontend[0].u.data; isyslog("DVB API version is 0x%04X (VDR was built with 0x%04X)", DvbApiVersion, DVBAPIVERSION); } // Determine the types of delivery systems this device provides: bool LegacyMode = true; if (DvbApiVersion >= 0x0505) { memset(&Frontend, 0, sizeof(Frontend)); memset(&CmdSeq, 0, sizeof(CmdSeq)); CmdSeq.props = Frontend; SETCMD(DTV_ENUM_DELSYS, 0); int Result = ioctl(fd_frontend, FE_GET_PROPERTY, &CmdSeq); if (Result == 0) { for (uint i = 0; i < Frontend[0].u.buffer.len; i++) { if (numDeliverySystems >= MAXDELIVERYSYSTEMS) { esyslog("ERROR: too many delivery systems on frontend %d/%d", adapter, frontend); break; } deliverySystems[numDeliverySystems++] = Frontend[0].u.buffer.data[i]; } LegacyMode = false; } else { esyslog("ERROR: can't query delivery systems on frontend %d/%d - falling back to legacy mode", adapter, frontend); } } if (LegacyMode) { // Legacy mode (DVB-API < 5.5): switch (frontendInfo.type) { case FE_QPSK: deliverySystems[numDeliverySystems++] = SYS_DVBS; if (frontendInfo.caps & FE_CAN_2G_MODULATION) deliverySystems[numDeliverySystems++] = SYS_DVBS2; break; case FE_OFDM: deliverySystems[numDeliverySystems++] = SYS_DVBT; if (frontendInfo.caps & FE_CAN_2G_MODULATION) deliverySystems[numDeliverySystems++] = SYS_DVBT2; break; case FE_QAM: deliverySystems[numDeliverySystems++] = SYS_DVBC_ANNEX_AC; break; case FE_ATSC: deliverySystems[numDeliverySystems++] = SYS_ATSC; break; default: esyslog("ERROR: unknown frontend type %d on frontend %d/%d", frontendInfo.type, adapter, frontend); } } if (numDeliverySystems > 0) { cString ds(""); for (int i = 0; i < numDeliverySystems; i++) ds = cString::sprintf("%s%s%s", *ds, i ? "," : "", DeliverySystemNames[deliverySystems[i]]); cString ms(""); if (frontendInfo.caps & FE_CAN_QPSK) { numModulations++; ms = cString::sprintf("%s%s%s", *ms, **ms ? "," : "", MapToUserString(QPSK, ModulationValues)); } if (frontendInfo.caps & FE_CAN_QAM_16) { numModulations++; ms = cString::sprintf("%s%s%s", *ms, **ms ? "," : "", MapToUserString(QAM_16, ModulationValues)); } if (frontendInfo.caps & FE_CAN_QAM_32) { numModulations++; ms = cString::sprintf("%s%s%s", *ms, **ms ? "," : "", MapToUserString(QAM_32, ModulationValues)); } if (frontendInfo.caps & FE_CAN_QAM_64) { numModulations++; ms = cString::sprintf("%s%s%s", *ms, **ms ? "," : "", MapToUserString(QAM_64, ModulationValues)); } if (frontendInfo.caps & FE_CAN_QAM_128) { numModulations++; ms = cString::sprintf("%s%s%s", *ms, **ms ? "," : "", MapToUserString(QAM_128, ModulationValues)); } if (frontendInfo.caps & FE_CAN_QAM_256) { numModulations++; ms = cString::sprintf("%s%s%s", *ms, **ms ? "," : "", MapToUserString(QAM_256, ModulationValues)); } if (frontendInfo.caps & FE_CAN_8VSB) { numModulations++; ms = cString::sprintf("%s%s%s", *ms, **ms ? "," : "", MapToUserString(VSB_8, ModulationValues)); } if (frontendInfo.caps & FE_CAN_16VSB) { numModulations++; ms = cString::sprintf("%s%s%s", *ms, **ms ? "," : "", MapToUserString(VSB_16, ModulationValues)); } if (frontendInfo.caps & FE_CAN_TURBO_FEC) { numModulations++; ms = cString::sprintf("%s%s%s", *ms, **ms ? "," : "", "TURBO_FEC"); } if (!**ms) ms = "unknown modulations"; isyslog("frontend %d/%d provides %s with %s ("%s")", adapter, frontend, *ds, *ms, frontendInfo.name); return true; } else esyslog("ERROR: frontend %d/%d doesn't provide any delivery systems", adapter, frontend); return false; }

bool cDvbDevice::Ready(void) { if (ciAdapter) return ciAdapter->Ready(); return true; }

bool cDvbDevice::BondDevices(const char *Bondings) { UnBondDevices(); if (Bondings) { cSatCableNumbers SatCableNumbers(MAXDEVICES, Bondings); for (int i = 0; i < cDevice::NumDevices(); i++) { int d = SatCableNumbers.FirstDeviceIndex(i); if (d >= 0) { int ErrorDevice = 0; if (cDevice *Device1 = cDevice::GetDevice(i)) { if (Device1->HasSubDevice()) Device1 = Device1->SubDevice(); if (cDevice *Device2 = cDevice::GetDevice(d)) { if (Device2->HasSubDevice()) Device2 = Device2->SubDevice(); if (cDvbDevice *DvbDevice1 = dynamic_cast<cDvbDevice *>(Device1)) { if (cDvbDevice *DvbDevice2 = dynamic_cast<cDvbDevice *>(Device2)) { if (!DvbDevice1->Bond(DvbDevice2)) return false; // Bond() has already logged the error } else ErrorDevice = d + 1; } else ErrorDevice = i + 1; if (ErrorDevice) { esyslog("ERROR: device '%d' in device bondings '%s' is not a cDvbDevice", ErrorDevice, Bondings); return false; } } else ErrorDevice = d + 1; } else ErrorDevice = i + 1; if (ErrorDevice) { esyslog("ERROR: unknown device '%d' in device bondings '%s'", ErrorDevice, Bondings); return false; } } } } return true; }

void cDvbDevice::UnBondDevices(void) { for (int i = 0; i < cDevice::NumDevices(); i++) { cDevice *dev = cDevice::GetDevice(i); if (dev && dev->HasSubDevice()) dev = dev->SubDevice(); if (cDvbDevice *d = dynamic_cast<cDvbDevice *>(dev)) d->UnBond(); } }

bool cDvbDevice::Bond(cDvbDevice *Device) { cMutexLock MutexLock(&bondMutex); if (!bondedDevice) { if (Device != this) { if ((ProvidesDeliverySystem(SYS_DVBS) || ProvidesDeliverySystem(SYS_DVBS2)) && (Device->ProvidesDeliverySystem(SYS_DVBS) || Device->ProvidesDeliverySystem(SYS_DVBS2))) { if (dvbTuner && Device->dvbTuner && dvbTuner->Bond(Device->dvbTuner)) { bondedDevice = Device->bondedDevice ? Device->bondedDevice : Device; Device->bondedDevice = this; dsyslog("device %d bonded with device %d", CardIndex() + 1, bondedDevice->CardIndex() + 1); return true; } } else esyslog("ERROR: can't bond device %d with device %d (only DVB-S(2) devices can be bonded)", CardIndex() + 1, Device->CardIndex() + 1); } else esyslog("ERROR: can't bond device %d with itself", CardIndex() + 1); } else esyslog("ERROR: device %d already bonded with device %d, can't bond with device %d", CardIndex() + 1, bondedDevice->CardIndex() + 1, Device->CardIndex() + 1); return false; }

void cDvbDevice::UnBond(void) { cMutexLock MutexLock(&bondMutex); if (cDvbDevice *d = bondedDevice) { if (dvbTuner) dvbTuner->UnBond(); dsyslog("device %d unbonded from device %d", CardIndex() + 1, bondedDevice->CardIndex() + 1); while (d->bondedDevice != this) d = d->bondedDevice; if (d == bondedDevice) d->bondedDevice = NULL; else d->bondedDevice = bondedDevice; bondedDevice = NULL; } }

bool cDvbDevice::BondingOk(const cChannel *Channel, bool ConsiderOccupied) const { cMutexLock MutexLock(&bondMutex); if (bondedDevice) return dvbTuner && dvbTuner->BondingOk(Channel, ConsiderOccupied); return true; }

bool cDvbDevice::SetIdleDevice(bool Idle, bool TestOnly) { if (TestOnly) { if (ciAdapter) return ciAdapter->SetIdle(Idle, true); return true; } if (!dvbTuner->SetIdle(Idle)) return false; if (ciAdapter && !ciAdapter->SetIdle(Idle, false)) { dvbTuner->SetIdle(!Idle); return false; } if (Idle) StopSectionHandler(); else StartSectionHandler(); return true; }

bool cDvbDevice::HasCi(void) { return ciAdapter; }

bool cDvbDevice::SetPid(cPidHandle *Handle, int Type, bool On) { if (Handle->pid) { dmx_pes_filter_params pesFilterParams; memset(&pesFilterParams, 0, sizeof(pesFilterParams)); if (On) { if (Handle->handle < 0) { Handle->handle = DvbOpen(DEV_DVB_DEMUX, adapter, frontend, O_RDWR | O_NONBLOCK, true); if (Handle->handle < 0) { LOG_ERROR; return false; } } pesFilterParams.pid = Handle->pid; pesFilterParams.input = DMX_IN_FRONTEND; pesFilterParams.output = DMX_OUT_TS_TAP; pesFilterParams.pes_type= DMX_PES_OTHER; pesFilterParams.flags = DMX_IMMEDIATE_START; if (ioctl(Handle->handle, DMX_SET_PES_FILTER, &pesFilterParams) < 0) { LOG_ERROR; return false; } } else if (!Handle->used) { CHECK(ioctl(Handle->handle, DMX_STOP)); if (Type <= ptTeletext) { pesFilterParams.pid = 0x1FFF; pesFilterParams.input = DMX_IN_FRONTEND; pesFilterParams.output = DMX_OUT_DECODER; pesFilterParams.pes_type= DMX_PES_OTHER; pesFilterParams.flags = DMX_IMMEDIATE_START; CHECK(ioctl(Handle->handle, DMX_SET_PES_FILTER, &pesFilterParams)); } close(Handle->handle); Handle->handle = -1; } } return true; }

int cDvbDevice::OpenFilter(u_short Pid, u_char Tid, u_char Mask) { cString FileName = DvbName(DEV_DVB_DEMUX, adapter, frontend); int f = open(FileName, O_RDWR | O_NONBLOCK); if (f >= 0) { dmx_sct_filter_params sctFilterParams; memset(&sctFilterParams, 0, sizeof(sctFilterParams)); sctFilterParams.pid = Pid; sctFilterParams.timeout = 0; sctFilterParams.flags = DMX_IMMEDIATE_START; sctFilterParams.filter.filter[0] = Tid; sctFilterParams.filter.mask[0] = Mask; if (ioctl(f, DMX_SET_FILTER, &sctFilterParams) >= 0) return f; else { esyslog("ERROR: can't set filter (pid=%d, tid=%02X, mask=%02X): %m", Pid, Tid, Mask); close(f); } } else esyslog("ERROR: can't open filter handle on '%s'", *FileName); return -1; }

void cDvbDevice::CloseFilter(int Handle) { close(Handle); }

bool cDvbDevice::ProvidesDeliverySystem(int DeliverySystem) const { for (int i = 0; i < numDeliverySystems; i++) { if (deliverySystems[i] == DeliverySystem) return true; } return false; }

bool cDvbDevice::ProvidesSource(int Source) const { if (Setup.ChannelBlocker == 1) { if (IsPrimaryDevice()) return false; //isyslog("ChannelBlocker aktive on primary Interface"); } int type = Source & cSource::st_Mask; return type == cSource::stNone || type == cSource::stAtsc && ProvidesDeliverySystem(SYS_ATSC) || type == cSource::stCable && (ProvidesDeliverySystem(SYS_DVBC_ANNEX_AC) || ProvidesDeliverySystem(SYS_DVBC_ANNEX_B)) || type == cSource::stSat && (ProvidesDeliverySystem(SYS_DVBS) || ProvidesDeliverySystem(SYS_DVBS2)) || type == cSource::stTerr && (ProvidesDeliverySystem(SYS_DVBT) || ProvidesDeliverySystem(SYS_DVBT2)); }

bool cDvbDevice::ProvidesTransponder(const cChannel *Channel) const { if (!ProvidesSource(Channel->Source())) return false; // doesn't provide source cDvbTransponderParameters dtp(Channel->Parameters()); if (!ProvidesDeliverySystem(GetRequiredDeliverySystem(Channel, &dtp)) || dtp.StreamId() != 0 && !(frontendInfo.caps & FE_CAN_MULTISTREAM) || dtp.Modulation() == QPSK && !(frontendInfo.caps & FE_CAN_QPSK) || dtp.Modulation() == QAM_16 && !(frontendInfo.caps & FE_CAN_QAM_16) || dtp.Modulation() == QAM_32 && !(frontendInfo.caps & FE_CAN_QAM_32) || dtp.Modulation() == QAM_64 && !(frontendInfo.caps & FE_CAN_QAM_64) || dtp.Modulation() == QAM_128 && !(frontendInfo.caps & FE_CAN_QAM_128) || dtp.Modulation() == QAM_256 && !(frontendInfo.caps & FE_CAN_QAM_256) || dtp.Modulation() == QAM_AUTO && !(frontendInfo.caps & FE_CAN_QAM_AUTO) || dtp.Modulation() == VSB_8 && !(frontendInfo.caps & FE_CAN_8VSB) || dtp.Modulation() == VSB_16 && !(frontendInfo.caps & FE_CAN_16VSB) || dtp.Modulation() == PSK_8 && !(frontendInfo.caps & FE_CAN_TURBO_FEC) && dtp.System() == SYS_DVBS) // "turbo fec" is a non standard FEC used by North American broadcasters - this is a best guess to determine this condition return false; // requires modulation system which frontend doesn't provide if (!cSource::IsSat(Channel->Source()) || (!Setup.DiSEqC || Diseqcs.Get(CardIndex() + 1, Channel->Source(), Channel->Frequency(), dtp.Polarization(), NULL))) return DeviceHooksProvidesTransponder(Channel); return false; }

bool cDvbDevice::ProvidesChannel(const cChannel *Channel, int Priority, bool *NeedsDetachReceivers) const { bool result = false; bool hasPriority = Priority == IDLEPRIORITY || Priority > this->Priority(); bool needsDetachReceivers = false; needsDetachBondedReceivers = false;

if (dvbTuner && ProvidesTransponder(Channel)) { result = hasPriority; if (Priority > IDLEPRIORITY) { if (Receiving()) { if (dvbTuner->IsTunedTo(Channel)) { if (Channel->Vpid() && !HasPid(Channel->Vpid()) || Channel->Apid(0) && !HasPid(Channel->Apid(0)) || Channel->Dpid(0) && !HasPid(Channel->Dpid(0))) { if (CamSlot() && Channel->Ca() >= CA_ENCRYPTED_MIN) { if (CamSlot()->CanDecrypt(Channel)) result = true; else needsDetachReceivers = true; } else result = true; } else result = true; } else needsDetachReceivers = Receiving(); } if (result) { cMutexLock MutexLock(&bondMutex); if (!BondingOk(Channel)) { // This device is bonded, so we need to check the priorities of the others: for (cDvbDevice *d = bondedDevice; d && d != this; d = d->bondedDevice) { if (d->Priority() >= Priority) { result = false; break; } needsDetachReceivers |= d->Receiving(); } needsDetachBondedReceivers = true; needsDetachReceivers |= Receiving(); } } } } if (NeedsDetachReceivers) *NeedsDetachReceivers = needsDetachReceivers; return result; }

bool cDvbDevice::ProvidesEIT(void) const { return !IsIdle() && (dvbTuner != NULL) && !dvbTuner->IsIdle() && ((ciAdapter == NULL) || !ciAdapter->IsIdle()); }

int cDvbDevice::NumProvidedSystems(void) const { return numDeliverySystems + numModulations; }

int cDvbDevice::SignalStrength(void) const { return dvbTuner ? dvbTuner->GetSignalStrength() : -1; }

int cDvbDevice::SignalQuality(void) const { return dvbTuner ? dvbTuner->GetSignalQuality() : -1; }

const cChannel *cDvbDevice::GetCurrentlyTunedTransponder(void) const { return dvbTuner ? dvbTuner->GetTransponder() : NULL; }

bool cDvbDevice::IsTunedToTransponder(const cChannel *Channel) const { return dvbTuner ? dvbTuner->IsTunedTo(Channel) : false; }

bool cDvbDevice::MaySwitchTransponder(const cChannel *Channel) const { return BondingOk(Channel, true) && cDevice::MaySwitchTransponder(Channel); }

bool cDvbDevice::SetChannelDevice(const cChannel *Channel, bool LiveView) { if (dvbTuner) dvbTuner->SetChannel(Channel); return true; }

bool cDvbDevice::HasLock(int TimeoutMs) const { return dvbTuner ? dvbTuner->Locked(TimeoutMs) : false; }

bool cDvbDevice::SendDiseqcCmd(dvb_diseqc_master_cmd cmd) { return dvbTuner->SendDiseqcCmd(cmd); }

void cDvbDevice::SetTransferModeForDolbyDigital(int Mode) { setTransferModeForDolbyDigital = Mode; }

bool cDvbDevice::OpenDvr(void) { CloseDvr(); fd_dvr = DvbOpen(DEV_DVB_DVR, adapter, frontend, O_RDONLY | O_NONBLOCK, true); if (fd_dvr >= 0) { if (ciAdapter) tsBuffer = ciAdapter->GetTSBuffer(fd_dvr); if (tsBuffer == NULL) tsBuffer = new cTSBuffer(fd_dvr, MEGABYTE(5), CardIndex() + 1); } return fd_dvr >= 0; }

void cDvbDevice::CloseDvr(void) { if (fd_dvr >= 0) { delete tsBuffer; tsBuffer = NULL; close(fd_dvr); fd_dvr = -1; } }

bool cDvbDevice::GetTSPacket(uchar *&Data) { if (tsBuffer) { Data = tsBuffer->Get(); return true; } return false; }

void cDvbDevice::DetachAllReceivers(void) { cMutexLock MutexLock(&bondMutex); cDvbDevice *d = this; do { d->cDevice::DetachAllReceivers(); d = d->bondedDevice; } while (d && d != this && needsDetachBondedReceivers); needsDetachBondedReceivers = false; }

// --- cDvbDeviceProbe -------------------------------------------------------

cList<cDvbDeviceProbe> DvbDeviceProbes;

cDvbDeviceProbe::cDvbDeviceProbe(void) { DvbDeviceProbes.Add(this); }

cDvbDeviceProbe::~cDvbDeviceProbe() { DvbDeviceProbes.Del(this, false); }

uint32_t cDvbDeviceProbe::GetSubsystemId(int Adapter, int Frontend) { uint32_t SubsystemId = 0; cString FileName = cString::sprintf("/dev/dvb/adapter%d/frontend%d", Adapter, Frontend); struct stat st; if (stat(FileName, &st) == 0) { cReadDir d("/sys/class/dvb"); if (d.Ok()) { struct dirent *e; while ((e = d.Next()) != NULL) { if (strstr(e->d_name, "frontend")) { FileName = cString::sprintf("/sys/class/dvb/%s/dev", e->d_name); if (FILE *f = fopen(FileName, "r")) { cReadLine ReadLine; char *s = ReadLine.Read(f); fclose(f); unsigned Major; unsigned Minor; if (s && 2 == sscanf(s, "%u:%u", &Major, &Minor)) { if (((Major << 8) | Minor) == st.st_rdev) { FileName = cString::sprintf("/sys/class/dvb/%s/device/subsystem_vendor", e->d_name); if ((f = fopen(FileName, "r")) != NULL) { if (char *s = ReadLine.Read(f)) SubsystemId = strtoul(s, NULL, 0) << 16; fclose(f); } FileName = cString::sprintf("/sys/class/dvb/%s/device/subsystem_device", e->d_name); if ((f = fopen(FileName, "r")) != NULL) { if (char *s = ReadLine.Read(f)) SubsystemId |= strtoul(s, NULL, 0); fclose(f); } break; } } } } } } } return SubsystemId; }