Files
@ c9ffd6e7ade5
Branch filter:
Location: CSY/reowolf/examples/bench_3/getter.c - annotation
c9ffd6e7ade5
734 B
text/x-csrc
more safety assertions, some minor cleanup, and major commenting
9485a0862e90 9485a0862e90 9485a0862e90 9485a0862e90 9485a0862e90 9485a0862e90 9485a0862e90 9485a0862e90 9485a0862e90 330b9c117fa5 9485a0862e90 9485a0862e90 9485a0862e90 9485a0862e90 9485a0862e90 9485a0862e90 9485a0862e90 9485a0862e90 9485a0862e90 9485a0862e90 9485a0862e90 9485a0862e90 9485a0862e90 9485a0862e90 9485a0862e90 9485a0862e90 9485a0862e90 9485a0862e90 9485a0862e90 | #include "../../reowolf.h"
#include "../utility.c"
int main(int argc, char** argv) {
Arc_ProtocolDescription * pd = protocol_description_parse("", 0);
char logpath[] = "./3_16_getter.txt";
Connector * c = connector_new_logging_with_id(pd, logpath, sizeof(logpath)-1, 0);
rw_err_peek(c);
PortId getter;
FfiSocketAddr addr = {{127, 0, 0, 1}, 8001};
rw_err_peek(c);
connector_add_net_port(c, &getter, addr, Polarity_Getter, EndpointPolarity_Passive);
connector_connect(c, -1);
rw_err_peek(c);
int i;
for(i=0; i<10; i++) {
connector_get(c, getter);
rw_err_peek(c);
connector_sync(c, -1);
rw_err_peek(c);
}
printf("Exiting\n");
protocol_description_destroy(pd);
connector_destroy(c);
sleep(1.0);
return 0;
}
|