Progress

src/main_test.c

@@ -15,7 +15,7 @@ int main(int argc, char **argv)
 
     // TODO: set simulation_should_stop=true on ctrl+C
 
-    startup_simulation(1);
+    startup_simulation(2);
 
     // Spawn metadata server (leader)
     spawn_simulated_process("--addr 127.0.0.1 --port 8080 --leader");

src/system.c

@@ -631,14 +631,13 @@ void update_simulation(void)
                     {
                         Descriptor *peer = handle_to_desc(desc->connection_peer);
                         if (peer == NULL) {
-                            assert(0); // TODO
-                        }
-
-                        if (!data_queue_full(&desc->output_data))
-                            revents |= POLLOUT;
-
-                        if (!data_queue_empty(&peer->output_data))
                             revents |= POLLIN;
+                        } else {
+                            if (!data_queue_full(&desc->output_data))
+                                revents |= POLLOUT;
+                            if (!data_queue_empty(&peer->output_data))
+                                revents |= POLLIN;
+                        }
                     }
                     break;