diff --git a/examples/bench_21/main.c b/examples/bench_21/main.c
new file mode 100644
index 0000000000000000000000000000000000000000..d602b88768f5f6c870f9b29b32c535298c3e626e
--- /dev/null
+++ b/examples/bench_21/main.c
@@ -0,0 +1,93 @@
+#include <time.h>
+#include "../../reowolf.h"
+#include "../utility.c"
+
+
+int main(int argc, char** argv) {
+	// one of two processes: {leader, follower}
+	// where a set of `par_msgs` messages are sent leader->follower after
+	// looping follower->leader->follower `msg_loops` times.
+	int i, j, cid, msg_loops, par_msgs;
+	char is_leader;
+	is_leader = argv[1][0];
+	msg_loops = atoi(argv[2]);
+	par_msgs = atoi(argv[3]);
+	// argv[4..8] encodes peer IP
+	printf("is_leader %c, msg_loops %d, par_msgs %d\n", is_leader, msg_loops, par_msgs);
+	cid = is_leader=='y'; // cid := { leader:1, follower:0 }
+
+	unsigned char pdl[] = "";
+	Arc_ProtocolDescription * pd = protocol_description_parse(pdl, sizeof(pdl)-1);
+	Connector * c = connector_new_with_id(pd, cid);
+	PortId native_ports[par_msgs];
+	FfiSocketAddr peer_addr = {
+		{
+			atoi(argv[4]),
+			atoi(argv[5]),
+			atoi(argv[6]),
+			atoi(argv[7])
+		}, 0/*dummy value*/};
+	int port = 7000;
+	
+	// for each parallel message 
+	for(i=0; i<par_msgs; i++) {
+		if(is_leader == 'y') {
+			peer_addr.port = port++;
+			connector_add_net_port(
+				c, &native_ports[i], peer_addr, Polarity_Putter, EndpointPolarity_Active);
+			printf("Error str `%s`\n", reowolf_error_peek(NULL));
+		}
+
+		for(j=0; j<msg_loops; j++) {
+			PortId loop_getter, loop_putter;
+
+			// create {putter, getter} port pair
+			connector_add_net_port(
+				c, &loop_getter,
+				(FfiSocketAddr) {{0,0,0,0}, port++},
+				Polarity_Getter, EndpointPolarity_Passive);
+			printf("Error str `%s`\n", reowolf_error_peek(NULL));
+
+			peer_addr.port = port++;
+			connector_add_net_port(
+				c, &loop_putter, peer_addr, Polarity_Putter, EndpointPolarity_Active);
+			printf("Error str `%s`\n", reowolf_error_peek(NULL));
+
+			connector_add_component(c, "forward", 7,
+				(PortId[]){loop_getter, loop_putter}, 2);
+			printf("Error str `%s`\n", reowolf_error_peek(NULL));
+		}
+
+		if(is_leader != 'y') {
+			connector_add_net_port(
+				c, &native_ports[i],
+				(FfiSocketAddr) {{0,0,0,0}, port++},
+				Polarity_Getter, EndpointPolarity_Passive);
+			printf("Error str `%s`\n", reowolf_error_peek(NULL));
+		}
+	}
+	printf("Added all ports!\n");
+	connector_connect(c, -1);
+	printf("Error str `%s`\n", reowolf_error_peek(NULL));
+	printf("Connect OK!\n");
+	
+	clock_t begin = clock();
+	char msg[] = "Hello, world!";
+	for(i=0; i<250; i++) {
+		if(is_leader == 'y') {
+			for(j=0; j<par_msgs; j++) {
+				connector_put_bytes(c, native_ports[j], msg, sizeof(msg)-1);
+			}
+		} else {
+			for(j=0; j<par_msgs; j++) {
+				connector_get(c, native_ports[j]);
+			}
+		}
+		connector_sync(c, -1);
+	}
+	
+	clock_t end = clock();
+	double time_spent = (double)(end - begin) / CLOCKS_PER_SEC;
+	printf("Time taken: %f\n", time_spent);
+	return 0;
+}
\ No newline at end of file