diff options
Diffstat (limited to 'src/server/comms.c')
| -rw-r--r-- | src/server/comms.c | 16 |
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; } |
