Increase socket buffer size

knizhnik · knizhnik · commit 597e2eed7af2 · 2015-12-29T13:35:44.000+03:00
diff --git a/contrib/multimaster/dtmd/include/limits.h b/contrib/multimaster/dtmd/include/limits.h
@@ -6,5 +6,6 @@
 #define BUFFER_SIZE (256 * 1024)
 #define LISTEN_QUEUE_SIZE 100
 #define MAX_STREAMS 4096
+#define SOCKET_BUFFER_SIZE (16*1024*1024)
 
 #endif
diff --git a/contrib/multimaster/dtmd/src/server.c b/contrib/multimaster/dtmd/src/server.c
@@ -81,6 +81,10 @@ static int create_listening_socket(const char *host, int port) {
 	int optval = 1;
 	setsockopt(s, IPPROTO_TCP, TCP_NODELAY, (char const*)&optval, sizeof(optval));
 	setsockopt(s, SOL_SOCKET, SO_REUSEADDR, (char const*)&optval, sizeof(optval));
+	optval = SOCKET_BUFFER_SIZE;
+	setsockopt(s, SOL_SOCKET, SO_SNDBUF, (const char*) &optval, sizeof(int));
+	optval = SOCKET_BUFFER_SIZE;
+	setsockopt(s, SOL_SOCKET, SO_RCVBUF, (const char*) &optval, sizeof(int));
 
 	struct sockaddr_in addr;
 	addr.sin_family = AF_INET;
diff --git a/contrib/multimaster/sockhub/sockhub.c b/contrib/multimaster/sockhub/sockhub.c
@@ -19,6 +19,8 @@
 
 #include "sockhub.h"
 
+const size_t SOCKHUB_BUFFER_SIZE (16*1024*1024)
+
 void ShubAddSocket(Shub* shub, int fd);
 
 inline void ShubAddSocket(Shub* shub, int fd)
@@ -189,6 +191,10 @@ static void reconnect(Shub* shub)
             } else { 
                 int optval = 1;
                 setsockopt(shub->output, IPPROTO_TCP, TCP_NODELAY, (char const*)&optval, sizeof(optval));
+				optval = SOCKHUB_BUFFER_SIZE;
+				setsockopt(shub->output, SOL_SOCKET, SO_SNDBUF, (const char*) &optval, sizeof(int));
+				optval = SOCKHUB_BUFFER_SIZE;
+				setsockopt(shub->output, SOL_SOCKET, SO_RCVBUF, (const char*) &optval, sizeof(int));
 
                 ShubAddSocket(shub, shub->output);
                 if (sep != NULL) { 
