Changeset 869

Timestamp:

04/10/08 16:45:45 (7 months ago)

Author:

michux

Message:

Add basic FIFO plugin

Location:

trunk

Files:

• Makefile.am (modified) (1 diff)
• plugin.c (modified) (3 diffs)
• plugin_fifo.c (copied) (copied from trunk/plugin_sample.c) (2 diffs)
• plugins.m4 (modified) (3 diffs)

trunk/Makefile.am

@@ -115 +115 @@
 plugin_dvb.c                  \
 plugin_exec.c                 \
+plugin_fifo.c                 \
 plugin_file.c                 \
 plugin_gps.c                  \

trunk/plugin.c

@@ -69 +69 @@
 int plugin_init_exec(void);
 void plugin_exit_exec(void);
+int plugin_init_fifo(void);
+void plugin_exit_fifo(void);
 int plugin_init_file(void);
 void plugin_exit_file(void);
@@ -145 +147 @@
     plugin_init_exec();
 #endif
+#ifdef PLUGIN_FIFO
+    plugin_init_fifo();
+#endif
 #ifdef PLUGIN_FILE
     plugin_init_file();
@@ -242 +247 @@
 #ifdef PLUGIN_EXEC
     plugin_exit_exec();
+#endif
+#ifdef PLUGIN_FIFO
+    plugin_exit_fifo();
 #endif
 #ifdef PLUGIN_FILE

trunk/plugin_fifo.c

@@ -4 +4 @@
  * plugin template
  *
- * Copyright (C) 2003 Michael Reinelt <michael@reinelt.co.at>
- * Copyright (C) 2004, 2005, 2006, 2007 The LCD4Linux Team <lcd4linux-devel@users.sourceforge.net>
+ * Copyright (C) 2008 Michael Vogt <michu@neophob.com>
+ * Copyright (C) 2004, 2005, 2006, 2007, 2008 The LCD4Linux Team <lcd4linux-devel@users.sourceforge.net>
  *
  * This file is part of LCD4Linux.
@@ -23 +23 @@
  * Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
  *
- */
-
+ */  
+    
 /* 
- * exported functions:
- *
- * int plugin_init_sample (void)
- *  adds various functions
- *
- */
-
-
-/* define the include files you need */
+ * Quick fifo hack for lcd4linux
+ * 
+ * most code is ripped ...
+ *
+ */ 
+    
+
+/* define the include files you need */ 
 #include "config.h"
-
+    
 #include <stdlib.h>
 #include <string.h>
 #include <ctype.h>
-
-/* these should always be included */
+#include <errno.h>
+#include <unistd.h>
+#include <fcntl.h>
+#include <sys/stat.h>
+    
+/* these should always be included */ 
 #include "debug.h"
 #include "plugin.h"
-
+#include "cfg.h"
+    
 #ifdef WITH_DMALLOC
 #include <dmalloc.h>
