X-Git-Url: https://git.sesse.net/?p=jam;a=blobdiff_plain;f=jam.c;h=1da8fc84f282189882fe5a4eddc6ff732bbd50df;hp=9f1a186a7647224b53238fef1ec89e00cd12c6bb;hb=7b42e7033fe932eeee2462c7bcfe2dd54889ebb5;hpb=a5b16ea110556894990164e360cf99560d7d7f7f

diff --git a/jam.c b/jam.c
index 9f1a186..1da8fc8 100644
--- a/jam.c
+++ b/jam.c
@@ -133,6 +133,10 @@ void *sender_worker(void *arg)
 {
 	unsigned i;
 	int sock;
+	char buf[65536];
+
+	for (i = 0; i < 65536; ++i)
+		buf[i] = rand() & 0xff;
 
 	for (i = 0; i < 1000; ++i) {
 		unsigned src_num = (unsigned)(num_sources * gen_uniform_random());
@@ -161,7 +165,23 @@ void *sender_worker(void *arg)
 		
 		fprintf(stderr, "connected\n");
 
-		// FIXME: send data here
+		while (num_bytes > 0) {
+			unsigned bytes_to_send = num_bytes;
+			unsigned ret;
+
+			if (bytes_to_send > 65536) {
+				bytes_to_send = 65536;	
+			}
+
+			ret = send(sock, buf, bytes_to_send, MSG_NOSIGNAL);
+			if (ret == -1) {
+				perror("send()");
+				exit(1);
+			}
+
+			num_bytes -= ret;
+		}
+		fprintf(stderr, "sent\n");
 
 		close(sock);
 	}