re_rtp.h

Go to the documentation of this file.

 
#include <stdint.h>
 
enum {
    RTP_VERSION     =  2,  
    RTCP_VERSION    =  2,  
    RTP_HEADER_SIZE = 12   
};
 
 
struct rtp_header {
    uint8_t  ver;       
    bool     pad;       
    bool     ext;       
    uint8_t  cc;        
    bool     m;         
    uint8_t  pt;        
    uint16_t seq;       
    uint32_t ts;        
    uint32_t ssrc;      
    uint32_t csrc[16];  
    struct {
        uint16_t type;  
        uint16_t len;   
    } x;
};
 
enum rtcp_type {
    RTCP_FIR   = 192,  
    RTCP_NACK  = 193,  
    RTCP_SR    = 200,  
    RTCP_RR    = 201,  
    RTCP_SDES  = 202,  
    RTCP_BYE   = 203,  
    RTCP_APP   = 204,  
    RTCP_RTPFB = 205,  
    RTCP_PSFB  = 206,  
    RTCP_XR    = 207,  
    RTCP_AVB   = 208,  
};
 
enum rtcp_sdes_type {
    RTCP_SDES_END   = 0,  
    RTCP_SDES_CNAME = 1,  
    RTCP_SDES_NAME  = 2,  
    RTCP_SDES_EMAIL = 3,  
    RTCP_SDES_PHONE = 4,  
    RTCP_SDES_LOC   = 5,  
    RTCP_SDES_TOOL  = 6,  
    RTCP_SDES_NOTE  = 7,  
    RTCP_SDES_PRIV  = 8   
};
 
enum rtcp_rtpfb {
    RTCP_RTPFB_GNACK = 1  
};
 
enum rtcp_psfb {
    RTCP_PSFB_PLI  = 1,   
    RTCP_PSFB_SLI  = 2,   
    RTCP_PSFB_AFB  = 15,  
};
 
struct rtcp_rr {
    uint32_t ssrc;            
    //unsigned int fraction:8;  /**< Fraction lost since last SR/RR  */
    //int lost:24;              /**< Cumul. no. pkts lost (signed!)  */
    uint32_t fraction_lost_32;
    uint32_t last_seq;        
    uint32_t jitter;          
    uint32_t lsr;             
    uint32_t dlsr;            
};
 
struct rtcp_sdes_item {
    enum rtcp_sdes_type type; 
    uint8_t length;           
    char *data;               
};
 
struct rtcp_msg {
    struct rtcp_hdr {
        unsigned int version:2;  
        unsigned int p:1;        
        unsigned int count:5;    
        unsigned int pt:8;       
        uint16_t length;         
    } hdr;
    union {
        struct {
            uint32_t ssrc;        
            uint32_t ntp_sec;     
            uint32_t ntp_frac;    
            uint32_t rtp_ts;      
            uint32_t psent;       
            uint32_t osent;       
            struct rtcp_rr rrv[1];  
        } sr;
 
        struct {
            uint32_t ssrc;        
            struct rtcp_rr rrv[1];  
        } rr;
    } r;
};
 
struct rtcp_stats {
    struct {
        uint32_t sent;  
        int lost;       
        uint32_t jit;   
    } tx;
    struct {
        uint32_t sent;  
        int lost;       
        uint32_t jit;   
    } rx;
    uint32_t rtt;           
};
 
struct sa;
struct re_printf;
struct rtp_sock;
 
typedef void (rtp_recv_h)(const struct sa *src, const struct rtp_header *hdr,
              struct mbuf *mb, void *arg);
typedef void (rtcp_recv_h)(const struct sa *src, struct rtcp_msg *msg,
               void *arg);
 
/* RTP api */
int   rtp_alloc(struct rtp_sock **rsp);
int   rtp_listen(struct rtp_sock **rsp, int proto, const struct sa *ip,
         uint16_t min_port, uint16_t max_port, bool enable_rtcp,
         rtp_recv_h *recvh, rtcp_recv_h *rtcph, void *arg);
int   rtp_hdr_encode(struct mbuf *mb, const struct rtp_header *hdr);
int   rtp_hdr_decode(struct rtp_header *hdr, struct mbuf *mb);
int   rtp_encode(struct rtp_sock *rs, bool marker, uint8_t pt,
         uint32_t ts, struct mbuf *mb);
int   rtp_decode(struct rtp_sock *rs, struct mbuf *mb, struct rtp_header *hdr);
int   rtp_send(struct rtp_sock *rs, const struct sa *dst,
           bool marker, uint8_t pt, uint32_t ts, struct mbuf *mb);
int   rtp_debug(struct re_printf *pf, const struct rtp_sock *rs);
void *rtp_sock(const struct rtp_sock *rs);
uint32_t rtp_sess_ssrc(const struct rtp_sock *rs);
const struct sa *rtp_local(const struct rtp_sock *rs);
 
/* RTCP session api */
void  rtcp_start(struct rtp_sock *rs, const char *cname,
         const struct sa *peer);
void  rtcp_enable_mux(struct rtp_sock *rs, bool enabled);
void  rtcp_set_srate(struct rtp_sock *rs, uint32_t sr_tx, uint32_t sr_rx);
void  rtcp_set_srate_tx(struct rtp_sock *rs, uint32_t srate_tx);
void  rtcp_set_srate_rx(struct rtp_sock *rs, uint32_t srate_rx);
int   rtcp_send_app(struct rtp_sock *rs, const char name[4],
            const uint8_t *data, size_t len);
int   rtcp_send_fir(struct rtp_sock *rs, uint32_t ssrc);
int   rtcp_send_nack(struct rtp_sock *rs, uint16_t fsn, uint16_t blp);
int   rtcp_send_pli(struct rtp_sock *rs, uint32_t fb_ssrc);
int   rtcp_debug(struct re_printf *pf, const struct rtp_sock *rs);
void *rtcp_sock(const struct rtp_sock *rs);
int   rtcp_stats(struct rtp_sock *rs, uint32_t ssrc, struct rtcp_stats *stats);
 
/* RTCP utils */
int   rtcp_encode(struct mbuf *mb, enum rtcp_type type, uint32_t count, ...);
int   rtcp_decode(struct rtcp_msg **msgp, struct mbuf *mb);
int   rtcp_msg_print(struct re_printf *pf, const struct rtcp_msg *msg);
int   rtcp_sdes_encode(struct mbuf *mb, uint32_t src, uint32_t itemc, ...);
const char *rtcp_type_name(enum rtcp_type type);
const char *rtcp_sdes_name(enum rtcp_sdes_type sdes);