frodovdr/vdr
1
0
Fork 0
mirror of https://github.com/vdr-projects/vdr.git synced 2025-03-01 10:50:46 +00:00
Code Issues Packages Projects Releases Wiki Activity

cMtdHandler::Put() now processes as many TS packets as possible in one call

Browse Source
This commit is contained in:
Klaus Schmidinger 2017-03-19 14:20:22 +01:00
parent e2756f8e9a
commit b7be7c900a
1 changed files with 22 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
mtd.c
View File

@ -4,7 +4,7 @@
* See the main source file 'vdr.c' for copyright information and * See the main source file 'vdr.c' for copyright information and
* how to reach the author. * how to reach the author.
* *
* $Id: mtd.c 1.2 2017/03/19 13:33:53 kls Exp $ * $Id: mtd.c 1.3 2017/03/19 14:20:22 kls Exp $
*/ */
#include "mtd.h" #include "mtd.h"
@ -59,24 +59,30 @@ cMtdCamSlot *cMtdHandler::GetMtdCamSlot(cCamSlot *MasterSlot)
int cMtdHandler::Put(const uchar *Data, int Count) int cMtdHandler::Put(const uchar *Data, int Count)
{ {
// TODO maybe handle more than one TS packet? int Used = 0;
if (Count > TS_SIZE) while (Count >= TS_SIZE) {
Count = TS_SIZE;
else if (Count < TS_SIZE)
return 0;
int Pid = TsPid(Data); int Pid = TsPid(Data);
if (Pid == CATPID) if (Pid != CATPID) { // the original CAT with mapped PIDs must be skipped here!
return Count; // this is the original CAT with mapped PIDs
#ifdef KEEPPIDS #ifdef KEEPPIDS
int Index = 0; int Index = 0;
#else #else
int Index = (Pid >> UNIQ_PID_SHIFT) - 1; int Index = (Pid >> UNIQ_PID_SHIFT) - 1;
#endif // KEEPPIDS #endif // KEEPPIDS
if (Index >= 0 && Index < camSlots.Size()) if (Index >= 0 && Index < camSlots.Size()) {
return camSlots[Index]->PutData(Data, Count); int w = camSlots[Index]->PutData(Data, TS_SIZE);
if (w == 0)
break;
else if (w != TS_SIZE)
esyslog("ERROR: incomplete MTD packet written (%d) in PID %d (%04X)", Index + 1, Pid, Pid);
}
else else
esyslog("ERROR: invalid MTD number (%d) in PID %d (%04X)", Index + 1, Pid, Pid); esyslog("ERROR: invalid MTD number (%d) in PID %d (%04X)", Index + 1, Pid, Pid);
return Count; // no such buffer - let's just drop the data so nothing stacks up }
Data += TS_SIZE;
Count -= TS_SIZE;
Used += TS_SIZE;
}
return Used;
} }
int cMtdHandler::Priority(void) int cMtdHandler::Priority(void)