Changeset 260

Timestamp:

Mar 1, 2006 11:05:11 PM (18 years ago)

Author:

bennylp

Message:

Maximize the size of SO_SNDBUF and SO_RCVBUF for UDP transport

File:

• pjproject/trunk/pjsip/src/pjsip/sip_transport_udp.c (modified) (3 diffs)

pjproject/trunk/pjsip/src/pjsip/sip_transport_udp.c

@@ -20 +20 @@
 #include <pjsip/sip_endpoint.h>
 #include <pjsip/sip_errno.h>
+#include <pj/addr_resolv.h>
+#include <pj/assert.h>
+#include <pj/lock.h>
+#include <pj/log.h>
+#include <pj/os.h>
 #include <pj/pool.h>
 #include <pj/sock.h>
-#include <pj/addr_resolv.h>
-#include <pj/os.h>
-#include <pj/lock.h>
 #include <pj/string.h>
-#include <pj/assert.h>
+
+
+#define THIS_FILE   "sip_transport_udp.c"
+
+/**
+ * These are the values for socket send and receive buffer sizes,
+ * respectively. They will be applied to UDP socket with setsockopt().
+ */
+#ifndef PJSIP_UDP_SO_SNDBUF_SIZE
+#   define PJSIP_UDP_SO_SNDBUF_SIZE     (4*1024*1024)
+#endif
+
+#ifndef PJSIP_UDP_SO_RCVBUF_SIZE
+#   define PJSIP_UDP_SO_RCVBUF_SIZE     (4*1024*1024)
+#endif
 
 
@@ -330 +346 @@
     pj_ioqueue_t *ioqueue;
     pj_ioqueue_callback ioqueue_cb;
+    long sobuf_size;
     unsigned i;
     pj_status_t status;
@@ -335 +352 @@
     PJ_ASSERT_RETURN(endpt && sock!=PJ_INVALID_SOCKET && a_name && async_cnt>0,
                      PJ_EINVAL);
+
+
+    /* Adjust socket rcvbuf size */
+    sobuf_size = PJSIP_UDP_SO_RCVBUF_SIZE;
+    status = pj_sock_setsockopt(sock, PJ_SOL_SOCKET, PJ_SO_RCVBUF,
+                                &sobuf_size, sizeof(sobuf_size));
+    if (status != PJ_SUCCESS) {
+        char errmsg[PJ_ERR_MSG_SIZE];
+        pj_strerror(status, errmsg, sizeof(errmsg));
+        PJ_LOG(4,(THIS_FILE, "Error setting SO_RCVBUF: %s [%d]", errmsg,
+                  status));
+    }
+
+    /* Adjust socket sndbuf size */
+    sobuf_size = PJSIP_UDP_SO_SNDBUF_SIZE;
+    status = pj_sock_setsockopt(sock, PJ_SOL_SOCKET, PJ_SO_SNDBUF,
+                                &sobuf_size, sizeof(sobuf_size));
+    if (status != PJ_SUCCESS) {
+        char errmsg[PJ_ERR_MSG_SIZE];
+        pj_strerror(status, errmsg, sizeof(errmsg));
+        PJ_LOG(4,(THIS_FILE, "Error setting SO_SNDBUF: %s [%d]", errmsg,
+                  status));
+    }
 
     /* Create pool. */