aboutsummaryrefslogtreecommitdiff
path: root/src/platform/windows
diff options
context:
space:
mode:
Diffstat (limited to 'src/platform/windows')
-rw-r--r--src/platform/windows/win_resolv.c10
-rw-r--r--src/platform/windows/win_tcpdial.c8
-rw-r--r--src/platform/windows/win_tcplisten.c12
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);