diff options
author | kulikov <kulikov@yandex-team.ru> | 2022-02-10 16:49:34 +0300 |
---|---|---|
committer | Daniil Cherednik <dcherednik@yandex-team.ru> | 2022-02-10 16:49:34 +0300 |
commit | 65e5266709e7ff94b14ae128309e229de714b0df (patch) | |
tree | d4901f06e56d95f5e5d36bd1806bcc144d03bf41 /library/cpp/coroutine/engine/cont_poller.h | |
parent | 0041d99876ae3dccc3f0fa8787131d85ddfd486b (diff) | |
download | ydb-65e5266709e7ff94b14ae128309e229de714b0df.tar.gz |
Restoring authorship annotation for <kulikov@yandex-team.ru>. Commit 1 of 2.
Diffstat (limited to 'library/cpp/coroutine/engine/cont_poller.h')
-rw-r--r-- | library/cpp/coroutine/engine/cont_poller.h | 26 |
1 files changed, 13 insertions, 13 deletions
diff --git a/library/cpp/coroutine/engine/cont_poller.h b/library/cpp/coroutine/engine/cont_poller.h index b638b2df1a..d158bbe9f5 100644 --- a/library/cpp/coroutine/engine/cont_poller.h +++ b/library/cpp/coroutine/engine/cont_poller.h @@ -143,13 +143,13 @@ namespace NCoro { auto* lst = Lists_.Get(event->Fd()); const ui16 oldFlags = Flags(*lst); lst->PushFront(event); - ui16 newFlags = Flags(*lst); + ui16 newFlags = Flags(*lst); if (newFlags != oldFlags) { - if (oldFlags) { - newFlags |= CONT_POLL_MODIFY; - } - + if (oldFlags) { + newFlags |= CONT_POLL_MODIFY; + } + P_->Set(lst, event->Fd(), newFlags); } } @@ -158,13 +158,13 @@ namespace NCoro { auto* lst = Lists_.Get(event->Fd()); const ui16 oldFlags = Flags(*lst); event->Unlink(); - ui16 newFlags = Flags(*lst); + ui16 newFlags = Flags(*lst); if (newFlags != oldFlags) { - if (newFlags) { - newFlags |= CONT_POLL_MODIFY; - } - + if (newFlags) { + newFlags |= CONT_POLL_MODIFY; + } + P_->Set(lst, event->Fd(), newFlags); } } @@ -174,9 +174,9 @@ namespace NCoro { P_->Wait(events, deadLine); } - EContPoller PollEngine() const { - return P_->PollEngine(); - } + EContPoller PollEngine() const { + return P_->PollEngine(); + } private: static ui16 Flags(TIntrusiveList<IPollEvent>& lst) noexcept { ui16 ret = 0; |