Files
@ 8278ae29364e
Branch filter:
Location: CSY/reowolf/examples/incr_9/amy.c - annotation
8278ae29364e
1.3 KiB
text/x-csrc
adopt Reo's naming conventions for canonical protocols, e.g., replicator2
673882671c9a 673882671c9a 673882671c9a 673882671c9a aebcee16d6bc aebcee16d6bc aebcee16d6bc aebcee16d6bc aebcee16d6bc aebcee16d6bc aebcee16d6bc aebcee16d6bc aebcee16d6bc aebcee16d6bc aebcee16d6bc aebcee16d6bc 673882671c9a 14c1a07d148a aebcee16d6bc 14c1a07d148a aebcee16d6bc aebcee16d6bc aebcee16d6bc aebcee16d6bc aebcee16d6bc aebcee16d6bc aebcee16d6bc aebcee16d6bc aebcee16d6bc aebcee16d6bc aebcee16d6bc aebcee16d6bc aebcee16d6bc aebcee16d6bc aebcee16d6bc aebcee16d6bc aebcee16d6bc aebcee16d6bc | /* This example demonstrates:
- Once created, ports transport messages regardless of whether
they were created with `connector_add_port_pair` or `connector_add_net_port`.
*/
#include <stdio.h>
#include <string.h>
#include "../../reowolf.h"
#include "../utility.c"
int main(int argc, char** argv) {
Arc_ProtocolDescription * pd = protocol_description_parse("", 0);
char logpath[] = "./9_amy_log.txt";
Connector * c = connector_new_logging(pd, logpath, sizeof(logpath)-1);
printf("Error str `%s`\n", reowolf_error_peek(NULL));
PortId putter, getter;
FfiSocketAddr addr = {{127, 0, 0, 1}, 8000};
connector_add_net_port(c, &putter, addr, Polarity_Putter, EndpointPolarity_Active);
printf("Error str `%s`\n", reowolf_error_peek(NULL));
connector_add_net_port(c, &getter, addr, Polarity_Getter, EndpointPolarity_Passive);
printf("Error str `%s`\n", reowolf_error_peek(NULL));
connector_connect(c, 4000);
printf("Error str `%s`\n", reowolf_error_peek(NULL));
connector_put_bytes(c, putter, "hi", 2);
printf("Error str `%s`\n", reowolf_error_peek(NULL));
connector_get(c, getter);
printf("Error str `%s`\n", reowolf_error_peek(NULL));
connector_sync(c, 4000);
printf("Error str `%s`\n", reowolf_error_peek(NULL));
protocol_description_destroy(pd);
connector_destroy(c);
return 0;
}
|