Refactored server and renamed mqtt module

Author: codepr

CMakeLists.txt

@@ -44,8 +44,11 @@ else (APPLE)
     TARGET_LINK_LIBRARIES(sol pthread ssl crypto crypt)
     TARGET_LINK_LIBRARIES(sol_test pthread ssl crypto crypt)
 endif (APPLE)
-    set(CMAKE_C_FLAGS "${CMAKE_C_FLAGS} -Wall -Wunused -Werror -pedantic \
-    -Wno-unused-result -std=c11 -O3")
+    # set(CMAKE_C_FLAGS "${CMAKE_C_FLAGS} -Wall -Wunused -Werror -pedantic \
+    # -Wno-unused-result -std=c11 -O3")
+set(CMAKE_C_FLAGS "${CMAKE_C_FLAGS} -Wall -Wunused -Werror -pedantic \
+    -Wno-unused-result -std=c11 -ggdb -fsanitize=address \
+    -fsanitize=undefined -fno-omit-frame-pointer -pg")
 
 endif (DEBUG)
 

conf/sol.conf

@@ -37,4 +37,4 @@ stats_publish_interval 10s
 # allow_anonymous false
 # password_file passwd_file
 
-tls_protocols tlsv1,tlsv1_1,tlsv1_2,tlsv1_3
+# tls_protocols tlsv1,tlsv1_1,tlsv1_2,tlsv1_3

src/ev.c

@@ -589,12 +589,13 @@ static int ev_api_fire_event(struct ev_ctx *ctx, int fd, int mask)
 {
     struct kqueue_api *k_api = ctx->api;
     struct kevent ke;
-    int op = 0;
+    int flags = EV_ADD | EV_ONESHOT;
+    int op    = 0;
     if (mask & (EV_READ | EV_EVENTFD))
-        op |= EVFILT_READ;
+        return EV_OK;
     if (mask & EV_WRITE)
         op |= EVFILT_WRITE;
-    EV_SET(&ke, fd, op, EV_ADD | EV_ENABLE, 0, 0, NULL);
+    EV_SET(&ke, fd, op, flags, 0, 0, NULL);
     if (kevent(k_api->fd, &ke, 1, NULL, 0, NULL) == -1)
         return -EV_ERR;
     return EV_OK;