mcast_stream.h

Go to the documentation of this file.

 
#ifndef __MCAST_STREAM_H__
#define __MCAST_STREAM_H__
 
#include <epan/tap.h>
 
#ifdef __cplusplus
extern "C" {
#endif /* __cplusplus */
 
#define MAX_SPEED 200000
 
/* typedefs for sliding window and buffer size */

typedef struct buffer {
    nstime_t *buff;          
    int32_t first;           
    int32_t last;            
    int32_t burstsize;       
    int32_t topburstsize;    
    int32_t count;           
    int32_t burststatus;     
    int32_t numbursts;       
    int32_t buffusage;       
    int32_t buffstatus;      
    int32_t numbuffalarms;   
    int32_t topbuffusage;    
    double maxbw;            
} t_buffer;
 
 
/* defines an mcast stream */
/* XXX - Not all of these seem to be used? */

typedef struct _mcast_stream_info {
    address src_addr;           
    uint16_t src_port;          
    address dest_addr;          
    uint16_t dest_port;         
    uint32_t npackets;          
    double apackets;            
    uint64_t total_bytes;       
    double average_bw;          
 
    uint32_t first_frame_num;   
    nstime_t start_abs;         
    nstime_t start_rel;         
    nstime_t stop_rel;          
 
    t_buffer element;           
} mcast_stream_info_t;

typedef struct _mcaststream_tapinfo mcaststream_tapinfo_t;

typedef void (*mcaststream_tap_reset_cb)(mcaststream_tapinfo_t *tapinfo);

typedef void (*mcaststream_tap_draw_cb)(mcaststream_tapinfo_t *tapinfo);

struct _mcaststream_tapinfo {
    void *user_data;                     
    mcaststream_tap_reset_cb tap_reset;  
    mcaststream_tap_draw_cb tap_draw;    
    GList *strinfo_list;                 
    uint32_t npackets;                   
    mcast_stream_info_t *allstreams;     
    bool is_registered;                  
};

extern int32_t mcast_stream_trigger;

extern int32_t mcast_stream_bufferalarm;

extern uint16_t mcast_stream_burstint;

extern int32_t mcast_stream_emptyspeed;

extern int32_t mcast_stream_cumulemptyspeed;
 
/****************************************************************************/
/* INTERFACE */

GString *register_tap_listener_mcast_stream(mcaststream_tapinfo_t *tapinfo);
 

void remove_tap_listener_mcast_stream(mcaststream_tapinfo_t *tapinfo);

void mcaststream_reset(mcaststream_tapinfo_t *tapinfo);

tap_packet_status mcaststream_packet(void *tapdata, packet_info *pinfo, epan_dissect_t *edt, const void *data, tap_flags_t flags);
 
#ifdef __cplusplus
}
#endif /* __cplusplus */
 
#endif /* __MCAST_STREAM_H__ */