发布时间 : 星期三 文章exosip2协议栈原理分析以和总结 - 图文更新完毕开始阅读8c460c28bdeb19e8b8f67c1cfad6195f302be86f
.
return -1;
i = eXosip_listen_addr (IPPROTO_UDP, NULL, port, AF_INET, 0); if (i!=0) {
eXosip_quit();
fprintf (stderr, \return -1; }
... then you have to send messages and wait for eXosip events...
这样，在初始化完成后，我们基本上完成了对内存中所用数据结构的配置，同时启动了 一个后台任务负责osip 状态机的驱动。
5、数据收发整体框架
5.1 接收过程
在初始化过程中我们创建了一个后台任务，现在可以看看这个后台任务都做了哪些操作。
任务的执行函数为_eXosip_thread，在该接口中，循环不断的调用eXosip_execute。在每一次
的eXosip_execute 执行中，完成如下的工作：
a. 首先计算出底层osip 离当前时间最近的超时时间。也就是查看底层所有的超时事件，
找出其中的最小值，然后将其与当前时间做差，结果就是最小的超时间隔了。这步是通
. .
.
过调用接口osip_timers_gettimeout 完成的。主要检查osip 全局结构体上的ict、ist、nict、
nist 以及ixt 上所有事务的事件的超时时间。如果 ict 事务队列上没有事件，则说明没 有有效的数据交互存在，返回值为默认的一年，实际上就是让后面的接收接口死等。如 果有事务队列上的事件的超时时间小于当前值，则说明已经超时了，需要马上处理，此 时将超时时间清为零，并返回。
b. 调用 eXosip_read_message 接口从底层接收消息并处理。如果返回-2，则任务退出。
c. 执行 osip 的状态机。具体为执行osip_timers_ict（ist|nict|nist）_execute 和osip_ict （ist|nict|nist）_execute 这几个函数。最后还检查释放已经终结的call、registrations 以及
publications。
d. 如果 keep_alive 设置了，则调用_eXosip_keep_alive 检查发送keep_alive 消息。 这样，当远端的终端代理发送sip 消息过来时，会被之前创建的监听端口捕获（sip 协议 默认的端口为5060）。在调用eXosip_read_message 接口时会将其接收上来。接收上来的数据存放在buffer 中交给接口_eXosip_handle_incoming_message 来处理。在其中首先调用osip_parse 进行消息的解析，这是osip 的核心功能之一。数据解析后，会生成一个osip_event 类型的事件。接着调用osip_message_fix_last_via_header 将接收到该消息的ip 地址和端口根据需要设置到数据头的via 域中。这在消息返回时有可能发挥作用。为了能够让消息正确的被处理，调用osip_find_transaction_and_add_event 接口将其添加到osip 的事务队列上。处理在这之后发生了分叉，如果osip 接纳了该事件，接口直接返回，因为这说明该事件在osip 上已经有匹配的事务了，或者说该事件是某一个事务过程的一部分。
. .
.
这样在后面执行状态机的接口时，该事件会被正确的处理。如果osip 没有拿走该事件，则说明针对该事件还没有事务与之对应。此时，我们首先检查其类型，如果是request，则说明很可能是一个新的事件到来（ 这将触发服务端的状态机的建立）， 调用eXosip_process_newrequest 接口进行处理。如果是response ， 则调用接口
eXosip_process_response_out_of_transaction 处理。在 eXosip_process_newrequest 接口中，如果是合法的事件，则会为其创建一个新的事务。
也就是说这是新事务的第一个事件。经过一大堆的处理后，该事件可能就被osip 消化了， 或者被exosip 消化了。如果需要上报给应用，由应用拿来对一些信息进行存储或者进行图 形显示之类，则会将该事件添加到exosip 的事件队列上。如下图所示：
应用程序在exosip 初始化完之后需要调用如下类似的代码，不断从事件队列上读取事件， 并进行处理。 eXosip_event_t *je; for (;;)
. .
.
{
je = eXosip_event_wait (0, 50); eXosip_lock();
eXosip_automatic_action (); eXosip_unlock(); if (je == NULL) break;
if (je->type == EXOSIP_CALL_NEW) { .... .... }
else if (je->type == EXOSIP_CALL_ACK) { .... .... }
else if (je->type == EXOSIP_CALL_ANSWERED) { .... .... }
. .