Files
@ 3dc3c63ab47f
Branch filter:
Location: CSY/reowolf/examples/pres_1/amy.c - annotation
3dc3c63ab47f
1.0 KiB
text/x-csrc
added hierarchal structure to connector fields such that fewer pointers to larger sub-structures must be passed around in tight loops of communication phase. Eg: NonSyncContext and SyncContext have shrunk substantially
a3c92705eeee 7b9df91324ad 7b9df91324ad a3c92705eeee a3c92705eeee 7b9df91324ad a3c92705eeee a3c92705eeee a3c92705eeee a3c92705eeee a3c92705eeee 7b9df91324ad 7b9df91324ad 7b9df91324ad a3c92705eeee 7b9df91324ad 7b9df91324ad 7b9df91324ad 7b9df91324ad a3c92705eeee a3c92705eeee a3c92705eeee 7b9df91324ad a3c92705eeee 7b9df91324ad a3c92705eeee 7b9df91324ad a3c92705eeee a3c92705eeee a3c92705eeee 7b9df91324ad a3c92705eeee 7b9df91324ad a3c92705eeee 7b9df91324ad 7b9df91324ad 7b9df91324ad 7b9df91324ad 7b9df91324ad 7b9df91324ad 7b9df91324ad |
#include "../../reowolf.h"
#include "../utility.c"
int main(int argc, char** argv) {
char msgbuf[64];
// ask user what message to send
size_t msglen = get_user_msg(msgbuf, sizeof(msgbuf));
// Create a connector, configured with our (trivial) protocol.
Arc_ProtocolDescription * pd = protocol_description_parse("", 0);
char logpath[] = "./pres_1_amy.txt";
Connector * c = connector_new_logging(pd, logpath, sizeof(logpath)-1);
rw_err_peek(c);
// ... with 1 outgoing network connection
PortId p0;
char addr_str[] = "127.0.0.1:8000";
connector_add_net_port(c, &p0, addr_str, sizeof(addr_str)-1,
Polarity_Putter, EndpointPolarity_Passive);
rw_err_peek(c);
// Connect with peers (5000ms timeout).
connector_connect(c, 5000);
rw_err_peek(c);
// Prepare a message to send
connector_put_bytes(c, p0, msgbuf, msglen);
rw_err_peek(c);
// ... reach new consistent state within 1000ms deadline.
connector_sync(c, 1000);
rw_err_peek(c);
printf("Exiting\n");
protocol_description_destroy(pd);
connector_destroy(c);
sleep(1.0);
return 0;
}
|