aboutsummaryrefslogtreecommitdiff
path: root/src/platform/windows/win_tcpdial.c
diff options
context:
space:
mode:
authorGarrett D'Amore <garrett@damore.org>2021-12-31 14:13:08 -0800
committerGarrett D'Amore <garrett@damore.org>2021-12-31 16:11:25 -0800
commit5e06e98541ff223e7a18b6a61120532acd09d410 (patch)
tree73d3b17ae7676a1e730e190d29f9e2661959b6a2 /src/platform/windows/win_tcpdial.c
parent2f66b99830e6dc731e4f631ea743771df701659e (diff)
downloadnng-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/windows/win_tcpdial.c')
-rw-r--r--src/platform/windows/win_tcpdial.c8
1 files changed, 4 insertions, 4 deletions
diff --git a/src/platform/windows/win_tcpdial.c b/src/platform/windows/win_tcpdial.c
index 3353d380..9463c241 100644
--- a/src/platform/windows/win_tcpdial.c
+++ b/src/platform/windows/win_tcpdial.c
@@ -79,7 +79,7 @@ nni_tcp_dialer_close(nni_tcp_dialer *d)
NNI_LIST_FOREACH (&d->aios, aio) {
nni_tcp_conn *c;
- if ((c = nni_aio_get_prov_extra(aio, 0)) != NULL) {
+ if ((c = nni_aio_get_prov_data(aio)) != NULL) {
c->conn_rv = NNG_ECLOSED;
CancelIoEx((HANDLE) c->s, &c->conn_io.olpd);
}
@@ -116,7 +116,7 @@ tcp_dial_cancel(nni_aio *aio, void *arg, int rv)
nni_tcp_conn * c;
nni_mtx_lock(&d->mtx);
- if ((c = nni_aio_get_prov_extra(aio, 0)) != NULL) {
+ if ((c = nni_aio_get_prov_data(aio)) != NULL) {
if (c->conn_rv == 0) {
c->conn_rv = rv;
}
@@ -144,7 +144,7 @@ tcp_dial_cb(nni_win_io *io, int rv, size_t cnt)
}
c->conn_aio = NULL;
- nni_aio_set_prov_extra(aio, 0, NULL);
+ nni_aio_set_prov_data(aio, NULL);
nni_aio_list_remove(aio);
if (c->conn_rv != 0) {
rv = c->conn_rv;
@@ -240,7 +240,7 @@ nni_tcp_dial(nni_tcp_dialer *d, const nni_sockaddr *sa, nni_aio *aio)
}
c->dialer = d;
- nni_aio_set_prov_extra(aio, 0, c);
+ nni_aio_set_prov_data(aio, c);
if ((rv = nni_aio_schedule(aio, tcp_dial_cancel, d)) != 0) {
nni_mtx_unlock(&d->mtx);
nng_stream_free(&c->ops);