aboutsummaryrefslogtreecommitdiffstats
path: root/plugin_ppp.c
blob: 44d55ad5d7e6215e4a7aa2095be796c63404b0ef (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
/* $Id: plugin_ppp.c,v 1.4 2004/03/03 04:44:16 reinelt Exp $
 *
 * plugin for ppp throughput
 *
 * Copyright 2003 Michael Reinelt <reinelt@eunet.at>
 * Copyright 2004 The LCD4Linux Team <lcd4linux-devel@users.sourceforge.net>
 *
 * 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_ppp.c,v $
 * Revision 1.4  2004/03/03 04:44:16  reinelt
 * changes (cosmetics?) to the big patch from Martin
 * hash patch un-applied
 *
 * Revision 1.3  2004/03/03 03:47:04  reinelt
 * big patch from Martin Hejl:
 * - use qprintf() where appropriate
 * - save CPU cycles on gettimeofday()
 * - add quit() functions to free allocated memory
 * - fixed lots of memory leaks
 *
 * Revision 1.2  2004/01/28 06:43:31  reinelt
 * plugin_ppp finished.
 *
 * Revision 1.1  2004/01/27 08:13:39  reinelt
 * ported PPP token to plugin_ppp
 *
 */

/* 
 * exported functions:
 *
 * int plugin_init_ppp (void)
 *  adds ppp() function
 *
 */

#include "config.h"

#include <stdlib.h>
#include <stdio.h>
#include <string.h>
#include <errno.h>
#include <sys/ioctl.h>

#ifdef HAVE_NET_IF_PPP_H
#include <net/if_ppp.h>
#else
#warning if_ppp.h not found. PPP support deactivated.
#endif

#include "debug.h"
#include "plugin.h"
#include "qprintf.h"
#include "hash.h"

#ifdef HAVE_NET_IF_PPP_H

static HASH PPP = { 0, };

static int get_ppp_stats (void)
{
  int age;
  int unit;
  unsigned ibytes, obytes;
  static int fd=-2;
  struct ifpppstatsreq req;
  char key[16], val[16];

  // reread every 10 msec only
  age=hash_age(&PPP, NULL, NULL);
  if (age>0 && age<=10) return 0;
  
  // open socket only once
  if (fd==-2) {
    fd = socket(AF_INET, SOCK_DGRAM, 0);
    if (fd==-1) {
      error ("socket() failed: %s", strerror(errno));
      return -1;
    }
  }
  
  for (unit=0; unit<8; unit++) {
    memset (&req, 0, sizeof (req));
    req.stats_ptr = (caddr_t) &req.stats;
    qprintf(req.ifr__name, sizeof(req.ifr__name), "ppp%d", unit);
    
    if (ioctl(fd, SIOCGPPPSTATS, &req) == 0) {
      ibytes=req.stats.p.ppp_ibytes;
      obytes=req.stats.p.ppp_obytes;
    } else {
      ibytes=obytes=0;
    }
    qprintf(key, sizeof(key), "Rx:%d", unit);
    qprintf(val, sizeof(val), "%d", ibytes);
    hash_set_delta (&PPP, key, val);
    qprintf(key, sizeof(key), "Tx:%d", unit);
    qprintf(val, sizeof(val), "%d", obytes);
    hash_set_delta (&PPP, key, val);

  }
  return 0;
}


static void my_ppp (RESULT *result, RESULT *arg1, RESULT *arg2)
{
  double value;
  
  if (get_ppp_stats()<0) {
    SetResult(&result, R_STRING, ""); 
    return;
  }
  value=hash_get_delta(&PPP, R2S(arg1), R2N(arg2));
  SetResult(&result, R_NUMBER, &value); 
}

#endif


int plugin_init_ppp (void)
{
#ifdef HAVE_NET_IF_PPP_H
  AddFunction ("ppp", 3, my_ppp);
#endif
  return 0;
}

void plugin_exit_ppp(void) 
{
	hash_destroy(&PPP);
}
span class="nb">NULL; static usb_dev_handle *lcd; extern int got_signal; /****************************************/ /*** hardware dependant functions ***/ /****************************************/ static int drv_IRLCD_open(char *bus_id, char *device_id) { struct usb_bus *busses, *bus; struct usb_device *dev; lcd = NULL; info("%s: scanning USB for IRLCD interface ...", Name); if (bus_id != NULL) info("%s: scanning for bus id: %s", Name, bus_id); if (device_id != NULL) info("%s: scanning for device id: %s", Name, device_id); usb_set_debug(0); usb_init(); usb_find_busses(); usb_find_devices(); busses = usb_get_busses(); for (bus = busses; bus; bus = bus->next) { /* search this bus if no bus id was given or if this is the given bus id */ if (!bus_id || (bus_id && !strcasecmp(bus->dirname, bus_id))) { for (dev = bus->devices; dev; dev = dev->next) { /* search this device if no device id was given or if this is the given device id */ if (!device_id || (device_id && !strcasecmp(dev->filename, device_id))) { if ((dev->descriptor.idVendor == LCD_USB_VENDOR) && (dev->descriptor.idProduct == LCD_USB_DEVICE)) { info("%s: found IRLCD interface on bus %s device %s", Name, bus->dirname, dev->filename); lcd = usb_open(dev); if (usb_claim_interface(lcd, 0) < 0) { error("%s: usb_claim_interface() failed!", Name); return -1; } return 0; } } } } } return -1; } static int drv_IRLCD_close(void) { usb_release_interface(lcd, 0); usb_close(lcd); return 0; } /* Send a buffer to lcd via a control message */ static int drv_IRLCD_send(int request, unsigned char *buffer, int size) { if (usb_control_msg(lcd, USB_TYPE_VENDOR | USB_RECIP_DEVICE | USB_ENDPOINT_OUT, /* bRequestType */ request, /* bRequest (LCD_INSTR / LCD_DATA) */ 0, /* wValue (0) */ 0, /* wIndex (0) */ (char *) buffer, /* pointer to destination buffer */ size, /* wLength */ 1000) < 0) { /* Timeout in millisectonds */ error("%s: USB request failed! Trying to reconnect device.", Name); usb_release_interface(lcd, 0); usb_close(lcd); /* try to close and reopen connection */ if (drv_IRLCD_open(bus_id, device_id) < 0) { error("%s: could not re-detect IRLCD USB LCD", Name); got_signal = -1; return -1; } /* and try to re-send command */ if (usb_control_msg(lcd, USB_TYPE_VENDOR | USB_RECIP_DEVICE | USB_ENDPOINT_OUT, /* bRequestType */ request, /* bRequest (LCD_INSTR / LCD_DATA) */ 0, /* wValue (0) */ 0, /* wIndex (0) */ (char *) buffer, /* pointer to destination buffer */ size, /* wLength */ 1000) < 0) { /* Timeout in millisectonds */ error("%s: retried USB request failed, aborting!", Name); got_signal = -1; return -1; } info("%s: Device successfully reconnected.", Name); } return 0; } /* text mode displays only */ static void drv_IRLCD_clear(void) { unsigned char cmd[1]; cmd[0] = 0x01; /* clear */ drv_IRLCD_send(LCD_INSTR, cmd, 1); cmd[0] = 0x03; /* home */ drv_IRLCD_send(LCD_INSTR, cmd, 1); } /* text mode displays only */ static void drv_IRLCD_write(const int row, const int col, const char *data, int len) { unsigned char cmd[1]; static int pos; /* for 2 lines display */ pos = (row % 2) * 64 + (row / 2) * 20 + col; /* do the cursor positioning here */ cmd[0] = 0x80 | pos; /* do positionning */ drv_IRLCD_send(LCD_INSTR, cmd, 1); /* send string to the display */ drv_IRLCD_send(LCD_DATA, (unsigned char *) data, len); } /* text mode displays only */ static void drv_IRLCD_defchar(const int ascii, const unsigned char *matrix) { unsigned char cmd[10]; int i; /* Write to CGRAM */ cmd[0] = 0x40 | 8 * ascii; drv_IRLCD_send(LCD_INSTR, cmd, 1); /* send bitmap to the display */ for (i = 0; i < 8; i++) { cmd[i] = matrix[i] & 0x1f; } drv_IRLCD_send(LCD_DATA, cmd, 8); } /* start text mode display */ static int drv_IRLCD_start(const char *section) { int rows = -1, cols = -1; char *s; s = cfg_get(section, "Size", NULL); if (s == NULL || *s == '\0') { error("%s: no '%s.Size' entry from %s", Name, section, cfg_source()); return -1; } if (sscanf(s, "%dx%d", &cols, &rows) != 2 || rows < 1 || cols < 1) { error("%s: bad %s.Size '%s' from %s", Name, section, s, cfg_source()); free(s); return -1; } DROWS = rows; DCOLS = cols; /* bus id and device id are strings and not just intergers, since */ /* the windows port of libusb treats them as strings. And this way */ /* we keep windows compatibility ... just in case ... */ bus_id = cfg_get(section, "Bus", NULL); device_id = cfg_get(section, "Device", NULL); if (drv_IRLCD_open(bus_id, device_id) < 0) { error("%s: could not find a IRLC USB LCD", Name); return -1; } /* reset & initialize display */ drv_IRLCD_clear(); /* clear display */ return 0; } /****************************************/ /*** plugins ***/ /****************************************/ /* no plugins capabilities */ /****************************************/ /*** widget callbacks ***/ /****************************************/ /* using drv_generic_text_draw(W) */ /* using drv_generic_text_icon_draw(W) */ /* using drv_generic_text_bar_draw(W) */ /* using drv_generic_gpio_draw(W) */ /****************************************/ /*** exported functions ***/ /****************************************/ /* list models */ int drv_IRLCD_list(void) { printf("generic"); return 0; } /* initialize driver & display */ int drv_IRLCD_init(const char *section, const int quiet) { WIDGET_CLASS wc; int asc255bug; int ret; info("%s: %s", Name, "$Rev$"); /* display preferences */ XRES = 5; /* pixel width of one char */ YRES = 8; /* pixel height of one char */ CHARS = 8; /* number of user-defineable characters */ CHAR0 = 0; /* ASCII of first user-defineable char */ GOTO_COST = 2; /* number of bytes a goto command requires */ /* real worker functions */ drv_generic_text_real_write = drv_IRLCD_write; drv_generic_text_real_defchar = drv_IRLCD_defchar; /* start display */ if ((ret = drv_IRLCD_start(section)) != 0) return ret; if (!quiet) { char buffer[40]; qprintf(buffer, sizeof(buffer), "%s %dx%d", Name, DCOLS, DROWS); if (drv_generic_text_greet(buffer, " www.civade.com")) { sleep(3); drv_IRLCD_clear(); } } /* initialize generic text driver */ if ((ret = drv_generic_text_init(section, Name)) != 0) return ret; /* initialize generic icon driver */ if ((ret = drv_generic_text_icon_init()) != 0) return ret; /* initialize generic bar driver */ if ((ret = drv_generic_text_bar_init(0)) != 0) return ret; /* add fixed chars to the bar driver */ /* most displays have a full block on ascii 255, but some have kind of */ /* an 'inverted P'. If you specify 'asc255bug 1 in the config, this */ /* char will not be used, but rendered by the bar driver */ cfg_number(section, "asc255bug", 0, 0, 1, &asc255bug); drv_generic_text_bar_add_segment(0, 0, 255, 32); /* ASCII 32 = blank */ if (!asc255bug) drv_generic_text_bar_add_segment(255, 255, 255, 255); /* ASCII 255 = block */ /* register text widget */ wc = Widget_Text; wc.draw = drv_generic_text_draw; widget_register(&wc); /* register icon widget */ wc = Widget_Icon; wc.draw = drv_generic_text_icon_draw; widget_register(&wc); /* register bar widget */ wc = Widget_Bar; wc.draw = drv_generic_text_bar_draw; widget_register(&wc); return 0; } /* close driver & display */ /* use this function for a text display */ int drv_IRLCD_quit(const int quiet) { info("%s: shutting down.", Name); drv_generic_text_quit(); /* clear display */ drv_IRLCD_clear(); /* say goodbye... */ if (!quiet) { drv_generic_text_greet("goodbye!", NULL); } debug("closing usb connection"); drv_IRLCD_close(); return (0); } /* use this one for a text display */ DRIVER drv_IRLCD = { .name = Name, .list = drv_IRLCD_list, .init = drv_IRLCD_init, .quit = drv_IRLCD_quit, };