Changeset 4562 for pjproject/trunk/pjsip/src/pjsip-ua/sip_inv.c

Timestamp:

Jul 15, 2013 4:23:31 AM (11 years ago)

Author:

ming

Message:

Re #817: Initial work for allowing application to respond to re-INVITE manually.

Patches integrated in this fix (with some modifications for adjustment to the current trunk):

• sip_inv-on_rx_reinvite.patch

Move the place where to call the callback so the callback will still be called when the re-invite contains no SDP

• sdp_neg_cancel_remote_offer

pjmedia_sdp_neg_cancel_remote_offer() is no longer necessary since pjmedia_sdp_neg_cancel_offer() can already handle that. Only integrate the chart for sdp negotiation doc.

• sip_inv-terminate-reinvite-tsx-on-cancel
• sip_inv-cancel_sdp_neg_on_sending_negative_reply_to_reinvite
• pjsip-allow_cancel_reinvite

File:

• pjproject/trunk/pjsip/src/pjsip-ua/sip_inv.c (modified) (9 diffs)

pjproject/trunk/pjsip/src/pjsip-ua/sip_inv.c

@@ -1836 +1836 @@
                 PJMEDIA_SDP_NEG_STATE_WAIT_NEGO)
         {
+            if (mod_inv.cb.on_rx_reinvite && inv->notify &&
+                msg->type == PJSIP_REQUEST_MSG &&
+                msg->line.req.method.id == PJSIP_INVITE_METHOD)
+            {
+                /* Do not return failure first, allow the application
+                 * to set the answer in the on_rx_reinvite() callback.
+                 */
+                return PJ_SUCCESS;
+            }
             return PJ_EINVALIDOP;
         }
@@ -1973 +1982 @@
     }
 
+    /* Cancel SDP negotiation if this is a negative reply to a re-INVITE */
+    if (st_code >= 300 && inv->neg != NULL &&
+        inv->state == PJSIP_INV_STATE_CONFIRMED)
+    {
+        pjmedia_sdp_neg_state neg_state;
+        neg_state = pjmedia_sdp_neg_get_state(inv->neg);
+        if (neg_state == PJMEDIA_SDP_NEG_STATE_REMOTE_OFFER) {
+            pjmedia_sdp_neg_cancel_offer(inv->neg);
+        }
+    }
 
     return PJ_SUCCESS;
@@ -2053 +2072 @@
 
 /*
- * Answer initial INVITE
- * Re-INVITE will be answered automatically, and will not use this function.
+ * Answer INVITE request.
  */ 
 PJ_DEF(pj_status_t) pjsip_inv_answer(   pjsip_inv_session *inv,
@@ -2277 +2295 @@
 
     pj_log_pop_indent();
+    return PJ_SUCCESS;
+}
+
+/*
+ * Cancel re-INVITE transaction.
+ */
+PJ_DEF(pj_status_t) pjsip_inv_cancel_reinvite( pjsip_inv_session *inv,
+                                               pjsip_tx_data **p_tdata )
+{
+    pjsip_tx_data *tdata;
+    pj_status_t status;
+
+    /* Verify arguments. */
+    PJ_ASSERT_RETURN(inv && p_tdata, PJ_EINVAL);
+    
+    pj_log_push_indent();
+
+    /* Create appropriate message. */
+    switch (inv->state) {
+    case PJSIP_INV_STATE_CONFIRMED:
+        /* MUST have the original UAC INVITE transaction  */
+        PJ_ASSERT_RETURN(inv->invite_tsx != NULL, PJ_EBUG);
+
+        /* CANCEL should only be called when we have received a
+         * provisional response.
+         */
+        if (inv->invite_tsx->status_code < 100) {
+            inv->cancelling = PJ_TRUE;
+            inv->pending_cancel = PJ_TRUE;
+            *p_tdata = NULL;
+            PJ_LOG(4, (inv->obj_name, "Delaying CANCEL since no "
+                       "provisional response is received yet"));
+            pj_log_pop_indent();
+            return PJ_SUCCESS;
+        }
+
+        status = pjsip_endpt_create_cancel(inv->dlg->endpt, 
+                                           inv->invite_tsx->last_tx,
+                                           &tdata);
+        if (status != PJ_SUCCESS) {
+            pj_log_pop_indent();
+            return status;
+        }
+        break;
+
+    default:
+        /* We cannot send CANCEL to a re-INVITE if the INVITE session is
+         * not confirmed.
+         */
+        pj_log_pop_indent();
+        return PJ_EINVALIDOP;
+    }
+
+    pj_log_pop_indent();
+
+    *p_tdata = tdata;
     return PJ_SUCCESS;
 }
