深入浅出asterisk(三):chan_sip代码分析（下）

现在回过头来把焦点转移到sipsock_read()函数。所有到来的sip包都在这里开始处理，在处理sip包期间，sipsock_read需要对sip的拥有者channel上锁，sipsock_read成功则返回0，失败则返回1。它解析sip包并且找到所在的dialog，或者创建新的dialog。并且把解析好的包交给handle_request()处理。

    sipsock_read第一步接收socket数据，存到结构sip_request的data域中。

15062    res = recvfrom(sipsock, req.data, sizeof(req.data) - 1, 0, (struct sockaddr *)&sin, &len);

解析SIP包，获取sip request method，如INVITE, BYE等

15086    parse_request(&req);

15087    req.method = find_sip_method(req.rlPart1);

    随后找到对应的sip_pvt结构，或者创建新的sip_pvt结构，结构指针返回到变量p中。

15099       /* Find the active SIP dialog or create a new one */

15100       p = find_call(&req, &sin, req.method); /* returns p locked */

   在进一步操作之前，需要对p->owner上锁，这个操作会最多尝试100次直至成功。

15107       /* Go ahead and lock the owner if it has one -- we may need it */

15108       /* becaues this is deadlock-prone, we need to try and unlock if failed */

15109       if (!p->owner || !ast_channel_trylock(p->owner))

15110          break;   /* locking succeeded */

如果上锁操作失败，将会返回503 sip消息。

15127       if (req.method != SIP_ACK)

15128          transmit_response(p, "503 Server error", &req); /* We must respond according to RFC 3261 sec 12.2 */

15129       /* XXX We could add retry-after to make sure they come back */

15130       append_history(p, "LockFail", "Owner lock failed, transaction failed.");

15131       return 1;

更深一步的解析处理操作交给handle_request()函数处理，完了之后就是释放channel的锁。

15134    if (handle_request(p, &req, &sin, &recount, &nounlock) == -1) {

15135       /* Request failed */

15136       if (option_debug)

15137          ast_log(LOG_DEBUG, "SIP message could not be handled, bad request: %-70.70s\n", p->callid[0] ? p->callid : "<no callid>");

15138    }

15139       

15140    if (p->owner && !nounlock)

15141       ast_channel_unlock(p->owner);

  

函数handle_request()视数据包的类型而处理，如果是对外出包的回应，则交给handle_response()处理，如果是一个请求包，则视请求类型（INVITE, OPTIONS, REFER, BYE, CANCEL etc）交给不同的函数处理。如果是一个INVITE包，则交给handle_request_invite()处理，在那里将会创建一个新的channel，这个通道随后会执行一个单独的通道线程。这就是一个来电呼叫。如果这个呼叫被应答，则一个桥接通道或者PBX本身会回调sip_answer()函数。而真正的媒体数据，音频或者视频，则会在RTP子系统中处理，具体见rtp.c

Outbound calls

 Outbound calls are set up by the PBX through the sip_request_call() function. After that, they are activated by sip_call().

Hanging up

 The PBX issues a hangup on both incoming and outgoing calls through the sip_hangup() function

 

01502 /*------Request handling functions */

01503 static int handle_request(struct sip_pvt *p, struct sip_request *req, struct sockaddr_in *sin, int *recount, int *nounlock);

01504 static int handle_request_invite(struct sip_pvt *p, struct sip_request *req, int debug, int seqno, struct sockaddr_in *sin, int *recount, char *e, int *nounlock);

01505 static int handle_request_refer(struct sip_pvt *p, struct sip_request *req, int debug, int ignore, int seqno, int *nounlock);

01506 static int handle_request_bye(struct sip_pvt *p, struct sip_request *req);

01507 static int handle_request_register(struct sip_pvt *p, struct sip_request *req, struct sockaddr_in *sin, char *e);

01508 static int handle_request_cancel(struct sip_pvt *p, struct sip_request *req);

01509 static int handle_request_message(struct sip_pvt *p, struct sip_request *req);

01510 static int handle_request_subscribe(struct sip_pvt *p, struct sip_request *req, struct sockaddr_in *sin, int seqno, char *e);

01511 static void handle_request_info(struct sip_pvt *p, struct sip_request *req);

01512 static int handle_request_options(struct sip_pvt *p, struct sip_request *req);

01513 static int handle_invite_replaces(struct sip_pvt *p, struct sip_request *req, int debug, int ignore, int seqno, struct sockaddr_in *sin);

01514 static int handle_request_notify(struct sip_pvt *p, struct sip_request *req, struct sockaddr_in *sin, int seqno, char *e);

01515 static int local_attended_transfer(struct sip_pvt *transferer, struct sip_dual *current, struct sip_request *req, int seqno);

01516 

01517 /*------Response handling functions */

01518 static void handle_response_invite(struct sip_pvt *p, int resp, char *rest, struct sip_request *req, int seqno);

01519 static void handle_response_refer(struct sip_pvt *p, int resp, char *rest, struct sip_request *req, int seqno);

01520 static int handle_response_register(struct sip_pvt *p, int resp, char *rest, struct sip_request *req, int ignore, int seqno);

01521 static void handle_response(struct sip_pvt *p, int resp, char *rest, struct sip_request *req, int ignore, int seqno);

    现在回顾一下注册SIP通道驱动时，我们注册了一系列通道驱动的回调函数，这些有什么用呢？比如当需要发出一个outbound call时，则会调用sip_request_call()。而当需要hangup时，则调用sip_hangup()。

01541 /*! \brief Definition of this channel for PBX channel registration */

01542 static const