← Back to branch summary

~ubuntu-branches/ubuntu/wily/ntop/wily-proposed

« back to all changes in this revision

Viewing changes to ntop/plugins/wapPlugin.c

  • Committer: Bazaar Package Importer
  • Author(s): Dennis Schoen
  • Date: 2002-04-12 11:38:47 UTC
  • Revision ID: james.westby@ubuntu.com-20020412113847-4k4yydw0pzybc6g8
Tags: upstream-2.0.0
Import upstream version 2.0.0

Show diffs side-by-side

added added

removed removed

Lines of Context:
ntop/plugins/wapPlugin.c
 
1
/*
 
2
 *  Copyright (C) 2001 Luca Deri <deri@ntop.org>
 
3
 *                      
 
4
 *                     http://www.ntop.org/
 
5
 *                                      
 
6
 *  This program is free software; you can redistribute it and/or modify
 
7
 *  it under the terms of the GNU General Public License as published by
 
8
 *  the Free Software Foundation; either version 2 of the License, or
 
9
 *  (at your option) any later version.
 
10
 *
 
11
 *  This program is distributed in the hope that it will be useful,
 
12
 *  but WITHOUT ANY WARRANTY; without even the implied warranty of
 
13
 *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 
14
 *  GNU General Public License for more details.
 
15
 *
 
16
 *  You should have received a copy of the GNU General Public License
 
17
 *  along with this program; if not, write to the Free Software
 
18
 *  Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
 
19
 */
 
20
 
 
21
#include "ntop.h"
 
22
#include "globals-report.h"
 
23
 
 
24
#ifndef MICRO_NTOP
 
25
static int wapColumnSort = 0;
 
26
 
 
27
/* ****************************** */
 
28
 
 
29
void printWMLheader(void)  {
 
30
  sendHTTPHeader(HTTP_TYPE_NONE, HTTP_FLAG_NO_CACHE_CONTROL | HTTP_FLAG_MORE_FIELDS);
 
31
  sendString("Content-Type: text/vnd.wap.wml;charset=UTF-8\n\n"); 
 
32
}
 
33
 
 
34
/* ********************** */
 
35
 
 
36
static void printWmlNotFoundError(void) {
 
37
 
 
38
}
 
39
 
 
40
/* ********************** */
 
41
 
 
42
static void printWmlNoDataYet(void) {
 
43
 
 
44
}
 
45
 
 
46
/* ********************** */
 
47
 
 
48
static int cmpWapFctn(const void *_a, const void *_b) {
 
49
  HostTraffic **a = (HostTraffic **)_a;
 
50
  HostTraffic **b = (HostTraffic **)_b;
 
51
  TrafficCounter a_, b_;
 
52
 
 
53
  if((a == NULL) && (b != NULL)) {
 
54
    traceEvent(TRACE_WARNING, "WARNING (1)\n");
 
55
    return(1);
 
56
  } else if((a != NULL) && (b == NULL)) {
 
57
    traceEvent(TRACE_WARNING, "WARNING (2)\n");
 
58
    return(-1);
 
59
  } else if((a == NULL) && (b == NULL)) {
 
60
    traceEvent(TRACE_WARNING, "WARNING (3)\n");
 
61
    return(0);
 
62
  }
 
63
 
 
64
  if(wapColumnSort == 0) {
 
65
    /* Data Sent */
 
66
    a_ = (*a)->bytesSent;
 
67
    b_ = (*b)->bytesSent;
 
68
  } else  {
 
69
    /* Data Rcvd */
 
70
    a_ = (*a)->bytesReceived;
 
71
    b_ = (*b)->bytesReceived;
 
72
  }
 
73
 
 
74
  if(a_ < b_)
 
75
    return(1);
 
76
  else if (a_ > b_)
 
77
    return(-1);
 
78
  else
 
79
    return(0);
 
80
}
 
81
 
 
82
/* ********************** */
 
