ipprobe-mt.h

Go to the documentation of this file.

/*
 * $Id: ipprobe-mt.h 366303 2010-03-05 13:14:01Z taoliu $
 *
 * This code is provided as is by Juniper Networks SDK Developer Support.
 * It is provided with no warranties or guarantees, and Juniper Networks
 * will not provide support or maintenance of this code in any fashion.
 * The code is provided only to help a developer better understand how
 * the SDK can be used.
 *
 * Copyright (c) 2009, Juniper Networks, Inc.
 * All rights reserved.
 */

#ifndef __IPPROBE_MT_H__
#define __IPPROBE_MT_H__

#define IP_HEADER_LEN             20    
#define PROBE_NAME_LEN            64    
#define PROBE_MNGR_PORT_DEFAULT   6068  
#define RSPD_MNGR_PORT_DEFAULT    6069  
#define CONN_RETRY_DEFAULT        32    
#define PROBE_MGMT_MSG_REG        1     
#define PROBE_MGMT_MSG_ADD_DST    2     
#define RSPD_MGMT_MSG_REQ         1     
#define RSPD_MGMT_MSG_ACK         2     
#define PROBE_PKT_REQ             1     
#define PROBE_PKT_REPLY           2     
#define PROBE_PKT_REQ_LAST        3     
#define PROBE_PKT_SIZE_MIN        64    
#define PROBE_PKT_SIZE_MAX        1024  
#define PROBE_PKT_COUNT_MAX       200   
#define PROBE_PKT_TTL_DEFAULT     128   
#define PROBE_TRACE(_msg_type, _fmt, ...) \
    junos_trace((_msg_type), _fmt, ##__VA_ARGS__)

#define PROBE_LOG(_level, _fmt, ...)   \
        ERRMSG(IPPROBE-MT, (_level), _fmt, ##__VA_ARGS__)

typedef struct probe_params_s {
    LIST_ENTRY(probe_params_s)  entry;                
    char                        name[PROBE_NAME_LEN]; 
    uint8_t                     proto;                
    uint8_t                     tos;                  
    uint16_t                    src_port;             
    uint16_t                    dst_port;             
    uint16_t                    pkt_size;             
    uint16_t                    pkt_count;            
    uint16_t                    pkt_interval;         
} probe_params_t;

typedef struct {
    u_short               id;              
    u_short               type;            
    u_short               seq;             
    struct timeval        tx_time;         
    struct timeval        target_rx_time;  
    struct timeval        target_tx_time;  
    struct timeval        rx_time;         
    char                  pad[0];          
} probe_pkt_data_t;

typedef struct {
    struct ip             header;          
    union {
        struct icmphdr    icmp;            
        struct udphdr     udp;             
    };
    probe_pkt_data_t      data;            
} probe_pkt_t;

typedef struct probe_s {
    LIST_ENTRY(probe_s)   entry;           
    pthread_t             tid;             
    evContext             ev_ctx;          
    pconn_client_t        *client_hdl;     
    pconn_session_t       *ssn;            
    probe_params_t        params;          
    int                   rspd_socket;     
    evFileID              rspd_read_fid;   
    in_addr_t             dst_first;       
    patroot               dst_pat;         
    int                   dst_count;       
    int                   tx_socket;       
    evTimerID             tx_tid;          
    int                   tx_count;        
    uint8_t               *tx_buf;         
    int                   rx_socket;       
    evFileID              rx_fid;          
} probe_t;

typedef struct {
    float             delay_sd;        
    float             delay_ds;        
    float             rrt;             
    float             jitter_sd;       
    float             jitter_ds;       
    float             jitter_rr;       
} pkt_stats_t;

typedef struct {
    float             delay_sd_average;   
    float             delay_ds_average;   
    float             delay_rr_average;   
    float             delay_sd_max;       
    float             delay_ds_max;       
    float             delay_rr_max;       
    float             jitter_sd_average;  
    float             jitter_ds_average;  
    float             jitter_rr_average;  
    float             jitter_sd_max;      
    float             jitter_ds_max;      
    float             jitter_rr_max;      
} probe_result_t;

typedef struct probe_rx_buf_s {
    LIST_ENTRY(probe_rx_buf_s)  entry;       
    uint8_t                     pkt[0];      
} probe_rx_buf_t;

typedef enum {
    PROBE_DST_STATE_INIT,                  
    PROBE_DST_STATE_RUN,                   
    PROBE_DST_STATE_DONE                   
} probe_dst_state_t;

typedef struct {
    patnode               node;            
    in_addr_t             dst_addr;        
    in_addr_t             local_addr;      
    probe_dst_state_t     state;           
    probe_result_t        result;          
    int                   rx_count;        
    LIST_HEAD(, probe_rx_buf_s)  rx_buf_list;  
    probe_rx_buf_t        *rx_buf_last;    
} probe_dst_t;

typedef struct {
    uint16_t              type;            
    uint16_t              timeout;         
    uint16_t              port;            
    uint8_t               proto;           
} rspd_mgmt_pkt_t;

typedef struct {
    evContext             ev_ctx;          
    pconn_server_t        *hdl;            
    uint16_t              port;            
} probe_mngr_t;

typedef struct {
    evContext             ev_ctx;          
    int                   socket;          
    evFileID              read_fid;        
    uint16_t              port;            
    rspd_mgmt_pkt_t       rx_pkt;          
} rspd_mngr_t;

typedef struct rspd_s {
    LIST_ENTRY(rspd_s)    entry;           
    evContext             ev_ctx;          
    int                   socket;          
    evFileID              read_fid;        
    uint8_t               proto;           
    uint16_t              port;            
    int                   usage;           
    int                   timeout;         
    uint8_t               rx_buf[PROBE_PKT_SIZE_MAX];  
} rspd_t;

int probe_mngr_init(evContext lev_ctx);
int probe_mngr_open(uint16_t port);
int probe_mngr_probe_start(char *name, in_addr_t dst_addr);
int probe_mngr_probe_stop(char *name);
int probe_mngr_probe_clear(char *name);
patroot *probe_mngr_probe_result_get(char *name);
void probe_mngr_close(void);

int rspd_mngr_init(evContext lev_ctx);
int rspd_mngr_open(uint16_t port);
void rspd_mngr_close(void);

int config_read(int check);
probe_params_t *probe_params_get(char *name);

void *probe_thrd_entry(probe_t *probe);

#endif

---