X-Git-Url: http://git.meshlink.io/?a=blobdiff_plain;f=test%2Futils.c;h=9a9bd211fcef7b85a5ee7904062e30f305009134;hb=HEAD;hp=f1f1c7700334e20ba1080b5a2e850c779203bbba;hpb=1de30bc05683aade10634f2d357dcc2379bfcc42;p=meshlink diff --git a/test/utils.c b/test/utils.c index f1f1c770..872060b1 100644 --- a/test/utils.c +++ b/test/utils.c @@ -1,4 +1,4 @@ -#define _GNU_SOURCE 1 +#define _GNU_SOURCE #ifdef NDEBUG #undef NDEBUG @@ -16,6 +16,7 @@ void init_sync_flag(struct sync_flag *s) { assert(pthread_mutex_init(&s->mutex, NULL) == 0); assert(pthread_cond_init(&s->cond, NULL) == 0); + s->flag = false; } void set_sync_flag(struct sync_flag *s, bool value) { @@ -132,7 +133,7 @@ void open_meshlink_pair_ephemeral(meshlink_handle_t **pa, meshlink_handle_t **pb static void pair_status_cb(meshlink_handle_t *mesh, meshlink_node_t *node, bool reachable) { (void)node; - if(reachable) { + if(reachable && meshlink_get_self(mesh) != node) { set_sync_flag(mesh->priv, true); } }