#include <time.h>

#include "../../reowolf.h"

#include "../utility.c"

int main(int argc, char** argv) {

	int i, inside, total;

	inside = atoi(argv[1]);

	total = atoi(argv[2]);

	printf("inside %d, total %d\n", inside, total);

	unsigned char pdl[] = ""; 

	Arc_ProtocolDescription * pd = protocol_description_parse(pdl, sizeof(pdl)-1);

	printf("Error str `%s`\n", reowolf_error_peek(NULL));

	char logpath[] = "./bench_10.txt";

	Connector * c = connector_new_logging(pd, logpath, sizeof(logpath)-1);

	PortId native_putter, native_getter;

	char ident[] = "sync"; // defined in reowolf's stdlib 

	connector_add_port_pair(c, &native_putter, &native_getter);

	for (i=0; i<inside; i++) {

		// create a forward linked in the ring

		PortId putter, getter;

		connector_add_port_pair(c, &putter, &getter);

		// native ports: {native_putter, native_getter, putter, getter}

		// thread a forward component onto native_tail

		connector_add_component(c, ident, sizeof(ident)-1, (PortId[]){native_getter, putter}, 2);

		// native ports: {native_putter, getter}

		printf("Error str `%s`\n", reowolf_error_peek(NULL));

		native_getter = getter;

	}

	for (i=inside; i<total; i++) {

		// create a forward linked to itself

		PortId putter, getter;

		connector_add_port_pair(c, &putter, &getter);

		connector_add_component(c, ident, sizeof(ident)-1, (PortId[]){getter, putter}, 2);

		printf("Error str `%s`\n", reowolf_error_peek(NULL));

	}

	connector_connect(c, -1);

	printf("Error str `%s`\n", reowolf_error_peek(NULL));

	clock_t begin = clock();

	char msg[] = "Hello, world!";

	for (i=0; i<1000000; i++) {

		connector_put_bytes(c, native_putter, msg, sizeof(msg)-1);

		connector_get(c, native_getter);

		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;

}

#include <time.h>

#include "../../reowolf.h"

#include "../utility.c"

int main(int argc, char** argv) {

	int i, j, forwards, num_options, correct_index;

	forwards = atoi(argv[1]);

	num_options = atoi(argv[2]);

	correct_index = atoi(argv[3]);

	printf("forwards %d, num_options %d, correct_index %d\n",

		forwards, num_options, correct_index);

	unsigned char pdl[] = 

	"primitive recv_zero(in a) {  "

	"    while(true) synchronous {"

	"        msg m = get(a);      "

	"        assert(m[0] == 0);   "

	"    }                        "

	"}                            "

	; 

	Arc_ProtocolDescription * pd = protocol_description_parse(pdl, sizeof(pdl)-1);

	printf("Error str `%s`\n", reowolf_error_peek(NULL));

	char logpath[] = "./bench_11.txt";

	Connector * c = connector_new_logging(pd, logpath, sizeof(logpath)-1);

	PortId native_putter, native_getter;

	connector_add_port_pair(c, &native_putter, &native_getter);

	for (i=0; i<forwards; i++) {

		// create a forward to tail of chain

		PortId putter, getter;

		connector_add_port_pair(c, &putter, &getter);

		// native ports: {native_putter, native_getter, putter, getter}

		// thread a forward component onto native_tail

		char ident[] = "forward";

		connector_add_component(c, ident, sizeof(ident)-1, (PortId[]){native_getter, putter}, 2);

		// native ports: {native_putter, getter}

		printf("Error str `%s`\n", reowolf_error_peek(NULL));

		native_getter = getter;

	}

	// add "recv_zero" on end of chain

	char ident[] = "recv_zero";

	connector_add_component(c, ident, sizeof(ident)-1, &native_getter, 1);

	connector_connect(c, -1);

	printf("Error str `%s`\n", reowolf_error_peek(NULL));

	clock_t begin = clock();

	char msg = 0;

	for (i=0; i<10000; i++) {

		for(j=0; j<num_options; j++) {

			msg = j==correct_index ? 0 : 1;

			connector_put_bytes(c, native_putter, &msg, 1);

			if(j+1 < num_options) {

				connector_next_batch(c);

			}

		}	

		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;

}

#include <time.h>

#include "../../reowolf.h"

#include "../utility.c"

int main(int argc, char** argv) {

	int i, proto_components;

	proto_components = atoi(argv[1]);

	printf("proto_components: %d\n", proto_components);

	const unsigned char pdl[] = 

	"primitive presync_work() {   "

	"    int i = 0;               "

	"    while(true) {            "

	"        i = 0;               "

	"        while(i < 2)  i++;   "

	"        synchronous {}       "

	"    }                        "

	"}                            "

	;

	Arc_ProtocolDescription * pd = protocol_description_parse(pdl, sizeof(pdl)-1);

	char logpath[] = "./bench_4.txt";

	Connector * c = connector_new_logging(pd, logpath, sizeof(logpath)-1);

	for (i=0; i<proto_components; i++) {

		char ident[] = "presync_work";

		connector_add_component(c, ident, sizeof(ident)-1, NULL, 0);

		printf("Error str `%s`\n", reowolf_error_peek(NULL));

	}

	connector_connect(c, -1);

	printf("Error str `%s`\n", reowolf_error_peek(NULL));

	clock_t begin = clock();

	for (i=0; i<1000000; i++) {

		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;

}

for options in {1..5}

	for forwards in {0..15}

	do

		./bench_11/main.exe $forwards $options 0

	done