@@ -4083 +4157 @@
 
         /*
-         * Handle strandled incoming CANCEL.
-         */
-        pjsip_rx_data *rdata = e->body.tsx_state.src.rdata;
-        pjsip_tx_data *tdata;
-        pj_status_t status;
-
-        status = pjsip_dlg_create_response(dlg, rdata, 200, NULL, &tdata);
-        if (status != PJ_SUCCESS) return;
-
-        status = pjsip_dlg_send_response(dlg, tsx, tdata);
-        if (status != PJ_SUCCESS) return;
+         * Handle strandled incoming CANCEL or CANCEL for re-INVITE
+         */
+        inv_respond_incoming_cancel(inv, tsx, e);
 
     } else if (tsx->role == PJSIP_ROLE_UAS &&
@@ -4229 +4295 @@
             pjsip_tx_data *tdata;
             pj_status_t status;
-            pjsip_rdata_sdp_info *sdp_info;
+            pjsip_rdata_sdp_info *sdp_info = NULL;
             pjsip_status_code st_code;
 
@@ -4302 +4368 @@
             status = inv_check_sdp_in_incoming_msg(inv, tsx, rdata);
 
+            if (status == PJ_SUCCESS && mod_inv.cb.on_rx_reinvite &&
+                inv->notify)
+            {
+                sdp_info = pjsip_rdata_get_sdp_info(rdata);
+                if ((*mod_inv.cb.on_rx_reinvite)
+                        (inv, sdp_info->sdp, rdata) == PJ_SUCCESS)
+                {
+                    /* Application will send its own response.
+                     * Our job is done. */
+                    return;
+                }
+
+                /* If application lets us answer the re-INVITE,
+                 * application must set the SDP answer with
+                 * #pjsip_inv_set_sdp_answer().
+                 */
+                if (pjmedia_sdp_neg_get_state(inv->neg) !=
+                    PJMEDIA_SDP_NEG_STATE_WAIT_NEGO)
+                {
+                    status = PJ_EINVALIDOP;
+                }
+            }
+
             if (status != PJ_SUCCESS) {
 
@@ -4343 +4432 @@
              * Otherwise generate offer from local active SDP.
              */
-            sdp_info = pjsip_rdata_get_sdp_info(rdata);
+            if (!sdp_info)
+                sdp_info = pjsip_rdata_get_sdp_info(rdata);
             if (sdp_info->sdp != NULL) {
                 status = process_answer(inv, 200, tdata, NULL);
@@ -4460 +4550 @@
             inv->invite_tsx = tsx;
 
+        } else if (tsx->state == PJSIP_TSX_STATE_PROCEEDING) {
+            
+            /* CANCEL the re-INVITE if necessary */
+            if (inv->pending_cancel) {
+                pj_status_t status;
+                pjsip_tx_data *cancel;
+
+                inv->pending_cancel = PJ_FALSE;
+
+                status = pjsip_inv_cancel_reinvite(inv, &cancel);
+                if (status == PJ_SUCCESS && cancel)
+                    status = pjsip_inv_send_msg(inv, cancel);
+            }
+
         } else if (tsx->state == PJSIP_TSX_STATE_TERMINATED &&
                    tsx->status_code/100 == 2)