Turn on TCP_NODELAY by default.

rabbitmq · Jul 2, 2010 · d2fb070 · d2fb070
1 parent 7478207
commit d2fb070
Showing 1 changed file with 10 additions and 0 deletions.
diff --git a/librabbitmq/amqp_socket.c b/librabbitmq/amqp_socket.c
@@ -65,6 +65,7 @@
 #include <sys/socket.h>
 #include <netdb.h>
 #include <netinet/in.h>
+#include <netinet/tcp.h>
 
 #include <assert.h>
 
@@ -89,6 +90,15 @@ int amqp_open_socket(char const *hostname,
     return -errno;
   }
 
+  {
+    int one = 1;
+    if (setsockopt(sockfd, IPPROTO_TCP, TCP_NODELAY, &one, sizeof(one)) < 0) {
+      int result = -errno;
+      close(sockfd);
+      return result;
+    }
+  }
+
   if (connect(sockfd, (struct sockaddr *) &addr, sizeof(addr)) < 0) {
     int result = -errno;
     close(sockfd);