now multiple connections are actually handled

1 files changed, 4 insertions, 0 deletions

diff --git a/src/server/comms.c b/src/server/comms.c
index 4549bdd..5580ef5 100644
--- a/src/server/comms.c
+++ b/src/server/comms.c
@@ -46,6 +46,10 @@ struct strs handle_input(mqd_t tx, mqd_t rx, char* payload, int len) {
   printf("Message: %.*s", len, payload);
   fflush(stdout);
 
+  send_queue(tx, payload, len);
+  char* buf = read_queue(rx);
+  assert(strcmp(buf, "Sending") == 0);
+
   struct strs output = init_strs();
 
   int n = get_num_messages(rx);