83
 
 
84
static void printWmlIndex(void) {
 
85
  int diff;
 
86
  u_int idx, numEntries=0;
 
87
  HostTraffic *el;
 
88
  HostTraffic* tmpTable[HASHNAMESIZE];
 
89
  char *tmpName, buf[BUF_SIZE];
 
90
  TrafficCounter unicastPkts=0;
 
91
 
 
92
  printWMLheader();
 
93
 
 
94
  for(idx=1; idx<device[actualDeviceId].actualHashSize; idx++)
 
95
    if(((el = device[actualDeviceId].hash_hostTraffic[idx]) != NULL) 
 
96
       && (!broadcastHost(el)))
 
97
      tmpTable[numEntries++]=el;
 
98
  
 
99
  if(numEntries == 0) {
 
100
    printWmlNoDataYet();
 
101
    return;
 
102
  }
 
103
 
 
104
  sendString("<?xml version=\"1.0\"?>\n");
 
105
  sendString("<!DOCTYPE wml PUBLIC \"-//WAPFORUM//DTD WML 1.1//EN\" \"http:///www.wapforum.org/DTD/wml_1.1.xml\">\n\n");
 
106
  sendString("<wml>\n");
 
107
  sendString("  <card id=\"home\" title=\"ntop for Wap\">\n");
 
108
  sendString("  <p>\n");
 
109
  sendString("          <a href=\"#senders\">Top Senders</a><br/>\n");
 
110
  sendString("          <a href=\"#receivers\">Top Receivers</a><br/>\n");
 
111
  sendString("          <a href=\"#stats\">Stats</a><br/>\n");
 
112
  sendString("  </p>\n");
 
113
  sendString("  </card>\n");
 
114
  sendString("  <card id=\"senders\" title=\"Top Senders\"> \n");
 
115
  sendString("  <p>\n");
 
116
  sendString("  <table columns=\"2\" align=\"LCC\">\n");
 
117
  sendString("          <tr><td><b>Host</b></td><td><b>Total</b></td></tr>\n");
 
118
  
 
119
  /* Data Sent */
 
120
  wapColumnSort = 0;  
 
121
  quicksort(tmpTable, numEntries, sizeof(HostTraffic*), cmpWapFctn); 
 
122
  
 
123
  for(idx=0; idx<numEntries; idx++) {
 
124
    if(idx == 5) break;
 
125
 
 
126
    el = tmpTable[idx];
 
127
    tmpName = getHostName(el, 0);
 
128
 
 
129
    if((strcmp(tmpName, "0.0.0.0") == 0) || (tmpName[0] == '\0'))
 
130
      tmpName = el->ethAddressString;
 
131
            
 
132
    if(snprintf(buf, sizeof(buf),
 
133
            "<tr><td><a href=\"/ntop/host.wml?%s\">%s</a></td>"
 
134
            "<td>%s</td></tr>\n",
 
135
            tmpName, tmpName,       
 
136
            formatBytes(el->bytesSent, 1)) < 0) 
 
137
      traceEvent(TRACE_ERROR, "Buffer overflow!");
 
138
    sendString(buf);
 
139
  }
 
140
 
 
141
  sendString("</table>\n");
 
142
  sendString("  <a href=\"#home\">[Back Home]</a><br/>\n");
 
143
  sendString("  </p>\n");
 
144
  sendString("  </card>\n");
 
145
  sendString("  <card id=\"receivers\" title=\"Top Receivers\">\n");
 
146
  sendString("  <p>\n");
 
147
  sendString("  <table columns=\"2\" align=\"LCC\">\n");
 
148
  sendString("  <tr><td><b>Host</b></td><td><b>Total</b></td></tr>\n");
 
149
 
 
150
  /* Data Rcvd */
 
151
  wapColumnSort = 1;  
 
152
  quicksort(tmpTable, numEntries, sizeof(HostTraffic*), cmpFctn); 
 
153
 
 
154
  for(idx=0; idx<numEntries; idx++) {
 
155
    if(idx == 5) break;
 
156
 
 
157
    el = tmpTable[idx];
 
158
    tmpName = getHostName(el, 0);
 
159
 
 
160
    if((strcmp(tmpName, "0.0.0.0") == 0) || (tmpName[0] == '\0'))
 
161
      tmpName = el->ethAddressString;
 
162
            
 
163
    if(snprintf(buf, sizeof(buf), 
 
164
            "<tr><td><a href=\"/ntop/host.wml?%s\">%s</a></td>"
 
165
            "<td>%s</td></tr>\n",
 
166
            tmpName, tmpName,       
 
167
            formatBytes(el->bytesReceived, 1)) < 0) 
 
168
      traceEvent(TRACE_ERROR, "Buffer overflow!");
 
169
    sendString(buf);
 
170
  }
 
171
 
 
172
  sendString("</table>\n");
 
173
  sendString("  <a href=\"#home\">[Back Home]</a><br/>\n");
 
174
  sendString("  </p>\n");
 
175
  sendString("  </card>\n");
 
176
  /* ************************* */
 
177
 
 
178
  sendString("  <card id=\"stats\" title=\"Traffic Stats\">\n");
 
179
  sendString("  <p>\n");
 
180
  sendString("  <table columns=\"2\" align=\"LCC\">\n");
 
181
 
 
182
  /** **/
 
183
 
 
184
  if(snprintf(buf, sizeof(buf),"<tr><td>Sampling&nbsp;Time</td>"
 
185
          "<td>%s</td></tr>\n",
 
186
          formatSeconds(actTime-initialSniffTime)) < 0) 
 
187
    traceEvent(TRACE_ERROR, "Buffer overflow!");
 
188
  sendString(buf);
 
189
 
 
190
  /** **/
 
191
  
 
192
  diff = (int)(device[actualDeviceId].ethernetPkts -
 
193
               device[actualDeviceId].broadcastPkts -
 
194
               device[actualDeviceId].multicastPkts);
 
195
  if(diff > 0)
 
196
    unicastPkts = 0; /* It shouldn't happen */
 
197
  else 
 
198
    unicastPkts = (TrafficCounter)diff; 
 
199
 
 
200
  if(device[actualDeviceId].ethernetPkts <= 0) device[actualDeviceId].ethernetPkts = 1;
 
201
        
 
202
  if(snprintf(buf, sizeof(buf),"<tr><td>Total</td><td>%s</td></tr>\n",
 
203
          formatPkts(device[actualDeviceId].ethernetPkts)) < 0) 
 
204
    traceEvent(TRACE_ERROR, "Buffer overflow!");
 
205
  sendString(buf);
 
206
 
 
207
  if(snprintf(buf, sizeof(buf),"<tr><td>Unicast</td>"
 
208
          "<td>%s [%.1f%%]</td></tr>\n", 
 
209
          formatPkts(unicastPkts),
 
210
          (float)(100*unicastPkts)/(float)device[actualDeviceId].ethernetPkts) < 0) 
 
211
    traceEvent(TRACE_ERROR, "Buffer overflow!");
 
212
  sendString(buf);
 
213
  if(snprintf(buf, sizeof(buf),"<tr><td>Broadcast</td>"
 
214
          "<td>%s [%.1f%%]</td></tr>\n", 
 
215
          formatPkts(device[actualDeviceId].broadcastPkts),
 
216
          (float)(100*device[actualDeviceId].broadcastPkts)
 
217
           /(float)device[actualDeviceId].ethernetPkts) < 0) 
 
218
    traceEvent(TRACE_ERROR, "Buffer overflow!");
 
219
  sendString(buf);
 
220
 
 
221
  if(device[actualDeviceId].multicastPkts > 0) {
 
222
    if(snprintf(buf, sizeof(buf),"<tr><td>Multicast</td>"
 
223
            "<td>%s [%.1f%%]</td></tr>\n", 
 
224
            formatPkts(device[actualDeviceId].multicastPkts),
 
225
            (float)(100*device[actualDeviceId].multicastPkts)
 
226
             /(float)device[actualDeviceId].ethernetPkts) < 0) 
 
227
      traceEvent(TRACE_ERROR, "Buffer overflow!");
 
228
    sendString(buf);
 
229
  }
 
230
 
 
231
  /** **/
 
232
  sendString("</table>\n");
 
233
  sendString("  <a href=\"#home\">[Back Home]</a><br/>\n");
 
234
  sendString("  </p>\n");
 
235
  sendString("  </card>\n");
 
236
 
 
237
  /* ************************* */
 
238
 
 
239
  sendString("</wml>\n");
 
240
}
 
