doubango(6)--Doubango协议栈中对RTP的管理

相关数据结构

1.    tsip_dialog_invite_t

描述:

一个invite_dialog代表了一个invite期间的所有的信令流程,因此,它首先是一个普遍的dialog的特殊化结构,在该结构的起始部分,有一个TSIP_DECLARE_DIALOG声明,该声明展开后是一个tsip_dilog_t __dialog字段的定义,这是一种在C中一个具化对象对通用对象的继承机制,tsip_dialog_t对象代表了更通用的实例,而tsip_dialog_invite_t对象则是tsip_dialog_t对象的具化和拓展。

一个dialog本身有自己的有限状态处理机,有自己的当前状态和当前状态应执行的动作,还有一个状态变化时的回调函数。它还需要有一个字段指向它所属的session,这些字段,反应在数据类型上上,分别是:

tsk_fsm_t(有限状态机),tsip_action_t(状态执行动作),tsip_dialog_state_t(当前状态),

tsip_dialog_event_callback_f(回调函数),tsip_ssession_t(所属session)。

创建时机:

tsip_action_INVITE()函数是上层应用与底层协议栈的接口,当上层应用发起一个INVITE时,便会分层调用到该接口。

tsip_dialog_invite_t类型的实例便是在该接口中创建的,对于创建时,还需要在协议栈的全局dialog队列中寻找一遍,看是否相关的dialog已经在之前被创建,若是,则沿用老的实例,若否,则用tsip_dialog_layer_new()函数创建一个新的实例,并链入到协议栈dialog_layer层的全局队列中。

关键点:

2.    tmedia_session_mgr_t

描述:

一个tmedia_session_mgr_t实例是由上述的tsip_dialog_invite_t实例的session_mgr字段记录的,代表了在一个对话期间各种媒体设置的管理者。

当发起一个INVITE时,首先必须存在一个代表信令流程的对象即dialog对象,其次,还要有一个负责管理媒体信息的对象,及该结构的实例。

创建时机:

该结构的首次创建是在invite_dialog的状态转换过程中,c0000_Started_2_Outgoing_X_oINVITE()函数是一个状态转化函数,它代表着当前dialog由初始状态向发起INVITE后状态转化需要执行的操作,在该函数内部,通过tmedia_session_mgr_create()创建tmedia_session_mgr_t实例,然后填写本地媒体信息(即sdp中得各个字段),申请rtp端口号,生成代表rtp的网络传输实例(tnet_transport_t对象),最后在该状态转换函数中,通过协议栈的代表信令的网络传输实例将INVITE消息传递出去。

 

关键点:

tmedia_session_mgr_t中,有一个tmedia_sessions_L_t*sessions的字段,这个字段其实是一个队列,挂载的表示代表了各种媒体的信息(音频,视频),每一个队列节点是一个tmedia_session_t的实例。

关键函数:

_tmedia_session_mgr_load_sessions(tmedia_session_mgr_t *mgr)函数

     原型:_tmedia_session_mgr_load_sessions(tmedia_session_mgr_t *mgr)

     作用:用于生成和加载各种类型的tmedia_session_t实例。

 

