From e824fa5d9096d07b4a6fdbba67280e655381863f Mon Sep 17 00:00:00 2001
From: "sgunderson@bigfoot.com" <>
Date: Wed, 31 Jan 2007 21:24:37 +0100
Subject: [PATCH] Make the sender a bit less dumb.

---
 jam.c | 38 +++++++++++++++++++++++++++++++++-----
 1 file changed, 33 insertions(+), 5 deletions(-)

diff --git a/jam.c b/jam.c
index e81e166..1df2eb9 100644
--- a/jam.c
+++ b/jam.c
@@ -29,9 +29,15 @@ const static struct option longopts[] = {
 	{ NULL, 0, NULL, 0 }
 };
 
+// generates from [0,1>
+double gen_uniform_random()
+{
+	return rand() / (RAND_MAX+1.0);
+}
+
 double gen_pareto_random(double min, double k)
 {
-	double u = rand() / (RAND_MAX+1.0);
+	double u = gen_uniform_random();
 	return min * pow(u, -1.0 / k);
 }
 
@@ -121,12 +127,34 @@ void parse_options(int argc, char **argv)
 void *sender_worker(void *arg)
 {
 	unsigned i;
-
-	printf("Dummy sender worker\n");
+	int sock;
 
 	for (i = 0; i < 1000; ++i) {
-		unsigned bytes = (unsigned)gen_pareto_random(1048576.0, 1.0);
-		printf("Sending %u bytes\n", bytes);
+		unsigned src_num = (unsigned)(num_sources * gen_uniform_random());
+		unsigned dst_num = (unsigned)(num_destinations * gen_uniform_random());
+		unsigned num_bytes = (unsigned)gen_pareto_random(1048576.0, 1.0);
+		struct sockaddr_in sin;
+
+		sock = socket(PF_INET, SOCK_STREAM, IPPROTO_TCP);
+		if (sock == -1) {
+			perror("socket()");
+			exit(1);
+		}
+		
+		// FIXME: bind to the right source
+		
+		sin.sin_family = AF_INET;
+		sin.sin_port = htons(port);
+		sin.sin_addr = destinations[dst_num];
+		
+		if (connect(sock, (struct sockaddr *)&sin, sizeof(sin)) == -1) {
+			perror("connect()");
+			exit(1);
+		}
+
+		// FIXME: send data here
+
+		close(sock);
 	}
 
 	pthread_exit(0);
-- 
2.39.2