Files
@ a3c92705eeee
Branch filter:
Location: CSY/reowolf/examples/pres_1/bob.c - annotation
a3c92705eeee
1.1 KiB
text/x-csrc
bugfix: native component branch forks that clash are MERGED rather than overwritten. Avoids race condition where (1) branch x ends and submits a solution, (2) branch y is created, has same predicate as x and overwrites it, but has a subset of its messages, (3) round ends in success but branch x is gone, so no suitable native branch is found
7b9df91324ad 7b9df91324ad 7b9df91324ad 7b9df91324ad a3c92705eeee 7b9df91324ad a3c92705eeee 7b9df91324ad 7b9df91324ad 7b9df91324ad a3c92705eeee 7b9df91324ad 7b9df91324ad 7b9df91324ad 7b9df91324ad a3c92705eeee a3c92705eeee a3c92705eeee 7b9df91324ad a3c92705eeee 7b9df91324ad a3c92705eeee 7b9df91324ad a3c92705eeee a3c92705eeee a3c92705eeee 7b9df91324ad a3c92705eeee 7b9df91324ad a3c92705eeee a3c92705eeee a3c92705eeee a3c92705eeee a3c92705eeee a3c92705eeee 7b9df91324ad 7b9df91324ad 7b9df91324ad 7b9df91324ad 7b9df91324ad 7b9df91324ad 7b9df91324ad |
#include "../../reowolf.h"
#include "../utility.c"
int main(int argc, char** argv) {
// Create a connector, configured with our (trivial) protocol.
Arc_ProtocolDescription * pd = protocol_description_parse("", 0);
char logpath[] = "./pres_1_bob.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_Getter, EndpointPolarity_Active);
rw_err_peek(c);
// Connect with peers (5000ms timeout).
connector_connect(c, 5000);
rw_err_peek(c);
// Prepare to receive a message.
connector_get(c, p0);
rw_err_peek(c);
// ... reach new consistent state within 1000ms deadline.
connector_sync(c, 1000);
rw_err_peek(c);
// Read our received message
size_t msg_len;
const char * msg_ptr = connector_gotten_bytes(c, p0, &msg_len);
printf("Got msg `%.*s`\n", msg_len, msg_ptr);
printf("Exiting\n");
protocol_description_destroy(pd);
connector_destroy(c);
sleep(1.0);
return 0;
}
|