socket frontend: Use nonblocking I/O for open connections.

diff --git a/src/frontend/sock.c b/src/frontend/sock.c
index 3662a2650cc41d313ea5c6e8613c59810825fd50..a389a142b94f8a1a609a02a2ae1773239dc0e624 100644 (file)
--- a/src/frontend/sock.c
+++ b/src/frontend/sock.c
@@ -43,6 +43,8 @@
 
 #include <unistd.h>
 
+#include <fcntl.h>
+
 #include <sys/time.h>
 #include <sys/types.h>
 #include <sys/select.h>
@@ -235,6 +237,7 @@ connection_init(sdb_object_t *obj, va_list ap)
 {
        connection_t *conn;
        int sock_fd;
+       int sock_fl;
 
        assert(obj);
        conn = &CONN(obj)->conn;
@@ -259,7 +262,16 @@ connection_init(sdb_object_t *obj, va_list ap)
                return -1;
        }
 
-       sdb_log(SDB_LOG_DEBUG, "frontend: Accepted connection on fd=%i\n",
+       sock_fl = fcntl(conn->fd, F_GETFL);
+       if (fcntl(conn->fd, F_SETFL, sock_fl | O_NONBLOCK)) {
+               char buf[1024];
+               sdb_log(SDB_LOG_ERR, "frontend: Failed to switch connection conn#%i "
+                               "to non-blocking mode: %s", conn->fd,
+                               sdb_strerror(errno, buf, sizeof(buf)));
+               return -1;
+       }
+
+       sdb_log(SDB_LOG_DEBUG, "frontend: Accepted connection on fd=%i",
                        conn->fd);
 
        /* update the object name */