feat(unix): introduce ability to close server

include/pandio/tcp.h

@@ -133,6 +133,8 @@ int pd_tcp_listen(pd_tcp_server_t*, int, pd_on_connection_cb);
 
 void pd_tcp_server_init(pd_io_t*, pd_tcp_server_t*);
 
+int pd_tcp_server_close(pd_tcp_server_t*);
+
 void pd_tcp_init(pd_io_t*, pd_tcp_t*);
 
 /* Creates pd_tcp_t from OS socket handle */

samples/server.c

@@ -60,24 +60,17 @@ void interval_task(pd_timer_t *timer) {
     printf("Timer callback\n");
 }
 
+void close_server(pd_timer_t *timer) {
+    printf("Closing server...\n");
+    pd_tcp_server_t *server = timer->data;
+    pd_tcp_server_close(server);
+    free(server);
+}
 
 int main() {
     pd_io_t *ctx = malloc(sizeof(pd_io_t));
     pd_io_init(ctx);
 
-    pd_threadpool_init(4);
-
-    pd_timer_t timer;
-    pd_timer_init(ctx, &timer);
-    pd_timer_repeat(&timer, interval_task, 4000);
-
-    for (int i = 0; i < 11; ++i) {
-        pd_task_t *task = malloc(sizeof(pd_task_t));
-        task->work = expensive_task;
-        task->done = task_done;
-        pd_task_submit(ctx, task);
-    }
-
     pd_tcp_server_t *server = malloc(sizeof(pd_tcp_server_t));
     pd_tcp_server_init(ctx, server);
     //pd_threadpool_end();
@@ -87,5 +80,10 @@ int main() {
         printf("Listener failed.\n");
     }
 
+    pd_timer_t timer;
+    pd_timer_init(ctx, &timer);
+    timer.data = server;
+    pd_timer_start(&timer, close_server, 10 * 1000);
+
     pd_io_run(ctx);
 }

src/sys/event_epoll.c

@@ -44,6 +44,7 @@ void pd_io_init(pd_io_t *ctx) {
     }
 
     ctx->now = pd_now();
+    queue_init(&ctx->pending_closes);
     pd_timers_heap_init(ctx);
 
     ctx->task_signal = malloc(sizeof(pd_notifier_t));

src/sys/event_kqueue.c

@@ -48,6 +48,7 @@ void pd_io_init(pd_io_t *ctx) {
         abort();
 
     ctx->now = pd_now();
+    queue_init(&ctx->pending_closes);
     pd_timers_heap_init(ctx);
 
     ctx->task_signal = malloc(sizeof(pd_notifier_t));

src/sys/tcp_unix.c

@@ -59,6 +59,21 @@ void pd_tcp_server_init(pd_io_t *ctx, pd_tcp_server_t *server) {
 }
 
 
+int pd_tcp_server_close(pd_tcp_server_t *server) {
+    int status;
+    status = pd__event_del(server->ctx, server->fd);
+    if (status < 0)
+        return status;
+
+    status  = pd__closesocket(server->fd);
+    if (status < 0)
+        return status;
+
+    server->ctx->refs--;
+    return 0;
+}
+
+
 /* handler for I/O events from epoll/kqueue */
 void pnd__tcp_listener_io(pd_event_t *event, unsigned events) {
     assert(events & PD_POLLIN);

src/sys/tcp_win32.c

@@ -49,6 +49,12 @@ void pd_tcp_server_init(pd_io_t *ctx, pd_tcp_server_t *server) {
 }
 
 
+int pd_tcp_server_close(pd_tcp_server_t *server) {
+    // not supported yet on Windows
+    return PD_UNKNOWN;
+}
+
+
 /* Handling callback from IOCP */
 void pd__tcp_accept_io(pd_event_t *event) {
     pd__accept_op_t *op = event->data;