# include <sys/types.h>
#endif
+#include <glib.h>
+
+#include <stdio.h>
#include <time.h>
#include <string.h>
#include <gtk/gtk.h>
#include <epan/epan.h>
+#include <epan/address.h>
#include <epan/packet.h>
#include <epan/tap.h>
#include <epan/strutil.h>
-#include "../globals.h"
-#include "../register.h"
#include "../alert_box.h"
#include "../simple_dialog.h"
#include <winsock2.h>
#endif
-gint32 trigger=50; /* limit for triggering the burst alarm (in packets per second) */
-gint32 bufferalarm = 10000; /* limit for triggernig the buffer alarm (in bytes) */
-guint16 burstint = 100; /* burts interval in ms */
-gint32 emptyspeed = 5000; /* outgoing speed for single stream (kbps)*/
-gint32 cumulemptyspeed = 100000; /* outgoiong speed for all streams (kbps)*/
-
-t_buffer **bufflist;
+gint32 mcast_stream_trigger = 50; /* limit for triggering the burst alarm (in packets per second) */
+gint32 mcast_stream_bufferalarm = 10000; /* limit for triggernig the buffer alarm (in bytes) */
+guint16 mcast_stream_burstint = 100; /* burst interval in ms */
+gint32 mcast_stream_emptyspeed = 5000; /* outgoing speed for single stream (kbps)*/
+gint32 mcast_stream_cumulemptyspeed = 100000; /* outgoiong speed for all streams (kbps)*/
/* sliding window and buffer usage */
-gint32 buffsize = (int)((double)MAX_SPEED * 100 / 1000) * 2;
-guint16 comparetimes(struct timeval *t1, struct timeval *t2, guint16 burstint);
-static void buffusagecalc(mcast_stream_info_t *strinfo, packet_info *pinfo, double emptyspeed);
-static void slidingwindow(mcast_stream_info_t *strinfo, packet_info *pinfo);
+static gint32 buffsize = (int)((double)MAX_SPEED * 100 / 1000) * 2;
+static guint16 comparetimes(struct timeval *t1, struct timeval *t2, guint16 burstint_lcl);
+static void buffusagecalc(mcast_stream_info_t *strinfo, packet_info *pinfo, double emptyspeed_lcl);
+static void slidingwindow(mcast_stream_info_t *strinfo, packet_info *pinfo);
/****************************************************************************/
/****************************************************************************/
/* GCompareFunc style comparison function for _mcast_stream_info */
-static gint mcast_stream_info_cmp(gconstpointer aa, gconstpointer bb)
+static gint
+mcast_stream_info_cmp(gconstpointer aa, gconstpointer bb)
{
const struct _mcast_stream_info* a = aa;
const struct _mcast_stream_info* b = bb;
/****************************************************************************/
/* when there is a [re]reading of packet's */
-void mcaststream_reset(mcaststream_tapinfo_t *tapinfo)
+void
+mcaststream_reset(mcaststream_tapinfo_t *tapinfo)
{
GList* list;
return;
}
-static void mcaststream_reset_cb(void *arg)
+static void
+mcaststream_reset_cb(void *arg)
{
mcaststream_reset(arg);
}
/****************************************************************************/
/* redraw the output */
-static void mcaststream_draw(void *arg _U_)
+static void
+mcaststream_draw(void *arg _U_)
{
/* XXX: see mcaststream_on_update in mcast_streams_dlg.c for comments
g_signal_emit_by_name(top_level, "signal_mcaststream_update");
/****************************************************************************/
/* whenever a udp packet is seen by the tap listener */
-static int mcaststream_packet(void *arg, packet_info *pinfo, epan_dissect_t *edt _U_, const void *arg2 _U_)
+static int
+mcaststream_packet(void *arg, packet_info *pinfo, epan_dissect_t *edt _U_, const void *arg2 _U_)
{
mcaststream_tapinfo_t *tapinfo = arg;
mcast_stream_info_t tmp_strinfo;
* address (for IPv6).
*/
if ((pinfo->dl_dst.type != AT_ETHER) ||
- ((strncmp("01005E", bytes_to_str(pinfo->dl_dst.data, pinfo->dl_dst.len), 6) != 0) &&
- (strncmp("3333", bytes_to_str(pinfo->dl_dst.data, pinfo->dl_dst.len), 4) != 0)) )
+ ((g_ascii_strncasecmp("01005E", bytes_to_str(pinfo->dl_dst.data, pinfo->dl_dst.len), 6) != 0) &&
+ (g_ascii_strncasecmp("3333", bytes_to_str(pinfo->dl_dst.data, pinfo->dl_dst.len), 4) != 0)) )
return 0;
- /* check wether we already have a stream with these parameters in the list */
+ /* check whether we already have a stream with these parameters in the list */
list = g_list_first(tapinfo->strinfo_list);
while (list)
{
/* sliding window and buffercalc for this group*/
slidingwindow(strinfo, pinfo);
- buffusagecalc(strinfo, pinfo, emptyspeed*1000);
+ buffusagecalc(strinfo, pinfo, mcast_stream_emptyspeed*1000);
/* sliding window and buffercalc for all groups */
slidingwindow(tapinfo->allstreams, pinfo);
- buffusagecalc(tapinfo->allstreams, pinfo, cumulemptyspeed*1000);
+ buffusagecalc(tapinfo->allstreams, pinfo, mcast_stream_cumulemptyspeed*1000);
/* end of sliding window */
return 1; /* refresh output */
/****************************************************************************/
/* scan for Mcast streams */
-void mcaststream_scan(void)
+void
+mcaststream_scan(void)
{
gboolean was_registered = the_tapinfo_struct.is_registered;
if (!the_tapinfo_struct.is_registered)
register_tap_listener_mcast_stream();
- cf_retap_packets(&cfile, FALSE);
+ cf_retap_packets(&cfile);
if (!was_registered)
remove_tap_listener_mcast_stream();
/****************************************************************************/
-const mcaststream_tapinfo_t* mcaststream_get_info(void)
+const mcaststream_tapinfo_t *
+mcaststream_get_info(void)
{
return &the_tapinfo_struct;
}
GString *error_string;
if (!the_tapinfo_struct.is_registered) {
error_string = register_tap_listener("udp", &the_tapinfo_struct,
- NULL, mcaststream_reset_cb, mcaststream_packet,
+ NULL, 0, mcaststream_reset_cb, mcaststream_packet,
mcaststream_draw);
if (error_string != NULL) {
/* sliding window and buffer calculations */
/* compare two times */
-guint16 comparetimes(struct timeval *t1, struct timeval *t2, guint16 burstint){
- if(((t2->tv_sec - t1->tv_sec)*1000 + (t2->tv_usec - t1->tv_usec)/1000) > burstint){
- return 1;
- } else{
- return 0;
- }
+static guint16
+comparetimes(struct timeval *t1, struct timeval *t2, guint16 burstint_lcl)
+{
+ if(((t2->tv_sec - t1->tv_sec)*1000 + (t2->tv_usec - t1->tv_usec)/1000) > burstint_lcl){
+ return 1;
+ } else{
+ return 0;
+ }
}
/* calculate buffer usage */
-void buffusagecalc(mcast_stream_info_t *strinfo, packet_info *pinfo, double emptyspeed)
+static void
+buffusagecalc(mcast_stream_info_t *strinfo, packet_info *pinfo, double emptyspeed_lcl)
{
- gint32 sec=0, usec=0, cur, prev;
- struct timeval *buffer;
- double timeelapsed;
-
- buffer = strinfo->element.buff;
- cur = strinfo->element.last;
- if(cur == 0){
- cur = buffsize - 1;
- prev = cur - 1;
- } else if(cur == 1){
- prev = buffsize - 1;
- cur = 0;
- } else{
- cur=cur-1;
- prev=cur-1;
- }
-
- sec = buffer[cur].tv_sec - buffer[prev].tv_sec;
- usec = buffer[cur].tv_usec - buffer[prev].tv_usec;
- timeelapsed = (double)usec/1000000 + (double)sec;
-
- /* bytes added to buffer */
- strinfo->element.buffusage+=pinfo->fd->pkt_len;
-
- /* bytes cleared from buffer */
- strinfo->element.buffusage-= (guint32) (timeelapsed * emptyspeed / 8);
-
- if(strinfo->element.buffusage < 0) strinfo->element.buffusage=0;
- if(strinfo->element.buffusage > strinfo->element.topbuffusage)
- strinfo->element.topbuffusage = strinfo->element.buffusage;
- /* check for buffer losses */
- if((strinfo->element.buffusage >= bufferalarm) && (strinfo->element.buffstatus == 0)){
- strinfo->element.buffstatus = 1;
- strinfo->element.numbuffalarms++;
- } else if(strinfo->element.buffusage < bufferalarm){
- strinfo->element.buffstatus = 0;
- }
-
- return;
+ gint32 sec=0, usec=0, cur, prev;
+ struct timeval *buffer;
+ double timeelapsed;
+
+ buffer = strinfo->element.buff;
+ cur = strinfo->element.last;
+ if(cur == 0){
+ cur = buffsize - 1;
+ prev = cur - 1;
+ } else if(cur == 1){
+ prev = buffsize - 1;
+ cur = 0;
+ } else{
+ cur=cur-1;
+ prev=cur-1;
+ }
+
+ sec = buffer[cur].tv_sec - buffer[prev].tv_sec;
+ usec = buffer[cur].tv_usec - buffer[prev].tv_usec;
+ timeelapsed = (double)usec/1000000 + (double)sec;
+
+ /* bytes added to buffer */
+ strinfo->element.buffusage+=pinfo->fd->pkt_len;
+
+ /* bytes cleared from buffer */
+ strinfo->element.buffusage-= (guint32) (timeelapsed * emptyspeed_lcl / 8);
+
+ if(strinfo->element.buffusage < 0) strinfo->element.buffusage=0;
+ if(strinfo->element.buffusage > strinfo->element.topbuffusage)
+ strinfo->element.topbuffusage = strinfo->element.buffusage;
+ /* check for buffer losses */
+ if((strinfo->element.buffusage >= mcast_stream_bufferalarm) && (strinfo->element.buffstatus == 0)){
+ strinfo->element.buffstatus = 1;
+ strinfo->element.numbuffalarms++;
+ } else if(strinfo->element.buffusage < mcast_stream_bufferalarm){
+ strinfo->element.buffstatus = 0;
+ }
+
+ return;
}
/* sliding window calculation */
-void slidingwindow(mcast_stream_info_t *strinfo, packet_info *pinfo)
+static void
+slidingwindow(mcast_stream_info_t *strinfo, packet_info *pinfo)
{
- struct timeval *buffer;
- gint32 diff;
-
- buffer = strinfo->element.buff;
-
- diff = strinfo->element.last - strinfo->element.first;
- if(diff < 0) diff+=buffsize;
-
- /* check if buffer is full */
- if(diff >= (buffsize - 2)){
- fprintf(stderr, "Warning: capture buffer full\n");
- strinfo->element.first++;
- if(strinfo->element.first >= buffsize) strinfo->element.first = strinfo->element.first % buffsize;
- }
-
- /* burst count */
- buffer[strinfo->element.last].tv_sec = (guint32) pinfo->fd->rel_ts.secs;
- buffer[strinfo->element.last].tv_usec = pinfo->fd->rel_ts.nsecs/1000;
- while(comparetimes((struct timeval *)&(buffer[strinfo->element.first]),
- (struct timeval *)&(buffer[strinfo->element.last]), burstint)){
- strinfo->element.first++;
- if(strinfo->element.first >= buffsize) strinfo->element.first = strinfo->element.first % buffsize;
- diff--;
- }
- strinfo->element.burstsize = diff;
- if(strinfo->element.burstsize > strinfo->element.topburstsize) {
- strinfo->element.topburstsize = strinfo->element.burstsize;
- strinfo->element.maxbw = (float)(strinfo->element.topburstsize) * 1000 / burstint * pinfo->fd->pkt_len * 8 / 1000000;
- }
-
- strinfo->element.last++;
- if(strinfo->element.last >= buffsize) strinfo->element.last = strinfo->element.last % buffsize;
- /* trigger check */
- if((strinfo->element.burstsize >= trigger) && (strinfo->element.burststatus == 0)){
- strinfo->element.burststatus = 1;
- strinfo->element.numbursts++;
- } else if(strinfo->element.burstsize < trigger){
- strinfo->element.burststatus = 0;
- }
-
- strinfo->element.count++;
+ struct timeval *buffer;
+ gint32 diff;
+
+ buffer = strinfo->element.buff;
+
+ diff = strinfo->element.last - strinfo->element.first;
+ if(diff < 0) diff+=buffsize;
+
+ /* check if buffer is full */
+ if(diff >= (buffsize - 2)){
+ fprintf(stderr, "Warning: capture buffer full\n");
+ strinfo->element.first++;
+ if(strinfo->element.first >= buffsize) strinfo->element.first = strinfo->element.first % buffsize;
+ }
+
+ /* burst count */
+ buffer[strinfo->element.last].tv_sec = (guint32) pinfo->fd->rel_ts.secs;
+ buffer[strinfo->element.last].tv_usec = pinfo->fd->rel_ts.nsecs/1000;
+ while(comparetimes((struct timeval *)&(buffer[strinfo->element.first]),
+ (struct timeval *)&(buffer[strinfo->element.last]), mcast_stream_burstint)){
+ strinfo->element.first++;
+ if(strinfo->element.first >= buffsize) strinfo->element.first = strinfo->element.first % buffsize;
+ diff--;
+ }
+ strinfo->element.burstsize = diff;
+ if(strinfo->element.burstsize > strinfo->element.topburstsize) {
+ strinfo->element.topburstsize = strinfo->element.burstsize;
+ strinfo->element.maxbw = (float)(strinfo->element.topburstsize) * 1000 / mcast_stream_burstint * pinfo->fd->pkt_len * 8 / 1000000;
+ }
+
+ strinfo->element.last++;
+ if(strinfo->element.last >= buffsize) strinfo->element.last = strinfo->element.last % buffsize;
+ /* trigger check */
+ if((strinfo->element.burstsize >= mcast_stream_trigger) && (strinfo->element.burststatus == 0)){
+ strinfo->element.burststatus = 1;
+ strinfo->element.numbursts++;
+ } else if(strinfo->element.burstsize < mcast_stream_trigger){
+ strinfo->element.burststatus = 0;
+ }
+
+ strinfo->element.count++;
}
git.samba.org / obnox / wireshark / wip.git / blobdiff