2002-06-16 12:57:31 +02:00
|
|
|
/*
|
2002-12-22 11:33:08 +01:00
|
|
|
* recorder.c: The actual DVB recorder
|
2002-06-16 12:57:31 +02:00
|
|
|
*
|
|
|
|
* See the main source file 'vdr.c' for copyright information and
|
|
|
|
* how to reach the author.
|
|
|
|
*
|
2011-09-04 10:13:14 +02:00
|
|
|
* $Id: recorder.c 2.15 2011/09/04 09:26:44 kls Exp $
|
2002-06-16 12:57:31 +02:00
|
|
|
*/
|
|
|
|
|
2006-01-08 11:03:44 +01:00
|
|
|
#include "recorder.h"
|
2007-02-25 10:56:29 +01:00
|
|
|
#include "shutdown.h"
|
2002-06-16 12:57:31 +02:00
|
|
|
|
2011-08-07 13:49:32 +02:00
|
|
|
#define RECORDERBUFSIZE (MEGABYTE(5) / TS_SIZE * TS_SIZE) // multiple of TS_SIZE
|
2002-06-16 12:57:31 +02:00
|
|
|
|
2003-05-16 13:36:06 +02:00
|
|
|
// The maximum time we wait before assuming that a recorded video data stream
|
|
|
|
// is broken:
|
|
|
|
#define MAXBROKENTIMEOUT 30 // seconds
|
|
|
|
|
2002-06-16 12:57:31 +02:00
|
|
|
#define MINFREEDISKSPACE (512) // MB
|
|
|
|
#define DISKCHECKINTERVAL 100 // seconds
|
|
|
|
|
2009-01-06 14:41:11 +01:00
|
|
|
// --- cRecorder -------------------------------------------------------------
|
2004-10-16 09:36:28 +02:00
|
|
|
|
2010-01-30 11:10:25 +01:00
|
|
|
cRecorder::cRecorder(const char *FileName, const cChannel *Channel, int Priority)
|
|
|
|
:cReceiver(Channel, Priority)
|
2009-01-06 14:41:11 +01:00
|
|
|
,cThread("recording")
|
2002-06-16 12:57:31 +02:00
|
|
|
{
|
2010-12-27 12:25:19 +01:00
|
|
|
recordingName = strdup(FileName);
|
|
|
|
|
2009-01-06 14:41:11 +01:00
|
|
|
// Make sure the disk is up and running:
|
|
|
|
|
|
|
|
SpinUpDisk(FileName);
|
|
|
|
|
2011-09-04 10:13:14 +02:00
|
|
|
ringBuffer = new cRingBufferLinear(RECORDERBUFSIZE, MIN_TS_PACKETS_FOR_FRAME_DETECTOR * TS_SIZE, true, "Recorder");
|
2009-01-06 14:41:11 +01:00
|
|
|
ringBuffer->SetTimeouts(0, 100);
|
2010-01-30 11:10:25 +01:00
|
|
|
|
|
|
|
int Pid = Channel->Vpid();
|
|
|
|
int Type = Channel->Vtype();
|
|
|
|
if (!Pid && Channel->Apid(0)) {
|
|
|
|
Pid = Channel->Apid(0);
|
2009-01-06 14:41:11 +01:00
|
|
|
Type = 0x04;
|
|
|
|
}
|
2010-01-30 11:10:25 +01:00
|
|
|
if (!Pid && Channel->Dpid(0)) {
|
|
|
|
Pid = Channel->Dpid(0);
|
2009-01-06 14:41:11 +01:00
|
|
|
Type = 0x06;
|
|
|
|
}
|
|
|
|
frameDetector = new cFrameDetector(Pid, Type);
|
2002-06-16 12:57:31 +02:00
|
|
|
index = NULL;
|
|
|
|
fileSize = 0;
|
|
|
|
lastDiskSpaceCheck = time(NULL);
|
|
|
|
fileName = new cFileName(FileName, true);
|
2009-05-24 15:11:28 +02:00
|
|
|
int PatVersion, PmtVersion;
|
|
|
|
if (fileName->GetLastPatPmtVersions(PatVersion, PmtVersion))
|
|
|
|
patPmtGenerator.SetVersions(PatVersion + 1, PmtVersion + 1);
|
|
|
|
patPmtGenerator.SetChannel(Channel);
|
2002-06-16 12:57:31 +02:00
|
|
|
recordFile = fileName->Open();
|
2005-10-31 13:14:26 +01:00
|
|
|
if (!recordFile)
|
2002-06-16 12:57:31 +02:00
|
|
|
return;
|
|
|
|
// Create the index file:
|
|
|
|
index = new cIndexFile(FileName, true);
|
|
|
|
if (!index)
|
|
|
|
esyslog("ERROR: can't allocate index");
|
|
|
|
// let's continue without index, so we'll at least have the recording
|
|
|
|
}
|
|
|
|
|
2009-01-06 14:41:11 +01:00
|
|
|
cRecorder::~cRecorder()
|
2002-06-16 12:57:31 +02:00
|
|
|
{
|
2009-01-06 14:41:11 +01:00
|
|
|
Detach();
|
2002-06-16 12:57:31 +02:00
|
|
|
delete index;
|
|
|
|
delete fileName;
|
2009-01-06 14:41:11 +01:00
|
|
|
delete frameDetector;
|
|
|
|
delete ringBuffer;
|
2010-12-27 12:25:19 +01:00
|
|
|
free(recordingName);
|
2002-06-16 12:57:31 +02:00
|
|
|
}
|
|
|
|
|
2009-01-06 14:41:11 +01:00
|
|
|
bool cRecorder::RunningLowOnDiskSpace(void)
|
2002-06-16 12:57:31 +02:00
|
|
|
{
|
|
|
|
if (time(NULL) > lastDiskSpaceCheck + DISKCHECKINTERVAL) {
|
|
|
|
int Free = FreeDiskSpaceMB(fileName->Name());
|
|
|
|
lastDiskSpaceCheck = time(NULL);
|
|
|
|
if (Free < MINFREEDISKSPACE) {
|
|
|
|
dsyslog("low disk space (%d MB, limit is %d MB)", Free, MINFREEDISKSPACE);
|
|
|
|
return true;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
return false;
|
|
|
|
}
|
|
|
|
|
2009-01-06 14:41:11 +01:00
|
|
|
bool cRecorder::NextFile(void)
|
2002-06-16 12:57:31 +02:00
|
|
|
{
|
2011-09-04 10:13:14 +02:00
|
|
|
if (recordFile && frameDetector->IndependentFrame()) { // every file shall start with an independent frame
|
2009-01-06 14:41:11 +01:00
|
|
|
if (fileSize > MEGABYTE(off_t(Setup.MaxVideoFileSize)) || RunningLowOnDiskSpace()) {
|
2002-06-16 12:57:31 +02:00
|
|
|
recordFile = fileName->NextFile();
|
|
|
|
fileSize = 0;
|
|
|
|
}
|
|
|
|
}
|
2005-10-31 13:14:26 +01:00
|
|
|
return recordFile != NULL;
|
2002-06-16 12:57:31 +02:00
|
|
|
}
|
|
|
|
|
2004-10-16 09:36:28 +02:00
|
|
|
void cRecorder::Activate(bool On)
|
|
|
|
{
|
2009-01-06 14:41:11 +01:00
|
|
|
if (On)
|
2004-10-16 09:36:28 +02:00
|
|
|
Start();
|
2005-08-13 13:17:24 +02:00
|
|
|
else
|
2004-10-16 09:36:28 +02:00
|
|
|
Cancel(3);
|
|
|
|
}
|
|
|
|
|
|
|
|
void cRecorder::Receive(uchar *Data, int Length)
|
|
|
|
{
|
2005-08-14 11:24:57 +02:00
|
|
|
if (Running()) {
|
2004-10-16 09:36:28 +02:00
|
|
|
int p = ringBuffer->Put(Data, Length);
|
2005-08-14 11:24:57 +02:00
|
|
|
if (p != Length && Running())
|
2004-10-16 09:36:28 +02:00
|
|
|
ringBuffer->ReportOverflow(Length - p);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
void cRecorder::Action(void)
|
|
|
|
{
|
2009-01-06 14:41:11 +01:00
|
|
|
time_t t = time(NULL);
|
|
|
|
bool InfoWritten = false;
|
2009-11-15 15:33:55 +01:00
|
|
|
bool FirstIframeSeen = false;
|
2005-08-14 11:24:57 +02:00
|
|
|
while (Running()) {
|
2004-10-16 09:36:28 +02:00
|
|
|
int r;
|
|
|
|
uchar *b = ringBuffer->Get(r);
|
|
|
|
if (b) {
|
2009-01-06 14:41:11 +01:00
|
|
|
int Count = frameDetector->Analyze(b, r);
|
|
|
|
if (Count) {
|
|
|
|
if (!Running() && frameDetector->IndependentFrame()) // finish the recording before the next independent frame
|
|
|
|
break;
|
2009-03-27 13:38:59 +01:00
|
|
|
if (frameDetector->Synced()) {
|
2009-01-06 14:41:11 +01:00
|
|
|
if (!InfoWritten) {
|
2010-12-27 12:25:19 +01:00
|
|
|
cRecordingInfo RecordingInfo(recordingName);
|
|
|
|
if (RecordingInfo.Read()) {
|
2011-06-12 14:24:09 +02:00
|
|
|
if (frameDetector->FramesPerSecond() > 0 && DoubleEqual(RecordingInfo.FramesPerSecond(), DEFAULTFRAMESPERSECOND) && !DoubleEqual(RecordingInfo.FramesPerSecond(), frameDetector->FramesPerSecond())) {
|
2010-12-27 12:25:19 +01:00
|
|
|
RecordingInfo.SetFramesPerSecond(frameDetector->FramesPerSecond());
|
|
|
|
RecordingInfo.Write();
|
|
|
|
Recordings.UpdateByName(recordingName);
|
2009-01-06 14:41:11 +01:00
|
|
|
}
|
|
|
|
}
|
|
|
|
InfoWritten = true;
|
|
|
|
}
|
2011-09-04 10:13:14 +02:00
|
|
|
if (FirstIframeSeen || frameDetector->IndependentFrame()) {
|
2009-11-15 15:33:55 +01:00
|
|
|
FirstIframeSeen = true; // start recording with the first I-frame
|
2011-09-04 10:13:14 +02:00
|
|
|
if (!NextFile())
|
2009-11-15 15:33:55 +01:00
|
|
|
break;
|
|
|
|
if (index && frameDetector->NewFrame())
|
2011-08-07 13:49:32 +02:00
|
|
|
index->Write(frameDetector->IndependentFrame(), fileName->Number(), fileSize);
|
2009-11-15 15:33:55 +01:00
|
|
|
if (frameDetector->IndependentFrame()) {
|
|
|
|
recordFile->Write(patPmtGenerator.GetPat(), TS_SIZE);
|
|
|
|
fileSize += TS_SIZE;
|
|
|
|
int Index = 0;
|
|
|
|
while (uchar *pmt = patPmtGenerator.GetPmt(Index)) {
|
|
|
|
recordFile->Write(pmt, TS_SIZE);
|
|
|
|
fileSize += TS_SIZE;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
if (recordFile->Write(b, Count) < 0) {
|
|
|
|
LOG_ERROR_STR(fileName->Name());
|
|
|
|
break;
|
|
|
|
}
|
|
|
|
fileSize += Count;
|
|
|
|
t = time(NULL);
|
2009-01-06 14:41:11 +01:00
|
|
|
}
|
|
|
|
}
|
2004-10-16 09:36:28 +02:00
|
|
|
ringBuffer->Del(Count);
|
2009-01-06 14:41:11 +01:00
|
|
|
}
|
|
|
|
}
|
|
|
|
if (time(NULL) - t > MAXBROKENTIMEOUT) {
|
|
|
|
esyslog("ERROR: video data stream broken");
|
|
|
|
ShutdownHandler.RequestEmergencyExit();
|
|
|
|
t = time(NULL);
|
2004-10-16 09:36:28 +02:00
|
|
|
}
|
2002-06-16 12:57:31 +02:00
|
|
|
}
|
|
|
|
}
|