241
 
 
242
/* ********************** */
 
243
 
 
244
static void printWmlHostInfo(char *host _UNUSED_) {
 
245
 
 
246
}
 
247
 
 
248
/* ********************** */
 
249
 
 
250
static void handleWAPrequest(char* url) {
 
251
 
 
252
  if((url == NULL) 
 
253
     || (url[0] == 0) 
 
254
     || (strncmp(url, "index.wml", 
 
255
                 strlen("index.wml")) == 0))  {
 
256
    printWmlIndex();
 
257
  } else if(strncmp(url, "host.wml", strlen("host.wml")) == 0)
 
258
    printWmlHostInfo(&url[strlen("host.wml")+1]);
 
259
  else
 
260
    printWmlNotFoundError();
 
261
}
 
262
 
 
263
/* ****************************** */
 
264
 
 
265
static void termWapFunct(void) {
 
266
  traceEvent(TRACE_INFO, "Thanks for using wapWatch...\n");
 
267
  traceEvent(TRACE_INFO, "Done.\n");
 
268
}
 
269
 
 
270
#endif /* MICRO_NTOP */
 
271
 
 
272
/* ****************************** */
 
273
 
 
274
static PluginInfo WAPPluginInfo[] = {
 
275
  { "WAPPlugin",
 
276
    "ntop WAP (Wireless Application protocol) Interface",
 
277
    "1.0",           /* version */
 
278
    "<A HREF=http://luca.ntop.org/>L.Deri</A>", 
 
279
    "WAPPlugin",      /* http://<host>:<port>/plugins/WAPPlugin */
 
280
    0, /* Not Active */
 
281
    NULL, /* no special startup after init */
 
282
#ifndef MICRO_NTOP
 
283
    termWapFunct,    /* TermFunc   */
 
284
#else
 
285
    NULL,
 
286
#endif
 
287
    NULL,    /* PluginFunc */
 
288
#ifndef MICRO_NTOP
 
289
    handleWAPrequest,
 
290
#else
 
291
    NULL,
 
292
#endif
 
293
    NULL,
 
294
    NULL /* BPF Filter */
 
295
  }
 
296
};
 
297
 
 
298
/* Plugin entry fctn */
 
299
#ifdef STATIC_PLUGIN
 
300
PluginInfo* wapPluginEntryFctn(void) {
 
301
#else
 
302
PluginInfo* PluginEntryFctn(void) {
 
303
#endif
 
304
  traceEvent(TRACE_INFO, "Welcome to %s. (C) 2000 by Luca Deri.\n",  
 
305
         WAPPluginInfo->pluginName);
 
306
 
 
307
  return(WAPPluginInfo);
 
308
}