diff options
| author | Garrett D'Amore <garrett@damore.org> | 2024-12-26 12:24:30 -0800 |
|---|---|---|
| committer | Garrett D'Amore <garrett@damore.org> | 2024-12-26 12:54:38 -0800 |
| commit | 81d11f02415980f2ad29f74af23913abcdc2566d (patch) | |
| tree | 148da2fb3948ffa6a08041e778ab767758fd9910 /src/supplemental | |
| parent | 8027aebffe30fefbd320ac1c14866bfe85c1e915 (diff) | |
| download | nng-81d11f02415980f2ad29f74af23913abcdc2566d.tar.gz nng-81d11f02415980f2ad29f74af23913abcdc2566d.tar.bz2 nng-81d11f02415980f2ad29f74af23913abcdc2566d.zip | |
http: use nni_aio_start
Diffstat (limited to 'src/supplemental')
| -rw-r--r-- | src/supplemental/http/http_conn.c | 14 |
1 files changed, 5 insertions, 9 deletions
diff --git a/src/supplemental/http/http_conn.c b/src/supplemental/http/http_conn.c index 9ff2c997..b30d2d42 100644 --- a/src/supplemental/http/http_conn.c +++ b/src/supplemental/http/http_conn.c @@ -1,5 +1,5 @@ // -// Copyright 2021 Staysail Systems, Inc. <info@staysail.tech> +// Copyright 2024 Staysail Systems, Inc. <info@staysail.tech> // Copyright 2018 Capitar IT Group BV <info@capitar.com> // Copyright 2019 Devolutions <info@devolutions.net> // @@ -363,14 +363,12 @@ http_rd_cancel(nni_aio *aio, void *arg, int rv) static void http_rd_submit(nni_http_conn *conn, nni_aio *aio, enum read_flavor flavor) { - if (nni_aio_begin(aio) != 0) { - return; - } + nni_aio_reset(aio); if (conn->closed) { nni_aio_finish_error(aio, NNG_ECLOSED); return; } - if (!nni_aio_defer(aio, http_rd_cancel, conn)) { + if (!nni_aio_start(aio, http_rd_cancel, conn)) { return; } conn->rd_flavor = flavor; @@ -480,14 +478,12 @@ http_wr_cancel(nni_aio *aio, void *arg, int rv) static void http_wr_submit(nni_http_conn *conn, nni_aio *aio, enum write_flavor flavor) { - if (nni_aio_begin(aio) != 0) { - return; - } + nni_aio_reset(aio); if (conn->closed) { nni_aio_finish_error(aio, NNG_ECLOSED); return; } - if (!nni_aio_defer(aio, http_wr_cancel, conn)) { + if (!nni_aio_start(aio, http_wr_cancel, conn)) { return; } conn->wr_flavor = flavor; |