+ // FIXME: fire off sender workers here
+
+ /*
+ * Listen for incoming connections, spawning off one receiver
+ * thread for each (which will just gobble up the data until
+ * we're done).
+ */
+ for ( ;; ) {
+ struct sockaddr_in addr;
+ socklen_t addr_len = sizeof(addr);
+ pthread_t thread;
+
+ int sock = accept(server_sock, (struct sockaddr *)&addr, &addr_len);
+ if (sock == -1) {
+ perror("accept()");
+ exit(1);
+ }
+
+ if (pthread_create(&thread, NULL, receiver_worker, (void *)sock) == -1) {
+ perror("pthread_create()");
+ exit(1);
+ }
+ }
+