aboutsummaryrefslogtreecommitdiff
path: root/src/platform
diff options
context:
space:
mode:
Diffstat (limited to 'src/platform')
-rw-r--r--src/platform/posix/posix_ipcdial.c18
-rw-r--r--src/platform/posix/posix_resolv_gai.c10
-rw-r--r--src/platform/posix/posix_tcpdial.c20
-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
6 files changed, 39 insertions, 39 deletions
diff --git a/src/platform/posix/posix_ipcdial.c b/src/platform/posix/posix_ipcdial.c
index 69ed4f77..464179a0 100644
--- a/src/platform/posix/posix_ipcdial.c
+++ b/src/platform/posix/posix_ipcdial.c
@@ -37,9 +37,9 @@ ipc_dialer_close(void *arg)
while ((aio = nni_list_first(&d->connq)) != NULL) {
nni_ipc_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);
}
@@ -84,13 +84,13 @@ ipc_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);
@@ -133,7 +133,7 @@ ipc_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);
nni_mtx_unlock(&d->mtx);
if (rv != 0) {
@@ -217,14 +217,14 @@ ipc_dialer_dial(void *arg, 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);
nni_mtx_unlock(&d->mtx);
nni_posix_ipc_start(c);
nni_aio_set_output(aio, 0, c);
@@ -232,7 +232,7 @@ ipc_dialer_dial(void *arg, 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);
diff --git a/src/platform/posix/posix_resolv_gai.c b/src/platform/posix/posix_resolv_gai.c
index aa6547a5..1c209f1f 100644
--- a/src/platform/posix/posix_resolv_gai.c
+++ b/src/platform/posix/posix_resolv_gai.c
@@ -63,12 +63,12 @@ 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)) {
// Already canceled?
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.
@@ -277,7 +277,7 @@ nni_resolv_ip(const char *host, const char *serv, int af, 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) {
@@ -313,7 +313,7 @@ resolv_worker(void *unused)
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.
@@ -324,7 +324,7 @@ resolv_worker(void *unused)
// 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/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);
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);
generated by cgit v1.2.3-70-g09d2 (git 2.46.0) at 2026-01-19 09:06:49 +0000