Changeset 2710 for pjproject/branches/projects/sipit24/pjsip/src/pjsip/sip_transport.c

Timestamp:

May 18, 2009 11:18:38 AM (14 years ago)

Author:

bennylp

Message:

More ticket #831:

• fixed Via address unchanged when switching transport
• reset transaction retransmit count and timeout timer when retrying
• handle case when TCP transport is not available
• added macro PJSIP_UDP_SIZE_THRESHOLD
• added API to encode transmit data (to avoid using stack when checking message size)

File:

• pjproject/branches/projects/sipit24/pjsip/src/pjsip/sip_transport.c (modified) (2 diffs)

pjproject/branches/projects/sipit24/pjsip/src/pjsip/sip_transport.c

@@ -435 +435 @@
 }
 
+/*
+ * Print the SIP message to transmit data buffer's internal buffer.
+ */
+PJ_DEF(pj_status_t) pjsip_tx_data_encode(pjsip_tx_data *tdata)
+{
+    /* Allocate buffer if necessary. */
+    if (tdata->buf.start == NULL) {
+        PJ_USE_EXCEPTION;
+
+        PJ_TRY {
+            tdata->buf.start = (char*) 
+                               pj_pool_alloc(tdata->pool, PJSIP_MAX_PKT_LEN);
+        }
+        PJ_CATCH_ANY {
+            return PJ_ENOMEM;
+        }
+        PJ_END
+
+        tdata->buf.cur = tdata->buf.start;
+        tdata->buf.end = tdata->buf.start + PJSIP_MAX_PKT_LEN;
+    }
+
+    /* Do we need to reprint? */
+    if (!pjsip_tx_data_is_valid(tdata)) {
+        pj_ssize_t size;
+
+        size = pjsip_msg_print( tdata->msg, tdata->buf.start, 
+                                tdata->buf.end - tdata->buf.start);
+        if (size < 0) {
+            return PJSIP_EMSGTOOLONG;
+        }
+        pj_assert(size != 0);
+        tdata->buf.cur[size] = '\0';
+        tdata->buf.cur += size;
+    }
+
+    return PJ_SUCCESS;
+}
+
 PJ_DEF(pj_bool_t) pjsip_tx_data_is_valid( pjsip_tx_data *tdata )
 {
@@ -568 +607 @@
 static pj_status_t mod_on_tx_msg(pjsip_tx_data *tdata)
 {
-    /* Allocate buffer if necessary. */
-    if (tdata->buf.start == NULL) {
-        PJ_USE_EXCEPTION;
-
-        PJ_TRY {
-            tdata->buf.start = (char*) 
-                               pj_pool_alloc(tdata->pool, PJSIP_MAX_PKT_LEN);
-        }
-        PJ_CATCH_ANY {
-            return PJ_ENOMEM;
-        }
-        PJ_END
-
-        tdata->buf.cur = tdata->buf.start;
-        tdata->buf.end = tdata->buf.start + PJSIP_MAX_PKT_LEN;
-    }
-
-    /* Do we need to reprint? */
-    if (!pjsip_tx_data_is_valid(tdata)) {
-        pj_ssize_t size;
-
-        size = pjsip_msg_print( tdata->msg, tdata->buf.start, 
-                                tdata->buf.end - tdata->buf.start);
-        if (size < 0) {
-            return PJSIP_EMSGTOOLONG;
-        }
-        pj_assert(size != 0);
-        tdata->buf.cur[size] = '\0';
-        tdata->buf.cur += size;
-    }
-
-    return PJ_SUCCESS;
+    return pjsip_tx_data_encode(tdata);
 }