/* * Copyright (C) 2020, University of the Basque Country (UPV/EHU) * Contact for licensing options: * * The original file was part of Open Source Doubango Framework * Copyright (C) 2010-2011 Mamadou Diop. * Copyright (C) 2012 Doubango Telecom * * This file is part of Open Source Doubango Framework. * * DOUBANGO is free software: you can redistribute it and/or modify * it under the terms of the GNU General Public License as published by * the Free Software Foundation, either version 3 of the License, or * (at your option) any later version. * * DOUBANGO is distributed in the hope that it will be useful, * but WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the * GNU General Public License for more details. * * You should have received a copy of the GNU General Public License * along with DOUBANGO. * */ /**@file trtp_manager.h * @brief RTP/RTCP manager. */ #ifndef TINYRTP_MANAGER_H #define TINYRTP_MANAGER_H #include "tinyrtp_config.h" #include "tinyrtp/rtp/trtp_rtp_session.h" #include "tinyrtp/rtcp/trtp_rtcp_session.h" #include "tinyrtp/trtp_srtp.h" #include "tinymedia/tmedia_defaults.h" #include "tinynet.h" TRTP_BEGIN_DECLS struct trtp_rtp_packet_s; /** RTP/RTCP manager */ typedef struct trtp_manager_s { TSK_DECLARE_OBJECT; char* local_ip; tsk_bool_t use_ipv6; tsk_bool_t is_started; tsk_bool_t use_rtcp; tsk_bool_t use_rtcpmux; tsk_bool_t is_socket_disabled; tsk_bool_t is_ice_neg_ok; tsk_bool_t is_ice_turn_active; tsk_bool_t is_force_symetric_rtp; tsk_bool_t is_symetric_rtp_checked; tsk_bool_t is_symetric_rtcp_checked; tsk_bool_t is_multicast; tsk_bool_t is_MCPTT_session; //Added MCPTT int32_t app_bw_max_upload; // application specific (kbps) int32_t app_bw_max_download; // application specific (kbps) tnet_transport_t* transport; struct tnet_ice_ctx_s* ice_ctx; tsk_timer_manager_handle_t* timer_mgr_global; struct{ tmedia_rtcweb_type_t local; tmedia_rtcweb_type_t remote; } rtcweb_type; struct{ uint16_t start; uint16_t stop; } port_range; struct{ uint16_t seq_num; uint32_t timestamp; uint8_t payload_type; int32_t dscp; char* remote_ip; tnet_port_t remote_port; struct sockaddr_storage remote_addr; char* public_ip; tnet_port_t public_port; struct{ uint32_t local; uint32_t remote; } ssrc; struct{ const void* usrdata; trtp_rtp_cb_f fun; } cb; struct{ void* ptr; tsk_size_t size; } serial_buffer; } rtp; struct{ char* cname; char* remote_ip; tnet_port_t remote_port; struct sockaddr_storage remote_addr; tnet_socket_t* local_socket; char* public_ip; tnet_port_t public_port; struct{ const void* usrdata; trtp_rtcp_cb_f fun; } cb; struct trtp_rtcp_session_s* session; } rtcp; struct{ char* multicast_ip; tnet_port_t multicast_port; char* multicast_iface; int multicast_iface_idx; } multicast; TSK_DECLARE_SAFEOBJ; #if HAVE_SRTP enum tmedia_srtp_type_e srtp_type; enum tmedia_srtp_mode_e srtp_mode; trtp_srtp_state_t srtp_state; trtp_srtp_ctx_xt srtp_contexts[2/*LINE_IDX*/][2/*CRYPTO_TYPE*/]; const struct trtp_srtp_ctx_xs* srtp_ctx_neg_local; const struct trtp_srtp_ctx_xs* srtp_ctx_neg_remote; struct{ char* file_ca; char* file_pbk; char* file_pvk; tsk_bool_t cert_verif; trtp_srtp_state_t state; // enable() could be postponed if net transport not ready yet (e.g. when ICE is ON) tsk_bool_t enable_postponed; tsk_bool_t srtp_connected; tsk_bool_t srtcp_connected; tsk_bool_t srtp_handshake_succeed; tsk_bool_t srtcp_handshake_succeed; trtp_srtp_crypto_type_t crypto_selected; struct{ uint64_t timeout; tsk_timer_id_t id; } timer_hanshaking; struct{ const void* usrdata; trtp_srtp_dtls_cb_f fun; } cb; struct{ tnet_fingerprint_t fp; tnet_dtls_hash_type_t fp_hash; } remote; struct{ tnet_dtls_setup_t setup; tsk_bool_t connection_new; }local; } dtls; #endif } trtp_manager_t; TINYRTP_API trtp_manager_t* trtp_manager_create(tsk_bool_t use_rtcp, const char* local_ip, tsk_bool_t use_ipv6, enum tmedia_srtp_type_e srtp_type, enum tmedia_srtp_mode_e srtp_mode); TINYRTP_API trtp_manager_t* trtp_manager_create_2(struct tnet_ice_ctx_s* ice_ctx, enum tmedia_srtp_type_e srtp_type, enum tmedia_srtp_mode_e srtp_mode); TINYRTP_API int trtp_manager_set_ice_ctx(trtp_manager_t* self, struct tnet_ice_ctx_s* ice_ctx); TINYRTP_API int trtp_manager_prepare(trtp_manager_t* self); #if HAVE_SRTP TINYRTP_API int trtp_manager_set_dtls_certs(trtp_manager_t* self, const char* ca, const char* pbk, const char* pvk, tsk_bool_t verify); TINYRTP_API int trtp_manager_set_dtls_remote_fingerprint(trtp_manager_t* self, const tnet_fingerprint_t* fp, const char* hash); TINYRTP_API enum tnet_dtls_hash_type_e trtp_manager_get_dtls_remote_fingerprint_hash(trtp_manager_t* self); TINYRTP_API int trtp_manager_set_dtls_local_setup(trtp_manager_t* self, tnet_dtls_setup_t setup, tsk_bool_t connection_new); TINYRTP_API int trtp_manager_set_dtls_callback(trtp_manager_t* self, const void* usrdata, trtp_srtp_dtls_cb_f fun); TINYRTP_API const char* trtp_manager_get_dtls_local_fingerprint(trtp_manager_t* self, enum tnet_dtls_hash_type_e hash); TINYRTP_API tsk_bool_t trtp_manager_is_dtls_enabled(trtp_manager_t* self); TINYRTP_API tsk_bool_t trtp_manager_is_dtls_activated(trtp_manager_t* self); TINYRTP_API tsk_bool_t trtp_manager_is_dtls_started(trtp_manager_t* self); TINYRTP_API tsk_bool_t trtp_manager_is_srtp_activated(trtp_manager_t* self); TINYRTP_API tsk_bool_t trtp_manager_is_srtp_started(trtp_manager_t* self); TINYRTP_API int trtp_manager_set_srtp_type_remote(trtp_manager_t* self, enum tmedia_srtp_type_e srtp_type); TINYRTP_API int trtp_manager_set_srtp_type_local(trtp_manager_t* self, enum tmedia_srtp_type_e srtp_type, enum tmedia_srtp_mode_e srtp_mode); #endif /* HAVE_SRTP */ TINYRTP_API tsk_bool_t trtp_manager_is_ready(trtp_manager_t* self); TINYRTP_API int trtp_manager_set_natt_ctx(trtp_manager_t* self, struct tnet_nat_ctx_s* natt_ctx); TINYRTP_API int trtp_manager_set_rtp_callback(trtp_manager_t* self, trtp_rtp_cb_f fun, const void* usrdata); TINYRTP_API int trtp_manager_set_rtcp_callback(trtp_manager_t* self, trtp_rtcp_cb_f fun, const void* usrdata); TINYRTP_API int trtp_manager_set_rtp_dscp(trtp_manager_t* self, int32_t dscp); TINYRTP_API int trtp_manager_set_payload_type(trtp_manager_t* self, uint8_t payload_type); TINYRTP_API int trtp_manager_set_rtp_remote(trtp_manager_t* self, const char* remote_ip, tnet_port_t remote_port); TINYRTP_API int trtp_manager_set_rtcp_remote(trtp_manager_t* self, const char* remote_ip, tnet_port_t remote_port); TINYRTP_API int trtp_manager_set_port_range(trtp_manager_t* self, uint16_t start, uint16_t stop); TINYRTP_API int trtp_manager_set_rtcweb_type_remote(trtp_manager_t* self, tmedia_rtcweb_type_t rtcweb_type); TINYRTP_API int trtp_manager_start(trtp_manager_t* self); TINYRTP_API tsk_size_t trtp_manager_send_rtp(trtp_manager_t* self, const void* data, tsk_size_t size, uint32_t duration, tsk_bool_t marker, tsk_bool_t last_packet); TINYRTP_API tsk_size_t trtp_manager_send_rtp_packet(trtp_manager_t* self, const struct trtp_rtp_packet_s* packet, tsk_bool_t bypass_encrypt); TINYRTP_API tsk_size_t trtp_manager_send_rtp_raw(trtp_manager_t* self, const void* data, tsk_size_t size); TINYRTP_API int trtp_manager_set_app_bandwidth_max(trtp_manager_t* self, int32_t bw_upload_kbps, int32_t bw_download_kbps); TINYRTP_API int trtp_manager_signal_pkt_loss(trtp_manager_t* self, uint32_t ssrc_media, const uint16_t* seq_nums, tsk_size_t count); TINYRTP_API int trtp_manager_signal_frame_corrupted(trtp_manager_t* self, uint32_t ssrc_media); TINYRTP_API int trtp_manager_signal_jb_error(trtp_manager_t* self, uint32_t ssrc_media); TINYRTP_API int trtp_manager_stop(trtp_manager_t* self); TINYRTP_API int trtp_manager_disable_automated_rtcp_reporting(trtp_manager_t* self); TINYRTP_GEXTERN const tsk_object_def_t *trtp_manager_def_t; TRTP_END_DECLS #endif /* TINYRTP_MANAGER_H */