diff options
Diffstat (limited to 'src/server')
| -rw-r--r-- | src/server/comms.c | 7 |
1 files changed, 4 insertions, 3 deletions
diff --git a/src/server/comms.c b/src/server/comms.c index a25752b..9dd83b9 100644 --- a/src/server/comms.c +++ b/src/server/comms.c @@ -45,14 +45,15 @@ void add_str(struct strs* strs, char* str) { } 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); - assert(strcmp(buf, "Sending") == 0); struct strs output = init_strs(); + if (strcmp(buf, "Sending") != 0) { + return output; + } + int n = get_num_messages(rx); while (n > 0) { char* buf = read_queue(rx); |
