Changeset 1192 for pjproject/branches/symbian/pjsip/src/pjsip/sip_transaction.c

Timestamp:

Apr 11, 2007 7:48:42 PM (17 years ago)

Author:

bennylp

Message:

Applying ticket #220 to Symbian branch: Bug in retransmission of non-INVITE SIP requests in UAC transaction (thanks Martin Peterzon)

File:

• pjproject/branches/symbian/pjsip/src/pjsip/sip_transaction.c (modified) (5 diffs)

pjproject/branches/symbian/pjsip/src/pjsip/sip_transaction.c

@@ -126 +126 @@
 static const pj_time_val t1_timer_val = { PJSIP_T1_TIMEOUT/1000, 
                                           PJSIP_T1_TIMEOUT%1000 };
+static const pj_time_val t2_timer_val = { PJSIP_T2_TIMEOUT/1000, 
+                                          PJSIP_T2_TIMEOUT%1000 };
 static const pj_time_val t4_timer_val = { PJSIP_T4_TIMEOUT/1000, 
                                           PJSIP_T4_TIMEOUT%1000 };
@@ -1704 +1706 @@
     pj_assert((tsx->transport_flag & TSX_HAS_PENDING_TRANSPORT) == 0);
 
-    msec_time = (1 << (tsx->retransmit_count)) * PJSIP_T1_TIMEOUT;
+    pj_assert(tsx->status_code < 200);
+
+    if (tsx->status_code >= 100)
+        msec_time = PJSIP_T2_TIMEOUT;
+    else
+        msec_time = (1 << (tsx->retransmit_count)) * PJSIP_T1_TIMEOUT;
 
     if (tsx->role == PJSIP_ROLE_UAC) {
@@ -1879 +1886 @@
     } else if (event->type == PJSIP_EVENT_RX_MSG) {
         pjsip_msg *msg;
-        //int code;
+        int code;
 
         /* Get message instance */
         msg = event->body.rx_msg.rdata->msg_info.msg;
 
-        /* Better be a response message. */
-        if (msg->type != PJSIP_RESPONSE_MSG)
-            return PJSIP_ENOTRESPONSEMSG;
-
-        /* Cancel retransmission timer A. */
-        if (tsx->retransmit_timer._timer_id != -1) {
-            pjsip_endpt_cancel_timer(tsx->endpt, &tsx->retransmit_timer);
-            tsx->retransmit_timer._timer_id = -1;
-        }
+        code = msg->line.status.code;
+
+        /* If the response is final, cancel both retransmission and timeout
+         * timer.
+         */
+        if (code >= 200) {
+            if (tsx->retransmit_timer._timer_id != -1) {
+                pjsip_endpt_cancel_timer(tsx->endpt, &tsx->retransmit_timer);
+                tsx->retransmit_timer._timer_id = -1;
+            }
+
+            if (tsx->timeout_timer._timer_id != -1) {
+                pjsip_endpt_cancel_timer(tsx->endpt, &tsx->timeout_timer);
+                tsx->timeout_timer._timer_id = -1;
+            }
+
+        } else {
+            /* Cancel retransmit timer (for non-INVITE transaction, the
+             * retransmit timer will be rescheduled at T2.
+             */
+            if (tsx->retransmit_timer._timer_id != -1) {
+                pjsip_endpt_cancel_timer(tsx->endpt, &tsx->retransmit_timer);
+                tsx->retransmit_timer._timer_id = -1;
+            }
+
+            /* For provisional response, only cancel retransmit when this
+             * is an INVITE transaction. For non-INVITE, section 17.1.2.1
+             * of RFC 3261 says that:
+             *  - retransmit timer is set to T2
+             *  - timeout timer F is not deleted.
+             */
+            if (tsx->method.id == PJSIP_INVITE_METHOD) {
+
+                /* Cancel timeout timer */
+                pjsip_endpt_cancel_timer(tsx->endpt, &tsx->timeout_timer);
+
+            } else {
+                if (!tsx->is_reliable) {
+                    pjsip_endpt_schedule_timer(tsx->endpt, 
+                                               &tsx->retransmit_timer,
+                                               &t2_timer_val);
+                }
+            }
+        }
+ 
         tsx->transport_flag &= ~(TSX_HAS_PENDING_RESCHED);
-
-
-        /* Cancel timer B (transaction timeout) */
-        pjsip_endpt_cancel_timer(tsx->endpt, &tsx->timeout_timer);
 
         /* Discard retransmission message if it is not INVITE.
@@ -2222 +2261 @@
         tsx->status_code = msg->line.status.code;
     } else {
-        tsx->status_code = PJSIP_SC_TSX_TIMEOUT;
+        if (event->body.timer.entry == &tsx->retransmit_timer) {
+            /* Retransmit message. */
+            pj_status_t status;
+
+            status = tsx_retransmit( tsx, 1 );
+            
+            return status;
+
+        } else {
+            tsx->status_code = PJSIP_SC_TSX_TIMEOUT;
+        }
     }
 
@@ -2266 +2315 @@
         }
 
+    } else if (event->type == PJSIP_EVENT_TIMER &&
+               event->body.timer.entry == &tsx->timeout_timer) {
+
+        /* Inform TU. */
+        tsx_set_state( tsx, PJSIP_TSX_STATE_TERMINATED, 
+                       PJSIP_EVENT_TIMER, &tsx->timeout_timer);
+
+
     } else if (tsx->status_code >= 300 && tsx->status_code <= 699) {