Fix MULTI / EXEC rendering in MONITOR output.

[redis.git] / src / anet.c

diff --git a/src/anet.c b/src/anet.c
index ba4e6cce89bbc7a552e8510a03a2cb67c53af1f6..4b52425cf8166754cecabd5877b5622b32619e2b 100644 (file)
--- a/src/anet.c
+++ b/src/anet.c
@@ -262,7 +262,11 @@ static int anetListen(char *err, int s, struct sockaddr *sa, socklen_t len) {
         close(s);
         return ANET_ERR;
     }
         close(s);
         return ANET_ERR;
     }

-    if (listen(s, 511) == -1) { /* the magic 511 constant is from nginx */
+
+    /* Use a backlog of 512 entries. We pass 511 to the listen() call because
+     * the kernel does: backlogsize = roundup_pow_of_two(backlogsize + 1);
+     * which will thus give us a backlog of 512 entries */
+    if (listen(s, 511) == -1) {

         anetSetError(err, "listen: %s", strerror(errno));
         close(s);
         return ANET_ERR;
         anetSetError(err, "listen: %s", strerror(errno));
         close(s);
         return ANET_ERR;


@@ -363,3 +367,18 @@ int anetPeerToString(int fd, char *ip, int *port) {
     if (port) *port = ntohs(sa.sin_port);
     return 0;
 }
     if (port) *port = ntohs(sa.sin_port);
     return 0;
 }

+
+int anetSockName(int fd, char *ip, int *port) {
+    struct sockaddr_in sa;
+    socklen_t salen = sizeof(sa);
+
+    if (getsockname(fd,(struct sockaddr*)&sa,&salen) == -1) {
+        *port = 0;
+        ip[0] = '?';
+        ip[1] = '\0';
+        return -1;
+    }
+    if (ip) strcpy(ip,inet_ntoa(sa.sin_addr));
+    if (port) *port = ntohs(sa.sin_port);
+    return 0;
+}