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) {
}
// 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");
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++) {
fprintf(stderr, "Sending message failed\n");
return 1;
}
- if(!sent) {
+ if(!sent)
usleep(100000);
- } else {
+ else {
len -= sent;
p += sent;
}