Files
@ ada07cee1f99
Branch filter:
Location: CSY/reowolf/examples/5_put_get/amy.c - annotation
ada07cee1f99
774 B
text/x-csrc
refactored the endpoint manager to support sending and receiving of messages. moved some behavior from src/runtime/communication to src/runtime/endpoints
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;
}
|