diff --git a/examples/0_forward/alice.c b/examples/0_forward/alice.c index 43ec7726a57900c2946a8356f26173459656246a..b8d1cd5d2a78d69512c78f4da3117c35d55d4d36 100644 --- a/examples/0_forward/alice.c +++ b/examples/0_forward/alice.c @@ -1,59 +1,38 @@ #include #include #include "../../reowolf.h" +#include "../check.c" -int main() { - // ALICE - - char* pdl ="\ - primitive forward(in i, out o) {\ - while(true) synchronous {\ - put(o, get(i));\ - }\ - }"; +int main() { // ALICE + char* pdl = + "primitive forward(in i, out o) {" + " while(true) synchronous {" + " put(o, get(i));" + " }" + "}" + ; char msg_buf[128]; memset(msg_buf, 0, 128); printf("input a message to send:"); - if (fgets(msg_buf, 128-1, stdin) == NULL) { - printf("LINE READ BAD\n"); - return 1; - } + + check("fgets", fgets(msg_buf, 128-1, stdin) == NULL); int msg_len = strlen(msg_buf); msg_buf[msg_len-1] = 0; printf("sending msg `%s`\n", msg_buf); Connector* c = connector_new(); - if (connector_configure(c, pdl, "forward")) { - printf("CONFIG FAILED: %s\n", connector_error_peek()); - return 1; - } - if (connector_bind_native(c, 0)) { - printf("BIND0 FAILED: %s\n", connector_error_peek()); - return 1; - } - if (connector_bind_passive(c, 1, "127.0.0.1:7000")) { - printf("BIND1 FAILED: %s\n", connector_error_peek()); - return 1; - } - printf("connecting... \n"); - if (connector_connect(c, 10000)) { - printf("CONNECT FAILED: %s\n", connector_error_peek()); - return 1; - } + check("config ", connector_configure(c, pdl, "forward")); + check("bind 0 ", connector_bind_native(c, 0)); + check("bind 1 ", connector_bind_passive(c, 1, "127.0.0.1:7000")); + check("connect", connector_connect(c, 10000)); int i; for (i = 0; i < 3; i++) { - if (connector_put(c, 0, msg_buf, msg_len)) { - printf("CONNECT PUT: %s\n", connector_error_peek()); - return 1; - } - if (connector_sync(c, 10000)) { - printf("SYNC FAILED: %s\n", connector_error_peek()); - return 1; - } + check("put ", connector_put(c, 0, msg_buf, msg_len)); + check("sync", connector_sync(c, 10000)); printf("SEND OK\n"); }