]> git.proxmox.com Git - mirror_kronosnet.git/commitdiff
[handle] be consistent in applying sockopts around
authorFabio M. Di Nitto <fdinitto@redhat.com>
Mon, 13 Jun 2016 19:14:01 +0000 (21:14 +0200)
committerFabio M. Di Nitto <fdinitto@redhat.com>
Mon, 13 Jun 2016 19:14:01 +0000 (21:14 +0200)
Signed-off-by: Fabio M. Di Nitto <fdinitto@redhat.com>
libknet/handle.c

index 262294d64c8637ad6a1cbeddc91bd9fe9d49f23a..bd3c396f760d3b39cbd172d299f0c014a0bd96c6 100644 (file)
@@ -180,6 +180,30 @@ static int _init_socketpair(knet_handle_t knet_h, int *sock0, int *sock1)
                goto exit_fail;
        }
 
+       value = KNET_RING_RCVBUFF;
+       if (setsockopt(*sock0, SOL_SOCKET, SO_SNDBUFFORCE, &value, sizeof(value)) < 0) {
+               savederrno = errno;
+               log_err(knet_h, KNET_SUB_HANDLE, "Unable to set send buffer on sock[0]: %s",
+                       strerror(savederrno));
+               goto exit_fail;
+       }
+
+       value = KNET_RING_RCVBUFF;
+       if (setsockopt(*sock1, SOL_SOCKET, SO_RCVBUFFORCE, &value, sizeof(value)) < 0) {
+               savederrno = errno;
+               log_err(knet_h, KNET_SUB_HANDLE, "Unable to set receive buffer on sock[1]: %s",
+                       strerror(savederrno));
+               goto exit_fail;
+       }
+
+       value = KNET_RING_RCVBUFF;
+       if (setsockopt(*sock1, SOL_SOCKET, SO_SNDBUFFORCE, &value, sizeof(value)) < 0) {
+               savederrno = errno;
+               log_err(knet_h, KNET_SUB_HANDLE, "Unable to set send buffer on sock[1]: %s",
+                       strerror(savederrno));
+               goto exit_fail;
+       }
+
        return 0;
 
 exit_fail: