diff options
Diffstat (limited to 'src/supplemental/http')
| -rw-r--r-- | src/supplemental/http/http_client.c | 2 | ||||
| -rw-r--r-- | src/supplemental/http/http_public.c | 2 | ||||
| -rw-r--r-- | src/supplemental/http/http_server.c | 2 |
3 files changed, 3 insertions, 3 deletions
diff --git a/src/supplemental/http/http_client.c b/src/supplemental/http/http_client.c index 918b7b09..9058b6e2 100644 --- a/src/supplemental/http/http_client.c +++ b/src/supplemental/http/http_client.c @@ -44,7 +44,7 @@ http_conn_done(void *arg) nni_mtx_lock(&c->mtx); rv = nni_aio_result(c->connaio); - p = rv == 0 ? nni_aio_get_pipe(c->connaio) : NULL; + p = rv == 0 ? nni_aio_get_output(c->connaio, 0) : NULL; if ((aio = nni_list_first(&c->aios)) == NULL) { if (p != NULL) { nni_plat_tcp_pipe_fini(p); diff --git a/src/supplemental/http/http_public.c b/src/supplemental/http/http_public.c index 9d23ed8e..5437a000 100644 --- a/src/supplemental/http/http_public.c +++ b/src/supplemental/http/http_public.c @@ -737,7 +737,7 @@ void nng_http_client_connect(nng_http_client *cli, nng_aio *aio) { #ifdef NNG_SUPP_HTTP - return (nni_http_client_connect(cli, aio)); + nni_http_client_connect(cli, aio); #else NNI_ARG_UNUSED(cli); if (nni_aio_start(aio, NULL, NULL)) { diff --git a/src/supplemental/http/http_server.c b/src/supplemental/http/http_server.c index 4a426c8c..4c89708d 100644 --- a/src/supplemental/http/http_server.c +++ b/src/supplemental/http/http_server.c @@ -719,7 +719,7 @@ http_server_acccb(void *arg) nni_mtx_unlock(&s->mtx); return; } - tcp = nni_aio_get_pipe(aio); + tcp = nni_aio_get_output(aio, 0); if (s->closed) { // If we're closing, then reject this one. nni_plat_tcp_pipe_fini(tcp); |
