refact: to use queue

Author: tricktux

source/prime-time/main.c

@@ -43,40 +43,41 @@ int handle_request(struct queue *sdq, int fd, char* raw_req, size_t size)
   }
 
   // Split and handle requests here
-  struct is_prime_request *req = NULL, *it = NULL;
-  int r = is_prime_request_builder(&req, raw_req, size);
+  struct is_prime_request *req = NULL;
+  int r = is_prime_request_builder(sdq, &req, raw_req, size);
   if (r <= 0) {
     log_warn("recv_and_handle: is_prime_request_builder returned '%d'", r);
     return -1;
   }
 
-  int l = 0, sl = 0, res = 0, mal = 0;
-  for (it = req; it != NULL; it = it->next) {
-    l = (int)strlen(it->response);
-    sl = l;
-    res = sendall(fd, it->response, &l);
-    if (res != 0) {
-      log_error("handle_request: failed during sendall function");
-      if (req != NULL)
-        is_prime_free(&req);
-      return -2;
-    }
-    if (sl != l) {
-      log_error("handle_request: failed to sendall the data");
-      if (req != NULL)
-        is_prime_free(&req);
-      return -3;
-    }
-
-    if (it->is_malformed) {
-      mal = 1;
-      break;
-    }
-  }
+  /*int l = 0, sl = 0, res = 0, mal = 0;*/
+  /*for (it = req; it != NULL; it = it->next) {*/
+  /*  l = (int)strlen(it->response);*/
+  /*  sl = l;*/
+  /*  res = sendall(fd, it->response, &l);*/
+  /*  if (res != 0) {*/
+  /*    log_error("handle_request: failed during sendall function");*/
+  /*    if (req != NULL)*/
+  /*      is_prime_free(&req);*/
+  /*    return -2;*/
+  /*  }*/
+  /*  if (sl != l) {*/
+  /*    log_error("handle_request: failed to sendall the data");*/
+  /*    if (req != NULL)*/
+  /*      is_prime_free(&req);*/
+  /*    return -3;*/
+  /*  }*/
+  /**/
+  /*  if (it->is_malformed) {*/
+  /*    mal = 1;*/
+  /*    break;*/
+  /*  }*/
+  /*}*/
 
   if (req != NULL)
     is_prime_free(&req);
-  return (mal == 1 ? 0 : 1);
+  return 1;
+  /*return (mal == 1 ? 0 : 1);*/
 }
 
 int main()
@@ -160,7 +161,7 @@ int main()
       // Handle there's data to process
       if (size > 0) {
         log_trace("main epoll loop: raw request(%d): '%s'", fd, data);
-        int result = handle_request(fd, data, (size_t)size);
+        int result = handle_request(sdqu, fd, data, (size_t)size);
         if (result <= 0) {
           if (result == 0)
             log_info("main epoll loop: there was a malformed respoonse. need to close socket");
@@ -172,6 +173,11 @@ int main()
           }
           continue;
         }
+        size = queue_pop_no_copy(sdqu, &data);
+        res = sendall(fd, data, &size);
+        if (res != 0) {
+          log_error("handle_request: failed during sendall function");
+        }
       }
 
       // Handle socket still open