Merge pull request #2 from felipeagger/feat/uring-ok

added thread pool on uring server.

Author: felipeagger

Makefile

@@ -17,7 +17,7 @@ epoll: epoll-server.c
 #	$(CC) $(CFLAGS) -o $@ $< -DFILE2_DEFINE -DADDITIONAL_FLAG
 
 uring: uring-server.c
-	$(CC) -o uring-server uring-server.c request-handle.c cpu-bound.c $(CFLAGS) -I/usr/local/include -L/usr/local/lib -luring
+	$(CC) -o uring-server uring-server.c threadpool.c request-handle.c cpu-bound.c $(CFLAGS) -pthread -I/usr/local/include -L/usr/local/lib -luring
 #	# $(CC) $(CFLAGS) -g -o $@ $< -DFILE3_DEFINE -lm
 #	# musl-gcc -o rest_server rest_server.c -I/usr/local/include -L/usr/local/lib -luring
 

README.md

@@ -4,7 +4,7 @@ This is a implementation of Http server using Linux SystemCalls.
 
 There are some implementations:
 - simple-server.c: Using only accept syscall.
-- epoll-server.c: Using epoll syscall with 10 events.
+- epoll-server.c: Using epoll syscall with 1000 events.
 - uring-server.c: Using io_uring (liburing) with queue depth 256. 
 
 ### Default port is 8080.

uring-server.c

@@ -14,6 +14,7 @@
 #define QUEUE_DEPTH             256
 #define READ_SZ                 8192
 #define BUFFER_SIZE             2048
+#define WORKERS 3
 
 #define EVENT_TYPE_ACCEPT       0
 #define EVENT_TYPE_READ         1
@@ -31,6 +32,8 @@ struct request {
 
 struct io_uring ring;
 
+ThreadPool pool;
+
 /*
  One function that prints the system call and the error details
  and then exits with error code 1. Non-zero meaning things didn't go well.
@@ -173,7 +176,8 @@ int handle_client_request(struct request *req) {
     strncpy(args->buffer, http_request, BUFFER_SIZE - 1);
     args->buffer[BUFFER_SIZE - 1] = '\0';
 
-    handle_request(args);
+    //handle_request(args); //sync
+    thread_pool_add(&pool, handle_request, args); //async
     return 0;
 }
 
@@ -182,6 +186,8 @@ void server_loop(int server_socket) {
     struct sockaddr_in client_addr;
     socklen_t client_addr_len = sizeof(client_addr);
 
+    thread_pool_init(&pool, WORKERS, QUEUE_DEPTH);
+
     add_accept_request(server_socket, &client_addr, &client_addr_len);
 
     while (1) {