说明:_tmedia_session_mgr_load_sessions()函数在tmedia_session_mgr_create()函数中被调用,在这个函数内,会生成各个tmedia_session_t实例,挂入tmedia_session_mgr_t实例的sessions队列。其中在_tmedia_session_mgr_load_sessions()函数内的处理片段为:

 

  1. int _tmedia_session_mgr_load_sessions(tmedia_session_mgr_t*self){  
  2.   
  3. const tmedia_session_plugin_def_t* plugin;  
  4.   
  5. …  
  6.   
  7. if(TSK_LIST_IS_EMPTY(self->sessions)){  
  8.   
  9.         /* for each registered plugin create a session instance */  
  10.   
  11.         while((i <TMED_SESSION_MAX_PLUGINS) && (plugin =__tmedia_session_plugins[i++])){  
  12.   
  13.             if((plugin->type &self->type) ==plugin->type){  
  14.   
  15.                 if((session =tmedia_session_create(plugin->type))){  
  16.   
  17.                    tsk_list_push_back_data(self->sessions, (void**)(&session));  
  18.   
  19.                 }  
  20.   
  21.            }  
  22.   
  23. }  

}

__tmedia_session_plugins是一个tmedia_session_plugin_def_t类型的全局指针数组,用于存放各种媒体类型的定义。

tmedia_session_create()函数用于更具媒体的类型创建一个tmedia_session_t类型的实例,媒体类型由上层应用指定,记录在tmedia_session_mgr_t实例的type字段,常用的有audio,vedio,audiovideo三个类型。

3.    tmedia_session_t

描述:

这其实也是一个通用结构,被更具体的结构包含着。

tdav_session_audio_t,tdav_session_video_t等结构便是更具体的结构,在这些结构的其实,包含了该通用的结构。每一个更通用的结构都记录一个trtp_manager_s的实例,这个结构便是代表语音流和视频流的管理者。

在创建tmedia_session_t实例时,是根据plugin->objdef来调用tsk_object_new()的,调用语句为tsk_object_new(plugin->objdef),plugin是上一节所述的__tmedia_session_plugins 所记录的tmedia_session_plugin_def_t 实例,故当plugin->type为audio类型时,创建的真正结构为tdav_session_audio_t,真正的构造函数为tdav_session_audio_ctor(),定义在tdav_session_audio.c中。

这个过程的调用堆栈为:

  1. int _tmedia_session_mgr_load_sessions(tmedia_session_mgr_t*self){  
  2.   
  3. const tmedia_session_plugin_def_t* plugin;  
  4.   
  5. …  
  6.   
  7. if(TSK_LIST_IS_EMPTY(self->sessions)){  
  8.   
  9.         /* for each registered plugin create a session instance */  
  10.   
  11.         while((i <TMED_SESSION_MAX_PLUGINS) && (plugin =__tmedia_session_plugins[i++])){  
  12.   
  13.             if((plugin->type &self->type) ==plugin->type){  
  14.   
  15.                 if((session =tmedia_session_create(plugin->type))){  
  16.   
  17.                    tsk_list_push_back_data(self->sessions, (void**)(&session));  
  18.   
  19.                 }  
  20.   
  21.            }  
  22.   
  23. }  

 

创建时机:

见上一条tmedia_session_mgr_t的关键点。

关键点:

在一个tmedia_session_t结构的实例中,承载了这个tmedia_session_t实际类型的编解码插件,例如tmedia_session_t的type为video时,在tmedia_session_init(tmedia_session_t*self)函数中会初始化一个tmedia_session_t的实例,而根据多态的原理,这个tmedia_session_t实例的真正类型为tdav_session_video_t实例,因此,在初始化时,会从__tmedia_codec_plugins数组中加载所有的type为video的解码模块,__tmedia_codec_plugins数组会在启动协议栈时初始化,具体的初始化函数是tdav_init(),这是也会根据能够加载的编解码模块,将各个编解码插件记录到该__tmedia_codec_plugins全局指针数组中,数组的每一个项都指向了一个plugin,一个plugin代表了一个实际的编解码模块。

关键函数描述:

tmedia_session_init()函数:

     原型: tmedia_session_init(tmedia_session_t*self,tmedia_type_ttype)

     作用: 初始化一个新生成的tmedia_session_t实例,加载各个编解码模块

_tmedia_session_load_codecs(tmedia_session_t  *self)函数;

     描述:该函数被tmedia_session_init(…)函数调用,用于加载编解码模块

加载编解码模块的代码片段为:

  

  1. int _tmedia_session_mgr_load_sessions(tmedia_session_mgr_t*self){  
  2.   
  3. const tmedia_session_plugin_def_t* plugin;  
  4.   
  5. …  
  6.   
  7. if(TSK_LIST_IS_EMPTY(self->sessions)){  
  8.   
  9.         /* for each registered plugin create a session instance */  
  10.   
  11.         while((i <TMED_SESSION_MAX_PLUGINS) && (plugin =__tmedia_session_plugins[i++])){  
  12.   
  13.             if((plugin->type &self->type) ==plugin->type){  
  14.   
  15.                 if((session =tmedia_session_create(plugin->type))){  
  16.   
  17.                    tsk_list_push_back_data(self->sessions, (void**)(&session));  
  18.   
  19.                 }  
  20.   
  21.            }  
  22.   
  23. }  

 

4.    tdav_session_audio_t

5.    tdav_session_video_t

6.tsip_request_t

描述:

在一个tsip_dialog_invite_t实例被创建,进入它的状态机执行时,第一个状态的转化为:

Started -> (oINVITE)-> Outgoing

此时由函数int c0000_Started_2_Outgoing_X_oINVITE(va_list*app)进行该状态的处理,在此函数内部,会为tsip_dialog_invite_t实例创建tmedia_session_mgr_t实例并记录在tsip_dialog_invite_t实例的msession_mgr字段,创建msession_mgr的同时,会建立msession_mgr的sessions队列和加载各种编解码模块。完成这一切后,会调用send_INVITEorUPDATE()函数,完成一个sip的invite request。

该函数的原型为:

int send_INVITEorUPDATE(tsip_dialog_invite_t*self,tsk_bool_tis_INVITE,tsk_bool_tforce_sdp)

从名字可以看出,函数除了完成INVITE外,还可以完成一个sip会话的更新操作,例如可能编解码变更,而不想重新发起一个INVITE请求时,便在原有请求的基础上进行UPDATE。

具体是一个新的INVITE还是一个UPDATE,由参数is_INVITE指定。

在一个新的INVITE请求发起时,最重要的结构便是tsip_request_t结构,这个结构代表了一个真正的sip消息。

 

关键点:

在一个INVITE请求发起时,生成一个tsip_request_t实例的过程有以下几步:

a)   用tsip_dialog_request_new()函数生成tsip_request_t结构的实例。并做相应的初始化。

b)   当这个dialog的状态为tsip_initial时,需要为SIP_INVITE消息的消息体生成SDP包,此时分解为以下几个小步骤(假设代码中的self为tsip_dialog_invite_t实例):

1)   调用用函数tmedia_session_mgr_get_lo(self->msession_mgr),通过msession_mgr中sessions队列记录的tmedia_session_t实例和每个tmedia_session_t实例codecs队列中记录的编解码模块生成一个tmedia_sdp_t的实例。该实例便携带了媒体协商的所有数据。在这个过程中,还要完成RTP端口的生成,为以后的音视频通话搭建真正的通道,这个过程将在后面解析。

2)   调用tsdp_message_tostring()函数将tmedia_sdp_t的实例转化为ASCII字符。假设这一步中得到的字符串为sdp。

3)   调用tsip_message_add_content()函数将sdp拷贝到tsip_request_t实例的的message_body中。释放sdp。

 

RTP端口的生成过程

tmedia_session_mgr_get_lo(…)函数

原型:const tsdp_message_t*tmedia_session_mgr_get_lo(tmedia_session_mgr_t*self)

作用:准备SDP信息,给新的通话开一个RTP端口

内存关系图

 

原文地址:https://www.cnblogs.com/fuland/p/3654852.html