Skip to content

Commit

Permalink
Include cardid in logging where possible.
Browse files Browse the repository at this point in the history
  • Loading branch information
jpoet committed Jan 19, 2013
1 parent 0db9bf4 commit 023b90f
Show file tree
Hide file tree
Showing 35 changed files with 78 additions and 53 deletions.
6 changes: 3 additions & 3 deletions mythtv/libs/libmythtv/mpeg/atscstreamdata.cpp
Expand Up @@ -57,7 +57,7 @@ ATSCStreamData::~ATSCStreamData()
_atsc81_eit_listeners.clear();
}

void ATSCStreamData::SetDesiredChannel(int major, int minor)
void ATSCStreamData::SetDesiredChannel(int major, int minor, int cardid)
{
bool reset = true;
const MasterGuideTable *mgt = GetCachedMGT();
Expand Down Expand Up @@ -91,12 +91,12 @@ void ATSCStreamData::SetDesiredChannel(int major, int minor)
if (cvct)
{
ProcessCVCT(cvct->TransportStreamID(), cvct);
SetDesiredProgram(cvct->ProgramNumber(chan_idx));
SetDesiredProgram(cvct->ProgramNumber(chan_idx), cardid);
}
else if (tvct)
{
ProcessTVCT(tvct->TransportStreamID(), tvct);
SetDesiredProgram(tvct->ProgramNumber(chan_idx));
SetDesiredProgram(tvct->ProgramNumber(chan_idx), cardid);
}
reset = false;
}
Expand Down
2 changes: 1 addition & 1 deletion mythtv/libs/libmythtv/mpeg/atscstreamdata.h
Expand Up @@ -35,7 +35,7 @@ class MTV_PUBLIC ATSCStreamData : virtual public MPEGStreamData
virtual void Reset(void) { ResetATSC(-1, -1); }
virtual void ResetMPEG(int desiredProgram);
virtual void ResetATSC(int desiredMajorChannel, int desiredMinorChannel);
void SetDesiredChannel(int major, int minor);
void SetDesiredChannel(int major, int minor, int cardid);

// Table processing
virtual bool HandleTables(uint pid, const PSIPTable &psip);
Expand Down
5 changes: 3 additions & 2 deletions mythtv/libs/libmythtv/mpeg/dvbstreamdata.cpp
Expand Up @@ -40,7 +40,8 @@ DVBStreamData::~DVBStreamData()
_dvb_has_eit.clear();
}

void DVBStreamData::SetDesiredService(uint netid, uint tsid, int serviceid)
void DVBStreamData::SetDesiredService(uint netid, uint tsid, int serviceid,
int cardid)
{
bool reset = true;

Expand All @@ -62,7 +63,7 @@ void DVBStreamData::SetDesiredService(uint netid, uint tsid, int serviceid)
ProcessSDT(_desired_tsid, sdt);
ReturnCachedTable(sdt);
}
SetDesiredProgram(serviceid);
SetDesiredProgram(serviceid, cardid);
}
}

Expand Down
2 changes: 1 addition & 1 deletion mythtv/libs/libmythtv/mpeg/dvbstreamdata.h
Expand Up @@ -36,7 +36,7 @@ class MTV_PUBLIC DVBStreamData : virtual public MPEGStreamData
uint desired_netid, uint desired_tsid, int desired_sid);

// DVB table monitoring
void SetDesiredService(uint netid, uint tsid, int serviceid);
void SetDesiredService(uint netid, uint tsid, int serviceid, int cardid);
uint DesiredNetworkID(void) const { return _desired_netid; }
uint DesiredTransportID(void) const { return _desired_tsid; }

Expand Down
8 changes: 5 additions & 3 deletions mythtv/libs/libmythtv/mpeg/mpegstreamdata.cpp
Expand Up @@ -105,13 +105,16 @@ MPEGStreamData::~MPEGStreamData()
_mpeg_sp_listeners.clear();
}

