tap-rtp-common.h

Go to the documentation of this file.

 
#ifndef __TAP_RTP_COMMON_H__
#define __TAP_RTP_COMMON_H__
 
#include "ui/rtp_stream.h"
 
#ifdef __cplusplus
extern "C" {
#endif /* __cplusplus */
 
typedef enum {
    TAP_RTP_NO_ERROR,          
    TAP_RTP_WRONG_CODEC,       
    TAP_RTP_WRONG_LENGTH,      
    TAP_RTP_PADDING_ERROR,     
    TAP_RTP_SHORT_FRAME,       
    TAP_RTP_FILE_OPEN_ERROR,   
    TAP_RTP_FILE_WRITE_ERROR,  
    TAP_RTP_NO_DATA            
} tap_rtp_error_type_t;
 
 
typedef struct _tap_rtp_save_info_t {
    FILE                 *fp;         
    uint32_t              count;      
    tap_rtp_error_type_t  error_type; 
    bool                  saved;      
} tap_rtp_save_info_t;
 
 
typedef struct _rtpstream_info_calc {
    char    *src_addr_str;            
    uint16_t src_port;                
    char    *dst_addr_str;            
    uint16_t dst_port;                
    uint32_t ssrc;                    
    char    *all_payload_type_names;  
    /* --- Packet counts --- */
    uint32_t packet_count;    
    uint32_t total_nr;        
    uint32_t packet_expected; 
    int32_t  lost_num;        
    double   lost_perc;       
    /* --- Inter-packet timing --- */
    double max_delta;   
    double min_delta;   
    double mean_delta;  
    /* --- Jitter --- */
    double min_jitter;  
    double max_jitter;  
    double mean_jitter; 
    double max_skew;    
    /* --- Stream health --- */
    bool problem; 
    /* --- Clock drift --- */
    double clock_drift_ms;   
    double freq_drift_hz;    
    double freq_drift_perc;  
    /* --- Timing and frame extents --- */
    double   duration_ms;      
    uint32_t sequence_err;     
    double   start_time_ms;    
    uint32_t first_packet_num; 
    uint32_t last_packet_num;  
} rtpstream_info_calc_t;
 
void rtpstream_info_init(rtpstream_info_t* info);
 
rtpstream_info_t *rtpstream_info_malloc_and_init(void);
 
void rtpstream_info_copy_deep(rtpstream_info_t *dest, const rtpstream_info_t *src);
 
rtpstream_info_t *rtpstream_info_malloc_and_copy_deep(const rtpstream_info_t *src);
 
void rtpstream_info_free_data(rtpstream_info_t* info);
 
void rtpstream_info_free_all(rtpstream_info_t* info);
 
int rtpstream_info_cmp(const void *aa, const void *bb);
 
bool rtpstream_info_is_reverse(const rtpstream_info_t *stream_a, rtpstream_info_t *stream_b);
 
bool rtpstream_is_payload_used(const rtpstream_info_t *stream_info, const uint8_t payload_type);
 
/****************************************************************************/
/* INTERFACE */
 
void register_tap_listener_rtpstream(rtpstream_tapinfo_t *tapinfo, const char *fstring, rtpstream_tap_error_cb tap_error);
 
void remove_tap_listener_rtpstream(rtpstream_tapinfo_t *tapinfo);
 
void rtpstream_reset(rtpstream_tapinfo_t *tapinfo);
 
void rtpstream_reset_cb(void *arg);
 
void rtp_write_header(rtpstream_info_t *strinfo, FILE *file);
 
tap_packet_status rtpstream_packet_cb(void *arg, packet_info *pinfo, epan_dissect_t *edt, const void *arg2, tap_flags_t flags);
 
void rtpstream_info_calculate(const rtpstream_info_t *strinfo, rtpstream_info_calc_t *calc);
 
void rtpstream_info_calc_free(rtpstream_info_calc_t *calc);
 
void rtpstream_info_analyse_init(rtpstream_info_t *stream_info, const packet_info *pinfo, const struct _rtp_info *rtpinfo);
 
void rtpstream_info_analyse_process(rtpstream_info_t *stream_info, const packet_info *pinfo, const struct _rtp_info *rtpinfo);
 
unsigned rtpstream_to_hash(const void *key);
 
void rtpstream_info_multihash_insert(GHashTable *multihash, rtpstream_info_t *new_stream_info);
 
rtpstream_info_t *rtpstream_info_multihash_lookup(GHashTable *multihash, rtpstream_id_t *stream_id);
 
void rtpstream_info_multihash_destroy_value(void *key, void *value, void *user_data);
 
#ifdef __cplusplus
}
#endif /* __cplusplus */
 
#endif /* __TAP_RTP_COMMON_H__ */