Files
@ 6d8a1e407c9e
Branch filter:
Location: CSY/reowolf/examples/0_forward/bob.c - annotation
6d8a1e407c9e
770 B
text/x-csrc
trying out a matrix representation for components
952d4edf0cbb 952d4edf0cbb 49b9c766fe5a 952d4edf0cbb 952d4edf0cbb 952d4edf0cbb 952d4edf0cbb 952d4edf0cbb 952d4edf0cbb 952d4edf0cbb 952d4edf0cbb 952d4edf0cbb 952d4edf0cbb 952d4edf0cbb 952d4edf0cbb 49b9c766fe5a 49b9c766fe5a 49b9c766fe5a 49b9c766fe5a 952d4edf0cbb 952d4edf0cbb 952d4edf0cbb 49b9c766fe5a 49b9c766fe5a 49b9c766fe5a 952d4edf0cbb 952d4edf0cbb 49b9c766fe5a 49b9c766fe5a 952d4edf0cbb 952d4edf0cbb 952d4edf0cbb 952d4edf0cbb 952d4edf0cbb 952d4edf0cbb 952d4edf0cbb | #include <stdio.h>
#include "../../reowolf.h"
#include "../check.c"
int main() {
char* pdl ="\
primitive forward(in i, out o) {\
while(true) synchronous {\
put(o, get(i));\
}\
}";
// BOB
Connector* c = connector_new();
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));
check("connect", connector_connect(c, 10000));
int i;
for (i = 0; i < 3; i++) {
check("get ", connector_get(c, 0));
check("sync", connector_sync(c, 10000));
int msg_len;
const unsigned char * msg;
check("read", connector_gotten(c, 0, &msg, &msg_len));
printf("received: `%s`\n", msg);
}
printf("OK\n");
connector_destroy(c);
return 0;
}
|