added io uring server

Author: felipeagger

Dockerfile

@@ -6,7 +6,18 @@ RUN apk add --no-cache \
     clang \
     llvm \
     musl-dev \
-    build-base
+    build-base \
+    git \
+    linux-headers
+    #liburing-dev
+
+
+# liburing
+RUN git clone https://github.com/axboe/liburing.git && \
+    cd liburing && \
+    make && \
+    make install
+    #ldconfig
 
 COPY . .
 
@@ -20,5 +31,5 @@ WORKDIR /home
 
 COPY --from=build /app/simple-server .
 COPY --from=build /app/epoll-server .
+COPY --from=build /app/uring-server .
 
-#CMD ["./app"]

Makefile

@@ -2,8 +2,8 @@ CC = clang
 CFLAGS = -static -lm -Wall -Wextra -O2
 
 # files
-SOURCES = simple-server.c epoll-server.c #uring-server.c
-TARGETS = simple epoll #uring-server
+SOURCES = simple-server.c epoll-server.c uring-server.c
+TARGETS = simple epoll uring
 
 all: $(TARGETS)
 
@@ -17,8 +17,8 @@ epoll: epoll-server.c
 #	$(CC) $(CFLAGS) -o $@ $< -DFILE2_DEFINE -DADDITIONAL_FLAG
 
 uring: uring-server.c
-#	# $(CC) $(CFLAGS) -o $@ $< -DFILE3_DEFINE -lm
-	$(CC) -g -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 request-handle.c cpu-bound.c $(CFLAGS) -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

@@ -1,11 +1,11 @@
 # c-http-server-from-scratch
 
-This is a implementation of Http server using directly Linux SystemCalls.
+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.
-- io_uring.c: TODO.
+- uring-server.c: Using io_uring (liburing) with queue depth 256. 
 
 ### Default port is 8080.
 
@@ -19,4 +19,5 @@ There are some implementations:
 
 # Entrypoints:
 - /home/simple-server
-- /home/epoll-server
+- /home/epoll-server
+- /home/uring-server

cpu-bound.c

@@ -0,0 +1,35 @@
+#include <stdio.h>
+#include <math.h>
+#include <time.h>
+#include <stdbool.h>
+#include "cpu-bound.h"
+
+//int timeout = 5; seconds
+//simulateCPU(timeout);
+
+void simulateCPU(int timeout) {
+    clock_t start = clock();
+    int i = 2;
+
+    while (1) {
+        // Verifica se o tempo limite foi atingido
+        if (((double)(clock() - start) / CLOCKS_PER_SEC) * 1000 > timeout) { // to ms
+            return;
+        }
+        isPrime(i); // Execute CPU-bound work
+        i++;
+    }
+}
+
+bool isPrime(int n) {
+    if (n < 2) {
+        return false;
+    }
+    for (int i = 2; i <= (int)sqrt((double)n); i++) {
+        if (n % i == 0) {
+            return false;
+        }
+    }
+    return true;
+}
+

cpu-bound.h

@@ -0,0 +1,10 @@
+#include <stdbool.h>
+
+#ifndef CPU_BOUND_H
+#define CPU_BOUND_H
+
+
+void simulateCPU(int);
+bool isPrime(int);
+
+#endif

epoll-server.c

@@ -98,7 +98,7 @@ int main() {
         exit(EXIT_FAILURE);
     }
 
-    printf("Servidor ouvindo na porta %d\n", PORT);
+    printf("epoll server listening on port %d\n", PORT);
 
     while (1) {
         int n = epoll_wait(epoll_fd, events, MAX_EVENTS, -1);
@@ -113,7 +113,18 @@ int main() {
                 printf("Nova conexão aceita\n");
             } else {
                 // process request
-                handle_request(events[i].data.fd);
+                char buffer[BUFFER_SIZE];
+                int bytes_read = read(events[i].data.fd, buffer, BUFFER_SIZE - 1);
+
+                if (bytes_read < 0) {
+                    perror("Erro ao ler do cliente");
+                    close(events[i].data.fd);
+                    continue;
+                }
+
+                buffer[bytes_read] = '\0';
+
+                handle_request(events[i].data.fd, buffer);
             }
         }
     }

request-handle.c

@@ -51,17 +51,7 @@ char* getParamQueryString(char buffer[BUF_SIZE], const char *param_name) {
     return NULL;
 }
 
-void handle_request(int client_fd) {
-    char buffer[BUF_SIZE];
-    int bytes_read = read(client_fd, buffer, BUF_SIZE - 1);
-
-    if (bytes_read < 0) {
-        perror("Erro ao ler do cliente");
-        close(client_fd);
-        return;
-    }
-
-    buffer[bytes_read] = '\0'; // Garante que o buffer seja uma string
+void handle_request(int client_fd, char *buffer) {
     printf("Requisição recebida:\n%s\n", buffer);
 
     //params

request-handle.h

@@ -2,6 +2,6 @@
 #define REQUEST_HANDLE_H
 
 
-void handle_request(int);
+void handle_request(int client_fd, char *buffer);
 
 #endif

simple-server.c

@@ -73,7 +73,7 @@ int main() {
         exit(EXIT_FAILURE);
     }
 
-    printf("Servidor ouvindo na porta %d...\n", PORT);
+    printf("simple server listening on port %d...\n", PORT);
 
     // 5. Loop principal para aceitar conexões
     while (1) {
@@ -90,7 +90,19 @@ int main() {
                inet_ntoa(client_addr.sin_addr),
                ntohs(client_addr.sin_port));
 
-        handle_request(client_fd);
+
+        char buffer[BUF_SIZE];
+        int bytes_read = read(client_fd, buffer, BUF_SIZE - 1);
+
+        if (bytes_read < 0) {
+            perror("Erro ao ler do cliente");
+            close(client_fd);
+            continue;
+        }
+
+        buffer[bytes_read] = '\0';
+
+        handle_request(client_fd, buffer);
     }
 
     close(server_fd);