void MPEGStreamData::SetDesiredProgram(int p)
void MPEGStreamData::SetDesiredProgram(int p, int cardid)
{
bool reset = true;
uint pid = 0;
const ProgramAssociationTable* pat = NULL;
pat_vec_t pats = GetCachedPATs();

LOG(VB_RECORD, LOG_INFO, QString("SetDesiredProgram[%1] (%2)")
.arg(cardid).arg(p));

for (uint i = (p) ? 0 : pats.size(); i < pats.size() && !pid; i++)
{
pat = pats[i];
Expand Down Expand Up @@ -812,8 +815,7 @@ void MPEGStreamData::ProcessPAT(const ProgramAssociationTable *pat)
{
_invalid_pat_warning = true; // only emit one warning...
// After 400ms emit error if we haven't found correct PAT.
LOG(VB_GENERAL, LOG_ERR,
"ProcessPAT: Program not found in PAT. "
LOG(VB_GENERAL, LOG_ERR, "ProcessPAT: Program not found in PAT. "
"Rescan your transports.");

send_single_program = CreatePATSingleProgram(*pat);
Expand Down
2 changes: 1 addition & 1 deletion mythtv/libs/libmythtv/mpeg/mpegstreamdata.h
Expand Up @@ -291,7 +291,7 @@ class MTV_PUBLIC MPEGStreamData : public EITSource

public:
// Single program stuff, sets
void SetDesiredProgram(int p);
void SetDesiredProgram(int p, int cardid);
inline void SetPATSingleProgram(ProgramAssociationTable*);
inline void SetPMTSingleProgram(ProgramMapTable*);
void SetVideoStreamsRequired(uint num)
Expand Down
3 changes: 2 additions & 1 deletion mythtv/libs/libmythtv/recorders/analogsignalmonitor.cpp
Expand Up @@ -14,7 +14,8 @@
#include "analogsignalmonitor.h"
#include "v4lchannel.h"

#define LOC QString("AnalogSM(%1): ").arg(channel->GetDevice())
#define LOC QString("AnalogSM[%1](%2): ") \
.arg(capturecardnum).arg(channel->GetDevice())

AnalogSignalMonitor::AnalogSignalMonitor(
int db_cardnum, V4LChannel *_channel, uint64_t _flags) :
Expand Down
2 changes: 1 addition & 1 deletion mythtv/libs/libmythtv/recorders/asichannel.cpp
Expand Up @@ -7,7 +7,7 @@
#include "mpegtables.h"
#include "asichannel.h"

#define LOC QString("ASIChan(%1): ").arg(GetDevice())
#define LOC QString("ASIChan[%1](%2): ").arg(GetCardID()).arg(GetDevice())

ASIChannel::ASIChannel(TVRec *parent, const QString &device) :
DTVChannel(parent), m_device(device), m_isopen(false)
Expand Down
4 changes: 3 additions & 1 deletion mythtv/libs/libmythtv/recorders/asirecorder.cpp
Expand Up @@ -28,7 +28,9 @@
#include "ringbuffer.h"
#include "tv_rec.h"

#define LOC QString("ASIRec(%1): ").arg(tvrec->GetCaptureCardNum())
#define LOC QString("ASIRec[%1](%2): ") \
.arg(tvrec ? tvrec->GetCaptureCardNum() : -1) \
.arg(channel->GetDevice())

ASIRecorder::ASIRecorder(TVRec *rec, ASIChannel *channel) :
DTVRecorder(rec), m_channel(channel), m_stream_handler(NULL),
Expand Down
3 changes: 2 additions & 1 deletion mythtv/libs/libmythtv/recorders/asisignalmonitor.cpp
Expand Up @@ -21,7 +21,8 @@
#include "asirecorder.h"
#include "asistreamhandler.h"

#define LOC QString("ASISM(%1): ").arg(channel->GetDevice())
#define LOC QString("ASISM[%1](%2): ") \
.arg(capturecardnum).arg(channel->GetDevice())

/**
* \brief Initializes signal lock and signal values.
Expand Down
2 changes: 1 addition & 1 deletion mythtv/libs/libmythtv/recorders/cetonchannel.cpp
Expand Up @@ -13,7 +13,7 @@
#include "channelutil.h"
#include "mythdbcon.h"

#define LOC QString("CetonChan(%1): ").arg(GetDevice())
#define LOC QString("CetonChan[%1](%2): ").arg(GetCardID()).arg(GetDevice())

CetonChannel::CetonChannel(TVRec *parent, const QString &device) :
DTVChannel(parent), _device_id(device), _stream_handler(NULL)
Expand Down
3 changes: 2 additions & 1 deletion mythtv/libs/libmythtv/recorders/cetonrecorder.cpp
Expand Up @@ -12,7 +12,8 @@
#include "mythlogging.h"
#include "tv_rec.h"

#define LOC QString("CetonRec(%1): ").arg(tvrec->GetCaptureCardNum())
#define LOC QString("CetonRec[%1]: ") \
.arg(tvrec ? tvrec->GetCaptureCardNum() : -1)

CetonRecorder::CetonRecorder(TVRec *rec, CetonChannel *channel) :
DTVRecorder(rec), _channel(channel), _stream_handler(NULL)
Expand Down
3 changes: 2 additions & 1 deletion mythtv/libs/libmythtv/recorders/cetonsignalmonitor.cpp
Expand Up @@ -13,7 +13,8 @@
#include "cetonrecorder.h"
#include "cetonchannel.h"

#define LOC QString("CetonSM(%1): ").arg(channel->GetDevice())
#define LOC QString("CetonSM[%1](%2): ") \
.arg(capturecardnum).arg(channel->GetDevice())

/**
* \brief Initializes signal lock and signal values.
Expand Down
2 changes: 1 addition & 1 deletion mythtv/libs/libmythtv/recorders/channelbase.cpp
Expand Up @@ -43,7 +43,7 @@ using namespace std;
#include "cardutil.h"
#include "compat.h"

#define LOC QString("ChannelBase(%1): ").arg(GetCardID())
#define LOC QString("ChannelBase[%1]: ").arg(GetCardID())

ChannelBase::ChannelBase(TVRec *parent) :
m_pParent(parent), m_curchannelname(""),
Expand Down
2 changes: 1 addition & 1 deletion mythtv/libs/libmythtv/recorders/dtvchannel.cpp
Expand Up @@ -10,7 +10,7 @@ using namespace std;
#include "mpegtables.h"
#include "mythlogging.h"

#define LOC QString("DTVChan(%1): ").arg(GetDevice())
#define LOC QString("DTVChan[%1](%2): ").arg(GetCardID()).arg(GetDevice())

QReadWriteLock DTVChannel::master_map_lock(QReadWriteLock::Recursive);
typedef QMap<QString,QList<DTVChannel*> > MasterMap;
Expand Down
8 changes: 5 additions & 3 deletions mythtv/libs/libmythtv/recorders/dtvrecorder.cpp
Expand Up @@ -33,7 +33,7 @@ extern "C" {
}

#define LOC ((tvrec) ? \
QString("DTVRec(%1): ").arg(tvrec->GetCaptureCardNum()) : \
QString("DTVRec[%1]: ").arg(tvrec->GetCaptureCardNum()) : \
QString("DTVRec(0x%1): ").arg(intptr_t(this),0,16))

const uint DTVRecorder::kMaxKeyFrameDistance = 80;
Expand Down Expand Up @@ -269,9 +269,11 @@ void DTVRecorder::InitStreamData(void)

if (atsc && atsc->DesiredMinorChannel())
atsc->SetDesiredChannel(atsc->DesiredMajorChannel(),
atsc->DesiredMinorChannel());
atsc->DesiredMinorChannel(),
tvrec ? tvrec->GetCaptureCardNum() : -1);
else if (_stream_data->DesiredProgram() >= 0)
_stream_data->SetDesiredProgram(_stream_data->DesiredProgram());
_stream_data->SetDesiredProgram(_stream_data->DesiredProgram(),
tvrec ? tvrec->GetCaptureCardNum() : -1);
}

void DTVRecorder::BufferedWrite(const TSPacket &tspacket)
Expand Down
13 changes: 8 additions & 5 deletions mythtv/libs/libmythtv/recorders/dtvsignalmonitor.cpp
Expand Up @@ -14,9 +14,11 @@ using namespace std;

#undef DBG_SM
#define DBG_SM(FUNC, MSG) LOG(VB_CHANNEL, LOG_INFO, \
QString("DTVSM(%1)::%2: %3").arg(channel->GetDevice()).arg(FUNC).arg(MSG))
QString("DTVSM[%1](%2)::%3: %4").arg(capturecardnum) \
.arg(channel->GetDevice()).arg(FUNC).arg(MSG))

#define LOC QString("DTVSM(%1): ").arg(channel->GetDevice())
#define LOC QString("DTVSM[%1](%2): ") \
.arg(capturecardnum).arg(channel->GetDevice())

// inserts tid&crc value into an ordered list
// returns true if item is inserted
Expand Down Expand Up @@ -211,7 +213,7 @@ void DTVSignalMonitor::SetChannel(int major, int minor)
kDTVSigMon_CryptSeen | kDTVSigMon_CryptMatch);
majorChannel = major;
minorChannel = minor;
GetATSCStreamData()->SetDesiredChannel(major, minor);
GetATSCStreamData()->SetDesiredChannel(major, minor, capturecardnum);
AddFlags(kDTVSigMon_WaitForVCT | kDTVSigMon_WaitForPAT);
}
}
Expand All @@ -226,7 +228,7 @@ void DTVSignalMonitor::SetProgramNumber(int progNum)
kDTVSigMon_CryptSeen | kDTVSigMon_CryptMatch);
programNumber = progNum;
if (GetStreamData())
GetStreamData()->SetDesiredProgram(programNumber);
GetStreamData()->SetDesiredProgram(programNumber, capturecardnum);
AddFlags(kDTVSigMon_WaitForPMT);
}
}
Expand All @@ -253,7 +255,8 @@ void DTVSignalMonitor::SetDVBService(uint netid, uint tsid, int serviceid)

if (GetDVBStreamData())
{
GetDVBStreamData()->SetDesiredService(netid, tsid, programNumber);
GetDVBStreamData()->SetDesiredService(netid, tsid, programNumber,
capturecardnum);
AddFlags(kDTVSigMon_WaitForPMT | kDTVSigMon_WaitForSDT);
GetDVBStreamData()->AddListeningPID(DVB_SDT_PID);
}
Expand Down
2 changes: 1 addition & 1 deletion mythtv/libs/libmythtv/recorders/dvbchannel.cpp
Expand Up @@ -55,7 +55,7 @@ static struct dvb_frontend_parameters dtvmultiplex_to_dvbparams(
static DTVMultiplex dvbparams_to_dtvmultiplex(
DTVTunerType, const dvb_frontend_parameters&);

#define LOC QString("DVBChan(%1:%2): ").arg(GetCardID()).arg(device)
#define LOC QString("DVBChan[%1](%2): ").arg(GetCardID()).arg(GetDevice())

/** \class DVBChannel
* \brief Provides interface to the tuning hardware when using DVB drivers
Expand Down
4 changes: 2 additions & 2 deletions mythtv/libs/libmythtv/recorders/dvbrecorder.cpp
Expand Up @@ -29,8 +29,8 @@
#include "tv_rec.h"
#include "mythlogging.h"

#define LOC QString("DVBRec(%1:%2): ") \
.arg(tvrec->GetCaptureCardNum()).arg(videodevice)
#define LOC QString("DVBRec[%1](%2): ") \
.arg(tvrec ? tvrec->GetCaptureCardNum() : -1).arg(videodevice)

DVBRecorder::DVBRecorder(TVRec *rec, DVBChannel *channel)
: DTVRecorder(rec), _channel(channel), _stream_handler(NULL)
Expand Down
3 changes: 2 additions & 1 deletion mythtv/libs/libmythtv/recorders/dvbsignalmonitor.cpp
Expand Up @@ -21,7 +21,8 @@
#include "dvbrecorder.h"
#include "dvbstreamhandler.h"

#define LOC QString("DVBSM(%1): ").arg(channel->GetDevice())
#define LOC QString("DVBSM[%1](%2): ") \
.arg(capturecardnum).arg(channel->GetDevice())

/**
* \brief Initializes signal lock and signal values.
Expand Down
2 changes: 1 addition & 1 deletion mythtv/libs/libmythtv/recorders/firewirechannel.cpp
Expand Up @@ -13,7 +13,7 @@
#endif
#include "firewirechannel.h"

#define LOC QString("FireChan(%1): ").arg(GetDevice())
#define LOC QString("FireChan[%1](%2): ").arg(GetCardID()).arg(GetDevice())

FirewireChannel::FirewireChannel(TVRec *parent, const QString &_videodevice,
const FireWireDBOptions &firewire_opts) :
Expand Down
4 changes: 3 additions & 1 deletion mythtv/libs/libmythtv/recorders/firewirerecorder.cpp
Expand Up @@ -12,7 +12,9 @@
#include "mpegstreamdata.h"
#include "tv_rec.h"

#define LOC QString("FireRecBase(%1): ").arg(channel->GetDevice())
#define LOC QString("FireRecBase[%1](%2): ") \
.arg(tvrec ? tvrec->GetCaptureCardNum() : -1) \
.arg(channel->GetDevice())

FirewireRecorder::FirewireRecorder(TVRec *rec, FirewireChannel *chan) :
DTVRecorder(rec),
Expand Down
3 changes: 2 additions & 1 deletion mythtv/libs/libmythtv/recorders/firewiresignalmonitor.cpp
Expand Up @@ -13,7 +13,8 @@
#include "firewiresignalmonitor.h"
#include "mythlogging.h"

#define LOC QString("FireSM(%1): ").arg(channel->GetDevice())
#define LOC QString("FireSM[%1](%2): ") \
.arg(capturecardnum).arg(channel->GetDevice())

void FirewireTableMonitorThread::run(void)
{
Expand Down
2 changes: 1 addition & 1 deletion mythtv/libs/libmythtv/recorders/hdhrchannel.cpp
Expand Up @@ -28,7 +28,7 @@ using namespace std;
#include "channelutil.h"
#include "hdhrstreamhandler.h"

#define LOC QString("HDHRChan(%1): ").arg(GetDevice())
#define LOC QString("HDHRChan[%1](%2): ").arg(GetCardID()).arg(GetDevice())

HDHRChannel::HDHRChannel(TVRec *parent, const QString &device)
: DTVChannel(parent),
Expand Down
3 changes: 2 additions & 1 deletion mythtv/libs/libmythtv/recorders/hdhrrecorder.cpp
Expand Up @@ -13,7 +13,8 @@
#include "tv_rec.h"
#include "mythlogging.h"

#define LOC QString("HDHRRec(%1): ").arg(tvrec->GetCaptureCardNum())
#define LOC QString("HDHRRec[%1]: ") \
.arg(tvrec ? tvrec->GetCaptureCardNum() : -1)

HDHRRecorder::HDHRRecorder(TVRec *rec, HDHRChannel *channel)
: DTVRecorder(rec), _channel(channel), _stream_handler(NULL)
Expand Down
3 changes: 2 additions & 1 deletion mythtv/libs/libmythtv/recorders/hdhrsignalmonitor.cpp
Expand Up @@ -21,7 +21,8 @@
#include "hdhrrecorder.h"
#include "hdhrstreamhandler.h"

#define LOC QString("HDHRSM(%1): ").arg(channel->GetDevice())
#define LOC QString("HDHRSM[%1](%2): ") \
.arg(capturecardnum).arg(channel->GetDevice())

/**
* \brief Initializes signal lock and signal values.
Expand Down
4 changes: 2 additions & 2 deletions mythtv/libs/libmythtv/recorders/importrecorder.cpp
Expand Up @@ -39,8 +39,8 @@
#define TVREC_CARDNUM \
((tvrec != NULL) ? QString::number(tvrec->GetCaptureCardNum()) : "NULL")

#define LOC QString("ImportRec(%1:%2): ") \
.arg(TVREC_CARDNUM).arg(videodevice)
#define LOC QString("ImportRec[%1](%2): ") \
.arg(TVREC_CARDNUM).arg(videodevice)

ImportRecorder::ImportRecorder(TVRec *rec) :
DTVRecorder(rec), _import_fd(-1)
Expand Down
2 changes: 1 addition & 1 deletion mythtv/libs/libmythtv/recorders/iptvchannel.cpp
Expand Up @@ -16,7 +16,7 @@
#include "mythlogging.h"
#include "mythdb.h"

#define LOC QString("IPTVChan(%1): ").arg(GetCardID())
#define LOC QString("IPTVChan[%1]: ").arg(GetCardID())

IPTVChannel::IPTVChannel(TVRec *rec, const QString&) :
DTVChannel(rec), m_open(false),
Expand Down
3 changes: 2 additions & 1 deletion mythtv/libs/libmythtv/recorders/iptvsignalmonitor.cpp
Expand Up @@ -6,7 +6,8 @@
#include "iptvchannel.h"
#include "mythlogging.h"

#define LOC QString("IPTVSM(%1): ").arg(channel->GetDevice())
#define LOC QString("IPTVSM[%1](%2): ") \
.arg(capturecardnum).arg(channel->GetDevice())

/** \brief Initializes signal lock and signal values.
*
Expand Down
5 changes: 3 additions & 2 deletions mythtv/libs/libmythtv/recorders/mpegrecorder.cpp
Expand Up @@ -46,7 +46,8 @@ extern "C" {

#define IVTV_KERNEL_VERSION(a,b,c) (((a) << 16) + ((b) << 8) + (c))

#define LOC QString("MPEGRec(%1): ").arg(videodevice)
#define LOC QString("MPEGRec[%1](%2): ") \
.arg(tvrec ? tvrec->GetCaptureCardNum() : -1).arg(videodevice)

const int MpegRecorder::audRateL1[] =
{
Expand Down Expand Up @@ -1367,7 +1368,7 @@ void MpegRecorder::StopEncoding(void)
void MpegRecorder::InitStreamData(void)
{
_stream_data->AddMPEGSPListener(this);
_stream_data->SetDesiredProgram(1);
_stream_data->SetDesiredProgram(1, tvrec ? tvrec->GetCaptureCardNum() : -1);
}

void MpegRecorder::SetBitrate(int bitrate, int maxbitrate,
Expand Down
4 changes: 2 additions & 2 deletions mythtv/libs/libmythtv/recorders/recorderbase.cpp
Expand Up @@ -33,8 +33,8 @@ using namespace std;
#define TVREC_CARDNUM \
((tvrec != NULL) ? QString::number(tvrec->GetCaptureCardNum()) : "NULL")

#define LOC QString("RecBase(%1:%2): ") \
.arg(TVREC_CARDNUM).arg(videodevice)
#define LOC QString("RecBase[%1](%2): ") \
.arg(TVREC_CARDNUM).arg(videodevice)

const uint RecorderBase::kTimeOfLatestDataIntervalTarget = 5000;

Expand Down

0 comments on commit 023b90f

Please sign in to comment.