diff options
| author | Garrett D'Amore <garrett@damore.org> | 2021-12-31 14:13:08 -0800 |
|---|---|---|
| committer | Garrett D'Amore <garrett@damore.org> | 2021-12-31 16:11:25 -0800 |
| commit | 5e06e98541ff223e7a18b6a61120532acd09d410 (patch) | |
| tree | 73d3b17ae7676a1e730e190d29f9e2661959b6a2 /src/platform/posix/posix_tcpdial.c | |
| parent | 2f66b99830e6dc731e4f631ea743771df701659e (diff) | |
| download | nng-5e06e98541ff223e7a18b6a61120532acd09d410.tar.gz nng-5e06e98541ff223e7a18b6a61120532acd09d410.tar.bz2 nng-5e06e98541ff223e7a18b6a61120532acd09d410.zip | |
Replace nni_aio_prov_set_extra with nni_aio_prov_set_data.
This takes one less parameter, and is simpler. It will let us
reclaim the aio_prov_extra data space as well, so that we can
use it for other purposes.
Diffstat (limited to 'src/platform/posix/posix_tcpdial.c')
| -rw-r--r-- | src/platform/posix/posix_tcpdial.c | 20 |
1 files changed, 10 insertions, 10 deletions
diff --git a/src/platform/posix/posix_tcpdial.c b/src/platform/posix/posix_tcpdial.c index f7568db3..d9b58210 100644 --- a/src/platform/posix/posix_tcpdial.c +++ b/src/platform/posix/posix_tcpdial.c @@ -1,5 +1,5 @@ // -// Copyright 2020 Staysail Systems, Inc. <info@staysail.tech> +// Copyright 2021 Staysail Systems, Inc. <info@staysail.tech> // Copyright 2018 Capitar IT Group BV <info@capitar.com> // Copyright 2018 Devolutions <info@devolutions.net> // @@ -52,9 +52,9 @@ nni_tcp_dialer_close(nni_tcp_dialer *d) while ((aio = nni_list_first(&d->connq)) != NULL) { nni_tcp_conn *c; nni_list_remove(&d->connq, aio); - if ((c = nni_aio_get_prov_extra(aio, 0)) != NULL) { + if ((c = nni_aio_get_prov_data(aio)) != NULL) { c->dial_aio = NULL; - nni_aio_set_prov_extra(aio, 0, NULL); + nni_aio_set_prov_data(aio, NULL); nng_stream_close(&c->stream); nng_stream_free(&c->stream); } @@ -97,13 +97,13 @@ tcp_dialer_cancel(nni_aio *aio, void *arg, int rv) nni_mtx_lock(&d->mtx); if ((!nni_aio_list_active(aio)) || - ((c = nni_aio_get_prov_extra(aio, 0)) == NULL)) { + ((c = nni_aio_get_prov_data(aio)) == NULL)) { nni_mtx_unlock(&d->mtx); return; } nni_aio_list_remove(aio); c->dial_aio = NULL; - nni_aio_set_prov_extra(aio, 0, NULL); + nni_aio_set_prov_data(aio, NULL); nni_mtx_unlock(&d->mtx); nni_aio_finish_error(aio, rv); @@ -148,7 +148,7 @@ tcp_dialer_cb(nni_posix_pfd *pfd, unsigned ev, void *arg) c->dial_aio = NULL; nni_aio_list_remove(aio); - nni_aio_set_prov_extra(aio, 0, NULL); + nni_aio_set_prov_data(aio, NULL); nd = d->nodelay ? 1 : 0; ka = d->keepalive ? 1 : 0; @@ -237,14 +237,14 @@ nni_tcp_dial(nni_tcp_dialer *d, const nni_sockaddr *sa, nni_aio *aio) goto error; } c->dial_aio = aio; - nni_aio_set_prov_extra(aio, 0, c); + nni_aio_set_prov_data(aio, c); nni_list_append(&d->connq, aio); nni_mtx_unlock(&d->mtx); return; } // Immediate connect, cool! This probably only happens - // on loopback, and probably not on every platform. - nni_aio_set_prov_extra(aio, 0, NULL); + // on loop back, and probably not on every platform. + nni_aio_set_prov_data(aio, NULL); nd = d->nodelay ? 1 : 0; ka = d->keepalive ? 1 : 0; nni_mtx_unlock(&d->mtx); @@ -254,7 +254,7 @@ nni_tcp_dial(nni_tcp_dialer *d, const nni_sockaddr *sa, nni_aio *aio) return; error: - nni_aio_set_prov_extra(aio, 0, NULL); + nni_aio_set_prov_data(aio, NULL); nni_mtx_unlock(&d->mtx); nng_stream_free(&c->stream); nni_aio_finish_error(aio, rv); |