7 #include "../src/meshlink.h"
9 volatile bool bar_reachable = false;
10 volatile bool bar_responded = false;
12 void log_cb(meshlink_handle_t *mesh, meshlink_log_level_t level, const char *text) {
14 fprintf(stderr, "(%s) ", mesh->name);
15 fprintf(stderr, "[%d] %s\n", level, text);
18 void status_cb(meshlink_handle_t *mesh, meshlink_node_t *node, bool reachable) {
19 if(!strcmp(node->name, "bar"))
20 bar_reachable = reachable;
23 void foo_receive_cb(meshlink_handle_t *mesh, meshlink_channel_t *channel, const void *data, size_t len) {
24 if(len == 5 && !memcmp(data, "Hello", 5))
28 void bar_receive_cb(meshlink_handle_t *mesh, meshlink_channel_t *channel, const void *data, size_t len) {
29 // Echo the data back.
30 meshlink_channel_send(mesh, channel, data, len);
33 bool reject_cb(meshlink_handle_t *mesh, meshlink_channel_t *channel, uint16_t port, const void *data, size_t len) {
37 bool accept_cb(meshlink_handle_t *mesh, meshlink_channel_t *channel, uint16_t port, const void *data, size_t len) {
40 meshlink_set_channel_receive_cb(mesh, channel, bar_receive_cb);
42 bar_receive_cb(mesh, channel, data, len);
46 void poll_cb(meshlink_handle_t *mesh, meshlink_channel_t *channel, size_t len) {
47 meshlink_set_channel_poll_cb(mesh, channel, NULL);
48 if(meshlink_channel_send(mesh, channel, "Hello", 5) != 5)
49 fprintf(stderr, "Could not send whole message\n");
52 int main1(int rfd, int wfd) {
53 meshlink_set_log_cb(NULL, MESHLINK_DEBUG, log_cb);
55 meshlink_handle_t *mesh1 = meshlink_open("channels_conf.1", "foo", "channels", DEV_CLASS_BACKBONE);
57 fprintf(stderr, "Could not initialize configuration for foo\n");
61 meshlink_add_address(mesh1, "localhost");
63 char *data = meshlink_export(mesh1);
65 fprintf(stderr, "Foo could not export its configuration\n");
69 size_t len = strlen(data);
70 write(wfd, &len, sizeof len);
71 write(wfd, data, len);
74 read(rfd, &len, sizeof len);
76 read(rfd, indata, len);
79 fprintf(stderr, "Foo exchanged data\n");
81 meshlink_import(mesh1, indata);
83 meshlink_set_channel_accept_cb(mesh1, reject_cb);
84 meshlink_set_node_status_cb(mesh1, status_cb);
86 if(!meshlink_start(mesh1)) {
87 fprintf(stderr, "Foo could not start\n");
91 for(int i = 0; i < 20; i++) {
98 fprintf(stderr, "Bar not reachable for foo after 20 seconds\n");
102 // Open a channel from foo to bar.
104 meshlink_node_t *bar = meshlink_get_node(mesh1, "bar");
106 fprintf(stderr, "Foo could not find bar\n");
110 meshlink_channel_t *channel = meshlink_channel_open(mesh1, bar, 7, foo_receive_cb, NULL, 0);
111 meshlink_set_channel_poll_cb(mesh1, channel, poll_cb);
113 for(int i = 0; i < 5; i++) {
120 fprintf(stderr, "Bar did not respond to foo's channel message\n");
124 meshlink_channel_close(mesh1, channel);
128 meshlink_close(mesh1);
134 int main2(int rfd, int wfd) {
137 meshlink_set_log_cb(NULL, MESHLINK_DEBUG, log_cb);
139 meshlink_handle_t *mesh2 = meshlink_open("channels_conf.2", "bar", "channels", DEV_CLASS_BACKBONE);
141 fprintf(stderr, "Could not initialize configuration for bar\n");
145 char *data = meshlink_export(mesh2);
147 fprintf(stderr, "Bar could not export its configuration\n");
151 size_t len = strlen(data);
152 if(write(wfd, &len, sizeof len) <= 0) abort();
153 if(write(wfd, data, len) <= 0) abort();
156 read(rfd, &len, sizeof len);
157 char indata[len + 1];
158 read(rfd, indata, len);
161 fprintf(stderr, "Bar exchanged data\n");
163 meshlink_import(mesh2, indata);
165 meshlink_set_channel_accept_cb(mesh2, accept_cb);
167 if(!meshlink_start(mesh2)) {
168 fprintf(stderr, "Bar could not start\n");
176 meshlink_close(mesh2);
182 int main(int argc, char *argv[]) {
183 int fda[2], fdb[2], result;
189 return main1(fda[0], fdb[1]);
191 return main2(fdb[0], fda[1]);