summaryrefslogtreecommitdiff
path: root/src/server
diff options
context:
space:
mode:
Diffstat (limited to 'src/server')
-rw-r--r--src/server/comms.c7
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);