diff options
Diffstat (limited to 'PLUGINS/src/sky/sky.c')
| -rw-r--r-- | PLUGINS/src/sky/sky.c | 243 |
1 files changed, 243 insertions, 0 deletions
diff --git a/PLUGINS/src/sky/sky.c b/PLUGINS/src/sky/sky.c new file mode 100644 index 0000000..41439be --- /dev/null +++ b/PLUGINS/src/sky/sky.c @@ -0,0 +1,243 @@ +/* + * sky.c: A plugin for the Video Disk Recorder + * + * See the README file for copyright information and how to reach the author. + * + * $Id: sky.c 1.1 2002/10/26 16:27:13 kls Exp $ + */ + +#include <sys/socket.h> +#include <sys/stat.h> +#include <sys/time.h> +#include <sys/un.h> +#include <unistd.h> +#include <vdr/plugin.h> +#include <vdr/sources.h> + +static const char *VERSION = "0.0.1"; +static const char *DESCRIPTION = "Sky Digibox interface"; + +// --- cDigiboxDevice -------------------------------------------------------- + +class cDigiboxDevice : public cDevice { +private: + int source; + int digiboxChannelNumber; + int fd_dvr; + cTSBuffer *tsBuffer; + int fd_lirc; + void LircSend(const char *s); + void LircSend(int n); +protected: + virtual bool SetPid(cPidHandle *Handle, int Type, bool On); + virtual bool OpenDvr(void); + virtual void CloseDvr(void); + virtual bool GetTSPacket(uchar *&Data); +public: + cDigiboxDevice(void); + virtual ~cDigiboxDevice(); + virtual bool ProvidesSource(int Source) const; + virtual bool ProvidesChannel(const cChannel *Channel, int Priority = -1, bool *NeedsSetChannel = NULL) const; + virtual bool SetChannelDevice(const cChannel *Channel, bool LiveView); + }; + +cDigiboxDevice::cDigiboxDevice(void) +{ + source = cSource::FromString("S28.2E");//XXX parameter??? + digiboxChannelNumber = 0; + fd_dvr = -1; + struct sockaddr_un addr; + addr.sun_family = AF_UNIX; + strn0cpy(addr.sun_path, "/dev/lircd", sizeof(addr.sun_path));//XXX parameter??? + fd_lirc = socket(AF_UNIX, SOCK_STREAM, 0); + if (fd_lirc >= 0) { + if (connect(fd_lirc, (struct sockaddr *)&addr, sizeof(addr)) < 0) { + LOG_ERROR; + close(fd_lirc); + } + } + else + LOG_ERROR; +} + +cDigiboxDevice::~cDigiboxDevice() +{ + if (fd_lirc >= 0) + close(fd_lirc); +} + +void cDigiboxDevice::LircSend(const char *s) +{ + const char *c = "SEND_ONCE SKY %s\n"; + char buf[100]; + sprintf(buf, c, s); + dsyslog(buf);//XXX + if (write(fd_lirc, buf, strlen(buf)) < 0) + LOG_ERROR;//XXX _STR + delay_ms(200); +} + +void cDigiboxDevice::LircSend(int n) +{ + char buf[10]; + snprintf(buf, sizeof(buf), "%d", n); + char *p = buf; + while (*p) { + char q[10]; + sprintf(q, "%c", *p); + LircSend(q); + p++; + } +} + +bool cDigiboxDevice::SetPid(cPidHandle *Handle, int Type, bool On) +{ + dsyslog("SetPid %d %d", Handle->pid, On); + return true; +} + +bool cDigiboxDevice::OpenDvr(void) +{ + CloseDvr(); + fd_dvr = open("/dev/video2", O_RDONLY | O_NONBLOCK);//XXX parameter??? + if (fd_dvr >= 0) + tsBuffer = new cTSBuffer(fd_dvr, KILOBYTE(256), CardIndex() + 1); + return fd_dvr >= 0; +} + +void cDigiboxDevice::CloseDvr(void) +{ + if (fd_dvr >= 0) { + close(fd_dvr); + fd_dvr = -1; + delete tsBuffer; + tsBuffer = NULL; + } +} + +bool cDigiboxDevice::GetTSPacket(uchar *&Data) +{ + if (tsBuffer) { + int r = tsBuffer->Read(); + if (r >= 0) { + Data = tsBuffer->Get(); + return true; + } + else if (FATALERRNO) { + LOG_ERROR; + return false; + } + return true; + } + return false; +} + +bool cDigiboxDevice::ProvidesSource(int Source) const +{ + return source == Source; +} + +bool cDigiboxDevice::ProvidesChannel(const cChannel *Channel, int Priority, bool *NeedsDetachReceivers) const +{ + bool result = false; + bool hasPriority = Priority < 0 || Priority > this->Priority(); + bool needsDetachReceivers = true; + + if (ProvidesSource(Channel->Source()) && ProvidesCa(Channel->Ca())) { + if (Receiving()) { + if (digiboxChannelNumber == Channel->Frequency()) { + needsDetachReceivers = false; + result = true; + } + else + result = hasPriority; + } + else + result = hasPriority; + } + if (NeedsDetachReceivers) + *NeedsDetachReceivers = needsDetachReceivers; + return result; +} + +bool cDigiboxDevice::SetChannelDevice(const cChannel *Channel, bool LiveView) +{ + if (fd_lirc >= 0 && !Receiving()) { // if we are receiving the channel is already set! + digiboxChannelNumber = Channel->Frequency(); + //XXX only when recording??? -> faster channel switching! + LircSend("SKY"); // makes sure the Digibox is "on" + //XXX lircprint(fd_lirc, "BACKUP"); + //XXX lircprint(fd_lirc, "BACKUP"); + //XXX lircprint(fd_lirc, "BACKUP"); + LircSend(digiboxChannelNumber); + } +return true; +} + +// --- cPluginSky ------------------------------------------------------------ + +class cPluginSky : public cPlugin { +private: + // Add any member variables or functions you may need here. +public: + cPluginSky(void); + virtual ~cPluginSky(); + virtual const char *Version(void) { return VERSION; } + virtual const char *Description(void) { return DESCRIPTION; } + virtual const char *CommandLineHelp(void); + virtual bool ProcessArgs(int argc, char *argv[]); + virtual bool Start(void); + virtual void Housekeeping(void); + virtual cMenuSetupPage *SetupMenu(void); + virtual bool SetupParse(const char *Name, const char *Value); + }; + +cPluginSky::cPluginSky(void) +{ + // Initialize any member variables here. + // DON'T DO ANYTHING ELSE THAT MAY HAVE SIDE EFFECTS, REQUIRE GLOBAL + // VDR OBJECTS TO EXIST OR PRODUCE ANY OUTPUT! +} + +cPluginSky::~cPluginSky() +{ + // Clean up after yourself! +} + +const char *cPluginSky::CommandLineHelp(void) +{ + // Return a string that describes all known command line options. + return NULL; +} + +bool cPluginSky::ProcessArgs(int argc, char *argv[]) +{ + // Implement command line argument processing here if applicable. + return true; +} + +bool cPluginSky::Start(void) +{ + // Start any background activities the plugin shall perform. + new cDigiboxDevice; + return true; +} + +void cPluginSky::Housekeeping(void) +{ + // Perform any cleanup or other regular tasks. +} + +cMenuSetupPage *cPluginSky::SetupMenu(void) +{ + // Return a setup menu in case the plugin supports one. + return NULL; +} + +bool cPluginSky::SetupParse(const char *Name, const char *Value) +{ + // Parse your own setup parameters and store their values. + return false; +} + +VDRPLUGINCREATOR(cPluginSky); // Don't touch this! |