mirror of https://github.com/VDR4Arch/vdr.git
84 lines
2.2 KiB
C
84 lines
2.2 KiB
C
/*
|
|
* transfer.c: Transfer mode
|
|
*
|
|
* See the main source file 'vdr.c' for copyright information and
|
|
* how to reach the author.
|
|
*
|
|
* $Id: transfer.c 5.1 2022/12/05 14:45:51 kls Exp $
|
|
*/
|
|
|
|
#include "transfer.h"
|
|
|
|
// --- cTransfer -------------------------------------------------------------
|
|
|
|
cTransfer::cTransfer(const cChannel *Channel)
|
|
:cReceiver(Channel, TRANSFERPRIORITY)
|
|
{
|
|
lastErrorReport = 0;
|
|
numLostPackets = 0;
|
|
patPmtGenerator.SetChannel(Channel);
|
|
}
|
|
|
|
cTransfer::~cTransfer()
|
|
{
|
|
cReceiver::Detach();
|
|
cPlayer::Detach();
|
|
}
|
|
|
|
void cTransfer::Activate(bool On)
|
|
{
|
|
if (On) {
|
|
PlayTs(patPmtGenerator.GetPat(), TS_SIZE);
|
|
int Index = 0;
|
|
while (uchar *pmt = patPmtGenerator.GetPmt(Index))
|
|
PlayTs(pmt, TS_SIZE);
|
|
}
|
|
else
|
|
cPlayer::Detach();
|
|
}
|
|
|
|
#define MAXRETRIES 20 // max. number of retries for a single TS packet
|
|
#define RETRYWAIT 5 // time (in ms) between two retries
|
|
#define ERRORDELTA 60 // seconds before reporting lost TS packets again
|
|
|
|
void cTransfer::Receive(const uchar *Data, int Length)
|
|
{
|
|
if (cPlayer::IsAttached()) {
|
|
// Transfer Mode means "live tv", so there's no point in doing any additional
|
|
// buffering here. The TS packets *must* get through here! However, every
|
|
// now and then there may be conditions where the packet just can't be
|
|
// handled when offered the first time, so that's why we try several times:
|
|
for (int i = 0; i < MAXRETRIES; i++) {
|
|
if (PlayTs(Data, Length) > 0)
|
|
return;
|
|
cCondWait::SleepMs(RETRYWAIT);
|
|
}
|
|
DeviceClear();
|
|
numLostPackets++;
|
|
if (time(NULL) - lastErrorReport > ERRORDELTA) {
|
|
esyslog("ERROR: %d TS packet(s) not accepted in Transfer Mode", numLostPackets);
|
|
numLostPackets = 0;
|
|
lastErrorReport = time(NULL);
|
|
}
|
|
}
|
|
}
|
|
|
|
// --- cTransferControl ------------------------------------------------------
|
|
|
|
cDevice *cTransferControl::receiverDevice = NULL;
|
|
|
|
cTransferControl::cTransferControl(cDevice *ReceiverDevice, const cChannel *Channel)
|
|
:cControl(NULL, true)
|
|
{
|
|
transfer = new cTransfer(Channel);
|
|
SetPlayer(transfer);
|
|
ReceiverDevice->AttachReceiver(transfer);
|
|
receiverDevice = ReceiverDevice;
|
|
}
|
|
|
|
cTransferControl::~cTransferControl()
|
|
{
|
|
receiverDevice = NULL;
|
|
delete transfer;
|
|
}
|