1 files changed, 81 insertions, 0 deletions
diff --git a/csrc/http.c b/csrc/http.c
new file mode 100644
index 0000000..0da89c4
--- /dev/null
+++ b/csrc/http.c
@@ -0,0 +1,81 @@
+#include "http.h"
+#include <arpa/inet.h>
+#include <pthread.h>
+#include <stdio.h>
+#include <stdlib.h>
+#include <string.h>
+#include <unistd.h>
+
+#define MAX_QUEUE 3
+
+void *handle_client(void *client_socket) {
+  int sock = *(int *)client_socket;
+
+  free(client_socket);
+
+  char buffer[1024];
+  int n;
+
+  n = read(sock, buffer, sizeof(buffer) - 1);
+  if (n < 0) {
+    perror("read");
+    close(sock);
+    exit(1);
+    return NULL;
+  }
+
+  buffer[n] = '\0';
+  printf("Request: %s\n", buffer);
+
+  const char *response = "HTTP/1.1 200 OK\r\n\r\nHello, World!";
+  write(sock, response, strlen(response));
+  close(sock);
+
+  return NULL;
+}
+
+void start_server(int port) {
+  int server_sock, client_sock, *new_sock;
+  struct sockaddr_in server, client;
+
+  socklen_t client_len = sizeof(client);
+  pthread_t thread_id;
+
+  server_sock = socket(AF_INET, SOCK_STREAM, 0);
+  if (server_sock < 0) {
+    perror("socket");
+    exit(1);
+  }
+
+  server.sin_family = AF_INET;
+  server.sin_port = htons(port);
+  server.sin_addr.s_addr = htonl(INADDR_ANY);
+
+  if (bind(server_sock, (struct sockaddr *)&server, sizeof(server)) < 0) {
+    perror("bind");
+    close(server_sock);
+    exit(1);
+  }
+
+  listen(server_sock, MAX_QUEUE);
+
+  printf("Server listening on port %d\n", port);
+
+  while ((client_sock =
+              accept(server_sock, (struct sockaddr *)&client, &client_len))) {
+    new_sock = malloc(sizeof(int));
+    *new_sock = client_sock;
+
+    if (pthread_create(&thread_id, NULL, handle_client, (void *)new_sock) < 0) {
+      perror("pthread_create");
+      exit(1);
+    }
+  }
+
+  if (client_sock < 0) {
+    perror("accept");
+    exit(1);
+  }
+
+  close(server_sock);
+}