Changeset 2315 for pjproject/trunk/pjsip/src/pjsip/sip_dialog.c

Timestamp:

Sep 24, 2008 10:10:15 AM (16 years ago)

Author:

bennylp

Message:

Ticket #635: Disconnect the other call leg when multiple 2xx/OK responses to INVITE are received due to forking

File:

• pjproject/trunk/pjsip/src/pjsip/sip_dialog.c (modified) (7 diffs)

pjproject/trunk/pjsip/src/pjsip/sip_dialog.c

@@ -581 +581 @@
 {
     pjsip_dialog *dlg;
-    const pjsip_route_hdr *r;
+    const pjsip_msg *msg = rdata->msg_info.msg;
+    const pjsip_hdr *end_hdr, *hdr;
+    const pjsip_contact_hdr *contact;
     pj_status_t status;
 
@@ -588 +590 @@
     
     /* rdata must be response message. */
-    PJ_ASSERT_RETURN(rdata->msg_info.msg->type == PJSIP_RESPONSE_MSG,
+    PJ_ASSERT_RETURN(msg->type == PJSIP_RESPONSE_MSG,
                      PJSIP_ENOTRESPONSEMSG);
 
     /* Status code MUST be 1xx (but not 100), or 2xx */
-    status = rdata->msg_info.msg->line.status.code;
+    status = msg->line.status.code;
     PJ_ASSERT_RETURN( (status/100==1 && status!=100) ||
                       (status/100==2), PJ_EBUG);
@@ -598 +600 @@
     /* To tag must present in the response. */
     PJ_ASSERT_RETURN(rdata->msg_info.to->tag.slen != 0, PJSIP_EMISSINGTAG);
+
+    /* Find Contact header in the response */
+    contact = (const pjsip_contact_hdr*)
+              pjsip_msg_find_hdr(msg, PJSIP_H_CONTACT, NULL);
+    if (contact == NULL)
+        return PJSIP_EMISSINGHDR;
 
     /* Create the dialog. */
@@ -604 +612 @@
         return status;
 
-    /* Clone remote target. */
-    dlg->target = (pjsip_uri*) pjsip_uri_clone(dlg->pool, first_dlg->target);
+    /* Set remote target from the response. */
+    dlg->target = (pjsip_uri*) pjsip_uri_clone(dlg->pool, contact->uri);
 
     /* Clone local info. */
@@ -637 +645 @@
 
     /* Dialog state depends on the response. */
-    status = rdata->msg_info.msg->line.status.code/100;
+    status = msg->line.status.code/100;
     if (status == 1 || status == 2)
         dlg->state = PJSIP_DIALOG_STATE_ESTABLISHED;
@@ -652 +660 @@
                    pjsip_hdr_clone(dlg->pool, first_dlg->call_id);
 
-    /* Duplicate Route-Set. */
+    /* Get route-set from the response. */
     pj_list_init(&dlg->route_set);
-    r = first_dlg->route_set.next;
-    while (r != &first_dlg->route_set) {
-        pjsip_route_hdr *h;
-
-        h = (pjsip_route_hdr*) pjsip_hdr_clone(dlg->pool, r);
-        pj_list_push_back(&dlg->route_set, h);
-
-        r = r->next;
-    }
+    end_hdr = &msg->hdr;
+    for (hdr=msg->hdr.prev; hdr!=end_hdr; hdr=hdr->prev) {
+        if (hdr->type == PJSIP_H_RECORD_ROUTE) {
+            pjsip_route_hdr *r;
+            r = (pjsip_route_hdr*) pjsip_hdr_clone(dlg->pool, hdr);
+            pjsip_routing_hdr_set_route(r);
+            pj_list_push_back(&dlg->route_set, r);
+        }
+    }
+
     //dlg->route_set_frozen = PJ_TRUE;
 
@@ -1814 +1823 @@
     }
 
+    /* Handle the case of forked response, when the application creates
+     * the forked dialog but not the invite session. In this case, the
+     * forked 200/OK response will be unhandled, and we must send ACK
+     * here.
+     */
+    if (dlg->usage_cnt==0) {
+        pj_status_t status;
+
+        if (rdata->msg_info.cseq->method.id==PJSIP_INVITE_METHOD && 
+            rdata->msg_info.msg->line.status.code/100 == 2) 
+        {
+            pjsip_tx_data *ack;
+
+            status = pjsip_dlg_create_request(dlg, &pjsip_ack_method,
+                                              rdata->msg_info.cseq->cseq,
+                                              &ack);
+            if (status == PJ_SUCCESS)
+                status = pjsip_dlg_send_request(dlg, ack, -1, NULL);
+        } else if (rdata->msg_info.msg->line.status.code==401 ||
+                   rdata->msg_info.msg->line.status.code==407)
+        {
+            pjsip_transaction *tsx = pjsip_rdata_get_tsx(rdata);
+            pjsip_tx_data *tdata;
+            
+            status = pjsip_auth_clt_reinit_req( &dlg->auth_sess, 
+                                                rdata, tsx->last_tx,
+                                                &tdata);
+            
+            if (status == PJ_SUCCESS) {
+                /* Re-send request. */
+                status = pjsip_dlg_send_request(dlg, tdata, -1, NULL);
+            }
+        }
+    }
+
     /* Unhandled response does not necessarily mean error because
        dialog usages may choose to process the transaction state instead.