-#endif
-
-
-
-/* sample function 'mul2' */
-/* takes one argument, a number */
-/* multiplies the number by 2.0 */
-/* Note: all local functions should be declared 'static' */
-
-static void my_mul2(RESULT * result, RESULT * arg1)
-{
-    double param;
-    double value;
-
-    /* Get Parameter */
-    /* R2N stands for 'Result to Number' */
-    param = R2N(arg1);
-
-    /* calculate value */
-    value = param * 2.0;
-
-    /* store result */
-    /* when called with R_NUMBER, it assumes the */
-    /* next parameter to be a pointer to double */
-    SetResult(&result, R_NUMBER, &value);
-}
-
-
-/* sample function 'mul3' */
-/* takes one argument, a number */
-/* multiplies the number by 3.0 */
-/* same as 'mul2', but shorter */
-
-static void my_mul3(RESULT * result, RESULT * arg1)
-{
-    /* do it all in one line */
-    double value = R2N(arg1) * 3.0;
-
-    /* store result */
-    SetResult(&result, R_NUMBER, &value);
-}
-
-
-/* sample function 'diff' */
-/* takes two arguments, both numbers */
-/* returns |a-b| */
-
-static void my_diff(RESULT * result, RESULT * arg1, RESULT * arg2)
-{
-    /* do it all in one line */
-    double value = R2N(arg1) - R2N(arg2);
-
-    /* some more calculations... */
-    if (value < 0)
-  value = -value;
-
-    /* store result */
-    SetResult(&result, R_NUMBER, &value);
-}
-
-
-/* sample function 'answer' */
-/* takes no argument! */
-/* returns the answer to all questions */
-
-static void my_answer(RESULT * result)
-{
-    /* we have to declare a variable because */
-    /* SetResult needs a pointer  */
-    double value = 42;
-
-    /* store result */
-    SetResult(&result, R_NUMBER, &value);
-}
-
-
-/* sample function 'length' */
-/* takes one argument, a string */
-/* returns the string length */
-
-static void my_length(RESULT * result, RESULT * arg1)
-{
-    /* Note #1: value *must* be double!  */
-    /* Note #2: R2S stands for 'Result to String' */
-    double value = strlen(R2S(arg1));
-
-    /* store result */
-    SetResult(&result, R_NUMBER, &value);
-}
-
-
-
-/* sample function 'upcase' */
-/* takes one argument, a string */
-/* returns the string in upper case letters */
-
-static void my_upcase(RESULT * result, RESULT * arg1)
-{
-    char *value, *p;
-
-    /* create a local copy of the argument */
-    /* Do *NOT* try to modify the original string! */
-    value = strdup(R2S(arg1));
-
-    /* process the string */
-    for (p = value; *p != '\0'; p++)
-  *p = toupper(*p);
-
-    /* store result */
-    /* when called with R_STRING, it assumes the */
-    /* next parameter to be a pointer to a string */
-    /* 'value' is already a char*, so use 'value', not '&value' */
-    SetResult(&result, R_STRING, value);
-
-    /* free local copy again */
-    /* Note that SetResult() makes its own string copy  */
-    free(value);
-}
-
-
-/* sample function 'cat' */
-/* takes variable number of arguments, all strings */
-/* returns all prameters concatenated */
-
-static void my_concat(RESULT * result, int argc, RESULT * argv[])
-{
-    int i, len;
-    char *value, *part;
-
-    /* start with a empty string */
-    value = strdup("");
-
-    /* process all arguments */
-    for (i = 0; i < argc; i++) {
-  part = R2S(argv[i]);
-  len = strlen(value) + strlen(part);
-  value = realloc(value, len + 1);
-  strcat(value, part);
-    }
-
-    /* store result */
-    SetResult(&result, R_STRING, value);
-
-    /* free local string */
-    free(value);
-}
-
-
-/* plugin initialization */
-/* MUST NOT be declared 'static'! */
-int plugin_init_sample(void)
-{
-
-    /* register all our cool functions */
-    /* the second parameter is the number of arguments */
-    /* -1 stands for variable argument list */
-    AddFunction("sample::mul2", 1, my_mul2);
-    AddFunction("sample::mul3", 1, my_mul3);
-    AddFunction("sample::answer", 0, my_answer);
-    AddFunction("sample::diff", 2, my_diff);
-    AddFunction("sample::length", 1, my_length);
-    AddFunction("sample::upcase", 1, my_upcase);
-    AddFunction("sample::concat", -1, my_concat);
-
-    return 0;
-}
-
-void plugin_exit_sample(void)
-{
-    /* free any allocated memory */
-    /* close filedescriptors */
-}
+#endif  /* 
+ */
+    
+#define FIFO_BUFFER_SIZE 80
+    
+typedef struct _FifoData {
+    
+char *path;
+    
+ int input;
+    
+ int created;
+
+ 
+} FifoData;
+
+
+static char Section[] = "Plugin:FIFO";
+
+
+static FifoData fd;
+
+static char msg[FIFO_BUFFER_SIZE];
+
+static char fifopath[1024];
+
+
+static void configure_fifo(void) 
+{
+    
+char *s;
+    
+s = cfg_get(Section, "fifopath", "/tmp/lcd4linux.fifo");
+    
+if (*s == '\0') {
+  
+info("[FIFO] empty '%s.fifopath' entry from %s, assuming '/tmp/lcd4linux.fifo'", Section, cfg_source());
+  
+strcpy(fifopath, "/tmp/lcd4linux.fifo");
+    
+} else
+  
+strcpy(fifopath, s);
+    
+
+free(s);
+
+}
+
+
+
+static void removeFifo() 
+{
+    
+debug("Removing FIFO \"%s\"\n", fd.path);
+    
+
+if (unlink(fd.path) < 0) {
+  
+error("Could not remove FIFO \"%s\": %s\n", fd.path, strerror(errno));
+  
+return;
+    
+}
+    
+
+fd.created = 0;
+
+}
+
+
+static void closeFifo() 
+{
+    
+struct stat st;
+    
+
+if (fd.input >= 0) {
+  
+close(fd.input);
+  
+fd.input = -1;
+    
+}
+    
+
+if (fd.created && (stat(fd.path, &st) == 0))
+  
+removeFifo(fd);
+
+}
+
+
+static int makeFifo() 
+{
+    
+if (mkfifo(fd.path, 0666) < 0) {
+  
+error("Couldn't create FIFO \"%s\": %s\n", fd.path, strerror(errno));
+  
+return -1;
+    
+}
+    
+
+fd.created = 1;
+    
+
+return 0;
+
+}
+
+
+
+static int checkFifo() 
+{
+    
+struct stat st;
+    
+if (stat(fd.path, &st) < 0) {
+  
+if (errno == ENOENT) {
+      
+    /* Path doesn't exist */ 
+    return makeFifo(fd);
+  
+}
+  
+
+error("Failed to stat FIFO \"%s\": %s\n", fd.path, strerror(errno));
+  
+return -1;
+    
+}
+    
+
+if (!S_ISFIFO(st.st_mode)) {
+  
+error("\"%s\" already exists, but is not a FIFO\n", fd.path);
+  
+return -1;
+    
+}
+    
+
+return 0;
+
+}
+
+
+static int openFifo() 
+{
+    
+if (checkFifo() < 0)
+  
+return -1;
+    
+
+fd.input = open(fd.path, O_RDONLY | O_NONBLOCK);
+    
+if (fd.input < 0) {
+  
+error("Could not open FIFO \"%s\" for reading: %s\n", fd.path, strerror(errno));
+  
+closeFifo();
+  
+return -1;
+    
+}
+    
+
+return 0;
+
+}
+
+
+static void fiforead(RESULT * result) 
+{
+    
+char buf[FIFO_BUFFER_SIZE];
+    
+int i, bytes = 1;
+    
+memset(buf, 0, FIFO_BUFFER_SIZE);
+    
+
+strcat(buf, "ERROR");
+    
+if (checkFifo() == 0) {
+  
+memset(buf, 0, FIFO_BUFFER_SIZE);
+  
+while (bytes > 0 && errno != EINTR)
+      
+bytes = read(fd.input, buf, FIFO_BUFFER_SIZE);
+  
+
+if (bytes < 0) {
+      
+error("[FIFO] Error %i: %s\n", errno, strerror(errno));
+  
+} else {
+      
+
+if (strlen(buf) > 0) {
+    
+strcpy(msg, buf);
+      
+}
+      
+
+for (i = 0; i < strlen(buf); i++) {
+    
+if (msg[i] < 0x20)
+        
+msg[i] = ' ';
+      
+}
+  
+}
+    
+}
+    
+
+  /* store result */ 
+  SetResult(&result, R_STRING, msg);
+
+}
+
+
+
+/* plugin initialization */ 
+int plugin_init_fifo(void) 
+{
+    
+configure_fifo();
+    
+
+fd.path = fifopath;
+    
+fd.input = -1;
+    
+fd.created = 0;
+    
+
+if (openFifo() < 0) {
+  
+return -1;
+    
+}
+    
+
+memset(msg, 0, FIFO_BUFFER_SIZE);
+    
+AddFunction("fifo::read", 0, fiforead);
+    
+
+return 0;
+
+}
+
+
+void plugin_exit_fifo(void) 
+{
+    
+  /* close filedescriptors */ 
+  closeFifo();
+
+} 

trunk/plugins.m4

@@ -61 +61 @@
          PLUGIN_DVB="yes"
          PLUGIN_EXEC="yes"
+         PLUGIN_FIFO="yes"
          PLUGIN_FILE="yes"
          PLUGIN_GPS="yes"
@@ -106 +107 @@
          PLUGIN_EXEC=$val
          ;;
+      fifo)
+         PLUGIN_FIFO=$val
+         ;;
       file)
          PLUGIN_FILE=$val
@@ -219 +223 @@
    PLUGINS="$PLUGINS plugin_file.o"
    AC_DEFINE(PLUGIN_FILE,1,[file plugin])
+fi
+if test "$PLUGIN_FIFO" = "yes"; then
+   PLUGINS="$PLUGINS plugin_fifo.o"
+   AC_DEFINE(PLUGIN_FIFO,1,[fifo plugin])
 fi
 if test "$PLUGIN_GPS" = "yes"; then