X-Git-Url: http://git.meshlink.io/?a=blobdiff_plain;ds=inline;f=test%2Fecho-fork.c;h=bd8da4451ecdadea1656404bf3e22ec85fad98ff;hb=d5de0bca747e9ba43bc28fbef54aaf5cfc321f5b;hp=ee24e8cb5e31e61d6b76dcafcaead08f62d864e6;hpb=8da66a40066247bdb63999433eb597d285b10aae;p=meshlink diff --git a/test/echo-fork.c b/test/echo-fork.c old mode 100755 new mode 100644 index ee24e8cb..bd8da445 --- a/test/echo-fork.c +++ b/test/echo-fork.c @@ -58,7 +58,7 @@ bool accept_cb(meshlink_handle_t *mesh, meshlink_channel_t *channel, uint16_t po void poll_cb(meshlink_handle_t *mesh, meshlink_channel_t *channel, size_t len) { meshlink_set_channel_poll_cb(mesh, channel, NULL); - bar_responded=true; + bar_responded = true; } int main1(void) { @@ -93,7 +93,7 @@ int main1(void) { } // Open a channel from foo to bar. - + meshlink_node_t *bar = meshlink_get_node(mesh1, "bar"); if(!bar) { fprintf(stderr, "Foo could not find bar\n"); @@ -104,7 +104,7 @@ int main1(void) { meshlink_set_channel_poll_cb(mesh1, channel, poll_cb); // read and buffer stdin - int BUF_SIZE = 1024*1024; + int BUF_SIZE = 1024 * 1024; char buffer[BUF_SIZE]; for(int i = 0; i < 5; i++) { @@ -130,9 +130,9 @@ int main1(void) { fprintf(stderr, "Sending message failed\n"); return 1; } - if(!sent) { + if(!sent) usleep(100000); - } else { + else { len -= sent; p += sent; }