diff options
Diffstat (limited to 'src/platform/windows')
| -rw-r--r-- | src/platform/windows/win_resolv.c | 10 | ||||
| -rw-r--r-- | src/platform/windows/win_tcpdial.c | 8 | ||||
| -rw-r--r-- | src/platform/windows/win_tcplisten.c | 12 |
3 files changed, 15 insertions, 15 deletions
diff --git a/src/platform/windows/win_resolv.c b/src/platform/windows/win_resolv.c index f855e255..528da451 100644 --- a/src/platform/windows/win_resolv.c +++ b/src/platform/windows/win_resolv.c @@ -56,11 +56,11 @@ resolv_cancel(nni_aio *aio, void *arg, int rv) resolv_item *item = arg; nni_mtx_lock(&resolv_mtx); - if (item != nni_aio_get_prov_extra(aio, 0)) { + if (item != nni_aio_get_prov_data(aio)) { nni_mtx_unlock(&resolv_mtx); return; } - nni_aio_set_prov_extra(aio, 0, NULL); + nni_aio_set_prov_data(aio, NULL); if (nni_aio_list_active(aio)) { // We have not been picked up by a resolver thread yet, // so we can just discard everything. @@ -248,7 +248,7 @@ nni_resolv_ip(const char *host, const char *serv, int family, bool passive, if (resolv_fini) { rv = NNG_ECLOSED; } else { - nni_aio_set_prov_extra(aio, 0, item); + nni_aio_set_prov_data(aio, item); rv = nni_aio_schedule(aio, resolv_cancel, item); } if (rv != 0) { @@ -282,7 +282,7 @@ resolv_worker(void *notused) continue; } - item = nni_aio_get_prov_extra(aio, 0); + item = nni_aio_get_prov_data(aio); nni_aio_list_remove(aio); // Now attempt to do the work. This runs synchronously. @@ -292,7 +292,7 @@ resolv_worker(void *notused) // Check to make sure we were not canceled. if ((aio = item->aio) != NULL) { - nni_aio_set_prov_extra(aio, 0, NULL); + nni_aio_set_prov_data(aio, NULL); item->aio = NULL; item->sa = NULL; 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); diff --git a/src/platform/windows/win_tcplisten.c b/src/platform/windows/win_tcplisten.c index 1e87fd31..ee829dba 100644 --- a/src/platform/windows/win_tcplisten.c +++ b/src/platform/windows/win_tcplisten.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> // @@ -102,7 +102,7 @@ tcp_accept_cb(nni_win_io *io, int rv, size_t cnt) return; } 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; @@ -174,7 +174,7 @@ nni_tcp_listener_close(nni_tcp_listener *l) NNI_LIST_FOREACH (&l->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); } @@ -275,7 +275,7 @@ tcp_accept_cancel(nni_aio *aio, void *arg, int rv) nni_tcp_conn * c; nni_mtx_lock(&l->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; } @@ -323,10 +323,10 @@ nni_tcp_listener_accept(nni_tcp_listener *l, nni_aio *aio) } c->listener = l; c->conn_aio = aio; - nni_aio_set_prov_extra(aio, 0, c); + nni_aio_set_prov_data(aio, c); if (((rv = nni_win_io_init(&c->conn_io, tcp_accept_cb, c)) != 0) || ((rv = nni_aio_schedule(aio, tcp_accept_cancel, l)) != 0)) { - nni_aio_set_prov_extra(aio, 0, NULL); + nni_aio_set_prov_data(aio, NULL); nni_mtx_unlock(&l->mtx); nng_stream_free(&c->ops); nni_aio_finish_error(aio, rv); |
