POTD skeleton #5.

Signed-off-by: Toni Uhlig <matzeton@googlemail.com>

1 files changed, 18 insertions, 4 deletions

diff --git a/src/server.c b/src/server.c
index f4e49aa..60925b6 100644
--- a/src/server.c
+++ b/src/server.c
@@ -13,6 +13,7 @@ typedef struct client_thread_args {
     pthread_t self;
     int client_fd;
     struct sockaddr_in clientaddr;
+    char host_buf[NI_MAXHOST], service_buf[NI_MAXSERV];
     const server_ctx *server_ctx;
 } client_thread_args;
 
@@ -103,7 +104,7 @@ int server_mainloop_epoll(int epoll_fd, const server_ctx ctx[], size_t siz)
                     /* new client connection, accept succeeded */
                     continue;
                 }
-                D2("FD: %d/%lu , %d", events[i].data.fd, siz, n);
+                W2("Server accept client failed: [fd: %d , npoll: %d]", events[i].data.fd, n);
             }
         }
     }
@@ -116,7 +117,7 @@ static int server_accept_client(const server_ctx ctx[],
                                 size_t siz, struct epoll_event *event)
 {
     size_t i;
-    int client_fd;
+    int s, client_fd;
     struct sockaddr_in clientaddr;
 
     for (i = 0; i < siz; ++i) {
@@ -132,15 +133,27 @@ static int server_accept_client(const server_ctx ctx[],
             args->client_fd = client_fd;
             args->clientaddr = clientaddr;
             args->server_ctx = &ctx[i];
+            s = socket_addrtostr_in(&clientaddr,
+                                    args->host_buf, args->service_buf);
+            if (s) {
+                E_GAIERR(s, "Convert socket address to string");
+                goto error;
+            }
+            N("New client connection from %s:%s",
+              args->host_buf, args->service_buf);
+
             if (pthread_create(&args->self, NULL,
                                client_mainloop_epoll, args))
             {
                 E_STRERR("Thread creation");
-                free(args);
-                return 0;
+                goto error;
             }
 
             return 1;
+error:
+            close(client_fd);
+            free(args);
+            return 0;
         }
     }
 
@@ -157,6 +170,7 @@ client_mainloop_epoll(void *arg)
 
     assert(arg);
     args = (client_thread_args *) arg;
+    pthread_detach(args->self);
     events = (struct epoll_event *) calloc(POTD_MAXEVENTS, sizeof(*events));
     assert(events);