Changeset 4407

Timestamp:

Feb 27, 2013 3:02:03 PM (12 years ago)

Author:

riza

Message:

Re #1620: backported to 1.x

Location:

pjproject/branches/1.x

Files:

• . (modified) (1 prop)
• pjnath/include/pjnath/stun_session.h (modified) (2 diffs)
• pjnath/include/pjnath/stun_transaction.h (modified) (2 diffs)
• pjnath/src/pjnath/ice_session.c (modified) (1 diff)
• pjnath/src/pjnath/stun_session.c (modified) (2 diffs)
• pjnath/src/pjnath/stun_transaction.c (modified) (8 diffs)

pjproject/branches/1.x/pjnath/include/pjnath/stun_session.h

@@ -683 +683 @@
  * @param sess      The STUN session instance.
  * @param tdata     The request message previously sent.
+ * @param mod_count Boolean flag to indicate whether transmission count
+ *                  needs to be incremented.
  *
  * @return          PJ_SUCCESS on success, or the appropriate error.
@@ -690 +692 @@
  */
 PJ_DECL(pj_status_t) pj_stun_session_retransmit_req(pj_stun_session *sess,
-                                                    pj_stun_tx_data *tdata);
+                                                    pj_stun_tx_data *tdata,
+                                                    pj_bool_t mod_count);
 
 

pjproject/branches/1.x/pjnath/include/pjnath/stun_transaction.h

@@ -235 +235 @@
  *
  * @param tsx           The STUN client transaction instance.
+ * @param mod_count     Boolean flag to indicate whether transmission count
+ *                      needs to be incremented.
  *
  * @return              PJ_SUCCESS on success, or PJNATH_ESTUNDESTROYED 
@@ -241 +243 @@
  *                      as returned by \a on_send_msg() callback.
  */
-PJ_DECL(pj_status_t) pj_stun_client_tsx_retransmit(pj_stun_client_tsx *tsx);
+PJ_DECL(pj_status_t) pj_stun_client_tsx_retransmit(pj_stun_client_tsx *tsx,
+                                                   pj_bool_t mod_count);
 
 

pjproject/branches/1.x/pjnath/src/pjnath/ice_session.c

@@ -2710 +2710 @@
             LOG5((ice->obj_name, "Triggered check for check %d not performed "
                   "because it's in progress. Retransmitting", i));
-            pj_stun_session_retransmit_req(comp->stun_sess, c->tdata);
+            pj_stun_session_retransmit_req(comp->stun_sess, c->tdata, PJ_FALSE);
 
         } else if (c->state == PJ_ICE_SESS_CHECK_STATE_SUCCEEDED) {

pjproject/branches/1.x/pjnath/src/pjnath/stun_session.c

@@ -1053 +1053 @@
  */
 PJ_DEF(pj_status_t) pj_stun_session_retransmit_req(pj_stun_session *sess,
-                                                   pj_stun_tx_data *tdata)
+                                                   pj_stun_tx_data *tdata,
+                                                   pj_bool_t mod_count)
 {
     pj_status_t status;
@@ -1064 +1065 @@
     pj_lock_acquire(sess->lock);
 
-    status = pj_stun_client_tsx_retransmit(tdata->client_tsx);
+    status = pj_stun_client_tsx_retransmit(tdata->client_tsx, mod_count);
 
     pj_lock_release(sess->lock);

pjproject/branches/1.x/pjnath/src/pjnath/stun_transaction.c

@@ -181 +181 @@
  * Transmit message.
  */
-static pj_status_t tsx_transmit_msg(pj_stun_client_tsx *tsx)
+static pj_status_t tsx_transmit_msg(pj_stun_client_tsx *tsx,
+                                    pj_bool_t mod_count)
 {
     pj_status_t status;
@@ -188 +189 @@
                      !tsx->require_retransmit, PJ_EBUSY);
 
-    if (tsx->require_retransmit) {
+    if (tsx->require_retransmit && mod_count) {
         /* Calculate retransmit/timeout delay */
         if (tsx->transmit_count == 0) {
@@ -222 +223 @@
 
 
-    tsx->transmit_count++;
+    if (mod_count)
+        tsx->transmit_count++;
 
     PJ_LOG(5,(tsx->obj_name, "STUN sending message (transmit count=%d)",
@@ -233 +235 @@
         /* We've been destroyed, don't access the object. */
     } else if (status != PJ_SUCCESS) {
-        if (tsx->retransmit_timer.id != 0) {
+        if (tsx->retransmit_timer.id != 0 && mod_count) {
             pj_timer_heap_cancel(tsx->timer_heap, 
                                  &tsx->retransmit_timer);
@@ -295 +297 @@
 
     /* Send the message */
-    status = tsx_transmit_msg(tsx);
+    status = tsx_transmit_msg(tsx, PJ_TRUE);
     if (status != PJ_SUCCESS) {
         if (tsx->retransmit_timer.id != 0) {
@@ -333 +335 @@
 
     tsx->retransmit_timer.id = 0;
-    status = tsx_transmit_msg(tsx);
+    status = tsx_transmit_msg(tsx, PJ_TRUE);
     if (status == PJNATH_ESTUNDESTROYED) {
         /* We've been destroyed, don't try to access the object */
@@ -351 +353 @@
  * Request to retransmit the request.
  */
-PJ_DEF(pj_status_t) pj_stun_client_tsx_retransmit(pj_stun_client_tsx *tsx)
+PJ_DEF(pj_status_t) pj_stun_client_tsx_retransmit(pj_stun_client_tsx *tsx,
+                                                  pj_bool_t mod_count)
 {
     if (tsx->destroy_timer.id != 0) {
@@ -362 +365 @@
     }
 
-    return tsx_transmit_msg(tsx);
+    return tsx_transmit_msg(tsx, mod_count);
 }