Menu uses colors; support for RGYB buttons; fixed DEBUG_REMOTE; Add, Del and Move for channels and timers; basic record/play file handling0.0.2

1 files changed, 238 insertions, 0 deletions

diff --git a/recording.c b/recording.c
new file mode 100644
index 00000000..afc2d8b3
--- /dev/null
+++ b/recording.c
@@ -0,0 +1,238 @@
+/*
+ * recording.h: Recording file handling
+ *
+ * See the main source file 'osm.c' for copyright information and
+ * how to reach the author.
+ *
+ * $Id: recording.c 1.1 2000/03/05 17:16:22 kls Exp $
+ */
+
+#include "recording.h"
+#include <errno.h>
+#include <stdio.h>
+#include <string.h>
+#include "interface.h"
+#include "tools.h"
+
+#define RECEXT       ".rec"
+#define DELEXT       ".del"
+#define DATAFORMAT   "%4d-%02d-%02d.%02d:%02d.%c.%02d.%02d" RECEXT
+#define NAMEFORMAT   "%s/%s/" DATAFORMAT
+
+#define FINDCMD      "find %s -type f -name '%s'"
+
+#define DFCMD        "df -m %s"
+#define MINDISKSPACE 1024 // MB
+
+const char *BaseDir = "/video";//XXX
+
+cDvbRecorder *Recorder = NULL;
+
+static bool LowDiskSpace(void)
+{
+  //TODO Find a simpler way to determine the amount of free disk space!
+  bool result = true;
+  char *cmd = NULL;
+  asprintf(&cmd, DFCMD, BaseDir);
+  FILE *p = popen(cmd, "r");
+  if (p) {
+     char *s;
+     while ((s = readline(p)) != NULL) {
+           if (*s == '/') {
+              int available;
+              sscanf(s, "%*s %*d %*d %d", &available);
+              result = available < MINDISKSPACE;
+              break;
+              }
+           }
+     pclose(p);
+     }
+  else
+     esyslog(LOG_ERR, "ERROR: can't open pipe for cmd '%s'", cmd);
+  delete cmd;
+  return result;
+}
+
+void AssertFreeDiskSpace(void)
+{
+  // With every call to this function we try to actually remove
+  // a file, or mark a file for removal ("delete" it), so that
+  // it will get removed during the next call.
+  if (Recorder && Recorder->Recording() && LowDiskSpace()) {
+     // Remove the oldest file that has been "deleted":
+     cRecordings Recordings;
+     if (Recordings.Load(true)) {
+        cRecording *r = Recordings.First();
+        cRecording *r0 = r;
+        while (r) {
+              if (r->start < r0->start)
+                 r0 = r;
+              r = Recordings.Next(r);
+              }
+        if (r0 && r0->Remove())
+           return;
+        }
+     // No "deleted" files to remove, so let's see if we can delete a recording:
+     if (Recordings.Load(false)) {
+        cRecording *r = Recordings.First();
+        cRecording *r0 = NULL;
+        while (r) {
+              if ((time(NULL) - r->start) / SECSINDAY > r->lifetime) {
+                 if (r0) {
+                    if (r->priority < r0->priority)
+                       r0 = r;
+                    }
+                 else
+                    r0 = r;
+                 }
+              r = Recordings.Next(r);
+              }
+        if (r0 && r0->Delete())
+           return;
+        }
+     // Unable to free disk space, but there's nothing we can do about that...
+     //TODO maybe a log entry - but make sure it doesn't come too often
+     }
+}
+
+// --- cRecording ------------------------------------------------------------
+
+cRecording::cRecording(const char *Name, time_t Start, char Quality, int Priority, int LifeTime)
+{
+  fileName = NULL;
+  name = strdup(Name);
+  start = Start;
+  quality = Quality;
+  priority = Priority;
+  lifetime = LifeTime;
+}
+
+cRecording::cRecording(cTimer *Timer)
+{
+  fileName = NULL;
+  name = strdup(Timer->file);
+  start = Timer->StartTime();
+  quality = Timer->quality;
+  priority = Timer->priority;
+  lifetime = Timer->lifetime;
+}
+
+cRecording::cRecording(const char *FileName)
+{
+  fileName = strdup(FileName);
+  FileName += strlen(BaseDir) + 1;
+  char *p = strrchr(FileName, '/');
+
+  name = NULL;
+  if (p) {
+     time_t now = time(NULL);
+     struct tm t = *localtime(&now); // this initializes the time zone in 't'
+     if (8 == sscanf(p + 1, DATAFORMAT, &t.tm_year, &t.tm_mon, &t.tm_mday, &t.tm_hour, &t.tm_min, &quality, &priority, &lifetime)) {
+        t.tm_year -= 1900;
+        t.tm_mon--;
+        t.tm_sec = 0;
+        start = mktime(&t);
+        name = new char[p - FileName + 1];
+        strncpy(name, FileName, p - FileName);
+        name[p - FileName] = 0;
+        }
+     }
+}
+
+cRecording::~cRecording()
+{
+  delete fileName;
+  delete name;
+}
+
+const char *cRecording::FileName(void)
+{
+  if (!fileName) {
+     struct tm *t = localtime(&start);
+     asprintf(&fileName, NAMEFORMAT, BaseDir, name, t->tm_year + 1900, t->tm_mon + 1, t->tm_mday, t->tm_hour, t->tm_min, quality, priority, lifetime);
+     }
+  return fileName;
+}
+
+bool cRecording::Delete(void)
+{
+  bool result = true;
+  char *NewName = strdup(FileName());
+  char *ext = strrchr(NewName, '.');
+  if (strcmp(ext, RECEXT) == 0) {
+     strncpy(ext, DELEXT, strlen(ext));
+     isyslog(LOG_INFO, "deleting recording %s", FileName());
+     if (rename(FileName(), NewName) == -1) {
+        esyslog(LOG_ERR, "ERROR: %s", strerror(errno));
+        result = false;
+        }
+     }
+  delete NewName;
+  return result;
+}
+
+bool cRecording::Remove(void)
+{
+  bool result = true;
+  isyslog(LOG_INFO, "removing recording %s", FileName());
+  if (remove(FileName()) == -1) {
+     esyslog(LOG_ERR, "ERROR: %s", strerror(errno));
+     result = false;
+     }
+  return result;
+}
+
+bool cRecording::AssertRecorder(void)
+{
+  if (!Recorder || !Recorder->Recording()) {
+     if (!Recorder)
+        Recorder = new cDvbRecorder;
+     return true;
+     }
+  Interface.Error("Recorder is in use!");
+  return false;
+}
+
+bool cRecording::Record(void)
+{
+  return AssertRecorder() && Recorder->Record(FileName(), quality);
+}
+
+bool cRecording::Play(void)
+{
+  return AssertRecorder() && Recorder->Play(FileName());
+}
+
+void cRecording::Stop(void)
+{
+  if (Recorder)
+     Recorder->Stop();
+}
+
+// --- cRecordings -----------------------------------------------------------
+
+bool cRecordings::Load(bool Deleted)
+{
+  Clear();
+  bool result = false;
+  char *cmd = NULL;
+  asprintf(&cmd, FINDCMD, BaseDir, Deleted ? "*" DELEXT : "*" RECEXT);
+  FILE *p = popen(cmd, "r");
+  if (p) {
+     char *s;
+     while ((s = readline(p)) != NULL) {
+           cRecording *r = new cRecording(s);
+           if (r->name)
+              Add(r);
+           else
+              delete r;
+           }
+     pclose(p);
+     result = Count() > 0;
+     }
+  else
+     Interface.Error("Error while opening pipe!");
+  delete cmd;
+  return result;
+}
+