summaryrefslogtreecommitdiff
path: root/status.c
diff options
context:
space:
mode:
Diffstat (limited to 'status.c')
-rw-r--r--status.c272
1 files changed, 272 insertions, 0 deletions
diff --git a/status.c b/status.c
new file mode 100644
index 0000000..e58d641
--- /dev/null
+++ b/status.c
@@ -0,0 +1,272 @@
+/*
+ * status.c: EPG2VDR plugin for the Video Disk Recorder
+ *
+ * See the README file for copyright information and how to reach the author.
+ *
+ */
+
+#include <vdr/tools.h>
+
+#include "update.h"
+#include "ttools.h"
+
+//***************************************************************************
+// ----> Copied from epgsearch ;-)
+//***************************************************************************
+
+#define LOC_INDEXFILESUFFIX "/index"
+
+bool IsPesRecording(const cRecording *pRecording)
+{
+#if VDRVERSNUM < 10703
+ return true;
+#else
+ return pRecording && pRecording->IsPesRecording();
+#endif
+}
+
+#if VDRVERSNUM < 10703
+
+int RecLengthInSecs(const cRecording* pRecording)
+{
+ struct stat buf;
+ cString fullname = cString::sprintf("%s%s", pRecording->FileName(), "/index.vdr");
+
+ if (stat(fullname, &buf) == 0)
+ {
+ struct tIndex { int offset; uchar type; uchar number; short reserved; };
+ int delta = buf.st_size % sizeof(tIndex);
+
+ if (delta)
+ {
+ delta = sizeof(tIndex) - delta;
+ tell(0, "ERROR: invalid file size (%ld) in '%s'", buf.st_size, *fullname);
+ }
+
+ return (buf.st_size + delta) / sizeof(tIndex) / SecondsToFrames(1);
+ }
+
+ return -1;
+}
+
+#else
+
+struct tIndexTs
+{
+ uint64_t offset:40; // up to 1TB per file (not using off_t here - must definitely be exactly 64 bit!)
+ int reserved:7; // reserved for future use
+ int independent:1; // marks frames that can be displayed by themselves (for trick modes)
+ uint16_t number:16; // up to 64K files per recording
+
+ tIndexTs(off_t Offset, bool Independent, uint16_t Number)
+ {
+ offset = Offset;
+ reserved = 0;
+ independent = Independent;
+ number = Number;
+ }
+};
+
+int RecLengthInSecs(const cRecording *pRecording)
+{
+ struct stat buf;
+ cString fullname = cString::sprintf("%s%s", pRecording->FileName(), IsPesRecording(pRecording) ? LOC_INDEXFILESUFFIX ".vdr" : LOC_INDEXFILESUFFIX);
+
+ if (pRecording->FileName() && *fullname && access(fullname, R_OK) == 0 && stat(fullname, &buf) == 0)
+ {
+ double frames = buf.st_size ? (buf.st_size - 1) / sizeof(tIndexTs) + 1 : 0;
+ double Seconds = 0;
+ modf((frames + 0.5) / pRecording->FramesPerSecond(), &Seconds);
+ return Seconds;
+ }
+
+ return -1;
+}
+
+#endif
+
+//***************************************************************************
+// Copied from epgsearch ;-) <----------
+//***************************************************************************
+
+//***************************************************************************
+// Notifications from VDRs Status Interface
+//***************************************************************************
+//***************************************************************************
+// Timers Change Notification
+//***************************************************************************
+
+void cUpdate::TimerChange(const cTimer* Timer, eTimerChange Change)
+{
+ if (!Epg2VdrConfig.shareInWeb)
+ return;
+
+ tell(1, "Timer changed, trigger update. Action was (%d)", Change);
+
+ timerTableUpdateTriggered = yes;
+ waitCondition.Broadcast(); // wakeup
+}
+
+//***************************************************************************
+// Recording Notification
+//***************************************************************************
+
+void cUpdate::Recording(const cDevice* Device, const char* Name, const char* FileName, bool On)
+{
+ cMutexLock lock(&runningRecMutex);
+ const int allowedBreakDuration = 2;
+
+ // Recording of 'Peter Hase' has 'started' [/srv/vdr/video.00/Peter_Hase/2014-10-08.11.05.18-0.rec]
+ // Recording of '(null)' has 'stopped' [/srv/vdr/video.00/Peter_Hase/2014-10-08.11.05.18-0.rec]
+
+ tell(1, "Recording of '%s' has '%s' [%s]", Name, On ? "started" : "stopped", FileName);
+
+ // at start of recording store event details to recording directory (info.epg2vdr)
+
+ if (On)
+ pendingNewRecordings.push(FileName);
+
+ // get timers lock
+
+#if defined (APIVERSNUM) && (APIVERSNUM >= 20301)
+ cTimersLock timersLock(false);
+ const cTimers* timers = timersLock.Timers();
+#else
+ const cTimers* timers = &Timers;
+#endif
+
+ // recording started ...
+
+ if (On && Name)
+ {
+ for (const cTimer* ti = timers->First(); ti; ti = timers->Next(ti))
+ {
+ if (ti->Recording()) // timer nimmt gerade auf
+ {
+ cRunningRecording* recording = 0;
+
+ // check if already known
+
+ for (cRunningRecording* rr = runningRecordings.First(); rr; rr = runningRecordings.Next(rr))
+ {
+ if (rr->timer == ti)
+ {
+ recording = rr;
+ break;
+ }
+ }
+
+ if (recording) // already handled -> a resume?!
+ {
+ tell(1, "Info: Detected resume of '%s' on device %d", Name, Device->CardIndex());
+ continue;
+ }
+
+ int doneid = na;
+ contentOfTag(ti, "doneid", doneid);
+
+ recording = new cRunningRecording(ti, doneid);
+ runningRecordings.Add(recording);
+ tell(1, "Info: Recording '%s' with doneid %d added to running list", Name, doneid);
+ }
+ }
+ }
+
+ // recording stopped ...
+
+ if (!On)
+ {
+ // loop over running recordings ..
+
+ for (cRunningRecording* rr = runningRecordings.First(); rr; rr = runningRecordings.Next(rr))
+ {
+ const cTimer* pendingTimer = 0;
+ int complete;
+ int recFraction = 100;
+ long timerLengthSecs = rr->timer->StopTime() - rr->timer->StartTime();
+ bool vpsUsed = rr->timer->HasFlags(tfVps) && rr->timer->Event() && rr->timer->Event()->Vps();
+
+ // check if timer still exists
+
+ for (pendingTimer = timers->First(); pendingTimer; pendingTimer = timers->Next(pendingTimer))
+ {
+ if (pendingTimer == rr->timer)
+ break;
+ }
+
+ // still recording :o ?
+
+ if (pendingTimer && pendingTimer->Recording())
+ continue;
+
+#if defined (APIVERSNUM) && (APIVERSNUM >= 20301)
+ cStateKey stateKey;
+
+ if (const cRecordings* recordings = cRecordings::GetRecordingsRead(stateKey))
+ {
+ const cRecording* pRecording = recordings->GetByName(FileName);
+
+ if (pRecording && timerLengthSecs)
+ {
+ int recLen = RecLengthInSecs(pRecording);
+ recFraction = double(recLen) * 100 / timerLengthSecs;
+ }
+
+ stateKey.Remove();
+ }
+#else
+ const cRecording* pRecording = Recordings.GetByName(FileName);
+
+ if (pRecording && timerLengthSecs)
+ {
+ int recLen = RecLengthInSecs(pRecording);
+ recFraction = double(recLen) * 100 / timerLengthSecs;
+ }
+#endif
+
+ // assure timer has reached it's end or at least 90% (vps) / 98% were recorded
+
+ complete = recFraction >= (vpsUsed ? 90 : 98);
+
+ if (complete)
+ tell(1, "Info: Finished: '%s'; recorded %d%%; VPS %s",
+ rr->timer->File(), recFraction, vpsUsed ? "Yes": "No");
+ else
+ tell(1, "Info: Finished: '%s' (not complete! - recorded only %d%%); VPS %s",
+ rr->timer->File(), recFraction, vpsUsed ? "Yes": "No");
+
+ if (complete)
+ rr->lastBreak = 0; // reset break
+ else if (!rr->lastBreak)
+ rr->lastBreak = time(0); // store first break
+
+ if (!rr->lastBreak || (time(0) - rr->lastBreak) > allowedBreakDuration)
+ {
+ char* infoTxt;
+
+ asprintf(&infoTxt, "Recording '%s' finished - %s complete (%d%%)",
+ rr->timer->File(), complete ? "" : "NOT", recFraction);
+
+ tell(1, "Info: %s", infoTxt);
+
+ rr->finished = yes;
+ rr->failed = !complete;
+ rr->setInfo(infoTxt);
+
+ free(infoTxt);
+ }
+ }
+ }
+
+ recordingStateChangedTrigger = yes;
+ waitCondition.Broadcast(); // wakeup
+}
+
+//***************************************************************************
+// Channel Switch Notification
+//***************************************************************************
+
+void cUpdate::ChannelSwitch(const cDevice* Device, int ChannelNumber, bool LiveView)
+{
+ // to be implemented ... ???
+}
generated by cgit v1.2.3 (git 2.25.1) at 2025-02-24 18:31:01 +0000