sin.sin_family = AF_INET;
sin.sin_port = htons(port);
sin.sin_addr = destinations[dst_num];
-
+
+ fprintf(stderr, "connecting %u\n", i);
+
if (connect(sock, (struct sockaddr *)&sin, sizeof(sin)) == -1) {
perror("connect()");
exit(1);
}
+
+ fprintf(stderr, "connected\n");
// FIXME: send data here
int sock = (int)arg;
char buf[65536];
- printf("Received worker for socket %u\n", sock);
-
for ( ;; ) {
int ret = read(sock, buf, 65536);
if (ret == 0)
// FIXME: update stats here
}
-
- printf("Socket %u done\n", sock);
if (close(sock) == -1) {
perror("close()");