rtpfwd.h

Go to the documentation of this file.

 
#ifndef JANUS_RTPFWD_H
#define JANUS_RTPFWD_H
 
#include "rtp.h"
#include "rtpsrtp.h"
 
 
int janus_rtp_forwarders_init(void);
void janus_rtp_forwarders_deinit(void);
 
typedef struct janus_rtp_forwarder {
        /* \brief Opaque pointer to the owner of this forwarder */
        void *source;
        /* \brief Context of the forwarder */
        char *context;
        /* \brief Unique ID (within the context) of the forwarder */
        uint32_t stream_id;
        /* \brief Socket used for sending RTP packets */
        int udp_fd;
        /* \brief Whether this is a video forwarder */
        gboolean is_video;
        /* \brief Whether this is an audio forwarder */
        gboolean is_data;
        /* \brief SSRC to put in forwarded RTP packets */
        uint32_t ssrc;
        /* \brief Payload type to put in forwarded RTP packets */
        int payload_type;
        /* \brief Substream to forward, in case this is part of a simulcast stream */
        int substream;
        /* \brief Recipient address (IPv4) */
        struct sockaddr_in serv_addr;
        /* \brief Recipient address (IPv6) */
        struct sockaddr_in6 serv_addr6;
        /* \brief RTCP socket, if needed */
        int rtcp_fd;
        /* \brief RTCP local and remote ports, if needed */
        uint16_t local_rtcp_port, remote_rtcp_port;
        /* \brief Callback to invoke when receiving RTCP messages, if any */
        void (*rtcp_callback)(struct janus_rtp_forwarder *rf, char *buffer, int len);
        /* \brief RTCP GSource, if needed */
        GSource *rtcp_recv;
        /* \brief Whether simulcast automatic selection is enabled for this forwarder */
        gboolean simulcast;
        /* \brief RTP switching context, if needed */
        janus_rtp_switching_context rtp_context;
        /* \brief Simulcast context, if needed */
        janus_rtp_simulcasting_context sim_context;
        /* \brief Whether SRTP is enabled for this forwarder */
        gboolean is_srtp;
        /* \brief The SRTP context, in case SRTP is enabled */
        srtp_t srtp_ctx;
        /* \brief The SRTP policy, in case SRTP is enabled */
        srtp_policy_t srtp_policy;
        /* \brief Opaque metadata property, in case it's useful to the owner
         * \note This can be anything (e.g., a string, an allocated struct, etc.),
         * as long as it can be freed with a single call to g_free(), as
         * that's all that will be done when getting rid of the forwarder */
        void *metadata;
        volatile gint destroyed;
        janus_refcount ref;
} janus_rtp_forwarder;
janus_rtp_forwarder *janus_rtp_forwarder_create(const char *ctx,
        uint32_t stream_id, int udp_fd, const char *host, int port,
        uint32_t ssrc, int pt, int srtp_suite, const char *srtp_crypto,
        gboolean simulcast, int substream, gboolean is_video, gboolean is_data);
int janus_rtp_forwarder_add_rtcp(janus_rtp_forwarder *rf, int rtcp_port,
        void (*rtcp_callback)(janus_rtp_forwarder *rf, char *buffer, int len));
void janus_rtp_forwarder_send_rtp(janus_rtp_forwarder *rf, char *buffer, int len, int substream);
void janus_rtp_forwarder_send_rtp_full(janus_rtp_forwarder *rf, char *buffer, int len, int substream,
        uint32_t *ssrcs, char **rids, janus_videocodec vcodec, janus_mutex *rid_mutex);
void janus_rtp_forwarder_destroy(janus_rtp_forwarder *rf);
 
#endif