Files
@ ab8066658334
Branch filter:
Location: CSY/reowolf/examples/bench_14/bob.c - annotation
ab8066658334
1.1 KiB
text/x-csrc
WIP on shutting down connectors
9ed6d091a817 9ed6d091a817 9ed6d091a817 9ed6d091a817 9ed6d091a817 9ed6d091a817 9ed6d091a817 9ed6d091a817 9ed6d091a817 9ed6d091a817 9ed6d091a817 9ed6d091a817 9ed6d091a817 9ed6d091a817 9ed6d091a817 9ed6d091a817 9ed6d091a817 9ed6d091a817 9ed6d091a817 9ed6d091a817 9ed6d091a817 9ed6d091a817 9ed6d091a817 9ed6d091a817 9ed6d091a817 9ed6d091a817 9ed6d091a817 9ed6d091a817 9ed6d091a817 9ed6d091a817 9ed6d091a817 9ed6d091a817 9ed6d091a817 9ed6d091a817 9ed6d091a817 9ed6d091a817 9ed6d091a817 9ed6d091a817 9ed6d091a817 | #include <time.h>
#include "../../reowolf.h"
#include "../utility.c"
int main(int argc, char** argv) {
int i;
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_14_bob.txt";
Connector * c = connector_new_logging_with_id(pd, logpath, sizeof(logpath)-1, 1);
PortId putter, getter;
connector_add_net_port(
c,
&putter,
(FfiSocketAddr) {{127, 0, 0, 1}, 7001},
Polarity_Putter,
EndpointPolarity_Active);
connector_add_net_port(
c,
&getter,
(FfiSocketAddr) {{127, 0, 0, 1}, 7000},
Polarity_Getter,
EndpointPolarity_Passive);
connector_add_component(c, "forward", 7, (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();
for (i=0; i<10000; 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;
}
|