aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/coroutine/engine
diff options
context:
space:
mode:
authorkikht <kikht@yandex-team.ru>2022-02-10 16:45:14 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:45:14 +0300
commit194cae0e8855b11be2005e1eff12c660c3ee9774 (patch)
treeed29c437b616690880c017855ebe0be34fdf81a2 /library/cpp/coroutine/engine
parent49116032d905455a7b1c994e4a696afc885c1e71 (diff)
downloadydb-194cae0e8855b11be2005e1eff12c660c3ee9774.tar.gz
Restoring authorship annotation for <kikht@yandex-team.ru>. Commit 1 of 2.
Diffstat (limited to 'library/cpp/coroutine/engine')
-rw-r--r--library/cpp/coroutine/engine/impl.cpp14
-rw-r--r--library/cpp/coroutine/engine/poller.cpp2
2 files changed, 8 insertions, 8 deletions
diff --git a/library/cpp/coroutine/engine/impl.cpp b/library/cpp/coroutine/engine/impl.cpp
index 7ae6f74051..f8793e0b61 100644
--- a/library/cpp/coroutine/engine/impl.cpp
+++ b/library/cpp/coroutine/engine/impl.cpp
@@ -277,12 +277,12 @@ void TContExecutor::ScheduleExecutionNow(TCont* cont) noexcept {
}
namespace {
- inline TContExecutor*& ThisThreadExecutor() {
- struct TThisThreadExecutorHolder {
+ inline TContExecutor*& ThisThreadExecutor() {
+ struct TThisThreadExecutorHolder {
TContExecutor* Executor = nullptr;
- };
- return FastTlsSingletonWithPriority<TThisThreadExecutorHolder, 0>()->Executor;
- }
+ };
+ return FastTlsSingletonWithPriority<TThisThreadExecutorHolder, 0>()->Executor;
+ }
}
void TContExecutor::DeleteScheduled() noexcept {
@@ -292,14 +292,14 @@ void TContExecutor::DeleteScheduled() noexcept {
}
TCont* RunningCont() {
- TContExecutor* thisThreadExecutor = ThisThreadExecutor();
+ TContExecutor* thisThreadExecutor = ThisThreadExecutor();
return thisThreadExecutor ? thisThreadExecutor->Running() : nullptr;
}
void TContExecutor::RunScheduler() noexcept {
try {
TContExecutor* const prev = ThisThreadExecutor();
- ThisThreadExecutor() = this;
+ ThisThreadExecutor() = this;
TCont* caller = Current_;
TExceptionSafeContext* context = caller ? caller->Trampoline_.Context() : &SchedContext_;
Y_DEFER {
diff --git a/library/cpp/coroutine/engine/poller.cpp b/library/cpp/coroutine/engine/poller.cpp
index 61164fa56b..0c1258e3b1 100644
--- a/library/cpp/coroutine/engine/poller.cpp
+++ b/library/cpp/coroutine/engine/poller.cpp
@@ -356,7 +356,7 @@ namespace {
}
THolder<IPollerFace> IPollerFace::Default() {
- return Construct(*SingletonWithPriority<TUserPoller, 0>());
+ return Construct(*SingletonWithPriority<TUserPoller, 0>());
}
THolder<IPollerFace> IPollerFace::Construct(TStringBuf name) {