init

Author: vpj

Makefile

@@ -0,0 +1,30 @@
+CC = gcc -fPIC
+LDFLAGS = -lm
+
+# set DEBUG options
+ifdef DEBUG
+CFLAGS = -Wall -Wextra -ggdb -pg -DDEBUG
+else
+CFLAGS = -Wall -O2
+endif
+
+#name all the object files
+OBJS = main.o debug.o echo.o ioloop.o server.o 
+
+all : server
+
+server: $(OBJS)
+	$(CC) $(LDFLAGS) -o main $^
+
+debug :
+	make all DEBUG=1
+
+%.o : %.c
+	$(CC) $(CFLAGS) -o $@ -c $^
+
+doxy :
+	doxygen Doxyfile
+
+clean :
+	rm -rf $(OBJS) main
+

README.md

@@ -1,4 +1,6 @@
 ahira
 =====
 
-An experimental server written in C ... intending to make it like node.js
+An experimental single threaded server written in C which uses epoll. It still doesn't have a HTTP handler.
+The intention is to create a platform like node.js, but in C, so that it will be super fast and memory efficient.
+

debug.c

@@ -0,0 +1,34 @@
+#include "debug.h"
+
+void log_epoll_event(struct epoll_event e) {
+ printf("Event fd: %d events: ", e.data.fd);
+ if(e.events & EPOLLERR)
+  printf("EPOLLERR ");
+ if(e.events & EPOLLET)
+  printf("EPOLLET ");
+ if(e.events & EPOLLHUP)
+  printf("EPOLLHUP ");
+ if(e.events & EPOLLIN)
+  printf("EPOLLIN ");
+ if(e.events & EPOLLONESHOT)
+  printf("EPOLLONESHOT ");
+ if(e.events & EPOLLOUT)
+  printf("EPOLLOUT ");
+ if(e.events & EPOLLPRI)
+  printf("EPOLLPRI ");
+
+ printf("\n");
+}
+
+void log_error(char *m, int level) {
+ if(level & FATAL_ERROR)
+  perror("FATAL ERROR: ");
+ else if(level & ERROR_MESSAGE)
+  perror("ERROR: ");
+
+ perror(m);
+
+ if(level & FATAL_ERROR)
+  exit(1);
+}
+

debug.h

@@ -0,0 +1,11 @@
+#ifndef DEBUG_H
+#define DEBUG_H
+#include "headers.h"
+
+#define FATAL_ERROR 2
+#define ERROR_MESSAGE 1
+
+void log_error(char *m, int level);
+
+void log_epoll_event(struct epoll_event e);
+#endif

echo.c

@@ -0,0 +1,83 @@
+#include "ioloop.h"
+#include "echo.h"
+#include "debug.h"
+
+echo_handler_context *
+echo_handler_init(int fd, struct sockaddr_in addr) {
+ echo_handler_context *c;
+
+ c = malloc(sizeof(echo_handler_context));
+ memset(c, 0, sizeof(echo_handler_context));
+
+ ioloop_set_nonblocking(fd);
+
+ c->fd = fd;
+ c->addr = addr;
+ c->received = 0;
+
+ ioloop_add_handler(fd, handle_echo_events, c, EPOLLIN);
+
+ return c;
+}
+
+static void
+free_context(echo_handler_context *c) {
+ free(c);
+}
+
+int 
+handle_echo_events(struct epoll_event e, void *context) {
+ echo_handler_context *c = (echo_handler_context *)context;
+
+ printf("echo event\n");
+ log_epoll_event(e);
+
+ if(e.events & EPOLLHUP) {
+  close(c->fd);
+
+  ioloop_remove_handler(c->fd);
+
+  free_context(c);
+  return -1;
+ }
+
+ if(e.events & EPOLLERR) {
+  return -1;
+ }
+
+ if(e.events & EPOLLOUT) {
+  if(c->received > 0) {
+   printf("Writing: %s\n", c->buffer);
+
+   if (send(c->fd, c->buffer, c->received, 0) != c->received) {
+    log_error("Could not write to stream", ERROR_MESSAGE);
+   }
+  }
+
+  c->received = 0;
+
+  ioloop_modify_handler(c->fd, EPOLLIN);
+ }
+
+ if(e.events & EPOLLIN) {
+  if ((c->received = recv(c->fd, c->buffer, BUFFER_SIZE, 0)) < 0) {
+   log_error("Error reading from socket", ERROR_MESSAGE);
+  } else {
+   c->buffer[c->received] = 0;
+   printf("Reading %d bytes: %s\n", c->received, c->buffer);
+  }
+
+  if(c->received > 0) {
+   ioloop_modify_handler(c->fd, EPOLLOUT);
+  } else {
+   close(c->fd);
+   ioloop_remove_handler(c->fd);
+
+   free_context(c);
+  }
+ }
+
+ return 0;
+}
+
+

echo.h

@@ -0,0 +1,21 @@
+#ifndef ECHO_H
+#define ECHO_H
+#include "headers.h"
+
+#define BUFFER_SIZE 1000
+
+typedef struct { 
+ struct sockaddr_in addr;
+ int fd;
+ char buffer[BUFFER_SIZE];
+ int received;
+} echo_handler_context;
+
+echo_handler_context *
+echo_handler_init(int fd, struct sockaddr_in addr);
+
+int 
+handle_echo_events(struct epoll_event e, void *context);
+
+#endif 
+

headers.h

@@ -0,0 +1,14 @@
+#ifndef HEADERS_H
+#define HEADERS_H
+
+#include <stdio.h>
+#include <sys/socket.h>
+#include <sys/epoll.h>
+#include <arpa/inet.h>
+#include <stdlib.h>
+#include <string.h>
+#include <unistd.h>
+#include <netinet/in.h>
+#include <fcntl.h>
+
+#endif