Accept client connections in a loop rather than accepting one per-wak…

…eup.

Ideally this should lead to better accept performance in that it should empty the accept backlog without having to go back for more events.

src/cloudbridge.cpp

@@ -2,6 +2,7 @@
 #include <netdb.h>
 #include <netinet/in.h>
 #include <unistd.h>
+#include <fcntl.h>
 #include <errno.h>
 #include <iostream>
 #include <fstream>
@@ -163,6 +164,12 @@ int main(int argc, char **argv)
 			int on = 1;
 			setsockopt(listen_socket, SOL_SOCKET, SO_REUSEADDR, &on, sizeof(on));
 
+			// go into nonblocking mode
+			int flags;
+			if (-1 == (flags = fcntl(listen_socket, F_GETFL, 0)))
+				flags = 0;
+		   	fcntl(listen_socket, F_SETFL, flags | O_NONBLOCK);
+
 			if (bind(listen_socket, addrinfo->ai_addr, addrinfo->ai_addrlen))
 			{
 				printf("Error binding socket. Errno: %d\n", errno);

src/listen_handler.cpp

@@ -11,8 +11,11 @@ void listen_handler::operator()(struct ev_loop *loop, evx_io *watcher, int reven
 {
 	struct sockaddr_in remote_addr;
 	socklen_t addr_len = sizeof(remote_addr);
-	int socket = accept(listen_socket, reinterpret_cast<struct sockaddr*>(&remote_addr), &addr_len);
-
-	connections->get_server_stats().incr("Connections");
-	buffered_connection::create_connection(loop, socket, buffered_connection::client_handler_ptr(new connection_finder(connections, host_key_secret)));
+	int socket;
+	while (-1 != (socket = accept(listen_socket, reinterpret_cast<struct sockaddr*>(&remote_addr), &addr_len)))
+	{
+		connections->get_server_stats().incr("Connections");
+		buffered_connection::create_connection(loop, socket, buffered_connection::client_handler_ptr(new connection_finder(connections, host_key_secret)));
+		addr_len = sizeof(remote_addr);
+	}
 }