Files
@ d23010006486
Branch filter:
Location: CSY/reowolf/examples/5_put_get/amy.c - annotation
d23010006486
774 B
text/x-csrc
bugfix: increment round index on recovery to avoid mixing messages once we switch away from tcp. refactoring communication internals to simplify bookkeeping structures. more consts in tests to make them terser
e9c737983088 e9c737983088 e9c737983088 e9c737983088 e9c737983088 e9c737983088 e9c737983088 e9c737983088 e9c737983088 e9c737983088 e9c737983088 e9c737983088 e9c737983088 e9c737983088 e9c737983088 e9c737983088 e9c737983088 e9c737983088 e9c737983088 e9c737983088 e9c737983088 e9c737983088 e9c737983088 e9c737983088 e9c737983088 e9c737983088 e9c737983088 e9c737983088 e9c737983088 e9c737983088 | #include <stdio.h>
#include <string.h>
#include "../../reowolf.h"
#include "../utility.c"
int main(int argc, char** argv) {
char * pdl_ptr = buffer_pdl("eg_protocols.pdl");
size_t pdl_len = strlen(pdl_ptr);
Arc_ProtocolDescription * pd = protocol_description_parse(pdl_ptr, pdl_len);
Connector * c = connector_new(pd);
PortId putter, getter;
connector_add_port_pair(c, &putter, &getter);
connector_connect(c, -1);
connector_print_debug(c);
connector_put_bytes(c, putter, "hello", 5);
connector_get(c, getter);
connector_sync(c, -1);
size_t msg_len;
const char * msg_ptr = connector_gotten_bytes(c, getter, &msg_len);
printf("Got msg `%.*s`\n", msg_len, msg_ptr);
protocol_description_destroy(pd);
connector_destroy(c);
free(pdl_ptr);
return 0;
}
|