diff options
Diffstat (limited to 'recording.c')
| -rw-r--r-- | recording.c | 238 |
1 files changed, 238 insertions, 0 deletions
diff --git a/recording.c b/recording.c new file mode 100644 index 0000000..afc2d8b --- /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; +} + |