| c732d49e |
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 */ |