X-Git-Url: http://git.meshlink.io/?a=blobdiff_plain;f=test%2Fchannels-aio.c;h=19472bad61b0751f9d826aa74ec41cc18fbf0b24;hb=refs%2Fheads%2Ffix%2Fspurious-channel-closure;hp=c43f1da1edac717ab1217e7e4741703f7a40cc50;hpb=6b125b5b68e2657eae9b36f23d7f569fb9e49f8d;p=meshlink diff --git a/test/channels-aio.c b/test/channels-aio.c index c43f1da1..19472bad 100644 --- a/test/channels-aio.c +++ b/test/channels-aio.c @@ -2,6 +2,8 @@ #undef NDEBUG #endif +#define _POSIX_C_SOURCE 200809L + #include #include #include @@ -45,16 +47,6 @@ static void aio_cb(meshlink_handle_t *mesh, meshlink_channel_t *channel, const v set_sync_flag(&info->flag, true); } -static bool reject_cb(meshlink_handle_t *mesh, meshlink_channel_t *channel, uint16_t port, const void *data, size_t len) { - (void)mesh; - (void)channel; - (void)port; - (void)data; - (void)len; - - return false; -} - static void receive_cb(meshlink_handle_t *mesh, meshlink_channel_t *channel, const void *data, size_t len) { (void)mesh; (void)channel; @@ -128,7 +120,6 @@ int main(void) { mesh_b->priv = in_infos; - meshlink_set_channel_accept_cb(mesh_a, reject_cb); meshlink_set_channel_accept_cb(mesh_b, accept_cb); // Start both instances @@ -198,9 +189,12 @@ int main(void) { // The non-AIO transfer should have completed before everything else assert(!timespec_lt(&out_infos[i].aio_infos[0].ts, &b_received_ts)); assert(!timespec_lt(&in_infos[i].aio_infos[0].ts, &b_received_ts)); + + free(in_infos[i].data); } // Clean up. close_meshlink_pair(mesh_a, mesh_b); + free(outdata); }