From deb556691c4a054bd33fb719348ea70d05c3a95d Mon Sep 17 00:00:00 2001 From: "Zezheng.Li" Date: Sun, 26 Jan 2025 16:38:49 +0800 Subject: [PATCH] fix format --- include/ylt/coro_io/coro_io.hpp | 23 ++++++++++++++--------- 1 file changed, 14 insertions(+), 9 deletions(-) diff --git a/include/ylt/coro_io/coro_io.hpp b/include/ylt/coro_io/coro_io.hpp index a19a33aaf..c66e51e71 100644 --- a/include/ylt/coro_io/coro_io.hpp +++ b/include/ylt/coro_io/coro_io.hpp @@ -225,7 +225,6 @@ constexpr int finish_cancel_flag = 3; template inline async_simple::coro::Lazy async_io(IO_func io_func, io_object &obj) noexcept { - callback_awaitor awaitor; auto slot = co_await async_simple::coro::CurrentSlot{}; if (!slot) { @@ -248,13 +247,16 @@ inline async_simple::coro::Lazy async_io(IO_func io_func, [&obj, lock](async_simple::SignalType signalType, async_simple::Signal *signal) { int expected = detail::no_cancel_flag; - if (!lock->compare_exchange_strong(expected, detail::could_cancel_flag, + if (!lock->compare_exchange_strong(expected, + detail::could_cancel_flag, std::memory_order_acq_rel)) { if (expected == detail::could_cancel_flag) { - if (lock->compare_exchange_strong(expected, detail::start_cancel_flag, + if (lock->compare_exchange_strong(expected, + detail::start_cancel_flag, std::memory_order_release)) { detail::cancel(obj); - lock->store(detail::finish_cancel_flag, std::memory_order_release); + lock->store(detail::finish_cancel_flag, + std::memory_order_release); } } } @@ -276,10 +278,12 @@ inline async_simple::coro::Lazy async_io(IO_func io_func, if (!lock->compare_exchange_strong(expected, detail::could_cancel_flag, std::memory_order_acq_rel)) { if (expected == detail::could_cancel_flag) { - if (lock->compare_exchange_strong(expected, detail::start_cancel_flag, + if (lock->compare_exchange_strong(expected, + detail::start_cancel_flag, std::memory_order_release)) { detail::cancel(obj); - lock->store(detail::finish_cancel_flag, std::memory_order_release); + lock->store(detail::finish_cancel_flag, + std::memory_order_release); } } } @@ -292,7 +296,8 @@ inline async_simple::coro::Lazy async_io(IO_func io_func, if (expected != detail::finish_cancel_flag) { do { if (expected == detail::could_cancel_flag) { - if (lock->compare_exchange_strong(expected, detail::finish_cancel_flag, + if (lock->compare_exchange_strong(expected, + detail::finish_cancel_flag, std::memory_order_acq_rel) || expected == detail::finish_cancel_flag) { break; @@ -300,8 +305,8 @@ inline async_simple::coro::Lazy async_io(IO_func io_func, } // flag is start_cancel_flag now. // wait cancel finish to make sure io object's life-time - for (; - lock->load(std::memory_order_acquire) == detail::start_cancel_flag;) { + for (; lock->load(std::memory_order_acquire) == + detail::start_cancel_flag;) { co_await coro_io::post( []() { },