summaryrefslogtreecommitdiff
path: root/src/server/comms.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/server/comms.c')
-rw-r--r--src/server/comms.c16
1 files changed, 5 insertions, 11 deletions
diff --git a/src/server/comms.c b/src/server/comms.c
index 5580ef5..a25752b 100644
--- a/src/server/comms.c
+++ b/src/server/comms.c
@@ -1,5 +1,7 @@
#include <assert.h>
+#include <string.h>
#include "../ipc.c"
+#include "../logger/logger.h"
struct str {
char msg[126];
@@ -42,9 +44,8 @@ void add_str(struct strs* strs, char* str) {
strs->count++;
}
-struct strs handle_input(mqd_t tx, mqd_t rx, char* payload, int len) {
- printf("Message: %.*s", len, payload);
- fflush(stdout);
+struct strs handle_input(mqd_t logging, mqd_t tx, mqd_t rx, char* payload, int len) {
+ log_infof("Received %.*s from frontend", len, payload);
send_queue(tx, payload, len);
char* buf = read_queue(rx);
@@ -60,13 +61,6 @@ struct strs handle_input(mqd_t tx, mqd_t rx, char* payload, int len) {
n--;
if (n == 0) n = get_num_messages(rx);
}
- printf(" -> done\n");
- // if (buf) free(buf);
- //
- // buf = read_queue(rx);
- // printf("%p\n", buf);
- // add_str(&output, buf);
- // if (buf) free(buf);
-
+ log_infof("Handled the request");
return output;
}