From 3c737870508ceba11eede58553a51b5e6034b3c0 Mon Sep 17 00:00:00 2001 From: reinelt <> Date: Tue, 6 Jan 2004 22:33:14 +0000 Subject: [lcd4linux @ 2004-01-06 22:33:13 by reinelt] Copyright statements cleaned up --- imon.c | 839 +++++++++++++++++++++++++++++++++-------------------------------- 1 file changed, 422 insertions(+), 417 deletions(-) (limited to 'imon.c') diff --git a/imon.c b/imon.c index 4f70ac0..1f34766 100755 --- a/imon.c +++ b/imon.c @@ -1,7 +1,9 @@ -/* $Id: imon.c,v 1.1 2003/10/12 06:08:28 nicowallmeier Exp $ +/* $Id: imon.c,v 1.2 2004/01/06 22:33:14 reinelt Exp $ * * imond/telmond data processing * + * Copyright 2003 Nico Wallmeier + * * This file is part of LCD4Linux. * * LCD4Linux is free software; you can redistribute it and/or modify @@ -20,423 +22,426 @@ * * * $Log: imon.c,v $ + * Revision 1.2 2004/01/06 22:33:14 reinelt + * Copyright statements cleaned up + * * Revision 1.1 2003/10/12 06:08:28 nicowallmeier * imond/telmond support * */ - -#include -#include -#include -#include -#include -#include -#include -#include -#include -#include -#include -#include - -#include -#include -#include -#include /* decl of inet_addr() */ -#include - -#include "cfg.h" -#include "debug.h" -#include "parser.h" -#include "imon.h" - -#define TRUE 1 -#define FALSE 0 - -static int fd; - - /*---------------------------------------------------------------------------- - * 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_numerical_value (char * cmd) - send cmd, get numval - *---------------------------------------------------------------------------- - */ -static int -get_numerical_value (char * cmd) -{ - char * answer; - int rtc; - - send_command (fd, cmd); - - answer = get_answer (fd); - - if (answer) - { - rtc = atoi (answer); - } - else - { - rtc = -1; - } - return (rtc); -} /* get_numerical_value (char * cmd, int arg) */ - - -/*---------------------------------------------------------------------------- - * 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) */ - - -int init(){ - char *s, *host; - int port; - int connect; - - host=cfg_get ("Imon_Host","127.0.0.1"); - if (*host=='\0') { - error ("Imon: no 'Imon_Host' entry in %s", cfg_source()); - return -1; - } - - if (cfg_number("Imon_Port",5000,1,65536,&port)<0){ - return -1; - } - - connect=service_connect(host,port); - - s=cfg_get ("Imon_Pass",NULL); - if ((s!=NULL) && (*s!='\0')) { // Passwort senden - char buf[40]; - sprintf(buf,"pass %s",s); - send_command(connect,buf); - s=get_answer(connect); - } - - return connect; -} - -int ImonCh(int index, struct imonchannel *ch, int token_usage[]) { - static int err[CHANNELS+1]; - char *s; - char buf[40]; - int result=0; - - if (err[index]) return -1; - if ((fd==0) && ((fd=init())<0)) return -1; - - if ((*ch).max_in == 0){ // not initializied - sprintf(buf, "Imon_%d_Dev", index); - s=cfg_get(buf,NULL); - if (s==NULL) { - error ("Imon: no 'Imon_%i_Dev' entry in %s", index, cfg_source()); - err[index]=1; - return -1; - } - strcpy((*ch).dev,s); - - sprintf(buf, "Imon_%d_MaxIn", index); - cfg_number(buf,768,1,65536,&(*ch).max_in); - - sprintf(buf, "Imon_%d_MaxOut", index); - cfg_number(buf,128,1,65536,&(*ch).max_out); - } - - sprintf(buf, "status %s", (*ch).dev); - s=get_value(buf); - strcpy((*ch).status,s); - - if ((1<= 0){ - int l = read (telmond_fd, telbuf, 127); - if ((l > 0) && (strcmp(telbuf,oldanswer))){ - char date[11]; - sscanf(telbuf,"%s %s %s %s",date,(*t).time,(*t).number,(*t).msn); - date[4]='\0'; - date[7]='\0'; - sprintf((*t).date,"%s.%s.%s",date+8,date+5,date); - phonebook((*t).number); - phonebook((*t).msn); - } - close (telmond_fd); - strcpy(oldanswer,telbuf); - } - } - return 0; -} - - + +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include + +#include +#include +#include +#include /* decl of inet_addr() */ +#include + +#include "cfg.h" +#include "debug.h" +#include "parser.h" +#include "imon.h" + +#define TRUE 1 +#define FALSE 0 + +static int fd; + + /*---------------------------------------------------------------------------- + * 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_numerical_value (char * cmd) - send cmd, get numval + *---------------------------------------------------------------------------- + */ +static int +get_numerical_value (char * cmd) +{ + char * answer; + int rtc; + + send_command (fd, cmd); + + answer = get_answer (fd); + + if (answer) + { + rtc = atoi (answer); + } + else + { + rtc = -1; + } + return (rtc); +} /* get_numerical_value (char * cmd, int arg) */ + + +/*---------------------------------------------------------------------------- + * 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) */ + + +int init(){ + char *s, *host; + int port; + int connect; + + host=cfg_get ("Imon_Host","127.0.0.1"); + if (*host=='\0') { + error ("Imon: no 'Imon_Host' entry in %s", cfg_source()); + return -1; + } + + if (cfg_number("Imon_Port",5000,1,65536,&port)<0){ + return -1; + } + + connect=service_connect(host,port); + + s=cfg_get ("Imon_Pass",NULL); + if ((s!=NULL) && (*s!='\0')) { // Passwort senden + char buf[40]; + sprintf(buf,"pass %s",s); + send_command(connect,buf); + s=get_answer(connect); + } + + return connect; +} + +int ImonCh(int index, struct imonchannel *ch, int token_usage[]) { + static int err[CHANNELS+1]; + char *s; + char buf[40]; + int result=0; + + if (err[index]) return -1; + if ((fd==0) && ((fd=init())<0)) return -1; + + if ((*ch).max_in == 0){ // not initializied + sprintf(buf, "Imon_%d_Dev", index); + s=cfg_get(buf,NULL); + if (s==NULL) { + error ("Imon: no 'Imon_%i_Dev' entry in %s", index, cfg_source()); + err[index]=1; + return -1; + } + strcpy((*ch).dev,s); + + sprintf(buf, "Imon_%d_MaxIn", index); + cfg_number(buf,768,1,65536,&(*ch).max_in); + + sprintf(buf, "Imon_%d_MaxOut", index); + cfg_number(buf,128,1,65536,&(*ch).max_out); + } + + sprintf(buf, "status %s", (*ch).dev); + s=get_value(buf); + strcpy((*ch).status,s); + + if ((1<= 0){ + int l = read (telmond_fd, telbuf, 127); + if ((l > 0) && (strcmp(telbuf,oldanswer))){ + char date[11]; + sscanf(telbuf,"%s %s %s %s",date,(*t).time,(*t).number,(*t).msn); + date[4]='\0'; + date[7]='\0'; + sprintf((*t).date,"%s.%s.%s",date+8,date+5,date); + phonebook((*t).number); + phonebook((*t).msn); + } + close (telmond_fd); + strcpy(oldanswer,telbuf); + } + } + return 0; +} + + -- cgit v1.2.3