]> git.webhop.me Git - lcd4linux.git/commitdiff
[lcd4linux @ 2004-02-22 17:35:41 by reinelt]
authorreinelt <reinelt@3ae390bd-cb1e-0410-b409-cd5a39f66f1f>
Sun, 22 Feb 2004 17:35:41 +0000 (17:35 +0000)
committerreinelt <reinelt@3ae390bd-cb1e-0410-b409-cd5a39f66f1f>
Sun, 22 Feb 2004 17:35:41 +0000 (17:35 +0000)
some fixes for generic graphic driver and T6963
removed ^M from plugin_imon (Nico, are you editing under Windows?)

git-svn-id: https://ssl.bulix.org/svn/lcd4linux/trunk@373 3ae390bd-cb1e-0410-b409-cd5a39f66f1f

Makefile.in
drv_T6963.c
drv_generic_graphic.c
lcd4linux.conf.sample
plugin_imon.c

index 549e53474323af973e04f21489eccb76798260ac..d5be94b724597eadc221240da4904b00ce4e2789 100644 (file)
@@ -106,7 +106,7 @@ lcd4linux_LDADD = @DRIVERS@ @DRVLIBS@
 #remove next line for liblcd4linux
 lcd4linux_DEPENDENCIES = @DRIVERS@
 
-lcd4linux_SOURCES =  lcd4linux.c                 cfg.c         cfg.h         debug.c       debug.h       drv.c         drv.h         evaluator.c   evaluator.h   hash.c        hash.h        layout.c      layout.h      lock.c              lock.h        pid.c         pid.h         timer.c       timer.h       udelay.c      udelay.h                                  widget.c      widget.h      widget_text.c widget_text.h widget_bar.c  widget_bar.h  widget_icon.c widget_icon.h                             plugin.c      plugin.h      plugin_math.c               plugin_string.c             plugin_cfg.c                plugin_uname.c              plugin_loadavg.c            plugin_proc_stat.c          plugin_cpuinfo.c            plugin_meminfo.c            plugin_netdev.c             plugin_ppp.c                plugin_dvb.c                plugin_i2c_sensors.c        plugin_xmms.c               
+lcd4linux_SOURCES =  lcd4linux.c                 cfg.c         cfg.h         debug.c       debug.h       drv.c         drv.h         evaluator.c   evaluator.h   hash.c        hash.h        layout.c      layout.h      lock.c              lock.h        pid.c         pid.h         timer.c       timer.h       udelay.c      udelay.h                                  widget.c      widget.h      widget_text.c widget_text.h widget_bar.c  widget_bar.h  widget_icon.c widget_icon.h                             plugin.c      plugin.h      plugin_math.c               plugin_string.c             plugin_cfg.c                plugin_uname.c              plugin_loadavg.c            plugin_proc_stat.c          plugin_cpuinfo.c            plugin_meminfo.c            plugin_netdev.c             plugin_ppp.c                plugin_dvb.c                plugin_i2c_sensors.c        plugin_imon.c               plugin_xmms.c               
 
 
 #liblcd4linux_la_DEPENDENCIES = @DRIVERS@
@@ -145,7 +145,8 @@ plugin_string.$(OBJEXT) plugin_cfg.$(OBJEXT) plugin_uname.$(OBJEXT) \
 plugin_loadavg.$(OBJEXT) plugin_proc_stat.$(OBJEXT) \
 plugin_cpuinfo.$(OBJEXT) plugin_meminfo.$(OBJEXT) \
 plugin_netdev.$(OBJEXT) plugin_ppp.$(OBJEXT) plugin_dvb.$(OBJEXT) \
-plugin_i2c_sensors.$(OBJEXT) plugin_xmms.$(OBJEXT)
+plugin_i2c_sensors.$(OBJEXT) plugin_imon.$(OBJEXT) \
+plugin_xmms.$(OBJEXT)
 CFLAGS = @CFLAGS@
 COMPILE = $(CC) $(DEFS) $(INCLUDES) $(AM_CPPFLAGS) $(CPPFLAGS) $(AM_CFLAGS) $(CFLAGS)
 LTCOMPILE = $(LIBTOOL) --mode=compile $(CC) $(DEFS) $(INCLUDES) $(AM_CPPFLAGS) $(CPPFLAGS) $(AM_CFLAGS) $(CFLAGS)
@@ -171,11 +172,12 @@ DEP_FILES =  .deps/BeckmannEgle.P .deps/MilfordInstruments.P \
 .deps/drv_generic_text.P .deps/evaluator.P .deps/hash.P .deps/layout.P \
 .deps/lcd4linux.P .deps/lock.P .deps/pid.P .deps/plugin.P \
 .deps/plugin_cfg.P .deps/plugin_cpuinfo.P .deps/plugin_dvb.P \
