aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/coroutine/engine/cont_poller.h
diff options
context:
space:
mode:
authorkulikov <kulikov@yandex-team.ru>2022-02-10 16:49:34 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:49:34 +0300
commit65e5266709e7ff94b14ae128309e229de714b0df (patch)
treed4901f06e56d95f5e5d36bd1806bcc144d03bf41 /library/cpp/coroutine/engine/cont_poller.h
parent0041d99876ae3dccc3f0fa8787131d85ddfd486b (diff)
downloadydb-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.h26
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;