X-Git-Url: http://git.meshlink.io/?a=blobdiff_plain;f=test%2Fecho-fork.c;h=6839c7743e43c656723464fc56645e0c851e18eb;hb=93a7614d2aa368a9799d6e39c73542a3998e70bf;hp=f5aa04e3134d63b2eb826048cfbe649e771eec30;hpb=668664d0ea90dc81670cccd7b7d56b36b8360eaa;p=meshlink diff --git a/test/echo-fork.c b/test/echo-fork.c index f5aa04e3..6839c774 100644 --- a/test/echo-fork.c +++ b/test/echo-fork.c @@ -24,6 +24,8 @@ void log_cb(meshlink_handle_t *mesh, meshlink_log_level_t level, const char *tex } void status_cb(meshlink_handle_t *mesh, meshlink_node_t *node, bool reachable) { + (void)mesh; + if(!strcmp(node->name, "bar")) { bar_reachable = reachable; } else if(!strcmp(node->name, "foo")) @@ -33,21 +35,37 @@ void status_cb(meshlink_handle_t *mesh, meshlink_node_t *node, bool reachable) { } void foo_receive_cb(meshlink_handle_t *mesh, meshlink_channel_t *channel, const void *data, size_t len) { + (void)mesh; + (void)channel; + (void)data; + (void)len; + // One way only. } void bar_receive_cb(meshlink_handle_t *mesh, meshlink_channel_t *channel, const void *data, size_t len) { + (void)mesh; + (void)channel; + if(!len) { fprintf(stderr, "Connection closed by foo\n"); foo_closed = true; return; } + int ret_val; + (void)ret_val; // Write data to stdout. - write(1, data, len); + ret_val = write(1, data, len); } bool reject_cb(meshlink_handle_t *mesh, meshlink_channel_t *channel, uint16_t port, const void *data, size_t len) { + (void)mesh; + (void)channel; + (void)port; + (void)data; + (void)len; + return false; } @@ -66,6 +84,8 @@ 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) { + (void)len; + meshlink_set_channel_poll_cb(mesh, channel, NULL); bar_responded = true; } @@ -208,7 +228,7 @@ int main2(void) { } -int main(int argc, char *argv[]) { +int main() { debug_level = getenv("DEBUG") ? MESHLINK_DEBUG : MESHLINK_ERROR; // Initialize and exchange configuration.