-.deps/plugin_i2c_sensors.P .deps/plugin_loadavg.P .deps/plugin_math.P \
-.deps/plugin_meminfo.P .deps/plugin_netdev.P .deps/plugin_ppp.P \
-.deps/plugin_proc_stat.P .deps/plugin_string.P .deps/plugin_uname.P \
-.deps/plugin_xmms.P .deps/timer.P .deps/udelay.P .deps/widget.P \
-.deps/widget_bar.P .deps/widget_icon.P .deps/widget_text.P
+.deps/plugin_i2c_sensors.P .deps/plugin_imon.P .deps/plugin_loadavg.P \
+.deps/plugin_math.P .deps/plugin_meminfo.P .deps/plugin_netdev.P \
+.deps/plugin_ppp.P .deps/plugin_proc_stat.P .deps/plugin_string.P \
+.deps/plugin_uname.P .deps/plugin_xmms.P .deps/timer.P .deps/udelay.P \
+.deps/widget.P .deps/widget_bar.P .deps/widget_icon.P \
+.deps/widget_text.P
 SOURCES = $(lcd4linux_SOURCES) $(EXTRA_lcd4linux_SOURCES)
 OBJECTS = $(lcd4linux_OBJECTS)
 
index 5a0e6a742f36e0d8c2a79ecd718b0cee2896e2f8..e581e8130439120138535b9841d168942dc5889a 100644 (file)
@@ -1,4 +1,4 @@
-/* $Id: drv_T6963.c,v 1.2 2004/02/18 06:39:20 reinelt Exp $
+/* $Id: drv_T6963.c,v 1.3 2004/02/22 17:35:41 reinelt Exp $
  *
  * new style driver for T6963-based displays
  *
  *
  *
  * $Log: drv_T6963.c,v $
+ * Revision 1.3  2004/02/22 17:35:41  reinelt
+ * some fixes for generic graphic driver and T6963
+ * removed ^M from plugin_imon (Nico, are you editing under Windows?)
+ *
  * Revision 1.2  2004/02/18 06:39:20  reinelt
  * T6963 driver for graphic displays finished
  *
@@ -310,7 +314,6 @@ static void drv_T6_blit(int row, int col, int height, int width)
   for (r=row; r<row+height; r++) {
     for (c=col; c<col+width; c++) {
       unsigned char mask = 1<<(XRES-1-c%XRES);
-      //if (c<8) debug ("c=%d c%%XRES=%d mask=%d", c, c%XRES, mask); 
       if (drv_generic_graphic_FB[r*LCOLS+c]) {
        // set bit
        Buffer1[(r*DCOLS+c)/XRES] |=  mask;
@@ -335,7 +338,6 @@ static void drv_T6_blit(int row, int col, int height, int width)
     }
     memcpy (Buffer2+j, Buffer1+j, i-j-e+1);
     drv_T6_copy (j, Buffer1+j, i-j-e+1);
-    // sleep (1);
   }
 }
 
@@ -410,6 +412,7 @@ static int drv_T6_start (char *section)
   // set direction: write
   drv_generic_parport_direction (0);
   
+
   // initialize display
 
   drv_T6_send_word (0x40, 0x0000);    // Set Text Home Address
index ac27be9cace0caab70a5e389fa687993bfd3f01c..1b01cf40e50bad09e2067ddb11d46bb50cc6673e 100644 (file)
  *
  *
  * $Log: drv_generic_graphic.c,v $
+ * Revision 1.3  2004/02/22 17:35:41  reinelt
+ * some fixes for generic graphic driver and T6963
+ * removed ^M from plugin_imon (Nico, are you editing under Windows?)
+ *
  * Revision 1.2  2004/02/18 06:39:20  reinelt
  * T6963 driver for graphic displays finished
  *
@@ -229,9 +233,9 @@ int drv_generic_graphic_bar_draw (WIDGET *W)
     
   case DIR_EAST:
     for (y=0; y<YRES; y++) {
-      len=y<YRES/2 ? val1 : val2;
+      int val=y<YRES/2 ? val1 : val2;
       for (x=0; x<max; x++) {
-       drv_generic_graphic_FB[(row+y)*LCOLS+col+x] = x<len ? !rev : rev;
+       drv_generic_graphic_FB[(row+y)*LCOLS+col+x] = x<val ? !rev : rev;
       }
     }
     break;
@@ -244,8 +248,8 @@ int drv_generic_graphic_bar_draw (WIDGET *W)
   case DIR_NORTH:
     for (y=0; y<max; y++) {
       for (x=0; x<XRES; x++) {
-       len=x<XRES/2 ? val1 : val2;
-       drv_generic_graphic_FB[(row+y)*LCOLS+col+x] = y<len ? !rev : rev;
+       int val=x<XRES/2 ? val1 : val2;
+       drv_generic_graphic_FB[(row+y)*LCOLS+col+x] = y<val ? !rev : rev;
       }
     }
     break;
index 567970efefa0d62c5bae45f0867600be73557233..777ca7eb414405c322d1475c86064c9bbd404dc5 100644 (file)
@@ -74,7 +74,7 @@ Display USBLCD {
 Display T6963-240x64 {
     Driver 'T6963'
     Port '/dev/parports/0'
-    Size '240x64'
+    Size '240x128'
     Wire.CE 'STROBE'
     Wire.CD 'SELECT'
     Wire.RD 'AUTOFD'
@@ -152,6 +152,48 @@ Widget LoadBar {
 }
 
 
+Widget Disk {
+    class 'Text'
+    # disk.[rw]blk return blocks, we assume a blocksize of 512
+    # to get the number in kB/s we would do blk*512/1024, which is blk/2 
+    expression (disk('.*', 'rblk', 500)+disk('.*', 'wblk', 500))/2
+    prefix 'disk'
+    postfix ' '
+    width 10   
+    precision 0
+    align 'R'  
+    update tick        
+}      
+
+Widget DiskBar {
+    class 'Bar'
+    expression  disk('.*', 'rblk', 500)
+    expression2 disk('.*', 'wblk', 500)
+    length 14  
+    direction 'E'
+    update tack
+}
+
+Widget Eth0 {
+    class 'Text'
+    expression (netdev('eth0.Rx.bytes', 500)+netdev('eth0.Tx.bytes', 500))/1024
+    prefix 'eth0'
+    postfix ' '
+    width 10   
+    precision 0
+    align 'R'  
+    update tick        
+}      
+
+Widget Eth0Bar {
+    class 'Bar'
+    expression  netdev('eth0.Rx.bytes', 500)
+    expression2 netdev('eth0.Tx.bytes', 500)
+    length 14  
+    direction 'E'
+    update tack
+}
+
 Widget Heartbeat {
     class 'Icon'
     speed 800
@@ -276,6 +318,14 @@ Layout Default {
        Col1 'Load'
        Col11 'LoadBar'
     }
+    Row5 {
+       Col1  'Disk'
+       Col11 'DiskBar'
+    }
+    Row6 {
+       Col1  'Eth0'
+       Col11 'Eth0Bar'
+    }
 }
 
 Layout L24x8 {
@@ -312,14 +362,14 @@ Layout Test {
     Row06.Col1 'Test'
     Row07.Col1 'Test'
     Row08.Col1 'Test'
-    Row09.Col1 'Test'
-    Row10.Col1 'Test'
-    Row11.Col1 'Test'
-    Row12.Col1 'Test'
-    Row13.Col1 'Test'
-    Row14.Col1 'Test'
-    Row15.Col1 'Test'
-    Row16.Col1 'Test'
+#    Row09.Col1 'Test'
+#    Row10.Col1 'Test'
+#    Row11.Col1 'Test'
+#    Row12.Col1 'Test'
+#    Row13.Col1 'Test'
+#    Row14.Col1 'Test'
+#    Row15.Col1 'Test'
+#    Row16.Col1 'Test'
 }
 
 #Display 'LK204'
@@ -331,9 +381,9 @@ Layout Test {
 #Display 'USBLCD'
 Display 'T6963-240x64'
 
-#Layout  'Default'
+Layout  'Default'
 #Layout  'L16x2'
-Layout 'Test'
+#Layout 'Test'
 
 
 Variables {
index fc49a967deb36979c3f8208f7b3d4bfca624ae01..a7aecc599f8673da9f3ff26914190a5c1d116326 100755 (executable)
-/* $Id: plugin_imon.c,v 1.1 2004/02/18 14:45:43 nicowallmeier Exp $\r
- *\r
- * imond/telmond data processing\r
- *\r
- * Copyright 2003 Nico Wallmeier <nico.wallmeier@post.rwth-aachen.de>\r
- *\r
- * This file is part of LCD4Linux.\r
- *\r
- * LCD4Linux is free software; you can redistribute it and/or modify\r
- * it under the terms of the GNU General Public License as published by\r
- * the Free Software Foundation; either version 2, or (at your option)\r
- * any later version.\r
- *\r
- * LCD4Linux is distributed in the hope that it will be useful,\r
- * but WITHOUT ANY WARRANTY; without even the implied warranty of\r
- * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the\r
- * GNU General Public License for more details.\r
- *\r
- * You should have received a copy of the GNU General Public License\r
- * along with this program; if not, write to the Free Software\r
- * Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.\r
- *\r
- *\r
+/* $Id: plugin_imon.c,v 1.2 2004/02/22 17:35:41 reinelt Exp $
+ *
+ * imond/telmond data processing
+ *
+ * Copyright 2003 Nico Wallmeier <nico.wallmeier@post.rwth-aachen.de>
+ *
+ * This file is part of LCD4Linux.
+ *
+ * LCD4Linux is free software; you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation; either version 2, or (at your option)
+ * any later version.
+ *
+ * LCD4Linux is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with this program; if not, write to the Free Software
+ * Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
+ *
+ *
  * $Log: plugin_imon.c,v $
+ * Revision 1.2  2004/02/22 17:35:41  reinelt
+ * some fixes for generic graphic driver and T6963
+ * removed ^M from plugin_imon (Nico, are you editing under Windows?)
+ *
  * Revision 1.1  2004/02/18 14:45:43  nicowallmeier
  * Imon/Telmon plugin ported
- *\r
- */\r
\r
-#include "config.h"\r
-#include "debug.h"\r
-#include "plugin.h"\r
-#include "cfg.h"\r
-#include "hash.h"\r
-\r
-#include <stdio.h>\r
-#include <string.h>\r
-#include <unistd.h>\r
-#include <stdlib.h>\r
-#include <sys/types.h>\r
-#include <sys/fcntl.h>\r
-#include <sys/ioctl.h>\r
-#include <sys/time.h>\r
-#include <linux/errno.h>\r
-#include <sys/stat.h>\r
-#include <string.h>\r
-#include <time.h>\r
-\r
-#include <netdb.h>\r
-#include <netinet/in.h>\r
-#include <netinet/tcp.h>\r
-#include <arpa/inet.h>                          /* decl of inet_addr()      */\r
-#include <sys/socket.h>\r
-\r
-static HASH TELMON = { 0, };\r
-static HASH IMON = { 0, };\r
-\r
-static char thost[256];\r
-static int tport;\r
-static char phoneb[256];\r
-\r
-static char ihost[256];\r
-static char ipass[256];\r
-static int iport;\r
-\r
-static int fd=0;\r
-static int err=0;\r
-\r
-/*----------------------------------------------------------------------------\r
- *  service_connect (host_name, port)       - connect to tcp-service\r
- *----------------------------------------------------------------------------\r
- */\r
-static int service_connect (char * host_name, int port){\r
-    struct sockaddr_in  addr;\r
-    struct hostent *    host_p;\r
-    int                 fd;\r
-    int                 opt = 1;\r
-\r
-    (void) memset ((char *) &addr, 0, sizeof (addr));\r
-\r
-    if ((addr.sin_addr.s_addr = inet_addr ((char *) host_name)) == INADDR_NONE)\r
-    {\r
-        host_p = gethostbyname (host_name);\r
-\r
-        if (! host_p)\r
-        {\r
-            error ("%s: host not found\n", host_name);\r
-            return (-1);\r
-        }\r
-\r
-        (void) memcpy ((char *) (&addr.sin_addr), host_p->h_addr,\r
-                        host_p->h_length);\r
-    }\r
-\r
-    addr.sin_family  = AF_INET;\r
-    addr.sin_port    = htons ((unsigned short) port);\r
-\r
-    if ((fd = socket (AF_INET, SOCK_STREAM, 0)) < 0)\r
-    {                                           /* open socket              */\r
-        perror ("socket");\r
-        return (-1);\r
-    }\r
-    \r
-    (void) setsockopt (fd, IPPROTO_TCP, TCP_NODELAY,\r
-                       (char *) &opt, sizeof (opt));\r
-\r
-    if (connect (fd, (struct sockaddr *) &addr, sizeof (addr)) != 0)\r
-    {\r
-        (void) close (fd);\r
-        perror (host_name);\r
-        return (-1);\r
-    }\r
-\r
-    return (fd);\r
-} /* service_connect (char * host_name, int port) */\r
-\r
-/*----------------------------------------------------------------------------\r
- *  send_command (int fd, char * str)       - send command to imond\r
- *----------------------------------------------------------------------------\r
- */\r
-static void\r
-send_command (int fd, char * str)\r
-{\r
-    char    buf[256];\r
-    int     len = strlen (str);\r
-\r
-    sprintf (buf, "%s\r\n", str);\r
-    write (fd, buf, len + 2);\r
-\r
-    return;\r
-} /* send_command (int fd, char * str) */\r
-\r
-\r
-/*----------------------------------------------------------------------------\r
- *  get_answer (int fd)                     - get answer from imond\r
- *----------------------------------------------------------------------------\r
- */\r
-static char *\r
-get_answer (int fd)\r
-{\r
-    static char buf[8192];\r
-    int         len;\r
-\r
-    len = read (fd, buf, 8192);\r
-\r
-    if (len <= 0)\r
-    {\r
-        return ((char *) NULL);\r
-    }\r
-\r
-    while (len > 1 && (buf[len - 1] == '\n' || buf[len - 1] == '\r'))\r
-    {\r
-        buf[len - 1] = '\0';\r
-        len--;\r
-    }\r
-\r
-    if (! strncmp (buf, "OK ", 3))                      /* OK xxxx          */\r
-    {\r
-        return (buf + 3);\r
-    }\r
-    else if (len > 2 && ! strcmp (buf + len - 2, "OK"))\r
-    {\r
-        *(buf + len - 2) = '\0';\r
-        return (buf);\r
-    }\r
-    else if (len == 2 && ! strcmp (buf + len - 2, "OK"))\r
-    {\r
-        return (buf);\r
-    }\r
-\r
-    return ((char *) NULL);                             /* ERR xxxx         */\r
-} /* get_answer (int fd) */\r
-\r
-/*----------------------------------------------------------------------------\r
- *  get_value (char * cmd)         - send command, get value\r
- *----------------------------------------------------------------------------\r
- */\r
-static char *\r
-get_value (char * cmd)\r
-{\r
-    char *  answer;\r
-\r
-    send_command (fd, cmd);\r
-\r
-    answer = get_answer (fd);\r
-\r
-    if (answer)\r
-    {\r
-        return (answer);\r
-    }\r
-\r
-    return ("");\r
-} /* get_value (char * cmd, int arg) */\r
-\r
-static void phonebook(char *number){\r
-  FILE *  fp;\r
-  char line[256];\r
-  \r
-  fp = fopen (phoneb, "r");\r
-  \r
-  if (! fp) return;\r
-  \r
-  while (fgets (line, 128, fp)){\r
-       if (*line == '#') continue;\r
-       if (!strncmp(line,number,strlen(number))){\r
-         char *komma=strchr(line,',');\r
-         char *beginn=strchr(line,'=');\r
-         if (!beginn) return;\r
-         while (strrchr(line,'\r')) strrchr(line,'\r')[0]='\0';\r
-         while (strrchr(line,'\n')) strrchr(line,'\n')[0]='\0';\r
-         if (komma) komma[0]='\0';\r
-         strcpy(number,beginn+1);\r
-         break;\r
-       }       \r
-  }\r
-  \r
-  fclose(fp);\r
-}\r
-\r
-\r
-static int parse_telmon(){\r
- static int telmond_fd=-2;\r
- static char oldanswer[128];\r
- int age;\r
-   \r
- // reread every 1 sec only\r
- age=hash_age(&TELMON, NULL, NULL);\r
- if (age>0 && age<=1000) return 0;\r
-\r
- if (telmond_fd != -1){\r
-  char    telbuf[128];\r
-\r
-  telmond_fd = service_connect (thost, tport);\r
-  if (telmond_fd >= 0){\r
-   int l = read (telmond_fd, telbuf, 127);\r
-   if ((l > 0) && (strcmp(telbuf,oldanswer))){\r
-       char date[11]; \r
-       char time[11];\r
-       char number[256];\r
-       char msn[256];\r
-       sscanf(telbuf,"%s %s %s %s",date,time,number,msn);\r
-       hash_set (&TELMON, "time", time);\r
-       date[4]='\0';\r
-       date[7]='\0';\r
-       snprintf(time, sizeof(time), "%s.%s.%s",date+8,date+5,date);\r
-       hash_set (&TELMON, "number", number);\r
-       hash_set (&TELMON, "msn", msn);\r
-       hash_set (&TELMON, "date", time);\r
-       phonebook(number);\r
-       phonebook(msn);\r
-       hash_set (&TELMON, "name", number);\r
-       hash_set (&TELMON, "msnname", msn);\r
-   }\r
-   close (telmond_fd);\r
-   strcpy(oldanswer,telbuf);\r
-  }\r
- }\r
- return 0;\r
-}\r
-\r
-static void my_telmon (RESULT *result, RESULT *arg1){\r
- char *val=NULL;\r
- if (parse_telmon()<0) {\r
-  SetResult(&result, R_STRING, ""); \r
-  return;\r
- }\r
-  \r
- val=hash_get(&TELMON, R2S(arg1));\r
- if (val==NULL) val="";\r
- SetResult(&result, R_STRING, val); \r
-}\r
-\r
-void init(){\r
- if (fd!=0) return;\r
\r
- fd=service_connect(ihost,iport);\r
-\r
- if (fd<0){\r
-  err++;\r
- } else if ((ipass!=NULL) && (*ipass!='\0')) { // Passwort senden\r
-  char buf[40];\r
-  snprintf(buf,sizeof(buf),"pass %s",ipass);\r
-  send_command(fd,buf);\r
-  get_answer(fd); \r
- }\r
-}\r
-\r
-static int parse_imon(char *cmd){\r
- // reread every half sec only\r
- int age=hash_age(&IMON, cmd, NULL);\r
- if (age>0 && age<=500) return 0;\r
-\r
- init(); // establish connection\r
-\r
- if (err) return -1;\r
\r
- hash_set (&IMON, cmd , get_value(cmd));\r
\r
- return 0;\r
-}\r
-\r
-static void my_imon_version (RESULT *result){\r
- char *val;\r
- // read only ones\r
- int age=hash_age(&IMON, "version", NULL);\r
- if (age<0){\r
-  char *s;\r
-  init();\r
-  if (err){\r
-   SetResult(&result, R_STRING, ""); \r
-   return;\r
-  }\r
-  s=get_value("version");\r
-  for (;;){ // interne Versionsnummer killen\r
-   if (s[0]==' '){\r
-    s=s+1;\r
-    break;\r
-   }\r
-   s=s+1;              \r
-  }\r
-  hash_set (&IMON, "version", s);\r
- }\r
-       \r
- val=hash_get(&IMON, "version");\r
- if (val==NULL) val="";\r
- SetResult(&result, R_STRING, val); \r
-}\r
-\r
-static int parse_imon_rates(char *channel){\r
- char buf[128],in[25],out[25];\r
- char *s;\r
- int age;\r
-  \r
- snprintf(buf,sizeof(buf),"rate %s in",channel);\r
\r
- // reread every half sec only\r
- age=hash_age(&IMON, buf, NULL);\r
- if (age>0 && age<=500) return 0;\r
-\r
- init(); // establish connection\r
-\r
- if (err) return -1;\r
-\r
- snprintf(buf, sizeof(buf), "rate %s", channel);\r
- s=get_value(buf);\r
\r
- if (sscanf(s,"%s %s",in, out)!=2) return -1;\r
-\r
- snprintf(buf, sizeof(buf), "rate %s in", channel);\r
- hash_set (&IMON, buf , in);\r
- snprintf(buf, sizeof(buf), "rate %s out", channel);\r
- hash_set (&IMON, buf , out);\r
\r
- return 0;\r
-}\r
-\r
-\r
-static void my_imon_rates (RESULT *result, RESULT *arg1, RESULT *arg2){\r
- char *val;\r
- char buf[128];\r
\r
- if (parse_imon_rates(R2S(arg1))<0) {\r
-  SetResult(&result, R_STRING, ""); \r
-  return;\r
- }\r
\r
- snprintf(buf,sizeof(buf),"rate %s %s",R2S(arg1),R2S(arg2));\r
-\r
- val=hash_get(&IMON, buf);\r
- if (val==NULL) val="";\r
- SetResult(&result, R_STRING, val); \r
-}\r
-\r
-static void my_imon (RESULT *result, RESULT *arg1){\r
- char *val=NULL,*cmd=R2S(arg1);\r
\r
- if (parse_imon(cmd)<0) {\r
-  SetResult(&result, R_STRING, ""); \r
-  return;\r
- }\r
-  \r
- val=hash_get(&IMON, cmd);\r
- if (val==NULL) val="";\r
- SetResult(&result, R_STRING, val); \r
-}\r
-\r
-int plugin_init_imon (void){\r
- char telmon='\1',imon='\1';   \r
-\r
- char *s=cfg_get ("Telmon", "Host","127.0.0.1");\r
- if (*s=='\0') {\r
-  error ("[Telmon] no 'Host' entry in %s", cfg_source());\r
-  telmon='\0';\r
- } \r
- strcpy(thost,s);\r
-  \r
- if ((telmon=='\01') && (cfg_number("Telmon", "Port",5001,1,65536,&tport)<0)){\r
-  error ("[Telmon] no valid port definition");\r
-  telmon='\0'; \r
- }\r
\r
- s=cfg_get ("Telmon", "Phonebook","/etc/phonebook");\r
- strcpy(phoneb,s);\r
\r
- s=cfg_get ("Imon", "Host", "127.0.0.1");\r
- if (*s=='\0') {\r
-  error ("[Imon] no 'Host' entry in %s", cfg_source());\r
-  imon='\0';\r
- }\r
- strcpy(ihost,s); \r
\r
- if ((imon=='\01') && (cfg_number("Imon", "Port",5000,1,65536,&iport)<0)){\r
-  error ("[Imon] no valid port definition");\r
-  imon='\0';   \r
- }\r
\r
- s=cfg_get ("Imon", "Pass", "");\r
- strcpy(ipass,s);\r
-       \r
- if (telmon=='\1') AddFunction ("telmon", 1, my_telmon);\r
- if (imon=='\1'){\r
-  AddFunction ("imon", 1, my_imon);\r
-  AddFunction ("version", 0, my_imon_version);\r
-  AddFunction ("rates", 2, my_imon_rates);\r
- }\r
-\r
- return 0;\r
-}
\ No newline at end of file
+ *
+ */
+#include "config.h"
+#include "debug.h"
+#include "plugin.h"
+#include "cfg.h"
+#include "hash.h"
+
+#include <stdio.h>
+#include <string.h>
+#include <unistd.h>
+#include <stdlib.h>
+#include <sys/types.h>
+#include <sys/fcntl.h>
+#include <sys/ioctl.h>
+#include <sys/time.h>
+#include <linux/errno.h>
+#include <sys/stat.h>
+#include <string.h>
+#include <time.h>
+
+#include <netdb.h>
+#include <netinet/in.h>
+#include <netinet/tcp.h>
+#include <arpa/inet.h>                          /* decl of inet_addr()      */
+#include <sys/socket.h>
+
+static HASH TELMON = { 0, };
+static HASH IMON = { 0, };
+
+static char thost[256];
+static int tport;
+static char phoneb[256];
+
+static char ihost[256];
+static char ipass[256];
+static int iport;
+
+static int fd=0;
+static int err=0;
+
+/*----------------------------------------------------------------------------
+ *  service_connect (host_name, port)       - connect to tcp-service
+ *----------------------------------------------------------------------------
+ */
+static int service_connect (char * host_name, int port){
+    struct sockaddr_in  addr;
+    struct hostent *    host_p;
+    int                 fd;
+    int                 opt = 1;
+
+    (void) memset ((char *) &addr, 0, sizeof (addr));
+
+    if ((addr.sin_addr.s_addr = inet_addr ((char *) host_name)) == INADDR_NONE)
+    {
+        host_p = gethostbyname (host_name);
+
+        if (! host_p)
+        {
+            error ("%s: host not found\n", host_name);
+            return (-1);
+        }
+
+        (void) memcpy ((char *) (&addr.sin_addr), host_p->h_addr,
+                        host_p->h_length);
+    }
+
+    addr.sin_family  = AF_INET;
+    addr.sin_port    = htons ((unsigned short) port);
+
+    if ((fd = socket (AF_INET, SOCK_STREAM, 0)) < 0)
+    {                                           /* open socket              */
+        perror ("socket");
+        return (-1);
+    }
+    
+    (void) setsockopt (fd, IPPROTO_TCP, TCP_NODELAY,
+                       (char *) &opt, sizeof (opt));
+
+    if (connect (fd, (struct sockaddr *) &addr, sizeof (addr)) != 0)
+    {
+        (void) close (fd);
+        perror (host_name);
+        return (-1);
+    }
+
+    return (fd);
+} /* service_connect (char * host_name, int port) */
+
+/*----------------------------------------------------------------------------
+ *  send_command (int fd, char * str)       - send command to imond
+ *----------------------------------------------------------------------------
+ */
+static void
+send_command (int fd, char * str)
+{
+    char    buf[256];
+    int     len = strlen (str);
+
+    sprintf (buf, "%s\r\n", str);
+    write (fd, buf, len + 2);
+
+    return;
+} /* send_command (int fd, char * str) */
+
+
+/*----------------------------------------------------------------------------
+ *  get_answer (int fd)                     - get answer from imond
+ *----------------------------------------------------------------------------
+ */
+static char *
+get_answer (int fd)
+{
+    static char buf[8192];
+    int         len;
+
+    len = read (fd, buf, 8192);
+
+    if (len <= 0)
+    {
+        return ((char *) NULL);
+    }
+
+    while (len > 1 && (buf[len - 1] == '\n' || buf[len - 1] == '\r'))
+    {
+        buf[len - 1] = '\0';
+        len--;
+    }
+
+    if (! strncmp (buf, "OK ", 3))                      /* OK xxxx          */
+    {
+        return (buf + 3);
+    }
+    else if (len > 2 && ! strcmp (buf + len - 2, "OK"))
+    {
+        *(buf + len - 2) = '\0';
+        return (buf);
+    }
+    else if (len == 2 && ! strcmp (buf + len - 2, "OK"))
+    {
+        return (buf);
+    }
+
+    return ((char *) NULL);                             /* ERR xxxx         */
+} /* get_answer (int fd) */
+
+/*----------------------------------------------------------------------------
+ *  get_value (char * cmd)         - send command, get value
+ *----------------------------------------------------------------------------
+ */
+static char *
+get_value (char * cmd)
+{
+    char *  answer;
+
+    send_command (fd, cmd);
+
+    answer = get_answer (fd);
+
+    if (answer)
+    {
+        return (answer);
+    }
+
+    return ("");
+} /* get_value (char * cmd, int arg) */
+
+static void phonebook(char *number){
+  FILE *  fp;
+  char line[256];
+  
+  fp = fopen (phoneb, "r");
+  
+  if (! fp) return;
+  
+  while (fgets (line, 128, fp)){
+       if (*line == '#') continue;
+       if (!strncmp(line,number,strlen(number))){
+         char *komma=strchr(line,',');
+         char *beginn=strchr(line,'=');
+         if (!beginn) return;
+         while (strrchr(line,'\r')) strrchr(line,'\r')[0]='\0';
+         while (strrchr(line,'\n')) strrchr(line,'\n')[0]='\0';
+         if (komma) komma[0]='\0';
+         strcpy(number,beginn+1);
+         break;
+       }       
+  }
+  
+  fclose(fp);
+}
+
+
+static int parse_telmon(){
+ static int telmond_fd=-2;
+ static char oldanswer[128];
+ int age;
+   
+ // reread every 1 sec only
+ age=hash_age(&TELMON, NULL, NULL);
+ if (age>0 && age<=1000) return 0;
+
+ if (telmond_fd != -1){
+  char    telbuf[128];
+
+  telmond_fd = service_connect (thost, tport);
+  if (telmond_fd >= 0){
+   int l = read (telmond_fd, telbuf, 127);
+   if ((l > 0) && (strcmp(telbuf,oldanswer))){
+       char date[11]; 
+       char time[11];
+       char number[256];
+       char msn[256];
+       sscanf(telbuf,"%s %s %s %s",date,time,number,msn);
+       hash_set (&TELMON, "time", time);
+       date[4]='\0';
+       date[7]='\0';
+       snprintf(time, sizeof(time), "%s.%s.%s",date+8,date+5,date);
+       hash_set (&TELMON, "number", number);
+       hash_set (&TELMON, "msn", msn);
+       hash_set (&TELMON, "date", time);
+       phonebook(number);
+       phonebook(msn);
+       hash_set (&TELMON, "name", number);
+       hash_set (&TELMON, "msnname", msn);
+   }
+   close (telmond_fd);
+   strcpy(oldanswer,telbuf);
+  }
+ }
+ return 0;
+}
+
+static void my_telmon (RESULT *result, RESULT *arg1){
+ char *val=NULL;
+ if (parse_telmon()<0) {
+  SetResult(&result, R_STRING, ""); 
+  return;
+ }
+  
+ val=hash_get(&TELMON, R2S(arg1));
+ if (val==NULL) val="";
+ SetResult(&result, R_STRING, val); 
+}
+
+void init(){
+ if (fd!=0) return;
+ fd=service_connect(ihost,iport);
+
+ if (fd<0){
+  err++;
+ } else if ((ipass!=NULL) && (*ipass!='\0')) { // Passwort senden
+  char buf[40];
+  snprintf(buf,sizeof(buf),"pass %s",ipass);
+  send_command(fd,buf);
+  get_answer(fd); 
+ }
+}
+
+static int parse_imon(char *cmd){
+ // reread every half sec only
+ int age=hash_age(&IMON, cmd, NULL);
+ if (age>0 && age<=500) return 0;
+
+ init(); // establish connection
+
+ if (err) return -1;
+ hash_set (&IMON, cmd , get_value(cmd));
+ return 0;
+}
+
+static void my_imon_version (RESULT *result){
+ char *val;
+ // read only ones
+ int age=hash_age(&IMON, "version", NULL);
+ if (age<0){
+  char *s;
+  init();
+  if (err){
+   SetResult(&result, R_STRING, ""); 
+   return;
+  }
+  s=get_value("version");
+  for (;;){ // interne Versionsnummer killen
+   if (s[0]==' '){
+    s=s+1;
+    break;
+   }
+   s=s+1;              
+  }
+  hash_set (&IMON, "version", s);
+ }
+       
+ val=hash_get(&IMON, "version");
+ if (val==NULL) val="";
+ SetResult(&result, R_STRING, val); 
+}
+
+static int parse_imon_rates(char *channel){
+ char buf[128],in[25],out[25];
+ char *s;
+ int age;
+  
+ snprintf(buf,sizeof(buf),"rate %s in",channel);
+ // reread every half sec only
+ age=hash_age(&IMON, buf, NULL);
+ if (age>0 && age<=500) return 0;
+
+ init(); // establish connection
+
+ if (err) return -1;
+
+ snprintf(buf, sizeof(buf), "rate %s", channel);
+ s=get_value(buf);
+ if (sscanf(s,"%s %s",in, out)!=2) return -1;
+
+ snprintf(buf, sizeof(buf), "rate %s in", channel);
+ hash_set (&IMON, buf , in);
+ snprintf(buf, sizeof(buf), "rate %s out", channel);
+ hash_set (&IMON, buf , out);
+ return 0;
+}
+
+
+static void my_imon_rates (RESULT *result, RESULT *arg1, RESULT *arg2){
+ char *val;
+ char buf[128];
+ if (parse_imon_rates(R2S(arg1))<0) {
+  SetResult(&result, R_STRING, ""); 
+  return;
+ }
+ snprintf(buf,sizeof(buf),"rate %s %s",R2S(arg1),R2S(arg2));
+
+ val=hash_get(&IMON, buf);
+ if (val==NULL) val="";
+ SetResult(&result, R_STRING, val); 
+}
+
+static void my_imon (RESULT *result, RESULT *arg1){
+ char *val=NULL,*cmd=R2S(arg1);
+ if (parse_imon(cmd)<0) {
+  SetResult(&result, R_STRING, ""); 
+  return;
+ }
+  
+ val=hash_get(&IMON, cmd);
+ if (val==NULL) val="";
+ SetResult(&result, R_STRING, val); 
+}
+
+int plugin_init_imon (void){
+ char telmon='\1',imon='\1';   
+
+ char *s=cfg_get ("Telmon", "Host","127.0.0.1");
+ if (*s=='\0') {
+  error ("[Telmon] no 'Host' entry in %s", cfg_source());
+  telmon='\0';
+ } 
+ strcpy(thost,s);
+  
+ if ((telmon=='\01') && (cfg_number("Telmon", "Port",5001,1,65536,&tport)<0)){
+  error ("[Telmon] no valid port definition");
+  telmon='\0'; 
+ }
+ s=cfg_get ("Telmon", "Phonebook","/etc/phonebook");
+ strcpy(phoneb,s);
+ s=cfg_get ("Imon", "Host", "127.0.0.1");
+ if (*s=='\0') {
+  error ("[Imon] no 'Host' entry in %s", cfg_source());
+  imon='\0';
+ }
+ strcpy(ihost,s); 
+ if ((imon=='\01') && (cfg_number("Imon", "Port",5000,1,65536,&iport)<0)){
+  error ("[Imon] no valid port definition");
+  imon='\0';   
+ }
+ s=cfg_get ("Imon", "Pass", "");
+ strcpy(ipass,s);
+       
+ if (telmon=='\1') AddFunction ("telmon", 1, my_telmon);
+ if (imon=='\1'){
+  AddFunction ("imon", 1, my_imon);
+  AddFunction ("version", 0, my_imon_version);
+  AddFunction ("rates", 2, my_imon_rates);
+ }
+
+ return 0;
+}