summaryrefslogtreecommitdiff
path: root/src/server.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/server.c')
-rw-r--r--src/server.c17
1 files changed, 5 insertions, 12 deletions
diff --git a/src/server.c b/src/server.c
index d2ed0e5..8b39d38 100644
--- a/src/server.c
+++ b/src/server.c
@@ -2,12 +2,12 @@
#include <netinet/in.h>
#include <openssl/sha.h>
#include <stdio.h>
-#include <stdlib.h>
#include <string.h>
#include <sys/socket.h>
#include <sys/wait.h>
#include <assert.h>
#include <unistd.h>
+#include "logger/logger.h"
#define PORT 3456
@@ -16,18 +16,11 @@
#include "server/comms.c"
#include "ipc.c"
-int main(int argc, char** argv) {
- assert(argc == 2);
-
+int main(void) {
+ mqd_t logging = mq_open("/logs", O_WRONLY);
mqd_t tx = mq_open("/server_to_engine", O_CREAT | O_WRONLY, 0666, &attr);
mqd_t rx = mq_open("/engine_to_server", O_CREAT | O_RDONLY, 0666, &attr);
- if (fork() == 0) {
- char* args[] = {argv[1], "listen", NULL};
- execvp(args[0], args);
- return 0;
- }
-
int server_fd = socket(AF_INET, SOCK_STREAM, 0);
int opt = 1;
@@ -40,7 +33,7 @@ int main(int argc, char** argv) {
bind(server_fd, (struct sockaddr *)&addr, sizeof(addr));
listen(server_fd, 16);
- printf("Listening on %d\n", PORT);
+ log_infof("Listening on %d\n", PORT);
for (;;) {
int client = accept(server_fd, NULL, NULL);
@@ -50,7 +43,7 @@ int main(int argc, char** argv) {
int n = recv(client, req, sizeof(req) - 1, 0);
if (n <= 0) {
- printf("Client close");
+ log_infof("Client close");
close(client);
continue;
}