}
static void channel_receive(meshlink_handle_t *mesh, meshlink_channel_t *channel, const void *data, size_t len) {
- const char *msg = data;
-
if(!len) {
if(meshlink_errno)
fprintf(stderr, "Error while reading data from %s: %s\n", channel->node->name, meshlink_strerror(meshlink_errno));
}
// TODO: we now have TCP semantics, don't expect exactly one message per receive call.
- if(msg[len - 1]) {
- fprintf(stderr, "Received invalid data from %s\n", channel->node->name);
- return;
- }
- printf("%s says: %s\n", channel->node->name, msg);
+ printf("%s says: ", channel->node->name);
+ fwrite(data, len, 1, stdout);
+ fputc('\n', stdout);
}
static bool channel_accept(meshlink_handle_t *mesh, meshlink_channel_t *channel, uint16_t port, const void *data, size_t len) {
return true;
}
+static void channel_poll(meshlink_handle_t *mesh, meshlink_channel_t *channel, size_t len) {
+ fprintf(stderr, "Channel to '%s' connected\n", channel->node->name);
+ meshlink_set_channel_poll_cb(mesh, channel, NULL);
+}
+
static void node_status(meshlink_handle_t *mesh, meshlink_node_t *node, bool reachable) {
if(reachable)
printf("%s joined.\n", node->name);
return;
}
destination->priv = channel;
+ meshlink_set_channel_poll_cb(mesh, channel, channel_poll);
}
- if(!meshlink_channel_send(mesh, channel, msg, len + 1)) {
+ if(!meshlink_channel_send(mesh, channel, msg, strlen(msg))) {
fprintf(stderr, "Could not send message to '%s': %s\n", destination->name, meshlink_strerror(meshlink_errno));
return;
}