X-Git-Url: http://git.meshlink.io/?p=meshlink;a=blobdiff_plain;f=test%2Fchannels-failure.c;h=18aef2d5e3453ae300170f001f8ce04f3dd984ee;hp=34018e1124e472162cea5ec103068c5aa0da8d32;hb=22cef91d16dcef1c41fc187b870c112d3f408ac7;hpb=03ab29c1e6e1b608311decb6630eb0a2177ce1dd diff --git a/test/channels-failure.c b/test/channels-failure.c index 34018e11..18aef2d5 100644 --- a/test/channels-failure.c +++ b/test/channels-failure.c @@ -72,11 +72,15 @@ int main() { sleep(1); + // Set a very small timeout for channels to b. + + meshlink_set_node_channel_timeout(mesh_a, b, 1); + // Stop mesh_b. We should get a notification that the channel has closed after a while. meshlink_stop(mesh_b); - assert(wait_sync_flag(&receive_flag, 70)); + assert(wait_sync_flag(&receive_flag, 5)); assert(receive_len == 0); meshlink_channel_close(mesh_a, channel); @@ -91,7 +95,7 @@ int main() { meshlink_set_channel_poll_cb(mesh_a, channel, poll_cb); - assert(wait_sync_flag(&poll_flag, 70)); + assert(wait_sync_flag(&poll_flag, 5)); assert(poll_len == 0); // Clean up.