From b21d7805523a407a14567017edbdef57ca81781f Mon Sep 17 00:00:00 2001 From: Garrett D'Amore Date: Wed, 8 Jan 2020 20:34:26 -0800 Subject: fixes #1094 Consider in-lining task and aio This only does it for rep, but it also has changes that should increase the overall test coverage for the REP protocol --- src/supplemental/tcp/tcp.c | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) (limited to 'src/supplemental/tcp/tcp.c') diff --git a/src/supplemental/tcp/tcp.c b/src/supplemental/tcp/tcp.c index 02d5d6ce..dd6f28ff 100644 --- a/src/supplemental/tcp/tcp.c +++ b/src/supplemental/tcp/tcp.c @@ -157,8 +157,8 @@ tcp_dialer_free(void *arg) nni_aio_stop(d->resaio); nni_aio_stop(d->conaio); - nni_aio_fini(d->resaio); - nni_aio_fini(d->conaio); + nni_aio_free(d->resaio); + nni_aio_free(d->conaio); if (d->d != NULL) { nni_tcp_dialer_close(d->d); @@ -234,8 +234,8 @@ tcp_dialer_alloc(tcp_dialer **dp) nni_aio_list_init(&d->resaios); nni_aio_list_init(&d->conaios); - if (((rv = nni_aio_init(&d->resaio, tcp_dial_res_cb, d)) != 0) || - ((rv = nni_aio_init(&d->conaio, tcp_dial_con_cb, d)) != 0) || + if (((rv = nni_aio_alloc(&d->resaio, tcp_dial_res_cb, d)) != 0) || + ((rv = nni_aio_alloc(&d->conaio, tcp_dial_con_cb, d)) != 0) || ((rv = nni_tcp_dialer_init(&d->d)) != 0)) { tcp_dialer_free(d); return (rv); @@ -446,11 +446,11 @@ nni_tcp_listener_alloc(nng_stream_listener **lp, const nng_url *url) nni_aio_wait(aio); if ((rv = nni_aio_result(aio)) != 0) { - nni_aio_fini(aio); + nni_aio_free(aio); return (rv); } nni_aio_get_sockaddr(aio, &sa); - nni_aio_fini(aio); + nni_aio_free(aio); return (tcp_listener_alloc_addr(lp, &sa)); } -- cgit v1.2.3-70-g09d2