transfer.c

Go to the documentation of this file.

/*
 * transfer.c: Transfer mode
 *
 * See the main source file 'vdr.c' for copyright information and
 * how to reach the author.
 *
 * $Id: transfer.c 5.3 2026/10/26 19:25:55 kls Exp $
 */
 
#include "transfer.h"
 
// --- cTransfer -------------------------------------------------------------
 
static cMutex TransferMutex;
 
cTransfer::cTransfer(const cChannel *Channel)
:cReceiver(Channel, TRANSFERPRIORITY)
{
  activated = false;
  lastErrorReport = 0;
  numLostPackets = 0;
  patPmtGenerator.SetChannel(Channel);
}
 
cTransfer::~cTransfer()
{
  cReceiver::Detach();
  cPlayer::Detach();
}
 
void cTransfer::Activate(bool On)
{
  cMutexLock MutexLock(&TransferMutex);
  if (On) {
     if (cPlayer::IsAttached()) {
        PlayTs(patPmtGenerator.GetPat(), TS_SIZE);
        int Index = 0;
        while (uchar *pmt = patPmtGenerator.GetPmt(Index))
              PlayTs(pmt, TS_SIZE);
        activated = true;
        }
     }
  else {
     activated = false;
     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)
{
  cMutexLock MutexLock(&TransferMutex);
  if (activated) {
     // 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 ------------------------------------------------------
 
std::atomic<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;
}