From 81d11f02415980f2ad29f74af23913abcdc2566d Mon Sep 17 00:00:00 2001 From: Garrett D'Amore Date: Thu, 26 Dec 2024 12:24:30 -0800 Subject: http: use nni_aio_start --- src/supplemental/http/http_conn.c | 14 +++++--------- 1 file changed, 5 insertions(+), 9 deletions(-) (limited to 'src/supplemental/http') 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. +// Copyright 2024 Staysail Systems, Inc. // Copyright 2018 Capitar IT Group BV // Copyright 2019 Devolutions // @@ -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; -- cgit v1.2.3-70-g09d2