diff --git a/examples/1_socketlike/bob.c b/examples/1_socketlike/bob.c index 2577e85a689bd56d9dac01840795c998e1c369aa..5457309363001adbd3038b6ec3c720b27958e6dc 100644 --- a/examples/1_socketlike/bob.c +++ b/examples/1_socketlike/bob.c @@ -4,41 +4,33 @@ int main() { - // bob hard-codes his protocol. + // Protocol is hard-coded. char* pdl = "primitive forward(in i, out o) {" - " while(true) synchronous {" - " put(o, get(i));" - " }" - "}" - ; + " while(true) synchronous { " + " put(o, get(i)); " + " } " + "} "; // setup a connector with one incoming network channel. 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"); - printf("connect err %d%n", connector_connect(c, 20000)); - printf("%s%n", connector_dump_log(c)); + 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, 5000)); // receive a message and print it to stdout three times - int i; + int i, msg_len; + const unsigned char * msg; 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("Received one message `%.*s`!\n", msg_len, msg); } - - // cleanup - printf("destroying...\n"); + + printf("cleaning up\n"); connector_destroy(c); - printf("exiting...\n"); return 0; } \ No newline at end of file