X-Git-Url: http://git.meshlink.io/?a=blobdiff_plain;f=test%2Ftrio.c;h=522020fe1d07bbe61d3811095d6fdf7278871ad1;hb=5a8c20cfd63b480e94101f7333e871511a92fd37;hp=fbf7255c0b30aeadd1bdbb02a45a3fd23650061e;hpb=5fda2d74e72d08209872429fbde08449e259f7ac;p=meshlink diff --git a/test/trio.c b/test/trio.c index fbf7255c..522020fe 100644 --- a/test/trio.c +++ b/test/trio.c @@ -12,28 +12,39 @@ #include "utils.h" static void log_cb(meshlink_handle_t *mesh, meshlink_log_level_t level, const char *text) { + (void)mesh; + static struct timeval tv0; struct timeval tv; - if(tv0.tv_sec == 0) + if(tv0.tv_sec == 0) { gettimeofday(&tv0, NULL); + } + gettimeofday(&tv, NULL); fprintf(stderr, "%u.%.03u ", (unsigned int)(tv.tv_sec - tv0.tv_sec), (unsigned int)tv.tv_usec / 1000); - if(mesh) + if(mesh) { fprintf(stderr, "(%s) ", mesh->name); + } + fprintf(stderr, "[%d] %s\n", level, text); } static bool received = false; static void receive_cb(meshlink_handle_t *mesh, meshlink_node_t *source, const void *data, size_t len) { + (void)mesh; + (void)source; + fprintf(stderr, "RECEIVED SOMETHING\n"); - if(len == 5 && !memcmp(data, "Hello", 5)) + + if(len == 5 && !memcmp(data, "Hello", 5)) { received = true; + } } -int main(int argc, char *argv[]) { +int main() { // Create three instances. const char *name[3] = {"foo", "bar", "baz"}; @@ -42,12 +53,16 @@ int main(int argc, char *argv[]) { for(int i = 0; i < 3; i++) { char *path; - asprintf(&path, "trio_conf.%d", i); + int ret_val; + (void)ret_val; + ret_val = asprintf(&path, "trio_conf.%d", i); assert(path); mesh[i] = meshlink_open(path, name[i], "trio", DEV_CLASS_BACKBONE); assert(mesh[i]); + meshlink_add_address(mesh[i], "localhost"); + data[i] = meshlink_export(mesh[i]); assert(data[i]); } @@ -69,8 +84,9 @@ int main(int argc, char *argv[]) { // start the nodes - for(int i = 0; i < 3; i++) - meshlink_start(mesh[i]); + for(int i = 0; i < 3; i++) { + assert(meshlink_start(mesh[i])); + } // the nodes should now learn about each other @@ -99,8 +115,9 @@ int main(int argc, char *argv[]) { // Stop the other nodes - for(int i = 1; i < 3; i++) + for(int i = 1; i < 3; i++) { meshlink_stop(mesh[i]); + } sleep(1); @@ -108,8 +125,9 @@ int main(int argc, char *argv[]) { meshlink_set_log_cb(mesh[1], MESHLINK_DEBUG, log_cb); - for(int i = 1; i < 3; i++) - meshlink_start(mesh[i]); + for(int i = 1; i < 3; i++) { + assert(meshlink_start(mesh[i])); + } assert(meshlink_get_node(mesh[1], name[2])); assert(meshlink_get_node(mesh[2], name[1])); @@ -121,6 +139,7 @@ int main(int argc, char *argv[]) { // Clean up. - for(int i = 0; i < 3; i++) + for(int i = 0; i < 3; i++) { meshlink_close(mesh[i]); + } }