diff options
Diffstat (limited to 'xine_frontend_lirc.c')
| -rw-r--r-- | xine_frontend_lirc.c | 157 |
1 files changed, 157 insertions, 0 deletions
diff --git a/xine_frontend_lirc.c b/xine_frontend_lirc.c new file mode 100644 index 00000000..dd1a8e09 --- /dev/null +++ b/xine_frontend_lirc.c @@ -0,0 +1,157 @@ +/* + * xine_frontend_lirc.c + * + * Forward (local) lirc keys to VDR (server) + * + * + * Almost directly copied from vdr-1.3.34 (lirc.c : cLircRemote) + * + * $Id: xine_frontend_lirc.c,v 1.1 2006-06-03 10:01:18 phintuka Exp $ + * + */ + +#include <stdint.h> +#include <netinet/in.h> +#include <sys/socket.h> +#include <sys/un.h> + +#define REPEATLIMIT 20 /* ms */ +#define REPEATDELAY 350 /* ms */ +#define KEYPRESSDELAY 150 /* ms */ +#define LIRC_KEY_BUF 30 +#define LIRC_BUFFER_SIZE 128 + +/* static data */ +pthread_t lirc_thread; +volatile char *lirc_device_name = NULL; +static volatile int fd_lirc = -1; + +static uint64_t time_ms() +{ + struct timeval t; + if (gettimeofday(&t, NULL) == 0) + return ((uint64_t)t.tv_sec) * 1000ULL + t.tv_usec / 1000ULL; + return 0; +} + +static uint64_t elapsed(uint64_t t) +{ + return time_ms() - t; +} + +void *lirc_receiver_thread(void *fe) +{ + struct sockaddr_un addr; + int timeout = -1; + uint64_t FirstTime = time_ms(); + uint64_t LastTime = time_ms(); + char buf[LIRC_BUFFER_SIZE]; + char LastKeyName[LIRC_KEY_BUF] = ""; + int repeat = 0; + + if(!lirc_device_name) { + LOGDBG("no lirc device given"); + goto out; + } + + addr.sun_family = AF_UNIX; + strcpy(addr.sun_path, (char*)lirc_device_name); + if ((fd_lirc = socket(AF_UNIX, SOCK_STREAM, 0)) < 0) { + LOGERR("lirc error: socket() < 0"); + goto out; + } + if (connect(fd_lirc, (struct sockaddr *)&addr, sizeof(addr))) { + LOGERR("lirc error: connect(%s) < 0", lirc_device_name); + goto out; + } + + while(lirc_device_name && fd_lirc >= 0) { + fd_set set; + int ready, ret = -1; + FD_ZERO(&set); + FD_SET(fd_lirc, &set); + + if (timeout >= 0) { + struct timeval tv; +#if 0 + if(TimeoutMs < 100) + TimeoutMs = 100; +#endif + tv.tv_sec = timeout / 1000; + tv.tv_usec = (timeout % 1000) * 1000; + ready = select(FD_SETSIZE, &set, NULL, NULL, &tv) > 0 && FD_ISSET(fd_lirc, &set); + } else { + ready = select(FD_SETSIZE, &set, NULL, NULL, NULL) > 0 && FD_ISSET(fd_lirc, &set); + } + + if(ready) { + + do { + ret = read(fd_lirc, buf, sizeof(buf)); + } while(ret < 0 && errno == EINTR); + + if (ret <= 0 ) { + LOGERR("LIRC connection lost"); + break; + } + + if (ret > 21) { + unsigned int count; + char KeyName[LIRC_KEY_BUF]; + LOGDBG("LIRC: %s", buf); + if (sscanf(buf, "%*x %x %29s", &count, KeyName) != 2) { + /* '29' in '%29s' is LIRC_KEY_BUF-1! */ + LOGMSG("unparseable lirc command: %s", buf); + continue; + } + + if (count == 0) { + if (strcmp(KeyName, LastKeyName) == 0 && elapsed(FirstTime) < KEYPRESSDELAY) + continue; /* skip keys coming in too fast */ + if (repeat) + if(find_input((fe_t*)fe)) + process_xine_keypress(((fe_t*)fe)->input, "LIRC", KeyName, 0, 1); + /* Put(LastKeyName, false, true); code, repeat, release */ + strcpy(LastKeyName, KeyName); + repeat = 0; + FirstTime = time_ms(); + timeout = -1; + } + else { + if (elapsed(FirstTime) < REPEATDELAY) + continue; /* repeat function kicks in after a short delay */ + repeat = 1; + timeout = REPEATDELAY; + } + LastTime = time_ms(); + + + if(find_input((fe_t*)fe)) + process_xine_keypress(((fe_t*)fe)->input, "LIRC", KeyName, repeat, 0); + + /*Put(KeyName, repeat);*/ + + + } + else if (repeat) { /* the last one was a repeat, so let's generate a release */ + if (elapsed(LastTime) >= REPEATDELAY) { + /* Put(LastKeyName, false, true); */ + if(find_input((fe_t*)fe)) + process_xine_keypress(((fe_t*)fe)->input, "LIRC", LastKeyName, 0, 1); + repeat = 0; + *LastKeyName = 0; + timeout = -1; + } + } + + } + } + + + out: + if(fd_lirc >= 0) + close(fd_lirc); + fd_lirc = -1; + pthread_exit(NULL); + return NULL; /* never reached */ +} |