15#define __STDC_FORMAT_MACROS
34#define SUMMARYFALLBACK
47#define DATAFORMATPES "%4d-%02d-%02d.%02d%*c%02d.%02d.%02d" RECEXT
48#define NAMEFORMATPES "%s/%s/" "%4d-%02d-%02d.%02d.%02d.%02d.%02d" RECEXT
49#define DATAFORMATTS "%4d-%02d-%02d.%02d.%02d.%d-%d" RECEXT
50#define NAMEFORMATTS "%s/%s/" DATAFORMATTS
52#define RESUMEFILESUFFIX "/resume%s%s"
54#define SUMMARYFILESUFFIX "/summary.vdr"
56#define INFOFILESUFFIX "/info"
57#define MARKSFILESUFFIX "/marks"
59#define SORTMODEFILE ".sort"
60#define TIMERRECFILE ".timer"
62#define MINDISKSPACE 1024
64#define REMOVECHECKDELTA 60
65#define DELETEDLIFETIME 300
66#define DISKCHECKDELTA 100
67#define REMOVELATENCY 10
68#define MARKSUPDATEDELTA 10
69#define MAXREMOVETIME 10
71#define MAX_LINK_LEVEL 6
73#define LIMIT_SECS_PER_MB_RADIO 5
90:
cThread(
"remove deleted recordings", true)
98 if (LockFile.
Lock()) {
99 time_t StartTime = time(NULL);
100 bool deleted =
false;
101 bool interrupted =
false;
103 for (
cRecording *r = DeletedRecordings->First(); r; ) {
115 DeletedRecordings->Del(r);
120 r = DeletedRecordings->
Next(r);
138 static time_t LastRemoveCheck = 0;
142 for (
const cRecording *r = DeletedRecordings->First(); r; r = DeletedRecordings->
Next(r)) {
149 LastRemoveCheck = time(NULL);
160 static time_t LastFreeDiskCheck = 0;
161 int Factor = (Priority == -1) ? 10 : 1;
162 if (Force || time(NULL) - LastFreeDiskCheck >
DISKCHECKDELTA / Factor) {
166 if (!LockFile.
Lock())
169 isyslog(
"low disk space while recording, trying to remove a deleted recording...");
170 int NumDeletedRecordings = 0;
173 NumDeletedRecordings = DeletedRecordings->Count();
174 if (NumDeletedRecordings) {
182 r = DeletedRecordings->
Next(r);
187 DeletedRecordings->Del(r0);
192 if (NumDeletedRecordings == 0) {
197 if (DeletedRecordings->Count())
202 isyslog(
"...no deleted recording found, trying to delete an old recording...");
204 Recordings->SetExplicitModify();
205 if (Recordings->Count()) {
222 r = Recordings->
Next(r);
226 Recordings->SetModified();
231 isyslog(
"...no old recording found, giving up");
234 isyslog(
"...no deleted recording found, priority %d too low to trigger deleting an old recording", Priority);
237 LastFreeDiskCheck = time(NULL);
253 esyslog(
"ERROR: can't allocate memory for resume file name");
267 if ((st.st_mode & S_IWUSR) == 0)
273 if (
safe_read(f, &resume,
sizeof(resume)) !=
sizeof(resume)) {
279 else if (errno != ENOENT)
288 while ((s = ReadLine.
Read(f)) != NULL) {
292 case 'I': resume = atoi(t);
299 else if (errno != ENOENT)
310 int f = open(
fileName, O_WRONLY | O_CREAT | O_TRUNC, DEFFILEMODE);
323 fprintf(f,
"I %d\n", Index);
343 else if (errno != ENOENT)
369 for (
int i = 0; i <
MAXAPIDS; i++) {
370 const char *s = Channel->
Alang(i);
375 else if (strlen(s) > strlen(Component->
language))
382 for (
int i = 0; i <
MAXDPIDS; i++) {
383 const char *s = Channel->
Dlang(i);
390 else if (strlen(s) > strlen(Component->
language))
395 for (
int i = 0; i <
MAXSPIDS; i++) {
396 const char *s = Channel->
Slang(i);
401 else if (strlen(s) > strlen(Component->
language))
471 while ((s = ReadLine.
Read(f)) != NULL) {
476 char *p = strchr(t,
' ');
487 unsigned int EventID;
490 unsigned int TableID = 0;
491 unsigned int Version = 0xFF;
492 int n = sscanf(t,
"%u %jd %d %X %X", &EventID, &StartTime, &Duration, &TableID, &Version);
493 if (n >= 3 && n <= 5) {
508 case 'O':
errors = atoi(t);
515 esyslog(
"ERROR: EPG data problem in line %d", line);
530 event->Dump(f, Prefix,
true);
532 fprintf(f,
"%sP %d\n", Prefix,
priority);
533 fprintf(f,
"%sL %d\n", Prefix,
lifetime);
534 fprintf(f,
"%sO %d\n", Prefix,
errors);
536 fprintf(f,
"%s@ %s\n", Prefix,
aux);
552 else if (errno != ENOENT)
576#define RESUME_NOT_INITIALIZED (-2)
609 case ' ': *p =
'_';
break;
616 if (
char *NewBuffer = (
char *)realloc(s, strlen(s) + 10)) {
620 sprintf(buf,
"#%02X", (
unsigned char)*p);
621 memmove(p + 2, p, strlen(p) + 1);
626 esyslog(
"ERROR: out of memory");
633 case '_': *p =
' ';
break;
638 if (strlen(p) > 2 && isxdigit(*(p + 1)) && isxdigit(*(p + 2))) {
640 sprintf(buf,
"%c%c", *(p + 1), *(p + 2));
644 memmove(p + 1, p + 3, strlen(p) - 2);
650 case '\x01': *p =
'\'';
break;
651 case '\x02': *p =
'/';
break;
652 case '\x03': *p =
':';
break;
659 if (*p == (ToFileSystem ? ce->a : ce->b)) {
660 *p = ToFileSystem ? ce->b : ce->a;
682 int Length = strlen(s);
685 bool NameTooLong =
false;
689 for (
char *p = s; *p; p++) {
692 NameTooLong |= NameLength > NameMax;
713 NameTooLong |= NameLength > NameMax;
721 while (i-- > 0 && a[i] >= 0) {
726 if (NameLength > NameMax) {
729 while (i-- > 0 && a[i] >= 0) {
731 if (NameLength - l <= NameMax) {
732 memmove(s + i, s + n, Length - n + 1);
733 memmove(a + i, a + n, Length - n + 1);
746 while (PathLength > PathMax && n > 0) {
751 while (--i > 0 && a[i - 1] >= 0) {
755 if (PathLength - l <= PathMax)
761 memmove(s + b, s + n, Length - n + 1);
788 const char *
Title = Event ? Event->
Title() : NULL;
789 const char *Subtitle = Event ? Event->
ShortText() : NULL;
796 if (macroTITLE || macroEPISODE) {
801 int l = strlen(
name);
848 const char *p = strrchr(
FileName,
'/');
853 time_t now = time(NULL);
855 struct tm t = *localtime_r(&now, &tm_r);
874 FILE *f = fopen(InfoFileName,
"r");
877 esyslog(
"ERROR: EPG data problem in file %s", *InfoFileName);
885 else if (errno != ENOENT)
887#ifdef SUMMARYFALLBACK
891 FILE *f = fopen(SummaryFileName,
"r");
894 char *data[3] = { NULL };
897 while ((s = ReadLine.
Read(f)) != NULL) {
898 if (*s || line > 1) {
901 len += strlen(data[line]) + 1;
902 if (
char *NewBuffer = (
char *)realloc(data[line], len + 1)) {
903 data[line] = NewBuffer;
904 strcat(data[line],
"\n");
905 strcat(data[line], s);
908 esyslog(
"ERROR: out of memory");
911 data[line] = strdup(s);
921 else if (data[1] && data[2]) {
925 int len = strlen(data[1]);
927 if (
char *NewBuffer = (
char *)realloc(data[1], len + 1 + strlen(data[2]) + 1)) {
929 strcat(data[1],
"\n");
930 strcat(data[1], data[2]);
936 esyslog(
"ERROR: out of memory");
940 for (
int i = 0; i < 3; i ++)
943 else if (errno != ENOENT)
964 char *t = s, *s1 = NULL, *s2 = NULL;
985 memmove(s1, s2, t - s2 + 1);
998 strftime(buf,
sizeof(buf),
"%Y%m%d%H%I", localtime_r(&
start, &tm_r));
1006 int l = strxfrm(NULL, s, 0) + 1;
1049 int l = strlen(Path);
1069 struct tm *t = localtime_r(&
start, &tm_r);
1085 const char *New = NewIndicator &&
IsNew() ?
"*" :
"";
1086 const char *Err = NewIndicator && (
info->
Errors() > 0) ?
"!" :
"";
1091 struct tm *t = localtime_r(&
start, &tm_r);
1126 const char *s =
name;
1159 const char *s =
name;
1202 if (!OtherFileName) {
1205 if (ExistingInfo.
Read())
1230 dsyslog(
"changing priority/lifetime of '%s' to %d/%d",
Name(), NewPriority, NewLifetime);
1254 if (strcmp(NewName,
Name())) {
1255 dsyslog(
"changing name of '%s' to '%s'",
Name(), NewName);
1261 name = strdup(NewName);
1263 bool Exists = access(NewFileName, F_OK) == 0;
1265 esyslog(
"ERROR: recording '%s' already exists", NewName);
1268 name = strdup(OldName);
1282 char *NewName = strdup(
FileName());
1283 char *ext = strrchr(NewName,
'.');
1284 if (ext && strcmp(ext,
RECEXT) == 0) {
1285 strncpy(ext,
DELEXT, strlen(ext));
1286 if (access(NewName, F_OK) == 0) {
1288 isyslog(
"removing recording '%s'", NewName);
1292 if (access(
FileName(), F_OK) == 0) {
1319 char *NewName = strdup(
FileName());
1320 char *ext = strrchr(NewName,
'.');
1321 if (ext && strcmp(ext,
DELEXT) == 0) {
1322 strncpy(ext,
RECEXT, strlen(ext));
1323 if (access(NewName, F_OK) == 0) {
1325 esyslog(
"ERROR: attempt to undelete '%s', while recording '%s' exists",
FileName(), NewName);
1401 void ScanVideoDir(
const char *DirName,
int LinkLevel = 0,
int DirLevel = 0);
1403 virtual void Action(
void);
1410:
cThread(
"video directory scanner", true)
1446 if (lstat(buffer, &st) == 0) {
1448 if (S_ISLNK(st.st_mode)) {
1450 isyslog(
"max link level exceeded - not scanning %s", *buffer);
1454 if (stat(buffer, &st) != 0)
1457 if (S_ISDIR(st.st_mode)) {
1465 Recordings->
Lock(StateKey,
true);
1467 dsyslog(
"activated name checking for initial read of video directory");
1492 if (!
initial && DirLevel == 0) {
1498 if (access(r->
FileName(), F_OK) != 0)
1544 if (lastModified > time(NULL))
1564 if (Recording->Id() == Id)
1574 if (strcmp(Recording->FileName(), FileName) == 0)
1601 Recording = dummy =
new cRecording(FileName);
1604 Del(Recording,
false);
1605 char *ext = strrchr(Recording->
fileName,
'.');
1607 strncpy(ext,
DELEXT, strlen(ext));
1608 if (access(Recording->
FileName(), F_OK) == 0) {
1610 DeletedRecordings->Add(Recording);
1621 Recording->ReadInfo();
1628 int FileSizeMB = Recording->FileSizeMB();
1629 if (FileSizeMB > 0 && Recording->IsOnVideoDirectoryFileSystem())
1640 if (Recording->IsOnVideoDirectoryFileSystem()) {
1641 int FileSizeMB = Recording->FileSizeMB();
1642 if (FileSizeMB > 0) {
1643 int LengthInSeconds = Recording->LengthInSeconds();
1644 if (LengthInSeconds > 0) {
1647 length += LengthInSeconds;
1653 return (size && length) ? double(size) * 60 / length : -1;
1660 if (Recording->IsInPath(Path))
1661 Use |= Recording->IsInUse();
1670 if (Recording->IsInPath(Path))
1678 if (OldPath && NewPath && strcmp(OldPath, NewPath)) {
1679 dsyslog(
"moving '%s' to '%s'", OldPath, NewPath);
1682 if (Recording->IsInPath(OldPath)) {
1683 const char *p = Recording->Name() + strlen(OldPath);
1685 if (!Recording->ChangeName(NewName))
1699 if (!ResumeFileName || strncmp(ResumeFileName, Recording->FileName(), strlen(Recording->FileName())) == 0)
1700 Recording->ResetResume();
1707 Recording->ClearSortName();
1719 virtual void Action(
void);
1721 cDirCopier(
const char *DirNameSrc,
const char *DirNameDst);
1744 dsyslog(
"suspending copy thread");
1750 dsyslog(
"resuming copy thread");
1767 size_t BufferSize = BUFSIZ;
1768 uchar *Buffer = NULL;
1782 size_t Read =
safe_read(From, Buffer, BufferSize);
1784 size_t Written =
safe_write(To, Buffer, Read);
1785 if (Written != Read) {
1786 esyslog(
"ERROR: can't write to destination file '%s': %m", *FileNameDst);
1790 else if (Read == 0) {
1792 if (fsync(To) < 0) {
1793 esyslog(
"ERROR: can't sync destination file '%s': %m", *FileNameDst);
1796 if (close(From) < 0) {
1797 esyslog(
"ERROR: can't close source file '%s': %m", *FileNameSrc);
1800 if (close(To) < 0) {
1801 esyslog(
"ERROR: can't close destination file '%s': %m", *FileNameDst);
1805 off_t FileSizeSrc =
FileSize(FileNameSrc);
1806 off_t FileSizeDst =
FileSize(FileNameDst);
1807 if (FileSizeSrc != FileSizeDst) {
1808 esyslog(
"ERROR: file size discrepancy: %" PRId64
" != %" PRId64, FileSizeSrc, FileSizeDst);
1813 esyslog(
"ERROR: can't read from source file '%s': %m", *FileNameSrc);
1817 else if ((e = d.
Next()) != NULL) {
1822 if (stat(FileNameSrc, &st) < 0) {
1823 esyslog(
"ERROR: can't access source file '%s': %m", *FileNameSrc);
1826 if (!(S_ISREG(st.st_mode) || S_ISLNK(st.st_mode))) {
1827 esyslog(
"ERROR: source file '%s' is neither a regular file nor a symbolic link", *FileNameSrc);
1830 dsyslog(
"copying file '%s' to '%s'", *FileNameSrc, *FileNameDst);
1832 BufferSize =
max(
size_t(st.st_blksize * 10),
size_t(BUFSIZ));
1835 esyslog(
"ERROR: out of memory");
1839 if (access(FileNameDst, F_OK) == 0) {
1840 esyslog(
"ERROR: destination file '%s' already exists", *FileNameDst);
1843 if ((From = open(FileNameSrc, O_RDONLY)) < 0) {
1844 esyslog(
"ERROR: can't open source file '%s': %m", *FileNameSrc);
1847 if ((To = open(FileNameDst, O_WRONLY | O_CREAT | O_EXCL, DEFFILEMODE)) < 0) {
1848 esyslog(
"ERROR: can't open destination file '%s': %m", *FileNameDst);
1887 int Usage(
const char *FileName = NULL)
const;
1915 if (FileName && *FileName) {
1964 if (Recording.
Delete()) {
1966 Recordings->DelByName(Recording.
FileName());
1969 Recordings->TouchUpdate();
2027 error |= r->Error();
2044 if (FileName && *FileName) {
2048 if (strcmp(FileName, r->FileNameSrc()) == 0 || strcmp(FileName, r->FileNameDst()) == 0)
2057 dsyslog(
"recordings handler add %d '%s' '%s'", Usage, FileNameSrc, FileNameDst);
2060 if (FileNameSrc && *FileNameSrc) {
2061 if (Usage ==
ruCut || FileNameDst && *FileNameDst) {
2063 if (Usage ==
ruCut && !FileNameDst)
2065 if (!
Get(FileNameSrc) && !
Get(FileNameDst)) {
2073 esyslog(
"ERROR: file name already present in recordings handler add %d '%s' '%s'", Usage, FileNameSrc, FileNameDst);
2076 esyslog(
"ERROR: missing dst file name in recordings handler add %d '%s' '%s'", Usage, FileNameSrc, FileNameDst);
2079 esyslog(
"ERROR: missing src file name in recordings handler add %d '%s' '%s'", Usage, FileNameSrc, FileNameDst);
2082 esyslog(
"ERROR: invalid usage in recordings handler add %d '%s' '%s'", Usage, FileNameSrc, FileNameDst);
2104 return r->Usage(FileName);
2146 const char *p = strchr(s,
' ');
2157 return fprintf(f,
"%s\n", *
ToText()) > 0;
2170 if (errno != ENOENT) {
2178bool cMarks::Load(
const char *RecordingFileName,
double FramesPerSecond,
bool IsPesRecording)
2192 time_t t = time(NULL);
2196 lastChange = LastModified > 0 ? LastModified : t;
2235 if (m->Position() - p) {
2246 if (m2->Position() < m1->Position()) {
2247 swap(m1->position, m2->position);
2248 swap(m1->comment, m2->comment);
2263 if (mi->Position() == Position)
2272 if (mi->Position() < Position)
2281 if (mi->Position() > Position)
2290 if (BeginMark && EndMark && BeginMark->
Position() == EndMark->
Position()) {
2291 while (
const cMark *NextMark =
Next(BeginMark)) {
2292 if (BeginMark->
Position() == NextMark->Position()) {
2293 if (!(BeginMark =
Next(NextMark)))
2308 if (EndMark && BeginMark && BeginMark->
Position() == EndMark->
Position()) {
2309 while (
const cMark *NextMark =
Next(EndMark)) {
2310 if (EndMark->
Position() == NextMark->Position()) {
2311 if (!(EndMark =
Next(NextMark)))
2323 int NumSequences = 0;
2331 if (NumSequences == 1 && BeginMark->Position() == 0)
2335 return NumSequences;
2350 isyslog(
"executing '%s'", *cmd);
2357#define IFG_BUFFER_SIZE KILOBYTE(100)
2364 virtual void Action(
void);
2371:
cThread(
"index file generator")
2372,recordingName(RecordingName)
2385 bool IndexFileComplete =
false;
2386 bool IndexFileWritten =
false;
2387 bool Rewind =
false;
2396 off_t FrameOffset = -1;
2397 uint16_t FileNumber = 1;
2398 off_t FileOffset = 0;
2404 Last = IndexFile.
Last();
2405 if (Last >= 0 && !IndexFile.
Get(Last, &FileNumber, &FileOffset, &Independent, &Length))
2409 isyslog(
"updating index file");
2412 isyslog(
"generating index file");
2416 bool Stuffed =
false;
2420 ReplayFile = FileName.
SetOffset(FileNumber, FileOffset);
2429 if (FrameDetector.
Synced()) {
2433 int Processed = FrameDetector.
Analyze(Data, Length);
2434 if (Processed > 0) {
2436 if (IndexFileWritten || Last < 0)
2439 IndexFileWritten =
true;
2442 Buffer.
Del(Processed);
2447 int Processed = FrameDetector.
Analyze(Data, Length);
2448 if (Processed > 0) {
2449 if (FrameDetector.
Synced()) {
2453 Buffer.
Del(Processed);
2463 else if (PatPmtParser.
IsPmtPid(Pid))
2469 FrameDetector.
SetPid(PatPmtParser.
Vpid() ? PatPmtParser.
Vpid() : PatPmtParser.
Apid(0), PatPmtParser.
Vpid() ? PatPmtParser.
Vtype() : PatPmtParser.
Atype(0));
2475 Buffer.
Del(p - Data);
2479 else if (ReplayFile) {
2480 int Result = Buffer.
Read(ReplayFile, BufferChunks);
2482 if (Buffer.
Available() > 0 && !Stuffed) {
2491 Buffer.
Put(StuffingPacket,
sizeof(StuffingPacket));
2505 IndexFileComplete =
true;
2510 if (IndexFileComplete) {
2511 if (IndexFileWritten) {
2513 if (RecordingInfo.
Read()) {
2516 RecordingInfo.
Write();
2533#define INDEXFILESUFFIX "/index"
2536#define MAXINDEXCATCHUP 8
2537#define INDEXCATCHUPWAIT 100
2551 tIndexTs(off_t Offset,
bool Independent, uint16_t Number)
2555 independent = Independent;
2560#define MAXWAITFORINDEXFILE 10
2561#define INDEXFILECHECKINTERVAL 500
2562#define INDEXFILETESTINTERVAL 10
2565:resumeFile(FileName, IsPesRecording)
2575 if (!Record && PauseLive) {
2578 while (time(NULL) < tmax &&
FileSize(
fileName) < off_t(2 *
sizeof(tIndexTs)))
2591 }
while (access(
fileName, R_OK) != 0 && time(NULL) < tmax);
2597 delta = int(buf.st_size %
sizeof(tIndexTs));
2599 delta =
sizeof(tIndexTs) - delta;
2600 esyslog(
"ERROR: invalid file size (%" PRId64
") in '%s'", buf.st_size, *
fileName);
2602 last = int((buf.st_size + delta) /
sizeof(tIndexTs) - 1);
2603 if ((!Record || Update) &&
last >= 0) {
2628 esyslog(
"ERROR: can't allocate %zd bytes for index '%s'",
size *
sizeof(tIndexTs), *
fileName);
2640 if ((
f = open(
fileName, O_WRONLY | O_CREAT | O_APPEND, DEFFILEMODE)) >= 0) {
2642 esyslog(
"ERROR: padding index file with %d '0' bytes", delta);
2669 while (Count-- > 0) {
2670 memcpy(&IndexPes, IndexTs,
sizeof(IndexPes));
2671 IndexTs->offset = IndexPes.offset;
2672 IndexTs->independent = IndexPes.type == 1;
2673 IndexTs->number = IndexPes.number;
2681 while (Count-- > 0) {
2682 IndexPes.offset = uint32_t(IndexTs->offset);
2683 IndexPes.type =
uchar(IndexTs->independent ? 1 : 2);
2684 IndexPes.number =
uchar(IndexTs->number);
2685 IndexPes.reserved = 0;
2686 memcpy((
void *)IndexTs, &IndexPes,
sizeof(*IndexTs));
2700 if (fstat(
f, &buf) == 0) {
2701 int newLast = int(buf.st_size /
sizeof(tIndexTs) - 1);
2702 if (newLast >
last) {
2704 if (NewSize <= newLast) {
2706 if (NewSize <= newLast)
2707 NewSize = newLast + 1;
2709 if (tIndexTs *NewBuffer = (tIndexTs *)realloc(
index, NewSize *
sizeof(tIndexTs))) {
2712 int offset = (
last + 1) *
sizeof(tIndexTs);
2713 int delta = (newLast -
last) *
sizeof(tIndexTs);
2714 if (lseek(
f, offset, SEEK_SET) == offset) {
2716 esyslog(
"ERROR: can't read from index");
2731 esyslog(
"ERROR: can't realloc() index");
2744 return index != NULL;
2750 tIndexTs i(FileOffset, Independent, FileNumber);
2764bool cIndexFile::Get(
int Index, uint16_t *FileNumber, off_t *FileOffset,
bool *Independent,
int *Length)
2767 if (Index >= 0 && Index <=
last) {
2768 *FileNumber =
index[Index].number;
2769 *FileOffset =
index[Index].offset;
2771 *Independent =
index[Index].independent;
2774 uint16_t fn =
index[Index + 1].number;
2775 off_t fo =
index[Index + 1].offset;
2776 if (fn == *FileNumber)
2777 *Length = int(fo - *FileOffset);
2793 int d = Forward ? 1 : -1;
2796 if (Index >= 0 && Index <=
last) {
2797 if (
index[Index].independent) {
2804 *FileNumber =
index[Index].number;
2805 *FileOffset =
index[Index].offset;
2808 uint16_t fn =
index[Index + 1].number;
2809 off_t fo =
index[Index + 1].offset;
2810 if (fn == *FileNumber)
2811 *Length = int(fo - *FileOffset);
2832 if (
index[Index].independent)
2838 if (
index[il].independent)
2845 if (
index[ih].independent)
2861 for (i = 0; i <=
last; i++) {
2862 if (
index[i].number > FileNumber || (
index[i].number == FileNumber) && off_t(
index[i].offset) >= FileOffset)
2891 if (*s && stat(s, &buf) == 0)
2892 return buf.st_size / (IsPesRecording ?
sizeof(tIndexTs) :
sizeof(tIndexPes));
2900 if (Recording.
Name()) {
2904 unlink(IndexFileName);
2906 while (IndexFileGenerator->
Active())
2908 if (access(IndexFileName, R_OK) == 0)
2911 fprintf(stderr,
"cannot create '%s'\n", *IndexFileName);
2914 fprintf(stderr,
"'%s' is not a TS recording\n", FileName);
2917 fprintf(stderr,
"'%s' is not a recording\n", FileName);
2920 fprintf(stderr,
"'%s' is not a directory\n", FileName);
2926#define MAXFILESPERRECORDINGPES 255
2927#define RECORDFILESUFFIXPES "/%03d.vdr"
2928#define MAXFILESPERRECORDINGTS 65535
2929#define RECORDFILESUFFIXTS "/%05d.ts"
2930#define RECORDFILESUFFIXLEN 20
2942 esyslog(
"ERROR: can't copy file name '%s'", FileName);
2972 int fd = open(
fileName, O_RDONLY | O_LARGEFILE, DEFFILEMODE);
2974 off_t pos = lseek(fd, -
TS_SIZE, SEEK_END);
2978 while (read(fd, buf,
sizeof(buf)) ==
sizeof(buf)) {
2980 int Pid =
TsPid(buf);
2982 PatPmtParser.
ParsePat(buf,
sizeof(buf));
2983 else if (PatPmtParser.
IsPmtPid(Pid)) {
2984 PatPmtParser.
ParsePmt(buf,
sizeof(buf));
2985 if (PatPmtParser.
GetVersions(PatVersion, PmtVersion)) {
2996 pos = lseek(fd, pos -
TS_SIZE, SEEK_SET);
3010 int BlockingFlag =
blocking ? 0 : O_NONBLOCK;
3024 else if (errno != ENOENT)
3054 if (buf.st_size != 0)
3058 dsyslog(
"cFileName::SetOffset: removing zero-sized file %s",
fileName);
3065 else if (errno != ENOENT) {
3072 if (!
record && Offset >= 0 &&
file->
Seek(Offset, SEEK_SET) != Offset) {
3079 esyslog(
"ERROR: max number of files (%d) exceeded", MaxFilesPerRecording);
3101 while ((s = ReadLine.
Read(f)) != NULL)
3119 if (fputs(
doneRecordings[i], f) == EOF || fputc(
'\n', f) == EOF) {
3141 if (FILE *f = fopen(
fileName,
"a")) {
3147 esyslog(
"ERROR: can't open '%s' for appending '%s'", *
fileName, Title);
3164 const char *t = Title;
3170 if (toupper(
uchar(*s)) != toupper(
uchar(*t)))
3185 const char *Sign =
"";
3191 int f = int(modf((Index + 0.5) / FramesPerSecond, &Seconds) * FramesPerSecond);
3192 int s = int(Seconds);
3193 int m = s / 60 % 60;
3196 return cString::sprintf(WithFrame ?
"%s%d:%02d:%02d.%02d" :
"%s%d:%02d:%02d", Sign, h, m, s, f);
3202 int n = sscanf(HMSF,
"%d:%d:%d.%d", &h, &m, &s, &f);
3206 return int(round((h * 3600 + m * 60 + s) * FramesPerSecond)) + f;
3212 return int(round(Seconds * FramesPerSecond));
3221 else if (Length > Max) {
3222 esyslog(
"ERROR: frame larger than buffer (%d > %d)", Length, Max);
3225 int r = f->
Read(b, Length);
3245 if (fgets(buf,
sizeof(buf), f))
3274 dsyslog(
"writing timer id '%s' to %s", TimerId, *FileName);
3275 if (FILE *f = fopen(FileName,
"w")) {
3276 fprintf(f,
"%s\n", TimerId);
3283 dsyslog(
"removing %s", *FileName);
3291 const char *Id = NULL;
3292 if (FILE *f = fopen(FileName,
"r")) {
3293 char buf[HOST_NAME_MAX + 10];
3294 if (fgets(buf,
sizeof(buf), f)) {
const char * Slang(int i) const
const char * Name(void) const
tChannelID GetChannelID(void) const
const char * Dlang(int i) const
const char * Alang(int i) const
tComponent * GetComponent(int Index, uchar Stream, uchar Type)
int NumComponents(void) const
void SetComponent(int Index, const char *s)
bool TimedWait(cMutex &Mutex, int TimeoutMs)
static void SleepMs(int TimeoutMs)
Creates a cCondWait object and uses it to sleep for TimeoutMs milliseconds, immediately giving up the...
bool Start(void)
Starts the actual cutting process.
bool Error(void)
Returns true if an error occurred while cutting the recording.
bool Active(void)
Returns true if the cutter is currently active.
static cString EditedFileName(const char *FileName)
Returns the full path name of the edited version of the recording with the given FileName.
cDirCopier(const char *DirNameSrc, const char *DirNameDst)
virtual void Action(void)
A derived cThread class must implement the code it wants to execute as a separate thread in this func...
cStringList doneRecordings
void Add(const char *Title)
void Append(const char *Title)
bool Load(const char *FileName)
bool Contains(const char *Title) const
const char * ShortText(void) const
const cComponents * Components(void) const
const char * Title(void) const
void SetStartTime(time_t StartTime)
void SetEventID(tEventID EventID)
void SetVersion(uchar Version)
void SetDuration(int Duration)
void SetTitle(const char *Title)
void SetTableID(uchar TableID)
cUnbufferedFile * NextFile(void)
cUnbufferedFile * Open(void)
cFileName(const char *FileName, bool Record, bool Blocking=false, bool IsPesRecording=false)
bool GetLastPatPmtVersions(int &PatVersion, int &PmtVersion)
cUnbufferedFile * SetOffset(int Number, off_t Offset=0)
bool Synced(void)
Returns true if the frame detector has synced on the data stream.
bool IndependentFrame(void)
Returns true if a new frame was detected and this is an independent frame (i.e.
double FramesPerSecond(void)
Returns the number of frames per second, or 0 if this information is not available.
int Analyze(const uchar *Data, int Length)
Analyzes the TS packets pointed to by Data.
void SetPid(int Pid, int Type)
Sets the Pid and stream Type to detect frames for.
bool NewFrame(void)
Returns true if the data given to the last call to Analyze() started a new frame.
cIndexFileGenerator(const char *RecordingName, bool Update=false)
virtual void Action(void)
A derived cThread class must implement the code it wants to execute as a separate thread in this func...
int GetNextIFrame(int Index, bool Forward, uint16_t *FileNumber=NULL, off_t *FileOffset=NULL, int *Length=NULL)
bool IsStillRecording(void)
void ConvertFromPes(tIndexTs *IndexTs, int Count)
bool Write(bool Independent, uint16_t FileNumber, off_t FileOffset)
static int GetLength(const char *FileName, bool IsPesRecording=false)
Calculates the recording length (number of frames) without actually reading the index file.
bool CatchUp(int Index=-1)
void ConvertToPes(tIndexTs *IndexTs, int Count)
cIndexFile(const char *FileName, bool Record, bool IsPesRecording=false, bool PauseLive=false, bool Update=false)
cIndexFileGenerator * indexFileGenerator
static cString IndexFileName(const char *FileName, bool IsPesRecording)
bool Get(int Index, uint16_t *FileNumber, off_t *FileOffset, bool *Independent=NULL, int *Length=NULL)
int GetClosestIFrame(int Index)
Returns the index of the I-frame that is closest to the given Index (or Index itself,...
int Last(void)
Returns the index of the last entry in this file, or -1 if the file is empty.
static bool Engaged(void)
Returns true if any I/O throttling object is currently active.
void Del(cListObject *Object, bool DeleteObject=true)
bool Lock(cStateKey &StateKey, bool Write=false, int TimeoutMs=0) const
Tries to get a lock on this list and returns true if successful.
void Add(cListObject *Object, cListObject *After=NULL)
cListObject * Next(void) const
const T * Prev(const T *Object) const
const T * First(void) const
Returns the first element in this list, or NULL if the list is empty.
const T * Next(const T *Object) const
< Returns the element immediately before Object in this list, or NULL if Object is the first element ...
const T * Last(void) const
Returns the last element in this list, or NULL if the list is empty.
bool Lock(int WaitSeconds=0)
cMark(int Position=0, const char *Comment=NULL, double FramesPerSecond=DEFAULTFRAMESPERSECOND)
bool Parse(const char *s)
const char * Comment(void) const
int GetNumSequences(void) const
Returns the actual number of sequences to be cut from the recording.
void Add(int Position)
If this cMarks object is used by multiple threads, the caller must Lock() it before calling Add() and...
const cMark * GetNextBegin(const cMark *EndMark=NULL) const
Returns the next "begin" mark after EndMark, skipping any marks at the same position as EndMark.
const cMark * GetNext(int Position) const
bool Load(const char *RecordingFileName, double FramesPerSecond=DEFAULTFRAMESPERSECOND, bool IsPesRecording=false)
const cMark * GetNextEnd(const cMark *BeginMark) const
Returns the next "end" mark after BeginMark, skipping any marks at the same position as BeginMark.
const cMark * Get(int Position) const
cString recordingFileName
static bool DeleteMarksFile(const cRecording *Recording)
static cString MarksFileName(const cRecording *Recording)
Returns the marks file name for the given Recording (regardless whether such a file actually exists).
const cMark * GetPrev(int Position) const
bool GetVersions(int &PatVersion, int &PmtVersion) const
Returns true if a valid PAT/PMT has been parsed and stores the current version numbers in the given v...
int Vtype(void) const
Returns the video stream type as defined by the current PMT, or 0 if no video stream type has been de...
void ParsePat(const uchar *Data, int Length)
Parses the PAT data from the single TS packet in Data.
void ParsePmt(const uchar *Data, int Length)
Parses the PMT data from the single TS packet in Data.
bool Completed(void)
Returns true if the PMT has been completely parsed.
bool IsPmtPid(int Pid) const
Returns true if Pid the one of the PMT pids as defined by the current PAT.
int Vpid(void) const
Returns the video pid as defined by the current PMT, or 0 if no video pid has been detected,...
struct dirent * Next(void)
static cRecordControl * GetRecordControl(const char *FileName)
void SetFramesPerSecond(double FramesPerSecond)
const char * ShortText(void) const
cRecordingInfo(const cChannel *Channel=NULL, const cEvent *Event=NULL)
bool Write(FILE *f, const char *Prefix="") const
const char * Title(void) const
const char * Aux(void) const
void SetFileName(const char *FileName)
void SetErrors(int Errors)
void SetAux(const char *Aux)
void SetData(const char *Title, const char *ShortText, const char *Description)
const char * Description(void) const
double FramesPerSecond(void) const
const cComponents * Components(void) const
static const char * command
static void InvokeCommand(const char *State, const char *RecordingFileName, const char *SourceFileName=NULL)
int isOnVideoDirectoryFileSystem
virtual int Compare(const cListObject &ListObject) const
Must return 0 if this object is equal to ListObject, a positive value if it is "greater",...
bool ChangePriorityLifetime(int NewPriority, int NewLifetime)
Changes the priority and lifetime of this recording to the given values.
bool HasMarks(void) const
Returns true if this recording has any editing marks.
bool WriteInfo(const char *OtherFileName=NULL)
Writes in info file of this recording.
int IsInUse(void) const
Checks whether this recording is currently in use and therefore shall not be tampered with.
bool ChangeName(const char *NewName)
Changes the name of this recording to the given value.
bool Undelete(void)
Changes the file name so that it will be visible in the "Recordings" menu again and not processed by ...
void ResetResume(void) const
bool Delete(void)
Changes the file name so that it will no longer be visible in the "Recordings" menu Returns false in ...
cString Folder(void) const
Returns the name of the folder this recording is stored in (without the video directory).
int NumFrames(void) const
Returns the number of frames in this recording.
bool IsEdited(void) const
int GetResume(void) const
Returns the index of the frame where replay of this recording shall be resumed, or -1 in case of an e...
bool IsInPath(const char *Path) const
Returns true if this recording is stored anywhere under the given Path.
void SetStartTime(time_t Start)
Sets the start time of this recording to the given value.
char * SortName(void) const
const char * Name(void) const
Returns the full name of the recording (without the video directory).
const char * FileName(void) const
Returns the full path name to the recording directory, including the video directory and the actual '...
const char * PrefixFileName(char Prefix)
bool DeleteMarks(void)
Deletes the editing marks from this recording (if any).
bool IsOnVideoDirectoryFileSystem(void) const
int HierarchyLevels(void) const
int FileSizeMB(void) const
Returns the total file size of this recording (in MB), or -1 if the file size is unknown.
cString BaseName(void) const
Returns the base name of this recording (without the video directory and folder).
const char * Title(char Delimiter=' ', bool NewIndicator=false, int Level=-1) const
bool Remove(void)
Actually removes the file from the disk Returns false in case of error.
cRecording(const cRecording &)
double FramesPerSecond(void) const
bool IsPesRecording(void) const
static char * StripEpisodeName(char *s, bool Strip)
int LengthInSeconds(void) const
Returns the length (in seconds) of this recording, or -1 in case of error.
const char * FileNameSrc(void) const
~cRecordingsHandlerEntry()
int Usage(const char *FileName=NULL) const
const char * FileNameDst(void) const
cRecordingsHandlerEntry(int Usage, const char *FileNameSrc, const char *FileNameDst)
void DelAll(void)
Deletes/terminates all operations.
cRecordingsHandlerEntry * Get(const char *FileName)
bool Add(int Usage, const char *FileNameSrc, const char *FileNameDst=NULL)
Adds the given FileNameSrc to the recordings handler for (later) processing.
bool Finished(bool &Error)
Returns true if all operations in the list have been finished.
virtual void Action(void)
A derived cThread class must implement the code it wants to execute as a separate thread in this func...
int GetUsage(const char *FileName)
Returns the usage type for the given FileName.
cList< cRecordingsHandlerEntry > operations
void Del(const char *FileName)
Deletes the given FileName from the list of operations.
virtual ~cRecordingsHandler()
void ResetResume(const char *ResumeFileName=NULL)
void UpdateByName(const char *FileName)
static const char * UpdateFileName(void)
double MBperMinute(void) const
Returns the average data rate (in MB/min) of all recordings, or -1 if this value is unknown.
cRecordings(bool Deleted=false)
int GetNumRecordingsInPath(const char *Path) const
Returns the total number of recordings in the given Path, including all sub-folders of Path.
const cRecording * GetById(int Id) const
static cRecordings deletedRecordings
void AddByName(const char *FileName, bool TriggerUpdate=true)
static cRecordings recordings
int TotalFileSizeMB(void) const
static void Update(bool Wait=false)
Triggers an update of the list of recordings, which will run as a separate thread if Wait is false.
static void TouchUpdate(void)
Touches the '.update' file in the video directory, so that other instances of VDR that access the sam...
void Add(cRecording *Recording)
static cVideoDirectoryScannerThread * videoDirectoryScannerThread
void DelByName(const char *FileName)
bool MoveRecordings(const char *OldPath, const char *NewPath)
Moves all recordings in OldPath to NewPath.
static bool NeedsUpdate(void)
void ClearSortNames(void)
static int lastRecordingId
const cRecording * GetByName(const char *FileName) const
static char * updateFileName
int PathIsInUse(const char *Path) const
Checks whether any recording in the given Path is currently in use and therefore the whole Path shall...
static bool HasKeys(void)
virtual void Action(void)
A derived cThread class must implement the code it wants to execute as a separate thread in this func...
cRemoveDeletedRecordingsThread(void)
static const char * NowReplaying(void)
cResumeFile(const char *FileName, bool IsPesRecording)
void Del(int Count)
Deletes at most Count bytes from the ring buffer.
int Put(const uchar *Data, int Count)
Puts at most Count bytes of Data into the ring buffer.
virtual int Available(void)
virtual void Clear(void)
Immediately clears the ring buffer.
uchar * Get(int &Count)
Gets data from the ring buffer.
int Read(int FileHandle, int Max=0)
Reads at most Max bytes from FileHandle and stores them in the ring buffer.
int AlwaysSortFoldersFirst
char SVDRPHostName[HOST_NAME_MAX]
int QueueMessage(eMessageType Type, const char *s, int Seconds=0, int Timeout=0)
Like Message(), but this function may be called from a background thread.
void Remove(bool IncState=true)
Removes this key from the lock it was previously used with.
static cString sprintf(const char *fmt,...) __attribute__((format(printf
void bool Start(void)
Sets the description of this thread, which will be used when logging starting or stopping of the thre...
bool Running(void)
Returns false if a derived cThread object shall leave its Action() function.
void Cancel(int WaitSeconds=0)
Cancels the thread by first setting 'running' to false, so that the Action() loop can finish in an or...
bool Active(void)
Checks whether the thread is still alive.
const char * Aux(void) const
const char * File(void) const
bool IsSingleEvent(void) const
void SetFile(const char *File)
time_t StartTime(void) const
the start time as given by the user
const cChannel * Channel(void) const
cUnbufferedFile is used for large files that are mainly written or read in a streaming manner,...
static cUnbufferedFile * Create(const char *FileName, int Flags, mode_t Mode=DEFFILEMODE)
ssize_t Read(void *Data, size_t Size)
off_t Seek(off_t Offset, int Whence)
virtual void Append(T Data)
cRecordings * deletedRecordings
void ScanVideoDir(const char *DirName, int LinkLevel=0, int DirLevel=0)
~cVideoDirectoryScannerThread()
cVideoDirectoryScannerThread(cRecordings *Recordings, cRecordings *DeletedRecordings)
virtual void Action(void)
A derived cThread class must implement the code it wants to execute as a separate thread in this func...
static cString PrefixVideoFileName(const char *FileName, char Prefix)
static void RemoveEmptyVideoDirectories(const char *IgnoreFiles[]=NULL)
static bool IsOnVideoDirectoryFileSystem(const char *FileName)
static const char * Name(void)
static cUnbufferedFile * OpenVideoFile(const char *FileName, int Flags)
static bool VideoFileSpaceAvailable(int SizeMB)
static bool MoveVideoFile(const char *FromName, const char *ToName)
static bool RenameVideoFile(const char *OldName, const char *NewName)
static bool RemoveVideoFile(const char *FileName)
#define TIMERMACRO_EPISODE
#define MAXFILESPERRECORDINGTS
tCharExchange CharExchange[]
cString GetRecordingTimerId(const char *Directory)
bool GenerateIndex(const char *FileName, bool Update)
Generates the index of the existing recording with the given FileName.
cString IndexToHMSF(int Index, bool WithFrame, double FramesPerSecond)
static const char * SkipFuzzyChars(const char *s)
void AssertFreeDiskSpace(int Priority, bool Force)
The special Priority value -1 means that we shall get rid of any deleted recordings faster than norma...
void GetRecordingsSortMode(const char *Directory)
char * LimitNameLengths(char *s, int PathMax, int NameMax)
static const char * FuzzyChars
bool NeedsConversion(const char *p)
int SecondsToFrames(int Seconds, double FramesPerSecond)
eRecordingsSortMode RecordingsSortMode
bool HasRecordingsSortMode(const char *Directory)
#define MAXFILESPERRECORDINGPES
#define INDEXFILETESTINTERVAL
#define MAXWAITFORINDEXFILE
#define INDEXFILECHECKINTERVAL
char * ExchangeChars(char *s, bool ToFileSystem)
void IncRecordingsSortMode(const char *Directory)
int HMSFToIndex(const char *HMSF, double FramesPerSecond)
#define LIMIT_SECS_PER_MB_RADIO
void SetRecordingsSortMode(const char *Directory, eRecordingsSortMode SortMode)
cDoneRecordings DoneRecordingsPattern
static cRemoveDeletedRecordingsThread RemoveDeletedRecordingsThread
int ReadFrame(cUnbufferedFile *f, uchar *b, int Length, int Max)
cRecordingsHandler RecordingsHandler
cMutex MutexMarkFramesPerSecond
static bool StillRecording(const char *Directory)
struct __attribute__((packed))
#define RESUME_NOT_INITIALIZED
#define RECORDFILESUFFIXLEN
#define RECORDFILESUFFIXPES
void SetRecordingTimerId(const char *Directory, const char *TimerId)
#define RECORDFILESUFFIXTS
double MarkFramesPerSecond
const char * InvalidChars
void RemoveDeletedRecordings(void)
#define SUMMARYFILESUFFIX
#define DEFAULTFRAMESPERSECOND
int HMSFToIndex(const char *HMSF, double FramesPerSecond=DEFAULTFRAMESPERSECOND)
eRecordingsSortMode RecordingsSortMode
#define RUC_COPIEDRECORDING
#define LOCK_DELETEDRECORDINGS_WRITE
char * ExchangeChars(char *s, bool ToFileSystem)
#define RUC_DELETERECORDING
#define RUC_MOVEDRECORDING
cRecordingsHandler RecordingsHandler
#define RUC_COPYINGRECORDING
#define LOCK_DELETEDRECORDINGS_READ
#define LOCK_RECORDINGS_WRITE
cString IndexToHMSF(int Index, bool WithFrame=false, double FramesPerSecond=DEFAULTFRAMESPERSECOND)
int TsPid(const uchar *p)
#define MIN_TS_PACKETS_FOR_FRAME_DETECTOR
static const tChannelID InvalidID
static tChannelID FromString(const char *s)
cString ToString(void) const
char language[MAXLANGCODE2]
int SystemExec(const char *Command, bool Detached)