Files
@ 1ec123c02fa8
Branch filter:
Location: CSY/reowolf/examples/2_dynamic_pdl/bob.c - annotation
1ec123c02fa8
867 B
text/x-csrc
Merge branch 'master' of https://github.com/sirkibsirkib/Reowolf
952d4edf0cbb 952d4edf0cbb 33da6b69e9a2 952d4edf0cbb aa7efaf3fd9b aa7efaf3fd9b aa7efaf3fd9b 1f2d007ac1cc 952d4edf0cbb 952d4edf0cbb 33da6b69e9a2 49b9c766fe5a 49b9c766fe5a 49b9c766fe5a 33da6b69e9a2 33da6b69e9a2 952d4edf0cbb 952d4edf0cbb 952d4edf0cbb 49b9c766fe5a 33da6b69e9a2 49b9c766fe5a 952d4edf0cbb 952d4edf0cbb 49b9c766fe5a 49b9c766fe5a 33da6b69e9a2 952d4edf0cbb 952d4edf0cbb 33da6b69e9a2 952d4edf0cbb 33da6b69e9a2 33da6b69e9a2 952d4edf0cbb 952d4edf0cbb | #include <stdio.h>
#include "../../reowolf.h"
#include "../utility.c"
int main() {
// bob's behavior is loaded from a file at runtime
char * pdl = buffer_pdl("eg_protocols.pdl");
Connector* c = connector_new();
printf("configuring...\n");
check("config ", connector_configure(c, pdl, "forward"));
check("bind 0 ", connector_bind_active(c, 0, "127.0.0.1:7000"));
check("bind 1 ", connector_bind_native(c, 1));
printf("connecting...\n");
check("connect", connector_connect(c, 5000));
int i;
for (i = 0; i < 3; i++) {
check("get ", connector_get(c, 0));
check("sync", connector_sync(c, 1000));
int msg_len;
const unsigned char * msg;
check("read", connector_gotten(c, 0, &msg, &msg_len));
printf("Received one message `%s`!\n", msg);
}
printf("destroying...\n");
connector_destroy(c);
printf("exiting...\n");
free(pdl);
return 0;
}
|