diff options
| author | kikht <kikht@yandex-team.ru> | 2022-02-10 16:45:14 +0300 |
|---|---|---|
| committer | Daniil Cherednik <dcherednik@yandex-team.ru> | 2022-02-10 16:45:14 +0300 |
| commit | 194cae0e8855b11be2005e1eff12c660c3ee9774 (patch) | |
| tree | ed29c437b616690880c017855ebe0be34fdf81a2 /library/cpp | |
| parent | 49116032d905455a7b1c994e4a696afc885c1e71 (diff) | |
| download | ydb-194cae0e8855b11be2005e1eff12c660c3ee9774.tar.gz | |
Restoring authorship annotation for <kikht@yandex-team.ru>. Commit 1 of 2.
Diffstat (limited to 'library/cpp')
160 files changed, 687 insertions, 687 deletions
diff --git a/library/cpp/cache/cache.h b/library/cpp/cache/cache.h index 6dc997076d..c5231e42d3 100644 --- a/library/cpp/cache/cache.h +++ b/library/cpp/cache/cache.h @@ -101,20 +101,20 @@ public: return ItemsAmount; } - size_t GetTotalSize() const { - return TotalSize; - } - - size_t GetMaxSize() const { - return MaxSize; - } - - // It does not remove current items if newSize is less than TotalSize. - // Caller should use RemoveIfOverflown to clean up list in this case - void SetMaxSize(size_t newSize) { - MaxSize = newSize; - } - + size_t GetTotalSize() const { + return TotalSize; + } + + size_t GetMaxSize() const { + return MaxSize; + } + + // It does not remove current items if newSize is less than TotalSize. + // Caller should use RemoveIfOverflown to clean up list in this case + void SetMaxSize(size_t newSize) { + MaxSize = newSize; + } + private: typedef TIntrusiveList<TItem> TListType; TListType List; @@ -212,16 +212,16 @@ public: return ListSize; } - size_t GetMaxSize() const { - return MaxSize; - } - - // It does not remove current items if newSize is less than TotalSize. - // Caller should use RemoveIfOverflown to clean up list in this case - void SetMaxSize(size_t newSize) { - MaxSize = newSize; - } - + size_t GetMaxSize() const { + return MaxSize; + } + + // It does not remove current items if newSize is less than TotalSize. + // Caller should use RemoveIfOverflown to clean up list in this case + void SetMaxSize(size_t newSize) { + MaxSize = newSize; + } + private: typedef TIntrusiveList<TItem> TListType; TListType List; @@ -333,16 +333,16 @@ public: return Size; } - size_t GetMaxSize() const { - return MaxSize; - } - - // It does not remove current items if newSize is less than TotalSize. - // Caller should use RemoveIfOverflown to clean up list in this case - void SetMaxSize(size_t newSize) { - MaxSize = newSize; - } - + size_t GetMaxSize() const { + return MaxSize; + } + + // It does not remove current items if newSize is less than TotalSize. + // Caller should use RemoveIfOverflown to clean up list in this case + void SetMaxSize(size_t newSize) { + MaxSize = newSize; + } + void Clear() { Heap.clear(); Removed.clear(); @@ -531,20 +531,20 @@ public: Index.clear(); } - void SetMaxSize(size_t newSize) { - List.SetMaxSize(newSize); - - TItem* removedItem = nullptr; - while ((removedItem = List.RemoveIfOverflown())) { - EraseFromIndex(removedItem); - } - Y_ASSERT(Index.size() == List.GetSize()); - } - - size_t GetMaxSize() const { - return List.GetMaxSize(); - } - + void SetMaxSize(size_t newSize) { + List.SetMaxSize(newSize); + + TItem* removedItem = nullptr; + while ((removedItem = List.RemoveIfOverflown())) { + EraseFromIndex(removedItem); + } + Y_ASSERT(Index.size() == List.GetSize()); + } + + size_t GetMaxSize() const { + return List.GetMaxSize(); + } + protected: TIndex Index; TListType List; @@ -595,10 +595,10 @@ public: TIterator FindOldest() { return TBase::Empty() ? TBase::End() : this->FindByItem(TBase::List.GetOldest()); } - + size_t TotalSize() const { - return TBase::List.GetTotalSize(); - } + return TBase::List.GetTotalSize(); + } }; template <typename TKey, typename TValue, typename TDeleter = TNoopDelete> diff --git a/library/cpp/cache/ut/cache_ut.cpp b/library/cpp/cache/ut/cache_ut.cpp index 329872cfde..87601ae3d6 100644 --- a/library/cpp/cache/ut/cache_ut.cpp +++ b/library/cpp/cache/ut/cache_ut.cpp @@ -172,145 +172,145 @@ Y_UNIT_TEST_SUITE(TCacheTest) { UNIT_ASSERT(s.Find(3) == s.End()); } - Y_UNIT_TEST(LRUSetMaxSizeTest) { - typedef TLRUCache<int, TString> TCache; - TCache s(2); // size 2 - s.Insert(1, "abcd"); - s.Insert(2, "efgh"); - s.Insert(3, "ijkl"); - UNIT_ASSERT(s.GetOldest() == "efgh"); - UNIT_ASSERT(s.Find(1) == s.End()); - UNIT_ASSERT(s.Find(2) != s.End()); - UNIT_ASSERT(s.Find(3) != s.End()); - - // Increasing size should not change anything - s.SetMaxSize(3); - UNIT_ASSERT(s.GetOldest() == "efgh"); - UNIT_ASSERT(s.Find(1) == s.End()); - UNIT_ASSERT(s.Find(2) != s.End()); - UNIT_ASSERT(s.Find(3) != s.End()); - - // And we should be able to add fit more entries - s.Insert(4, "mnop"); - s.Insert(5, "qrst"); - UNIT_ASSERT(s.GetOldest() == "ijkl"); - UNIT_ASSERT(s.Find(1) == s.End()); - UNIT_ASSERT(s.Find(2) == s.End()); - UNIT_ASSERT(s.Find(3) != s.End()); - UNIT_ASSERT(s.Find(4) != s.End()); - UNIT_ASSERT(s.Find(5) != s.End()); - - // Decreasing size should remove oldest entries - s.SetMaxSize(2); - UNIT_ASSERT(s.GetOldest() == "mnop"); - UNIT_ASSERT(s.Find(1) == s.End()); - UNIT_ASSERT(s.Find(2) == s.End()); - UNIT_ASSERT(s.Find(3) == s.End()); - UNIT_ASSERT(s.Find(4) != s.End()); - UNIT_ASSERT(s.Find(5) != s.End()); - - // Ano no more entries will fit - s.Insert(6, "uvwx"); - UNIT_ASSERT(s.GetOldest() == "qrst"); - UNIT_ASSERT(s.Find(1) == s.End()); - UNIT_ASSERT(s.Find(2) == s.End()); - UNIT_ASSERT(s.Find(3) == s.End()); - UNIT_ASSERT(s.Find(4) == s.End()); - UNIT_ASSERT(s.Find(5) != s.End()); - UNIT_ASSERT(s.Find(6) != s.End()); - } - - Y_UNIT_TEST(LWSetMaxSizeTest) { - typedef TLWCache<int, TString, size_t, TStrokaWeighter> TCache; - TCache s(2); // size 2 - s.Insert(1, "a"); - s.Insert(2, "aa"); - s.Insert(3, "aaa"); - UNIT_ASSERT(s.GetLightest() == "aa"); - UNIT_ASSERT(s.Find(1) == s.End()); - UNIT_ASSERT(s.Find(2) != s.End()); - UNIT_ASSERT(s.Find(3) != s.End()); - - // Increasing size should not change anything - s.SetMaxSize(3); - UNIT_ASSERT(s.GetLightest() == "aa"); - UNIT_ASSERT(s.Find(1) == s.End()); - UNIT_ASSERT(s.Find(2) != s.End()); - UNIT_ASSERT(s.Find(3) != s.End()); - - // And we should be able to add fit more entries - s.Insert(4, "aaaa"); - s.Insert(5, "aaaaa"); - UNIT_ASSERT(s.GetLightest() == "aaa"); - UNIT_ASSERT(s.Find(1) == s.End()); - UNIT_ASSERT(s.Find(2) == s.End()); - UNIT_ASSERT(s.Find(3) != s.End()); - UNIT_ASSERT(s.Find(4) != s.End()); - UNIT_ASSERT(s.Find(5) != s.End()); - - // Decreasing size should remove oldest entries - s.SetMaxSize(2); - UNIT_ASSERT(s.GetLightest() == "aaaa"); - UNIT_ASSERT(s.Find(1) == s.End()); - UNIT_ASSERT(s.Find(2) == s.End()); - UNIT_ASSERT(s.Find(3) == s.End()); - UNIT_ASSERT(s.Find(4) != s.End()); - UNIT_ASSERT(s.Find(5) != s.End()); - - // Ano no more entries will fit - s.Insert(6, "aaaaaa"); - UNIT_ASSERT(s.GetLightest() == "aaaaa"); - UNIT_ASSERT(s.Find(1) == s.End()); - UNIT_ASSERT(s.Find(2) == s.End()); - UNIT_ASSERT(s.Find(3) == s.End()); - UNIT_ASSERT(s.Find(4) == s.End()); - UNIT_ASSERT(s.Find(5) != s.End()); - UNIT_ASSERT(s.Find(6) != s.End()); - } - - Y_UNIT_TEST(LFUSetMaxSizeTest) { - typedef TLFUCache<int, TString> TCache; - TCache s(2); // size 2 - s.Insert(1, "abcd"); - s.Insert(2, "efgh"); - s.Insert(3, "ijkl"); - UNIT_ASSERT(s.Find(1) == s.End()); - UNIT_ASSERT(s.Find(2) != s.End()); - UNIT_ASSERT(s.Find(3) != s.End()); - - // Increasing size should not change anything - s.SetMaxSize(3); - UNIT_ASSERT(s.Find(1) == s.End()); - UNIT_ASSERT(s.Find(2) != s.End()); - UNIT_ASSERT(s.Find(3) != s.End()); - - // And we should be able to add fit more entries - s.Insert(4, "mnop"); - s.Insert(5, "qrst"); - UNIT_ASSERT(s.Find(1) == s.End()); - UNIT_ASSERT(s.Find(2) == s.End()); - UNIT_ASSERT(s.Find(3) != s.End()); - UNIT_ASSERT(s.Find(4) != s.End()); - UNIT_ASSERT(s.Find(5) != s.End()); - - // Decreasing size should remove oldest entries - s.SetMaxSize(2); - UNIT_ASSERT(s.Find(1) == s.End()); - UNIT_ASSERT(s.Find(2) == s.End()); - UNIT_ASSERT(s.Find(3) != s.End()); - UNIT_ASSERT(s.Find(4) == s.End()); - UNIT_ASSERT(s.Find(5) != s.End()); - - // Ano no more entries will fit - s.Insert(6, "uvwx"); - UNIT_ASSERT(s.Find(1) == s.End()); - UNIT_ASSERT(s.Find(2) == s.End()); - UNIT_ASSERT(s.Find(3) != s.End()); - UNIT_ASSERT(s.Find(4) == s.End()); - UNIT_ASSERT(s.Find(5) == s.End()); - UNIT_ASSERT(s.Find(6) != s.End()); - } - + Y_UNIT_TEST(LRUSetMaxSizeTest) { + typedef TLRUCache<int, TString> TCache; + TCache s(2); // size 2 + s.Insert(1, "abcd"); + s.Insert(2, "efgh"); + s.Insert(3, "ijkl"); + UNIT_ASSERT(s.GetOldest() == "efgh"); + UNIT_ASSERT(s.Find(1) == s.End()); + UNIT_ASSERT(s.Find(2) != s.End()); + UNIT_ASSERT(s.Find(3) != s.End()); + + // Increasing size should not change anything + s.SetMaxSize(3); + UNIT_ASSERT(s.GetOldest() == "efgh"); + UNIT_ASSERT(s.Find(1) == s.End()); + UNIT_ASSERT(s.Find(2) != s.End()); + UNIT_ASSERT(s.Find(3) != s.End()); + + // And we should be able to add fit more entries + s.Insert(4, "mnop"); + s.Insert(5, "qrst"); + UNIT_ASSERT(s.GetOldest() == "ijkl"); + UNIT_ASSERT(s.Find(1) == s.End()); + UNIT_ASSERT(s.Find(2) == s.End()); + UNIT_ASSERT(s.Find(3) != s.End()); + UNIT_ASSERT(s.Find(4) != s.End()); + UNIT_ASSERT(s.Find(5) != s.End()); + + // Decreasing size should remove oldest entries + s.SetMaxSize(2); + UNIT_ASSERT(s.GetOldest() == "mnop"); + UNIT_ASSERT(s.Find(1) == s.End()); + UNIT_ASSERT(s.Find(2) == s.End()); + UNIT_ASSERT(s.Find(3) == s.End()); + UNIT_ASSERT(s.Find(4) != s.End()); + UNIT_ASSERT(s.Find(5) != s.End()); + + // Ano no more entries will fit + s.Insert(6, "uvwx"); + UNIT_ASSERT(s.GetOldest() == "qrst"); + UNIT_ASSERT(s.Find(1) == s.End()); + UNIT_ASSERT(s.Find(2) == s.End()); + UNIT_ASSERT(s.Find(3) == s.End()); + UNIT_ASSERT(s.Find(4) == s.End()); + UNIT_ASSERT(s.Find(5) != s.End()); + UNIT_ASSERT(s.Find(6) != s.End()); + } + + Y_UNIT_TEST(LWSetMaxSizeTest) { + typedef TLWCache<int, TString, size_t, TStrokaWeighter> TCache; + TCache s(2); // size 2 + s.Insert(1, "a"); + s.Insert(2, "aa"); + s.Insert(3, "aaa"); + UNIT_ASSERT(s.GetLightest() == "aa"); + UNIT_ASSERT(s.Find(1) == s.End()); + UNIT_ASSERT(s.Find(2) != s.End()); + UNIT_ASSERT(s.Find(3) != s.End()); + + // Increasing size should not change anything + s.SetMaxSize(3); + UNIT_ASSERT(s.GetLightest() == "aa"); + UNIT_ASSERT(s.Find(1) == s.End()); + UNIT_ASSERT(s.Find(2) != s.End()); + UNIT_ASSERT(s.Find(3) != s.End()); + + // And we should be able to add fit more entries + s.Insert(4, "aaaa"); + s.Insert(5, "aaaaa"); + UNIT_ASSERT(s.GetLightest() == "aaa"); + UNIT_ASSERT(s.Find(1) == s.End()); + UNIT_ASSERT(s.Find(2) == s.End()); + UNIT_ASSERT(s.Find(3) != s.End()); + UNIT_ASSERT(s.Find(4) != s.End()); + UNIT_ASSERT(s.Find(5) != s.End()); + + // Decreasing size should remove oldest entries + s.SetMaxSize(2); + UNIT_ASSERT(s.GetLightest() == "aaaa"); + UNIT_ASSERT(s.Find(1) == s.End()); + UNIT_ASSERT(s.Find(2) == s.End()); + UNIT_ASSERT(s.Find(3) == s.End()); + UNIT_ASSERT(s.Find(4) != s.End()); + UNIT_ASSERT(s.Find(5) != s.End()); + + // Ano no more entries will fit + s.Insert(6, "aaaaaa"); + UNIT_ASSERT(s.GetLightest() == "aaaaa"); + UNIT_ASSERT(s.Find(1) == s.End()); + UNIT_ASSERT(s.Find(2) == s.End()); + UNIT_ASSERT(s.Find(3) == s.End()); + UNIT_ASSERT(s.Find(4) == s.End()); + UNIT_ASSERT(s.Find(5) != s.End()); + UNIT_ASSERT(s.Find(6) != s.End()); + } + + Y_UNIT_TEST(LFUSetMaxSizeTest) { + typedef TLFUCache<int, TString> TCache; + TCache s(2); // size 2 + s.Insert(1, "abcd"); + s.Insert(2, "efgh"); + s.Insert(3, "ijkl"); + UNIT_ASSERT(s.Find(1) == s.End()); + UNIT_ASSERT(s.Find(2) != s.End()); + UNIT_ASSERT(s.Find(3) != s.End()); + + // Increasing size should not change anything + s.SetMaxSize(3); + UNIT_ASSERT(s.Find(1) == s.End()); + UNIT_ASSERT(s.Find(2) != s.End()); + UNIT_ASSERT(s.Find(3) != s.End()); + + // And we should be able to add fit more entries + s.Insert(4, "mnop"); + s.Insert(5, "qrst"); + UNIT_ASSERT(s.Find(1) == s.End()); + UNIT_ASSERT(s.Find(2) == s.End()); + UNIT_ASSERT(s.Find(3) != s.End()); + UNIT_ASSERT(s.Find(4) != s.End()); + UNIT_ASSERT(s.Find(5) != s.End()); + + // Decreasing size should remove oldest entries + s.SetMaxSize(2); + UNIT_ASSERT(s.Find(1) == s.End()); + UNIT_ASSERT(s.Find(2) == s.End()); + UNIT_ASSERT(s.Find(3) != s.End()); + UNIT_ASSERT(s.Find(4) == s.End()); + UNIT_ASSERT(s.Find(5) != s.End()); + + // Ano no more entries will fit + s.Insert(6, "uvwx"); + UNIT_ASSERT(s.Find(1) == s.End()); + UNIT_ASSERT(s.Find(2) == s.End()); + UNIT_ASSERT(s.Find(3) != s.End()); + UNIT_ASSERT(s.Find(4) == s.End()); + UNIT_ASSERT(s.Find(5) == s.End()); + UNIT_ASSERT(s.Find(6) != s.End()); + } + Y_UNIT_TEST(MultiCacheTest) { typedef TLRUCache<int, TString> TCache; TCache s(3, true); 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) { diff --git a/library/cpp/messagebus/acceptor.cpp b/library/cpp/messagebus/acceptor.cpp index 64a38619c2..6669512b5b 100644 --- a/library/cpp/messagebus/acceptor.cpp +++ b/library/cpp/messagebus/acceptor.cpp @@ -1,13 +1,13 @@ -#include "acceptor.h" +#include "acceptor.h" #include "key_value_printer.h" #include "mb_lwtrace.h" -#include "network.h" +#include "network.h" -#include <util/network/init.h> -#include <util/system/defaults.h> -#include <util/system/error.h> -#include <util/system/yassert.h> +#include <util/network/init.h> +#include <util/system/defaults.h> +#include <util/system/error.h> +#include <util/system/yassert.h> LWTRACE_USING(LWTRACE_MESSAGEBUS_PROVIDER) diff --git a/library/cpp/messagebus/acceptor.h b/library/cpp/messagebus/acceptor.h index 57cb010bf2..0eeb162aea 100644 --- a/library/cpp/messagebus/acceptor.h +++ b/library/cpp/messagebus/acceptor.h @@ -1,16 +1,16 @@ #pragma once -#include "acceptor_status.h" -#include "defs.h" +#include "acceptor_status.h" +#include "defs.h" #include "event_loop.h" #include "netaddr.h" #include "session_impl.h" #include "shutdown_state.h" #include <library/cpp/messagebus/actor/actor.h> - -#include <util/system/event.h> - + +#include <util/system/event.h> + namespace NBus { namespace NPrivate { class TAcceptor diff --git a/library/cpp/messagebus/acceptor_status.cpp b/library/cpp/messagebus/acceptor_status.cpp index 5006ff68ae..6c481bfb6f 100644 --- a/library/cpp/messagebus/acceptor_status.cpp +++ b/library/cpp/messagebus/acceptor_status.cpp @@ -1,9 +1,9 @@ -#include "acceptor_status.h" +#include "acceptor_status.h" #include "key_value_printer.h" -#include <util/stream/format.h> -#include <util/stream/output.h> +#include <util/stream/format.h> +#include <util/stream/output.h> using namespace NBus; using namespace NBus::NPrivate; diff --git a/library/cpp/messagebus/acceptor_status.h b/library/cpp/messagebus/acceptor_status.h index 6aa1404f4d..c799eee6a7 100644 --- a/library/cpp/messagebus/acceptor_status.h +++ b/library/cpp/messagebus/acceptor_status.h @@ -1,7 +1,7 @@ #pragma once -#include "netaddr.h" - +#include "netaddr.h" + #include <util/network/init.h> namespace NBus { diff --git a/library/cpp/messagebus/actor/actor.h b/library/cpp/messagebus/actor/actor.h index 9b8f20298a..6d6b394a51 100644 --- a/library/cpp/messagebus/actor/actor.h +++ b/library/cpp/messagebus/actor/actor.h @@ -1,11 +1,11 @@ #pragma once -#include "executor.h" +#include "executor.h" #include "tasks.h" #include "what_thread_does.h" -#include <util/system/yassert.h> - +#include <util/system/yassert.h> + namespace NActor { class IActor: protected IWorkItem { public: diff --git a/library/cpp/messagebus/actor/actor_ut.cpp b/library/cpp/messagebus/actor/actor_ut.cpp index b76ab55bfa..4329aabd77 100644 --- a/library/cpp/messagebus/actor/actor_ut.cpp +++ b/library/cpp/messagebus/actor/actor_ut.cpp @@ -4,10 +4,10 @@ #include "queue_in_actor.h" #include <library/cpp/messagebus/misc/test_sync.h> - -#include <util/generic/object_counter.h> -#include <util/system/event.h> - + +#include <util/generic/object_counter.h> +#include <util/system/event.h> + using namespace NActor; template <typename TThis> diff --git a/library/cpp/messagebus/actor/executor.cpp b/library/cpp/messagebus/actor/executor.cpp index 7a2227a458..b6d33c7c0e 100644 --- a/library/cpp/messagebus/actor/executor.cpp +++ b/library/cpp/messagebus/actor/executor.cpp @@ -1,14 +1,14 @@ -#include "executor.h" +#include "executor.h" #include "thread_extra.h" #include "what_thread_does.h" #include "what_thread_does_guard.h" -#include <util/generic/utility.h> -#include <util/random/random.h> -#include <util/stream/str.h> -#include <util/system/tls.h> -#include <util/system/yassert.h> +#include <util/generic/utility.h> +#include <util/random/random.h> +#include <util/stream/str.h> +#include <util/system/tls.h> +#include <util/system/yassert.h> #include <array> diff --git a/library/cpp/messagebus/actor/executor.h b/library/cpp/messagebus/actor/executor.h index 7292d8be53..538b2196f0 100644 --- a/library/cpp/messagebus/actor/executor.h +++ b/library/cpp/messagebus/actor/executor.h @@ -1,13 +1,13 @@ #pragma once -#include "ring_buffer_with_spin_lock.h" - +#include "ring_buffer_with_spin_lock.h" + #include <util/generic/array_ref.h> #include <util/generic/vector.h> #include <util/system/condvar.h> #include <util/system/event.h> -#include <util/system/mutex.h> -#include <util/system/thread.h> +#include <util/system/mutex.h> +#include <util/system/thread.h> #include <util/thread/lfqueue.h> namespace NActor { diff --git a/library/cpp/messagebus/actor/queue_in_actor.h b/library/cpp/messagebus/actor/queue_in_actor.h index 9865996532..df6b53557d 100644 --- a/library/cpp/messagebus/actor/queue_in_actor.h +++ b/library/cpp/messagebus/actor/queue_in_actor.h @@ -3,8 +3,8 @@ #include "actor.h" #include "queue_for_actor.h" -#include <functional> - +#include <functional> + namespace NActor { template <typename TItem> class IQueueInActor { diff --git a/library/cpp/messagebus/actor/ring_buffer.h b/library/cpp/messagebus/actor/ring_buffer.h index ec5706f7c7..6346756d85 100644 --- a/library/cpp/messagebus/actor/ring_buffer.h +++ b/library/cpp/messagebus/actor/ring_buffer.h @@ -1,9 +1,9 @@ #pragma once -#include <util/generic/array_ref.h> -#include <util/generic/maybe.h> -#include <util/generic/utility.h> -#include <util/generic/vector.h> +#include <util/generic/array_ref.h> +#include <util/generic/maybe.h> +#include <util/generic/utility.h> +#include <util/generic/vector.h> #include <util/system/yassert.h> template <typename T> diff --git a/library/cpp/messagebus/actor/ring_buffer_ut.cpp b/library/cpp/messagebus/actor/ring_buffer_ut.cpp index bdb379b3a9..b0dd1bb933 100644 --- a/library/cpp/messagebus/actor/ring_buffer_ut.cpp +++ b/library/cpp/messagebus/actor/ring_buffer_ut.cpp @@ -2,8 +2,8 @@ #include "ring_buffer.h" -#include <util/random/random.h> - +#include <util/random/random.h> + Y_UNIT_TEST_SUITE(RingBuffer) { struct TRingBufferTester { TRingBuffer<unsigned> RingBuffer; diff --git a/library/cpp/messagebus/actor/ring_buffer_with_spin_lock.h b/library/cpp/messagebus/actor/ring_buffer_with_spin_lock.h index f0b7cd90e4..325d8bb397 100644 --- a/library/cpp/messagebus/actor/ring_buffer_with_spin_lock.h +++ b/library/cpp/messagebus/actor/ring_buffer_with_spin_lock.h @@ -1,7 +1,7 @@ #pragma once -#include "ring_buffer.h" - +#include "ring_buffer.h" + #include <util/system/spinlock.h> template <typename T> diff --git a/library/cpp/messagebus/actor/tasks.h b/library/cpp/messagebus/actor/tasks.h index 31d35931d2..9df0453931 100644 --- a/library/cpp/messagebus/actor/tasks.h +++ b/library/cpp/messagebus/actor/tasks.h @@ -1,6 +1,6 @@ #pragma once -#include <util/system/atomic.h> +#include <util/system/atomic.h> #include <util/system/yassert.h> namespace NActor { diff --git a/library/cpp/messagebus/actor/temp_tls_vector.h b/library/cpp/messagebus/actor/temp_tls_vector.h index 675d92f5b0..1860f544ff 100644 --- a/library/cpp/messagebus/actor/temp_tls_vector.h +++ b/library/cpp/messagebus/actor/temp_tls_vector.h @@ -1,8 +1,8 @@ #pragma once -#include "thread_extra.h" - -#include <util/generic/vector.h> +#include "thread_extra.h" + +#include <util/generic/vector.h> #include <util/system/yassert.h> template <typename T, typename TTag = void, template <typename, class> class TVectorType = TVector> diff --git a/library/cpp/messagebus/actor/thread_extra.cpp b/library/cpp/messagebus/actor/thread_extra.cpp index 048480f255..bce931ff1d 100644 --- a/library/cpp/messagebus/actor/thread_extra.cpp +++ b/library/cpp/messagebus/actor/thread_extra.cpp @@ -1,7 +1,7 @@ -#include "thread_extra.h" - -#include <util/stream/str.h> -#include <util/system/execpath.h> +#include "thread_extra.h" + +#include <util/stream/str.h> +#include <util/system/execpath.h> #include <util/system/platform.h> #include <util/system/thread.h> diff --git a/library/cpp/messagebus/actor/what_thread_does.cpp b/library/cpp/messagebus/actor/what_thread_does.cpp index bebb6a888c..bda58de407 100644 --- a/library/cpp/messagebus/actor/what_thread_does.cpp +++ b/library/cpp/messagebus/actor/what_thread_does.cpp @@ -1,9 +1,9 @@ -#include "what_thread_does.h" +#include "what_thread_does.h" #include "thread_extra.h" -#include <util/system/tls.h> - +#include <util/system/tls.h> + Y_POD_STATIC_THREAD(const char*) WhatThreadDoes; diff --git a/library/cpp/messagebus/actor/what_thread_does_guard_ut.cpp b/library/cpp/messagebus/actor/what_thread_does_guard_ut.cpp index e4b218a7ca..12efbfc89e 100644 --- a/library/cpp/messagebus/actor/what_thread_does_guard_ut.cpp +++ b/library/cpp/messagebus/actor/what_thread_does_guard_ut.cpp @@ -2,8 +2,8 @@ #include "what_thread_does_guard.h" -#include <util/system/mutex.h> - +#include <util/system/mutex.h> + Y_UNIT_TEST_SUITE(WhatThreadDoesGuard) { Y_UNIT_TEST(Simple) { TMutex mutex; diff --git a/library/cpp/messagebus/async_result.h b/library/cpp/messagebus/async_result.h index d24dde284a..dc7281e02f 100644 --- a/library/cpp/messagebus/async_result.h +++ b/library/cpp/messagebus/async_result.h @@ -2,9 +2,9 @@ #include <util/generic/maybe.h> #include <util/generic/noncopyable.h> -#include <util/system/condvar.h> -#include <util/system/mutex.h> -#include <util/system/yassert.h> +#include <util/system/condvar.h> +#include <util/system/mutex.h> +#include <util/system/yassert.h> #include <functional> diff --git a/library/cpp/messagebus/cc_semaphore_ut.cpp b/library/cpp/messagebus/cc_semaphore_ut.cpp index 206bb7c96a..b534dbde7b 100644 --- a/library/cpp/messagebus/cc_semaphore_ut.cpp +++ b/library/cpp/messagebus/cc_semaphore_ut.cpp @@ -2,8 +2,8 @@ #include "cc_semaphore.h" -#include <util/system/atomic.h> - +#include <util/system/atomic.h> + namespace { struct TTestSemaphore: public TComplexConditionSemaphore<TTestSemaphore> { TAtomic Current; diff --git a/library/cpp/messagebus/config/defs.h b/library/cpp/messagebus/config/defs.h index 92b1df9969..c27ea26b77 100644 --- a/library/cpp/messagebus/config/defs.h +++ b/library/cpp/messagebus/config/defs.h @@ -2,13 +2,13 @@ // unique tag to fix pragma once gcc glueing: ./library/cpp/messagebus/defs.h -#include "codegen.h" -#include "netaddr.h" - +#include "codegen.h" +#include "netaddr.h" + #include <library/cpp/deprecated/enum_codegen/enum_codegen.h> - + #include <util/generic/list.h> - + #include <utility> // For historical reasons TCrawlerModule need to access diff --git a/library/cpp/messagebus/config/netaddr.cpp b/library/cpp/messagebus/config/netaddr.cpp index 962ac538e2..4e189ccfde 100644 --- a/library/cpp/messagebus/config/netaddr.cpp +++ b/library/cpp/messagebus/config/netaddr.cpp @@ -1,5 +1,5 @@ -#include "netaddr.h" - +#include "netaddr.h" + #include <util/network/address.h> #include <cstdlib> diff --git a/library/cpp/messagebus/config/netaddr.h b/library/cpp/messagebus/config/netaddr.h index b79c0cc355..2d43cc014b 100644 --- a/library/cpp/messagebus/config/netaddr.h +++ b/library/cpp/messagebus/config/netaddr.h @@ -3,7 +3,7 @@ #include <util/digest/numeric.h> #include <util/generic/hash.h> #include <util/generic/ptr.h> -#include <util/generic/strbuf.h> +#include <util/generic/strbuf.h> #include <util/generic/vector.h> #include <util/network/address.h> diff --git a/library/cpp/messagebus/connection.cpp b/library/cpp/messagebus/connection.cpp index 07580ce18a..9b6796d36b 100644 --- a/library/cpp/messagebus/connection.cpp +++ b/library/cpp/messagebus/connection.cpp @@ -1,8 +1,8 @@ -#include "connection.h" +#include "connection.h" #include "remote_client_connection.h" -#include <util/generic/cast.h> +#include <util/generic/cast.h> using namespace NBus; using namespace NBus::NPrivate; diff --git a/library/cpp/messagebus/connection.h b/library/cpp/messagebus/connection.h index b1df64ddc1..ae2107b251 100644 --- a/library/cpp/messagebus/connection.h +++ b/library/cpp/messagebus/connection.h @@ -3,8 +3,8 @@ #include "defs.h" #include "message.h" -#include <util/generic/ptr.h> - +#include <util/generic/ptr.h> + namespace NBus { struct TBusClientConnection { /// if you want to open connection early diff --git a/library/cpp/messagebus/coreconn.cpp b/library/cpp/messagebus/coreconn.cpp index d9411bb5db..470b8fa102 100644 --- a/library/cpp/messagebus/coreconn.cpp +++ b/library/cpp/messagebus/coreconn.cpp @@ -1,5 +1,5 @@ #include "coreconn.h" - + #include "remote_connection.h" #include <util/datetime/base.h> diff --git a/library/cpp/messagebus/coreconn.h b/library/cpp/messagebus/coreconn.h index fca228d82e..ddc783aa9d 100644 --- a/library/cpp/messagebus/coreconn.h +++ b/library/cpp/messagebus/coreconn.h @@ -25,7 +25,7 @@ #include <util/thread/lfqueue.h> #include <deque> -#include <utility> +#include <utility> #ifdef NO_ERROR #undef NO_ERROR diff --git a/library/cpp/messagebus/coreconn_ut.cpp b/library/cpp/messagebus/coreconn_ut.cpp index beb6850f26..87ef125bd8 100644 --- a/library/cpp/messagebus/coreconn_ut.cpp +++ b/library/cpp/messagebus/coreconn_ut.cpp @@ -1,5 +1,5 @@ #include <library/cpp/testing/unittest/registar.h> - + #include "coreconn.h" #include <util/generic/yexception.h> diff --git a/library/cpp/messagebus/debug_receiver/debug_receiver_handler.cpp b/library/cpp/messagebus/debug_receiver/debug_receiver_handler.cpp index 05f99e94ca..131476182c 100644 --- a/library/cpp/messagebus/debug_receiver/debug_receiver_handler.cpp +++ b/library/cpp/messagebus/debug_receiver/debug_receiver_handler.cpp @@ -1,9 +1,9 @@ -#include "debug_receiver_handler.h" +#include "debug_receiver_handler.h" #include "debug_receiver_proto.h" -#include <util/generic/cast.h> -#include <util/string/printf.h> +#include <util/generic/cast.h> +#include <util/string/printf.h> void TDebugReceiverHandler::OnError(TAutoPtr<NBus::TBusMessage>, NBus::EMessageStatus status) { Cerr << "error " << status << "\n"; diff --git a/library/cpp/messagebus/duration_histogram.cpp b/library/cpp/messagebus/duration_histogram.cpp index 32a0001d41..ebefee7918 100644 --- a/library/cpp/messagebus/duration_histogram.cpp +++ b/library/cpp/messagebus/duration_histogram.cpp @@ -1,6 +1,6 @@ -#include "duration_histogram.h" - -#include <util/generic/singleton.h> +#include "duration_histogram.h" + +#include <util/generic/singleton.h> #include <util/stream/str.h> namespace { diff --git a/library/cpp/messagebus/duration_histogram.h b/library/cpp/messagebus/duration_histogram.h index ed060b0101..93a5c5d992 100644 --- a/library/cpp/messagebus/duration_histogram.h +++ b/library/cpp/messagebus/duration_histogram.h @@ -1,7 +1,7 @@ #pragma once #include <util/datetime/base.h> -#include <util/generic/bitops.h> +#include <util/generic/bitops.h> #include <util/generic/string.h> #include <array> diff --git a/library/cpp/messagebus/event_loop.cpp b/library/cpp/messagebus/event_loop.cpp index f685135bed..f8462cc8d4 100644 --- a/library/cpp/messagebus/event_loop.cpp +++ b/library/cpp/messagebus/event_loop.cpp @@ -1,18 +1,18 @@ -#include "event_loop.h" +#include "event_loop.h" -#include "network.h" +#include "network.h" #include "thread_extra.h" #include <util/generic/hash.h> #include <util/network/pair.h> #include <util/network/poller.h> -#include <util/system/event.h> -#include <util/system/mutex.h> +#include <util/system/event.h> +#include <util/system/mutex.h> #include <util/system/thread.h> #include <util/system/yassert.h> #include <util/thread/lfqueue.h> -#include <errno.h> +#include <errno.h> using namespace NEventLoop; diff --git a/library/cpp/messagebus/event_loop.h b/library/cpp/messagebus/event_loop.h index d5b0a53b0c..6fc2c1837b 100644 --- a/library/cpp/messagebus/event_loop.h +++ b/library/cpp/messagebus/event_loop.h @@ -1,6 +1,6 @@ #pragma once -#include <util/generic/object_counter.h> +#include <util/generic/object_counter.h> #include <util/generic/ptr.h> #include <util/network/init.h> #include <util/network/socket.h> diff --git a/library/cpp/messagebus/futex_like.h b/library/cpp/messagebus/futex_like.h index 31d60c60f1..5171806e74 100644 --- a/library/cpp/messagebus/futex_like.h +++ b/library/cpp/messagebus/futex_like.h @@ -1,7 +1,7 @@ #pragma once -#include <util/system/condvar.h> -#include <util/system/mutex.h> +#include <util/system/condvar.h> +#include <util/system/mutex.h> #include <util/system/platform.h> class TFutexLike { diff --git a/library/cpp/messagebus/handler.cpp b/library/cpp/messagebus/handler.cpp index 333bd52934..1cef09d63d 100644 --- a/library/cpp/messagebus/handler.cpp +++ b/library/cpp/messagebus/handler.cpp @@ -1,6 +1,6 @@ #include "handler.h" - -#include "remote_server_connection.h" + +#include "remote_server_connection.h" #include "ybus.h" using namespace NBus; diff --git a/library/cpp/messagebus/handler.h b/library/cpp/messagebus/handler.h index 60002c68a6..3c8496d6a3 100644 --- a/library/cpp/messagebus/handler.h +++ b/library/cpp/messagebus/handler.h @@ -1,13 +1,13 @@ #pragma once #include "defs.h" -#include "message.h" +#include "message.h" #include "message_status.h" #include "use_after_free_checker.h" #include "use_count_checker.h" -#include <util/generic/noncopyable.h> - +#include <util/generic/noncopyable.h> + namespace NBus { ///////////////////////////////////////////////////////////////// /// \brief Interface to message bus handler diff --git a/library/cpp/messagebus/handler_impl.h b/library/cpp/messagebus/handler_impl.h index 6593f04cc3..70fb02e575 100644 --- a/library/cpp/messagebus/handler_impl.h +++ b/library/cpp/messagebus/handler_impl.h @@ -1,7 +1,7 @@ #pragma once -#include "handler.h" -#include "local_flags.h" +#include "handler.h" +#include "local_flags.h" #include "session.h" namespace NBus { diff --git a/library/cpp/messagebus/key_value_printer.cpp b/library/cpp/messagebus/key_value_printer.cpp index c8592145c7..5c2567e495 100644 --- a/library/cpp/messagebus/key_value_printer.cpp +++ b/library/cpp/messagebus/key_value_printer.cpp @@ -1,5 +1,5 @@ -#include "key_value_printer.h" - +#include "key_value_printer.h" + #include <util/stream/format.h> TKeyValuePrinter::TKeyValuePrinter(const TString& sep) diff --git a/library/cpp/messagebus/key_value_printer.h b/library/cpp/messagebus/key_value_printer.h index bca1fde50e..6ee63a30fa 100644 --- a/library/cpp/messagebus/key_value_printer.h +++ b/library/cpp/messagebus/key_value_printer.h @@ -2,8 +2,8 @@ #include <util/generic/string.h> #include <util/generic/typetraits.h> -#include <util/generic/vector.h> -#include <util/string/cast.h> +#include <util/generic/vector.h> +#include <util/string/cast.h> class TKeyValuePrinter { private: diff --git a/library/cpp/messagebus/latch.h b/library/cpp/messagebus/latch.h index 373f4c0e13..7e01f2d035 100644 --- a/library/cpp/messagebus/latch.h +++ b/library/cpp/messagebus/latch.h @@ -1,6 +1,6 @@ #pragma once -#include <util/system/condvar.h> +#include <util/system/condvar.h> #include <util/system/mutex.h> class TLatch { diff --git a/library/cpp/messagebus/left_right_buffer.h b/library/cpp/messagebus/left_right_buffer.h index f937cefad0..fc92d6917c 100644 --- a/library/cpp/messagebus/left_right_buffer.h +++ b/library/cpp/messagebus/left_right_buffer.h @@ -1,7 +1,7 @@ #pragma once -#include <util/generic/buffer.h> -#include <util/generic/noncopyable.h> +#include <util/generic/buffer.h> +#include <util/generic/noncopyable.h> #include <util/system/yassert.h> namespace NBus { diff --git a/library/cpp/messagebus/lfqueue_batch.h b/library/cpp/messagebus/lfqueue_batch.h index 8128d3154d..aa67b6ae40 100644 --- a/library/cpp/messagebus/lfqueue_batch.h +++ b/library/cpp/messagebus/lfqueue_batch.h @@ -1,7 +1,7 @@ #pragma once #include <library/cpp/messagebus/actor/temp_tls_vector.h> - + #include <util/generic/vector.h> #include <util/thread/lfstack.h> diff --git a/library/cpp/messagebus/local_flags.cpp b/library/cpp/messagebus/local_flags.cpp index 877e533f76..ad0a30e232 100644 --- a/library/cpp/messagebus/local_flags.cpp +++ b/library/cpp/messagebus/local_flags.cpp @@ -1,6 +1,6 @@ -#include "local_flags.h" - -#include <util/stream/str.h> +#include "local_flags.h" + +#include <util/stream/str.h> #include <util/string/printf.h> using namespace NBus; diff --git a/library/cpp/messagebus/local_flags.h b/library/cpp/messagebus/local_flags.h index f589283188..fc3f126443 100644 --- a/library/cpp/messagebus/local_flags.h +++ b/library/cpp/messagebus/local_flags.h @@ -1,7 +1,7 @@ #pragma once #include <library/cpp/deprecated/enum_codegen/enum_codegen.h> - + #include <util/generic/string.h> #include <util/stream/output.h> diff --git a/library/cpp/messagebus/locator.cpp b/library/cpp/messagebus/locator.cpp index e38a35c426..7ca49fda3f 100644 --- a/library/cpp/messagebus/locator.cpp +++ b/library/cpp/messagebus/locator.cpp @@ -4,8 +4,8 @@ #include "locator.h" -#include "ybus.h" - +#include "ybus.h" + #include <util/generic/hash_set.h> #include <util/system/hostname.h> diff --git a/library/cpp/messagebus/locator.h b/library/cpp/messagebus/locator.h index f8556a3fce..39ca346748 100644 --- a/library/cpp/messagebus/locator.h +++ b/library/cpp/messagebus/locator.h @@ -1,13 +1,13 @@ #pragma once -#include "defs.h" - +#include "defs.h" + #include <util/generic/hash.h> -#include <util/generic/map.h> -#include <util/generic/set.h> -#include <util/generic/string.h> +#include <util/generic/map.h> +#include <util/generic/set.h> +#include <util/generic/string.h> #include <util/network/interface.h> -#include <util/system/mutex.h> +#include <util/system/mutex.h> namespace NBus { /////////////////////////////////////////////// diff --git a/library/cpp/messagebus/mb_lwtrace.cpp b/library/cpp/messagebus/mb_lwtrace.cpp index c54cd5ab71..1bd0096654 100644 --- a/library/cpp/messagebus/mb_lwtrace.cpp +++ b/library/cpp/messagebus/mb_lwtrace.cpp @@ -1,8 +1,8 @@ -#include "mb_lwtrace.h" +#include "mb_lwtrace.h" #include <library/cpp/lwtrace/all.h> -#include <util/generic/singleton.h> +#include <util/generic/singleton.h> LWTRACE_DEFINE_PROVIDER(LWTRACE_MESSAGEBUS_PROVIDER) diff --git a/library/cpp/messagebus/mb_lwtrace.h b/library/cpp/messagebus/mb_lwtrace.h index e62728b265..465e630c4b 100644 --- a/library/cpp/messagebus/mb_lwtrace.h +++ b/library/cpp/messagebus/mb_lwtrace.h @@ -2,8 +2,8 @@ #include <library/cpp/lwtrace/all.h> -#include <util/generic/string.h> - +#include <util/generic/string.h> + #define LWTRACE_MESSAGEBUS_PROVIDER(PROBE, EVENT, GROUPS, TYPES, NAMES) \ PROBE(Error, GROUPS("MessagebusRare"), TYPES(TString, TString, TString), NAMES("status", "address", "misc")) \ PROBE(ServerUnknownVersion, GROUPS("MessagebusRare"), TYPES(TString, ui32), NAMES("address", "version")) \ diff --git a/library/cpp/messagebus/message.cpp b/library/cpp/messagebus/message.cpp index bfa7ed8e9b..01e3b5440b 100644 --- a/library/cpp/messagebus/message.cpp +++ b/library/cpp/messagebus/message.cpp @@ -1,11 +1,11 @@ -#include "remote_server_connection.h" -#include "ybus.h" +#include "remote_server_connection.h" +#include "ybus.h" -#include <util/random/random.h> -#include <util/string/printf.h> +#include <util/random/random.h> +#include <util/string/printf.h> #include <util/system/atomic.h> -#include <string.h> +#include <string.h> using namespace NBus; diff --git a/library/cpp/messagebus/message.h b/library/cpp/messagebus/message.h index 005ca10c65..783cbeeb94 100644 --- a/library/cpp/messagebus/message.h +++ b/library/cpp/messagebus/message.h @@ -1,16 +1,16 @@ #pragma once -#include "base.h" -#include "local_flags.h" -#include "message_status.h" -#include "netaddr.h" -#include "socket_addr.h" - -#include <util/generic/array_ref.h> -#include <util/generic/noncopyable.h> +#include "base.h" +#include "local_flags.h" +#include "message_status.h" +#include "netaddr.h" +#include "socket_addr.h" + +#include <util/generic/array_ref.h> +#include <util/generic/noncopyable.h> #include <util/generic/ptr.h> #include <util/generic/string.h> -#include <util/system/defaults.h> +#include <util/system/defaults.h> #include <util/system/type_name.h> #include <util/system/yassert.h> diff --git a/library/cpp/messagebus/message_counter.cpp b/library/cpp/messagebus/message_counter.cpp index 04d9343f6a..29f567b355 100644 --- a/library/cpp/messagebus/message_counter.cpp +++ b/library/cpp/messagebus/message_counter.cpp @@ -1,5 +1,5 @@ -#include "message_counter.h" - +#include "message_counter.h" + #include <util/stream/str.h> using namespace NBus; diff --git a/library/cpp/messagebus/message_counter.h b/library/cpp/messagebus/message_counter.h index e4be1180b0..0a1e094824 100644 --- a/library/cpp/messagebus/message_counter.h +++ b/library/cpp/messagebus/message_counter.h @@ -1,9 +1,9 @@ #pragma once -#include <util/generic/string.h> - -#include <cstddef> - +#include <util/generic/string.h> + +#include <cstddef> + namespace NBus { namespace NPrivate { struct TMessageCounter { diff --git a/library/cpp/messagebus/message_ptr_and_header.h b/library/cpp/messagebus/message_ptr_and_header.h index 9b4e2fd270..dea9af70a5 100644 --- a/library/cpp/messagebus/message_ptr_and_header.h +++ b/library/cpp/messagebus/message_ptr_and_header.h @@ -1,10 +1,10 @@ #pragma once -#include "message.h" +#include "message.h" #include "nondestroying_holder.h" -#include <util/generic/noncopyable.h> -#include <util/generic/utility.h> +#include <util/generic/noncopyable.h> +#include <util/generic/utility.h> namespace NBus { namespace NPrivate { diff --git a/library/cpp/messagebus/message_status.h b/library/cpp/messagebus/message_status.h index e1878960b3..cf9816be1a 100644 --- a/library/cpp/messagebus/message_status.h +++ b/library/cpp/messagebus/message_status.h @@ -1,8 +1,8 @@ #pragma once -#include "codegen.h" -#include "defs.h" - +#include "codegen.h" +#include "defs.h" + #include <library/cpp/deprecated/enum_codegen/enum_codegen.h> namespace NBus { diff --git a/library/cpp/messagebus/message_status_counter.cpp b/library/cpp/messagebus/message_status_counter.cpp index 891c8f5bb2..d69ba3fdcb 100644 --- a/library/cpp/messagebus/message_status_counter.cpp +++ b/library/cpp/messagebus/message_status_counter.cpp @@ -1,5 +1,5 @@ -#include "message_status_counter.h" - +#include "message_status_counter.h" + #include "key_value_printer.h" #include "text_utils.h" diff --git a/library/cpp/messagebus/message_status_counter.h b/library/cpp/messagebus/message_status_counter.h index e8ba2fdd31..b3be955ab5 100644 --- a/library/cpp/messagebus/message_status_counter.h +++ b/library/cpp/messagebus/message_status_counter.h @@ -1,7 +1,7 @@ #pragma once -#include "message_status.h" - +#include "message_status.h" + #include <library/cpp/messagebus/monitoring/mon_proto.pb.h> #include <util/generic/string.h> diff --git a/library/cpp/messagebus/message_status_counter_ut.cpp b/library/cpp/messagebus/message_status_counter_ut.cpp index 9598651329..eb6923f1bb 100644 --- a/library/cpp/messagebus/message_status_counter_ut.cpp +++ b/library/cpp/messagebus/message_status_counter_ut.cpp @@ -1,7 +1,7 @@ #include <library/cpp/testing/unittest/registar.h> -#include "message_status_counter.h" - +#include "message_status_counter.h" + #include <library/cpp/messagebus/monitoring/mon_proto.pb.h> using namespace NBus; diff --git a/library/cpp/messagebus/messqueue.cpp b/library/cpp/messagebus/messqueue.cpp index 3474d62705..5f9bae04e8 100644 --- a/library/cpp/messagebus/messqueue.cpp +++ b/library/cpp/messagebus/messqueue.cpp @@ -1,11 +1,11 @@ -#include "key_value_printer.h" -#include "mb_lwtrace.h" +#include "key_value_printer.h" +#include "mb_lwtrace.h" #include "remote_client_session.h" #include "remote_server_session.h" -#include "ybus.h" - -#include <util/generic/singleton.h> +#include "ybus.h" +#include <util/generic/singleton.h> + using namespace NBus; using namespace NBus::NPrivate; using namespace NActor; diff --git a/library/cpp/messagebus/misc/atomic_box.h b/library/cpp/messagebus/misc/atomic_box.h index 401621f933..ac4a602cc1 100644 --- a/library/cpp/messagebus/misc/atomic_box.h +++ b/library/cpp/messagebus/misc/atomic_box.h @@ -1,7 +1,7 @@ #pragma once -#include <util/system/atomic.h> - +#include <util/system/atomic.h> + // TAtomic with human interface template <typename T> class TAtomicBox { diff --git a/library/cpp/messagebus/misc/granup.h b/library/cpp/messagebus/misc/granup.h index 36ecfebc93..ec8648711f 100644 --- a/library/cpp/messagebus/misc/granup.h +++ b/library/cpp/messagebus/misc/granup.h @@ -1,7 +1,7 @@ #pragma once -#include <util/datetime/base.h> -#include <util/system/guard.h> +#include <util/datetime/base.h> +#include <util/system/guard.h> #include <util/system/mutex.h> #include <util/system/spinlock.h> diff --git a/library/cpp/messagebus/misc/test_sync.h b/library/cpp/messagebus/misc/test_sync.h index be3f4f20b8..2752f79ac9 100644 --- a/library/cpp/messagebus/misc/test_sync.h +++ b/library/cpp/messagebus/misc/test_sync.h @@ -1,6 +1,6 @@ #pragma once -#include <util/system/condvar.h> +#include <util/system/condvar.h> #include <util/system/mutex.h> class TTestSync { diff --git a/library/cpp/messagebus/network.cpp b/library/cpp/messagebus/network.cpp index 304bedae5a..6554d160d7 100644 --- a/library/cpp/messagebus/network.cpp +++ b/library/cpp/messagebus/network.cpp @@ -1,10 +1,10 @@ #include "network.h" -#include <util/generic/maybe.h> -#include <util/generic/ptr.h> +#include <util/generic/maybe.h> +#include <util/generic/ptr.h> #include <util/network/init.h> #include <util/network/socket.h> -#include <util/system/platform.h> +#include <util/system/platform.h> using namespace NBus; using namespace NBus::NPrivate; diff --git a/library/cpp/messagebus/network.h b/library/cpp/messagebus/network.h index cc4bd76ea3..a3a8b6e7e6 100644 --- a/library/cpp/messagebus/network.h +++ b/library/cpp/messagebus/network.h @@ -1,12 +1,12 @@ #pragma once -#include "netaddr.h" +#include "netaddr.h" #include <util/generic/array_ref.h> -#include <util/generic/ptr.h> +#include <util/generic/ptr.h> #include <util/network/socket.h> -#include <utility> +#include <utility> namespace NBus { namespace NPrivate { diff --git a/library/cpp/messagebus/network_ut.cpp b/library/cpp/messagebus/network_ut.cpp index f1798419db..9fe8dc7620 100644 --- a/library/cpp/messagebus/network_ut.cpp +++ b/library/cpp/messagebus/network_ut.cpp @@ -3,7 +3,7 @@ #include "network.h" #include <library/cpp/messagebus/test/helper/fixed_port.h> - + using namespace NBus; using namespace NBus::NPrivate; using namespace NBus::NTest; diff --git a/library/cpp/messagebus/oldmodule/module.cpp b/library/cpp/messagebus/oldmodule/module.cpp index 24bd778799..6b8ec2b2a6 100644 --- a/library/cpp/messagebus/oldmodule/module.cpp +++ b/library/cpp/messagebus/oldmodule/module.cpp @@ -6,9 +6,9 @@ #include <library/cpp/messagebus/actor/queue_in_actor.h> #include <library/cpp/messagebus/actor/what_thread_does.h> #include <library/cpp/messagebus/actor/what_thread_does_guard.h> - -#include <util/generic/singleton.h> -#include <util/string/printf.h> + +#include <util/generic/singleton.h> +#include <util/string/printf.h> #include <util/system/event.h> using namespace NActor; diff --git a/library/cpp/messagebus/oldmodule/module.h b/library/cpp/messagebus/oldmodule/module.h index 8d1c4a5d52..df79bfcbd9 100644 --- a/library/cpp/messagebus/oldmodule/module.h +++ b/library/cpp/messagebus/oldmodule/module.h @@ -39,13 +39,13 @@ /// for a later time. This should be done in case NBus::TBusJob::Send() returns /// error (not MESSAGE_OK) -#include "startsession.h" +#include "startsession.h" #include <library/cpp/messagebus/ybus.h> -#include <util/generic/noncopyable.h> -#include <util/generic/object_counter.h> - +#include <util/generic/noncopyable.h> +#include <util/generic/object_counter.h> + namespace NBus { class TBusJob; class TBusModule; diff --git a/library/cpp/messagebus/oldmodule/startsession.cpp b/library/cpp/messagebus/oldmodule/startsession.cpp index 7c38801d62..787952affe 100644 --- a/library/cpp/messagebus/oldmodule/startsession.cpp +++ b/library/cpp/messagebus/oldmodule/startsession.cpp @@ -14,10 +14,10 @@ #include "startsession.h" -#include "module.h" - +#include "module.h" + #include <library/cpp/messagebus/ybus.h> - + namespace NBus { void* TBusStarter::_starter(void* data) { TBusStarter* pThis = static_cast<TBusStarter*>(data); diff --git a/library/cpp/messagebus/oldmodule/startsession.h b/library/cpp/messagebus/oldmodule/startsession.h index 5e26e7e1e5..87c2f47982 100644 --- a/library/cpp/messagebus/oldmodule/startsession.h +++ b/library/cpp/messagebus/oldmodule/startsession.h @@ -1,7 +1,7 @@ #pragma once #include <library/cpp/messagebus/ybus.h> - + #include <util/system/thread.h> namespace NBus { diff --git a/library/cpp/messagebus/protobuf/ybusbuf.cpp b/library/cpp/messagebus/protobuf/ybusbuf.cpp index 63415b3737..4d1433164e 100644 --- a/library/cpp/messagebus/protobuf/ybusbuf.cpp +++ b/library/cpp/messagebus/protobuf/ybusbuf.cpp @@ -1,7 +1,7 @@ -#include "ybusbuf.h" +#include "ybusbuf.h" #include <library/cpp/messagebus/actor/what_thread_does.h> - + #include <google/protobuf/io/coded_stream.h> using namespace NBus; diff --git a/library/cpp/messagebus/protobuf/ybusbuf.h b/library/cpp/messagebus/protobuf/ybusbuf.h index 57b4267ea5..48f2f0ebc9 100644 --- a/library/cpp/messagebus/protobuf/ybusbuf.h +++ b/library/cpp/messagebus/protobuf/ybusbuf.h @@ -5,9 +5,9 @@ #include <google/protobuf/descriptor.h> #include <google/protobuf/message.h> -#include <util/generic/cast.h> -#include <util/generic/vector.h> -#include <util/stream/mem.h> +#include <util/generic/cast.h> +#include <util/generic/vector.h> +#include <util/stream/mem.h> #include <array> diff --git a/library/cpp/messagebus/rain_check/core/coro.cpp b/library/cpp/messagebus/rain_check/core/coro.cpp index 500841dd5b..a133fe8a9f 100644 --- a/library/cpp/messagebus/rain_check/core/coro.cpp +++ b/library/cpp/messagebus/rain_check/core/coro.cpp @@ -1,9 +1,9 @@ -#include "coro.h" +#include "coro.h" #include "coro_stack.h" -#include <util/system/tls.h> -#include <util/system/yassert.h> +#include <util/system/tls.h> +#include <util/system/yassert.h> using namespace NRainCheck; diff --git a/library/cpp/messagebus/rain_check/core/coro_stack.cpp b/library/cpp/messagebus/rain_check/core/coro_stack.cpp index 83b984ca6e..31e820b030 100644 --- a/library/cpp/messagebus/rain_check/core/coro_stack.cpp +++ b/library/cpp/messagebus/rain_check/core/coro_stack.cpp @@ -1,10 +1,10 @@ -#include "coro_stack.h" +#include "coro_stack.h" #include <util/generic/singleton.h> #include <util/system/valgrind.h> #include <cstdlib> -#include <stdio.h> +#include <stdio.h> using namespace NRainCheck; using namespace NRainCheck::NPrivate; diff --git a/library/cpp/messagebus/rain_check/core/coro_ut.cpp b/library/cpp/messagebus/rain_check/core/coro_ut.cpp index 61a33584a5..26e2d00724 100644 --- a/library/cpp/messagebus/rain_check/core/coro_ut.cpp +++ b/library/cpp/messagebus/rain_check/core/coro_ut.cpp @@ -1,6 +1,6 @@ #include <library/cpp/testing/unittest/registar.h> -#include "coro.h" +#include "coro.h" #include "spawn.h" #include <library/cpp/messagebus/rain_check/test/ut/test.h> diff --git a/library/cpp/messagebus/rain_check/core/env.h b/library/cpp/messagebus/rain_check/core/env.h index f6dd7fceb6..a8bcecd18c 100644 --- a/library/cpp/messagebus/rain_check/core/env.h +++ b/library/cpp/messagebus/rain_check/core/env.h @@ -1,11 +1,11 @@ #pragma once -#include "sleep.h" -#include "spawn.h" +#include "sleep.h" +#include "spawn.h" #include <library/cpp/messagebus/actor/executor.h> -#include <util/generic/ptr.h> +#include <util/generic/ptr.h> namespace NRainCheck { struct IEnv { diff --git a/library/cpp/messagebus/rain_check/core/rain_check.h b/library/cpp/messagebus/rain_check/core/rain_check.h index 0f289717a2..cd651a390f 100644 --- a/library/cpp/messagebus/rain_check/core/rain_check.h +++ b/library/cpp/messagebus/rain_check/core/rain_check.h @@ -1,8 +1,8 @@ #pragma once #include "coro.h" -#include "env.h" +#include "env.h" #include "simple.h" #include "sleep.h" #include "spawn.h" -#include "task.h" +#include "task.h" diff --git a/library/cpp/messagebus/rain_check/core/simple_ut.cpp b/library/cpp/messagebus/rain_check/core/simple_ut.cpp index d4545e05aa..df0fa14379 100644 --- a/library/cpp/messagebus/rain_check/core/simple_ut.cpp +++ b/library/cpp/messagebus/rain_check/core/simple_ut.cpp @@ -1,10 +1,10 @@ #include <library/cpp/testing/unittest/registar.h> #include <library/cpp/messagebus/rain_check/test/ut/test.h> - + #include <library/cpp/messagebus/latch.h> -#include <util/system/event.h> +#include <util/system/event.h> using namespace NRainCheck; diff --git a/library/cpp/messagebus/rain_check/core/sleep.cpp b/library/cpp/messagebus/rain_check/core/sleep.cpp index f5d0b4cac9..012586f4b1 100644 --- a/library/cpp/messagebus/rain_check/core/sleep.cpp +++ b/library/cpp/messagebus/rain_check/core/sleep.cpp @@ -1,5 +1,5 @@ -#include "rain_check.h" - +#include "rain_check.h" + #include <util/system/yassert.h> using namespace NRainCheck; diff --git a/library/cpp/messagebus/rain_check/core/sleep.h b/library/cpp/messagebus/rain_check/core/sleep.h index 1a7a1f8674..71d3ba2cee 100644 --- a/library/cpp/messagebus/rain_check/core/sleep.h +++ b/library/cpp/messagebus/rain_check/core/sleep.h @@ -1,10 +1,10 @@ #pragma once -#include "fwd.h" +#include "fwd.h" #include <library/cpp/messagebus/scheduler/scheduler.h> -#include <util/datetime/base.h> +#include <util/datetime/base.h> namespace NRainCheck { class TSleepService { diff --git a/library/cpp/messagebus/rain_check/core/sleep_ut.cpp b/library/cpp/messagebus/rain_check/core/sleep_ut.cpp index 2ae85a87b1..5c7d0bb85b 100644 --- a/library/cpp/messagebus/rain_check/core/sleep_ut.cpp +++ b/library/cpp/messagebus/rain_check/core/sleep_ut.cpp @@ -2,8 +2,8 @@ #include <library/cpp/messagebus/rain_check/test/ut/test.h> -#include <util/system/event.h> - +#include <util/system/event.h> + using namespace NRainCheck; using namespace NActor; diff --git a/library/cpp/messagebus/rain_check/core/spawn.h b/library/cpp/messagebus/rain_check/core/spawn.h index f2b146bf29..cb15157a0d 100644 --- a/library/cpp/messagebus/rain_check/core/spawn.h +++ b/library/cpp/messagebus/rain_check/core/spawn.h @@ -2,7 +2,7 @@ #include "coro.h" #include "simple.h" -#include "task.h" +#include "task.h" namespace NRainCheck { namespace NPrivate { diff --git a/library/cpp/messagebus/rain_check/core/spawn_ut.cpp b/library/cpp/messagebus/rain_check/core/spawn_ut.cpp index ba5a5e41cf..f4d538d101 100644 --- a/library/cpp/messagebus/rain_check/core/spawn_ut.cpp +++ b/library/cpp/messagebus/rain_check/core/spawn_ut.cpp @@ -2,10 +2,10 @@ #include <library/cpp/messagebus/rain_check/test/helper/misc.h> #include <library/cpp/messagebus/rain_check/test/ut/test.h> - + #include <library/cpp/messagebus/latch.h> -#include <util/system/event.h> +#include <util/system/event.h> #include <array> diff --git a/library/cpp/messagebus/rain_check/core/task.cpp b/library/cpp/messagebus/rain_check/core/task.cpp index a098437d53..f89a69e9ff 100644 --- a/library/cpp/messagebus/rain_check/core/task.cpp +++ b/library/cpp/messagebus/rain_check/core/task.cpp @@ -1,9 +1,9 @@ -#include "rain_check.h" +#include "rain_check.h" #include <library/cpp/messagebus/actor/temp_tls_vector.h> #include <util/system/type_name.h> -#include <util/system/tls.h> +#include <util/system/tls.h> using namespace NRainCheck; using namespace NRainCheck::NPrivate; diff --git a/library/cpp/messagebus/rain_check/core/task.h b/library/cpp/messagebus/rain_check/core/task.h index 7d8778bcda..bf669a11f5 100644 --- a/library/cpp/messagebus/rain_check/core/task.h +++ b/library/cpp/messagebus/rain_check/core/task.h @@ -1,12 +1,12 @@ #pragma once -#include "fwd.h" - +#include "fwd.h" + #include <library/cpp/messagebus/actor/actor.h> #include <library/cpp/messagebus/misc/atomic_box.h> - + #include <library/cpp/deprecated/enum_codegen/enum_codegen.h> - + #include <util/generic/noncopyable.h> #include <util/generic/ptr.h> #include <util/thread/lfstack.h> diff --git a/library/cpp/messagebus/rain_check/core/track.h b/library/cpp/messagebus/rain_check/core/track.h index d387de7574..6277c807bc 100644 --- a/library/cpp/messagebus/rain_check/core/track.h +++ b/library/cpp/messagebus/rain_check/core/track.h @@ -1,15 +1,15 @@ #pragma once -#include "spawn.h" -#include "task.h" +#include "spawn.h" +#include "task.h" #include <library/cpp/messagebus/async_result.h> #include <library/cpp/messagebus/actor/queue_in_actor.h> #include <library/cpp/messagebus/misc/atomic_box.h> -#include <util/generic/intrlist.h> -#include <util/system/event.h> - +#include <util/generic/intrlist.h> +#include <util/system/event.h> + namespace NRainCheck { class TTaskTracker; diff --git a/library/cpp/messagebus/rain_check/core/track_ut.cpp b/library/cpp/messagebus/rain_check/core/track_ut.cpp index 05f7de1319..3caee731dd 100644 --- a/library/cpp/messagebus/rain_check/core/track_ut.cpp +++ b/library/cpp/messagebus/rain_check/core/track_ut.cpp @@ -1,7 +1,7 @@ #include <library/cpp/testing/unittest/registar.h> -#include "track.h" - +#include "track.h" + #include <library/cpp/messagebus/rain_check/test/helper/misc.h> #include <library/cpp/messagebus/rain_check/test/ut/test.h> diff --git a/library/cpp/messagebus/rain_check/http/client.cpp b/library/cpp/messagebus/rain_check/http/client.cpp index 5ef5ceeece..d2e36093dc 100644 --- a/library/cpp/messagebus/rain_check/http/client.cpp +++ b/library/cpp/messagebus/rain_check/http/client.cpp @@ -8,7 +8,7 @@ #include <library/cpp/neh/location.h> #include <library/cpp/neh/neh.h> -#include <util/generic/ptr.h> +#include <util/generic/ptr.h> #include <util/generic/strbuf.h> #include <util/network/socket.h> #include <util/stream/str.h> diff --git a/library/cpp/messagebus/rain_check/http/client.h b/library/cpp/messagebus/rain_check/http/client.h index d4199c4c98..689718b65e 100644 --- a/library/cpp/messagebus/rain_check/http/client.h +++ b/library/cpp/messagebus/rain_check/http/client.h @@ -3,7 +3,7 @@ #include <library/cpp/messagebus/rain_check/core/task.h> #include <library/cpp/http/misc/httpcodes.h> - + #include <util/generic/maybe.h> #include <util/generic/ptr.h> #include <util/generic/string.h> diff --git a/library/cpp/messagebus/rain_check/http/client_ut.cpp b/library/cpp/messagebus/rain_check/http/client_ut.cpp index 1628114391..0a39c6b1b1 100644 --- a/library/cpp/messagebus/rain_check/http/client_ut.cpp +++ b/library/cpp/messagebus/rain_check/http/client_ut.cpp @@ -1,10 +1,10 @@ #include <library/cpp/testing/unittest/registar.h> - + #include "client.h" #include "http_code_extractor.h" - + #include <library/cpp/messagebus/rain_check/test/ut/test.h> - + #include <library/cpp/messagebus/test/helper/fixed_port.h> #include <library/cpp/http/io/stream.h> @@ -16,13 +16,13 @@ #include <util/generic/string.h> #include <util/generic/vector.h> #include <util/network/ip.h> -#include <util/stream/str.h> -#include <util/string/printf.h> +#include <util/stream/str.h> +#include <util/string/printf.h> #include <util/system/defaults.h> #include <util/system/yassert.h> #include <cstdlib> -#include <utility> +#include <utility> using namespace NRainCheck; using namespace NBus::NTest; diff --git a/library/cpp/messagebus/rain_check/http/http_code_extractor.cpp b/library/cpp/messagebus/rain_check/http/http_code_extractor.cpp index 51d75762f6..2b02c17435 100644 --- a/library/cpp/messagebus/rain_check/http/http_code_extractor.cpp +++ b/library/cpp/messagebus/rain_check/http/http_code_extractor.cpp @@ -2,8 +2,8 @@ #include <library/cpp/http/io/stream.h> #include <library/cpp/http/misc/httpcodes.h> - -#include <util/generic/maybe.h> + +#include <util/generic/maybe.h> #include <util/generic/strbuf.h> #include <util/string/cast.h> diff --git a/library/cpp/messagebus/rain_check/http/http_code_extractor.h b/library/cpp/messagebus/rain_check/http/http_code_extractor.h index 33b565fa1c..43f860b731 100644 --- a/library/cpp/messagebus/rain_check/http/http_code_extractor.h +++ b/library/cpp/messagebus/rain_check/http/http_code_extractor.h @@ -1,7 +1,7 @@ #pragma once #include <library/cpp/http/misc/httpcodes.h> - + #include <util/generic/maybe.h> #include <util/generic/strbuf.h> diff --git a/library/cpp/messagebus/rain_check/messagebus/messagebus_client.h b/library/cpp/messagebus/rain_check/messagebus/messagebus_client.h index 0a291cdea6..6d9144cf3e 100644 --- a/library/cpp/messagebus/rain_check/messagebus/messagebus_client.h +++ b/library/cpp/messagebus/rain_check/messagebus/messagebus_client.h @@ -1,7 +1,7 @@ #pragma once #include <library/cpp/messagebus/rain_check/core/task.h> - + #include <library/cpp/messagebus/ybus.h> namespace NRainCheck { diff --git a/library/cpp/messagebus/rain_check/messagebus/messagebus_client_ut.cpp b/library/cpp/messagebus/rain_check/messagebus/messagebus_client_ut.cpp index 1b3618558b..05d2d6e02f 100644 --- a/library/cpp/messagebus/rain_check/messagebus/messagebus_client_ut.cpp +++ b/library/cpp/messagebus/rain_check/messagebus/messagebus_client_ut.cpp @@ -1,13 +1,13 @@ #include <library/cpp/testing/unittest/registar.h> -#include "messagebus_client.h" - +#include "messagebus_client.h" + #include <library/cpp/messagebus/rain_check/test/ut/test.h> - + #include <library/cpp/messagebus/test/helper/example.h> #include <library/cpp/messagebus/test/helper/object_count_check.h> -#include <util/generic/cast.h> +#include <util/generic/cast.h> using namespace NBus; using namespace NBus::NTest; diff --git a/library/cpp/messagebus/rain_check/messagebus/messagebus_server.cpp b/library/cpp/messagebus/rain_check/messagebus/messagebus_server.cpp index 5d4b13d664..88995e36f8 100644 --- a/library/cpp/messagebus/rain_check/messagebus/messagebus_server.cpp +++ b/library/cpp/messagebus/rain_check/messagebus/messagebus_server.cpp @@ -1,5 +1,5 @@ -#include "messagebus_server.h" - +#include "messagebus_server.h" + #include <library/cpp/messagebus/rain_check/core/spawn.h> using namespace NRainCheck; diff --git a/library/cpp/messagebus/rain_check/messagebus/messagebus_server_ut.cpp b/library/cpp/messagebus/rain_check/messagebus/messagebus_server_ut.cpp index 7c11399f1b..68060e62e7 100644 --- a/library/cpp/messagebus/rain_check/messagebus/messagebus_server_ut.cpp +++ b/library/cpp/messagebus/rain_check/messagebus/messagebus_server_ut.cpp @@ -1,6 +1,6 @@ #include <library/cpp/testing/unittest/registar.h> -#include "messagebus_server.h" +#include "messagebus_server.h" #include <library/cpp/messagebus/rain_check/test/ut/test.h> diff --git a/library/cpp/messagebus/rain_check/test/helper/misc.cpp b/library/cpp/messagebus/rain_check/test/helper/misc.cpp index c0fcb27252..0fe3700b96 100644 --- a/library/cpp/messagebus/rain_check/test/helper/misc.cpp +++ b/library/cpp/messagebus/rain_check/test/helper/misc.cpp @@ -1,5 +1,5 @@ -#include "misc.h" - +#include "misc.h" + #include <util/system/yassert.h> using namespace NRainCheck; diff --git a/library/cpp/messagebus/rain_check/test/perftest/perftest.cpp b/library/cpp/messagebus/rain_check/test/perftest/perftest.cpp index 22edbd8c6b..980b6b2abf 100644 --- a/library/cpp/messagebus/rain_check/test/perftest/perftest.cpp +++ b/library/cpp/messagebus/rain_check/test/perftest/perftest.cpp @@ -2,8 +2,8 @@ #include <library/cpp/messagebus/rain_check/core/rain_check.h> -#include <util/datetime/base.h> - +#include <util/datetime/base.h> + #include <array> using namespace NRainCheck; diff --git a/library/cpp/messagebus/rain_check/test/ut/test.h b/library/cpp/messagebus/rain_check/test/ut/test.h index 724f6b7530..e91470d3a3 100644 --- a/library/cpp/messagebus/rain_check/test/ut/test.h +++ b/library/cpp/messagebus/rain_check/test/ut/test.h @@ -1,7 +1,7 @@ #pragma once #include <library/cpp/messagebus/rain_check/core/rain_check.h> - + #include <library/cpp/messagebus/misc/test_sync.h> template <typename TSelf> diff --git a/library/cpp/messagebus/remote_client_connection.cpp b/library/cpp/messagebus/remote_client_connection.cpp index 8c7a6db3a8..051618afe0 100644 --- a/library/cpp/messagebus/remote_client_connection.cpp +++ b/library/cpp/messagebus/remote_client_connection.cpp @@ -1,14 +1,14 @@ #include "remote_client_connection.h" -#include "mb_lwtrace.h" -#include "network.h" +#include "mb_lwtrace.h" +#include "network.h" #include "remote_client_session.h" #include <library/cpp/messagebus/actor/executor.h> #include <library/cpp/messagebus/actor/temp_tls_vector.h> -#include <util/generic/cast.h> -#include <util/thread/singleton.h> +#include <util/generic/cast.h> +#include <util/thread/singleton.h> LWTRACE_USING(LWTRACE_MESSAGEBUS_PROVIDER) diff --git a/library/cpp/messagebus/remote_client_connection.h b/library/cpp/messagebus/remote_client_connection.h index fe80b7d2f9..557cc2e03d 100644 --- a/library/cpp/messagebus/remote_client_connection.h +++ b/library/cpp/messagebus/remote_client_connection.h @@ -1,12 +1,12 @@ #pragma once -#include "connection.h" +#include "connection.h" #include "local_tasks.h" -#include "remote_client_session.h" +#include "remote_client_session.h" #include "remote_connection.h" -#include <util/generic/object_counter.h> - +#include <util/generic/object_counter.h> + namespace NBus { namespace NPrivate { class TRemoteClientConnection: public TRemoteConnection, public TBusClientConnection { diff --git a/library/cpp/messagebus/remote_client_session.cpp b/library/cpp/messagebus/remote_client_session.cpp index 3bc421944f..b2f98a19f2 100644 --- a/library/cpp/messagebus/remote_client_session.cpp +++ b/library/cpp/messagebus/remote_client_session.cpp @@ -1,12 +1,12 @@ #include "remote_client_session.h" -#include "mb_lwtrace.h" +#include "mb_lwtrace.h" #include "remote_client_connection.h" #include <library/cpp/messagebus/scheduler/scheduler.h> -#include <util/generic/cast.h> -#include <util/system/defaults.h> +#include <util/generic/cast.h> +#include <util/system/defaults.h> LWTRACE_USING(LWTRACE_MESSAGEBUS_PROVIDER) diff --git a/library/cpp/messagebus/remote_client_session.h b/library/cpp/messagebus/remote_client_session.h index 7160d0dae9..9758235195 100644 --- a/library/cpp/messagebus/remote_client_session.h +++ b/library/cpp/messagebus/remote_client_session.h @@ -3,9 +3,9 @@ #include "remote_client_session_semaphore.h" #include "session_impl.h" -#include <util/generic/array_ref.h> -#include <util/generic/object_counter.h> - +#include <util/generic/array_ref.h> +#include <util/generic/object_counter.h> + #ifdef _MSC_VER #pragma warning(push) #pragma warning(disable : 4250) // 'NBus::NPrivate::TRemoteClientSession' : inherits 'NBus::NPrivate::TBusSessionImpl::NBus::NPrivate::TBusSessionImpl::GetConfig' via dominance diff --git a/library/cpp/messagebus/remote_client_session_semaphore.cpp b/library/cpp/messagebus/remote_client_session_semaphore.cpp index f877ed4257..c5601e5511 100644 --- a/library/cpp/messagebus/remote_client_session_semaphore.cpp +++ b/library/cpp/messagebus/remote_client_session_semaphore.cpp @@ -1,6 +1,6 @@ -#include "remote_client_session_semaphore.h" - -#include <util/stream/output.h> +#include "remote_client_session_semaphore.h" + +#include <util/stream/output.h> #include <util/system/yassert.h> using namespace NBus; diff --git a/library/cpp/messagebus/remote_client_session_semaphore.h b/library/cpp/messagebus/remote_client_session_semaphore.h index 286ca3c86f..c3850d7d90 100644 --- a/library/cpp/messagebus/remote_client_session_semaphore.h +++ b/library/cpp/messagebus/remote_client_session_semaphore.h @@ -1,10 +1,10 @@ #pragma once -#include "cc_semaphore.h" - +#include "cc_semaphore.h" + #include <util/generic/noncopyable.h> -#include <util/system/atomic.h> -#include <util/system/condvar.h> +#include <util/system/atomic.h> +#include <util/system/condvar.h> #include <util/system/mutex.h> namespace NBus { diff --git a/library/cpp/messagebus/remote_connection.cpp b/library/cpp/messagebus/remote_connection.cpp index 22932569db..18cb3ebd39 100644 --- a/library/cpp/messagebus/remote_connection.cpp +++ b/library/cpp/messagebus/remote_connection.cpp @@ -1,19 +1,19 @@ -#include "remote_connection.h" +#include "remote_connection.h" #include "key_value_printer.h" -#include "mb_lwtrace.h" -#include "network.h" +#include "mb_lwtrace.h" +#include "network.h" #include "remote_client_connection.h" #include "remote_client_session.h" #include "remote_server_session.h" -#include "session_impl.h" +#include "session_impl.h" #include <library/cpp/messagebus/actor/what_thread_does.h> -#include <util/generic/cast.h> -#include <util/network/init.h> -#include <util/system/atomic.h> - +#include <util/generic/cast.h> +#include <util/network/init.h> +#include <util/system/atomic.h> + LWTRACE_USING(LWTRACE_MESSAGEBUS_PROVIDER) using namespace NActor; diff --git a/library/cpp/messagebus/remote_connection.h b/library/cpp/messagebus/remote_connection.h index 4538947368..91e343e171 100644 --- a/library/cpp/messagebus/remote_connection.h +++ b/library/cpp/messagebus/remote_connection.h @@ -1,18 +1,18 @@ #pragma once #include "async_result.h" -#include "defs.h" +#include "defs.h" #include "event_loop.h" -#include "left_right_buffer.h" -#include "lfqueue_batch.h" -#include "message_ptr_and_header.h" +#include "left_right_buffer.h" +#include "lfqueue_batch.h" +#include "message_ptr_and_header.h" #include "nondestroying_holder.h" #include "remote_connection_status.h" #include "scheduler_actor.h" #include "socket_addr.h" -#include "storage.h" +#include "storage.h" #include "vector_swaps.h" -#include "ybus.h" +#include "ybus.h" #include "misc/granup.h" #include "misc/tokenquota.h" @@ -21,11 +21,11 @@ #include <library/cpp/messagebus/actor/queue_for_actor.h> #include <library/cpp/messagebus/actor/queue_in_actor.h> #include <library/cpp/messagebus/scheduler/scheduler.h> - -#include <util/system/atomic.h> -#include <util/system/event.h> -#include <util/thread/lfstack.h> - + +#include <util/system/atomic.h> +#include <util/system/event.h> +#include <util/thread/lfstack.h> + namespace NBus { namespace NPrivate { class TRemoteConnection; diff --git a/library/cpp/messagebus/remote_connection_status.cpp b/library/cpp/messagebus/remote_connection_status.cpp index 2c48b2a287..a79fc01587 100644 --- a/library/cpp/messagebus/remote_connection_status.cpp +++ b/library/cpp/messagebus/remote_connection_status.cpp @@ -1,13 +1,13 @@ -#include "remote_connection_status.h" +#include "remote_connection_status.h" #include "key_value_printer.h" #include <library/cpp/messagebus/monitoring/mon_proto.pb.h> -#include <util/stream/format.h> -#include <util/stream/output.h> -#include <util/system/yassert.h> - +#include <util/stream/format.h> +#include <util/stream/output.h> +#include <util/system/yassert.h> + using namespace NBus; using namespace NBus::NPrivate; diff --git a/library/cpp/messagebus/remote_connection_status.h b/library/cpp/messagebus/remote_connection_status.h index 5db10e51ea..e3c725df5f 100644 --- a/library/cpp/messagebus/remote_connection_status.h +++ b/library/cpp/messagebus/remote_connection_status.h @@ -1,16 +1,16 @@ #pragma once #include "codegen.h" -#include "duration_histogram.h" -#include "message_counter.h" +#include "duration_histogram.h" +#include "message_counter.h" #include "message_status_counter.h" #include "queue_config.h" #include "session_config.h" #include <library/cpp/messagebus/actor/executor.h> - + #include <library/cpp/deprecated/enum_codegen/enum_codegen.h> - + namespace NBus { class TConnectionStatusMonRecord; } diff --git a/library/cpp/messagebus/remote_server_connection.cpp b/library/cpp/messagebus/remote_server_connection.cpp index 74be34ded9..a87ca51e42 100644 --- a/library/cpp/messagebus/remote_server_connection.cpp +++ b/library/cpp/messagebus/remote_server_connection.cpp @@ -1,9 +1,9 @@ #include "remote_server_connection.h" -#include "mb_lwtrace.h" +#include "mb_lwtrace.h" #include "remote_server_session.h" -#include <util/generic/cast.h> +#include <util/generic/cast.h> LWTRACE_USING(LWTRACE_MESSAGEBUS_PROVIDER) diff --git a/library/cpp/messagebus/remote_server_connection.h b/library/cpp/messagebus/remote_server_connection.h index 63d7f20646..c4f6dbf33d 100644 --- a/library/cpp/messagebus/remote_server_connection.h +++ b/library/cpp/messagebus/remote_server_connection.h @@ -1,7 +1,7 @@ #pragma once -#include "session_impl.h" - +#include "session_impl.h" + #include <util/generic/object_counter.h> namespace NBus { diff --git a/library/cpp/messagebus/remote_server_session.cpp b/library/cpp/messagebus/remote_server_session.cpp index 6abbf88a60..638e3b6f7b 100644 --- a/library/cpp/messagebus/remote_server_session.cpp +++ b/library/cpp/messagebus/remote_server_session.cpp @@ -1,15 +1,15 @@ -#include "remote_server_session.h" - -#include "remote_connection.h" -#include "remote_server_connection.h" +#include "remote_server_session.h" +#include "remote_connection.h" +#include "remote_server_connection.h" + #include <library/cpp/messagebus/actor/temp_tls_vector.h> - -#include <util/generic/cast.h> + +#include <util/generic/cast.h> #include <util/stream/output.h> #include <util/system/yassert.h> -#include <typeinfo> +#include <typeinfo> using namespace NActor; using namespace NBus; diff --git a/library/cpp/messagebus/remote_server_session_semaphore.cpp b/library/cpp/messagebus/remote_server_session_semaphore.cpp index 6094a3586e..99f1db1715 100644 --- a/library/cpp/messagebus/remote_server_session_semaphore.cpp +++ b/library/cpp/messagebus/remote_server_session_semaphore.cpp @@ -1,6 +1,6 @@ -#include "remote_server_session_semaphore.h" - -#include <util/stream/output.h> +#include "remote_server_session_semaphore.h" + +#include <util/stream/output.h> #include <util/system/yassert.h> using namespace NBus; diff --git a/library/cpp/messagebus/remote_server_session_semaphore.h b/library/cpp/messagebus/remote_server_session_semaphore.h index de714fd342..8673c10ef5 100644 --- a/library/cpp/messagebus/remote_server_session_semaphore.h +++ b/library/cpp/messagebus/remote_server_session_semaphore.h @@ -1,7 +1,7 @@ #pragma once -#include "cc_semaphore.h" - +#include "cc_semaphore.h" + #include <util/generic/noncopyable.h> namespace NBus { diff --git a/library/cpp/messagebus/scheduler/scheduler.h b/library/cpp/messagebus/scheduler/scheduler.h index afcc0de55d..c01d8f0b33 100644 --- a/library/cpp/messagebus/scheduler/scheduler.h +++ b/library/cpp/messagebus/scheduler/scheduler.h @@ -1,13 +1,13 @@ #pragma once #include <library/cpp/threading/future/legacy_future.h> - -#include <util/datetime/base.h> -#include <util/generic/object_counter.h> + +#include <util/datetime/base.h> +#include <util/generic/object_counter.h> #include <util/generic/ptr.h> #include <util/generic/vector.h> #include <util/system/atomic.h> -#include <util/system/condvar.h> +#include <util/system/condvar.h> #include <util/system/mutex.h> #include <util/system/thread.h> diff --git a/library/cpp/messagebus/scheduler_actor.h b/library/cpp/messagebus/scheduler_actor.h index d0c23c94c4..0fe005c82e 100644 --- a/library/cpp/messagebus/scheduler_actor.h +++ b/library/cpp/messagebus/scheduler_actor.h @@ -6,7 +6,7 @@ #include <library/cpp/messagebus/actor/what_thread_does_guard.h> #include <library/cpp/messagebus/scheduler/scheduler.h> -#include <util/system/mutex.h> +#include <util/system/mutex.h> namespace NBus { namespace NPrivate { diff --git a/library/cpp/messagebus/scheduler_actor_ut.cpp b/library/cpp/messagebus/scheduler_actor_ut.cpp index e81ffd3186..3136011e9c 100644 --- a/library/cpp/messagebus/scheduler_actor_ut.cpp +++ b/library/cpp/messagebus/scheduler_actor_ut.cpp @@ -1,6 +1,6 @@ #include <library/cpp/testing/unittest/registar.h> -#include "scheduler_actor.h" +#include "scheduler_actor.h" #include "misc/test_sync.h" using namespace NBus; diff --git a/library/cpp/messagebus/session.cpp b/library/cpp/messagebus/session.cpp index 46a7ece6a8..ff96320435 100644 --- a/library/cpp/messagebus/session.cpp +++ b/library/cpp/messagebus/session.cpp @@ -1,5 +1,5 @@ -#include "ybus.h" - +#include "ybus.h" + #include <util/generic/cast.h> using namespace NBus; diff --git a/library/cpp/messagebus/session.h b/library/cpp/messagebus/session.h index fb12ab7c22..f5a75615c1 100644 --- a/library/cpp/messagebus/session.h +++ b/library/cpp/messagebus/session.h @@ -1,19 +1,19 @@ #pragma once -#include "connection.h" +#include "connection.h" #include "defs.h" -#include "handler.h" +#include "handler.h" #include "message.h" #include "netaddr.h" -#include "network.h" +#include "network.h" #include "session_config.h" -#include "misc/weak_ptr.h" +#include "misc/weak_ptr.h" #include <library/cpp/messagebus/monitoring/mon_proto.pb.h> -#include <util/generic/array_ref.h> -#include <util/generic/ptr.h> - +#include <util/generic/array_ref.h> +#include <util/generic/ptr.h> + namespace NBus { template <typename TBusSessionSubclass> class TBusSessionPtr; diff --git a/library/cpp/messagebus/session_impl.cpp b/library/cpp/messagebus/session_impl.cpp index ddf9f360c4..29fa554630 100644 --- a/library/cpp/messagebus/session_impl.cpp +++ b/library/cpp/messagebus/session_impl.cpp @@ -1,15 +1,15 @@ -#include "session_impl.h" +#include "session_impl.h" -#include "acceptor.h" +#include "acceptor.h" #include "network.h" -#include "remote_client_connection.h" +#include "remote_client_connection.h" #include "remote_client_session.h" #include "remote_server_connection.h" -#include "remote_server_session.h" -#include "misc/weak_ptr.h" - -#include <util/generic/cast.h> +#include "remote_server_session.h" +#include "misc/weak_ptr.h" +#include <util/generic/cast.h> + using namespace NActor; using namespace NBus; using namespace NBus::NPrivate; diff --git a/library/cpp/messagebus/session_impl.h b/library/cpp/messagebus/session_impl.h index 90ef246ff8..3dcfedace6 100644 --- a/library/cpp/messagebus/session_impl.h +++ b/library/cpp/messagebus/session_impl.h @@ -1,24 +1,24 @@ #pragma once -#include "acceptor_status.h" -#include "async_result.h" -#include "event_loop.h" +#include "acceptor_status.h" +#include "async_result.h" +#include "event_loop.h" #include "netaddr.h" -#include "remote_connection.h" +#include "remote_connection.h" #include "remote_connection_status.h" #include "session_job_count.h" #include "shutdown_state.h" -#include "ybus.h" +#include "ybus.h" #include <library/cpp/messagebus/actor/actor.h> #include <library/cpp/messagebus/actor/queue_in_actor.h> #include <library/cpp/messagebus/monitoring/mon_proto.pb.h> #include <library/cpp/threading/future/legacy_future.h> - -#include <util/generic/array_ref.h> -#include <util/generic/string.h> - + +#include <util/generic/array_ref.h> +#include <util/generic/string.h> + namespace NBus { namespace NPrivate { typedef TIntrusivePtr<TRemoteClientConnection> TRemoteClientConnectionPtr; diff --git a/library/cpp/messagebus/session_job_count.cpp b/library/cpp/messagebus/session_job_count.cpp index 33322b1910..1068dd7a15 100644 --- a/library/cpp/messagebus/session_job_count.cpp +++ b/library/cpp/messagebus/session_job_count.cpp @@ -1,5 +1,5 @@ -#include "session_job_count.h" - +#include "session_job_count.h" + #include <util/system/yassert.h> using namespace NBus; diff --git a/library/cpp/messagebus/session_job_count.h b/library/cpp/messagebus/session_job_count.h index 23aca618b1..ef28c30cef 100644 --- a/library/cpp/messagebus/session_job_count.h +++ b/library/cpp/messagebus/session_job_count.h @@ -1,7 +1,7 @@ #pragma once #include <util/system/atomic.h> -#include <util/system/condvar.h> +#include <util/system/condvar.h> #include <util/system/mutex.h> namespace NBus { diff --git a/library/cpp/messagebus/shutdown_state.cpp b/library/cpp/messagebus/shutdown_state.cpp index a4e2bfa8b2..b4b2a19dce 100644 --- a/library/cpp/messagebus/shutdown_state.cpp +++ b/library/cpp/messagebus/shutdown_state.cpp @@ -1,5 +1,5 @@ -#include "shutdown_state.h" - +#include "shutdown_state.h" + #include <util/system/yassert.h> void TAtomicShutdownState::ShutdownCommand() { diff --git a/library/cpp/messagebus/shutdown_state.h b/library/cpp/messagebus/shutdown_state.h index 86bd7110ae..10104c1d9a 100644 --- a/library/cpp/messagebus/shutdown_state.h +++ b/library/cpp/messagebus/shutdown_state.h @@ -1,7 +1,7 @@ #pragma once -#include "misc/atomic_box.h" - +#include "misc/atomic_box.h" + #include <util/system/event.h> enum EShutdownState { diff --git a/library/cpp/messagebus/socket_addr.cpp b/library/cpp/messagebus/socket_addr.cpp index c1b3a28fbe..b82fa24ae3 100644 --- a/library/cpp/messagebus/socket_addr.cpp +++ b/library/cpp/messagebus/socket_addr.cpp @@ -1,10 +1,10 @@ -#include "socket_addr.h" +#include "socket_addr.h" #include "netaddr.h" -#include <util/network/address.h> -#include <util/network/init.h> -#include <util/system/yassert.h> +#include <util/network/address.h> +#include <util/network/init.h> +#include <util/system/yassert.h> using namespace NAddr; diff --git a/library/cpp/messagebus/socket_addr.h b/library/cpp/messagebus/socket_addr.h index 959eafe689..98b157c3d1 100644 --- a/library/cpp/messagebus/socket_addr.h +++ b/library/cpp/messagebus/socket_addr.h @@ -1,13 +1,13 @@ #pragma once -#include "hash.h" +#include "hash.h" #include <util/generic/hash.h> -#include <util/generic/utility.h> +#include <util/generic/utility.h> #include <util/network/address.h> -#include <util/network/init.h> +#include <util/network/init.h> -#include <string.h> +#include <string.h> namespace NBus { class TNetAddr; diff --git a/library/cpp/messagebus/socket_addr_ut.cpp b/library/cpp/messagebus/socket_addr_ut.cpp index 783bb62a86..606b33fa2b 100644 --- a/library/cpp/messagebus/socket_addr_ut.cpp +++ b/library/cpp/messagebus/socket_addr_ut.cpp @@ -1,10 +1,10 @@ #include <library/cpp/testing/unittest/registar.h> -#include "netaddr.h" +#include "netaddr.h" #include "socket_addr.h" -#include <util/string/cast.h> - +#include <util/string/cast.h> + using namespace NBus; using namespace NBus::NPrivate; diff --git a/library/cpp/messagebus/storage.cpp b/library/cpp/messagebus/storage.cpp index efefc87340..1b856c7d61 100644 --- a/library/cpp/messagebus/storage.cpp +++ b/library/cpp/messagebus/storage.cpp @@ -1,5 +1,5 @@ -#include "storage.h" - +#include "storage.h" + #include <typeinfo> namespace NBus { diff --git a/library/cpp/messagebus/storage.h b/library/cpp/messagebus/storage.h index 7d168844ed..8fc2362ee6 100644 --- a/library/cpp/messagebus/storage.h +++ b/library/cpp/messagebus/storage.h @@ -1,12 +1,12 @@ #pragma once -#include "message_ptr_and_header.h" -#include "moved.h" -#include "ybus.h" - -#include <contrib/libs/sparsehash/src/sparsehash/dense_hash_map> - -#include <util/generic/deque.h> +#include "message_ptr_and_header.h" +#include "moved.h" +#include "ybus.h" + +#include <contrib/libs/sparsehash/src/sparsehash/dense_hash_map> + +#include <util/generic/deque.h> #include <util/generic/noncopyable.h> #include <util/generic/utility.h> diff --git a/library/cpp/messagebus/synchandler.cpp b/library/cpp/messagebus/synchandler.cpp index 8e891d66b3..c965259740 100644 --- a/library/cpp/messagebus/synchandler.cpp +++ b/library/cpp/messagebus/synchandler.cpp @@ -1,6 +1,6 @@ #include "remote_client_session.h" #include "remote_connection.h" -#include "ybus.h" +#include "ybus.h" using namespace NBus; using namespace NBus::NPrivate; diff --git a/library/cpp/messagebus/test/example/client/client.cpp b/library/cpp/messagebus/test/example/client/client.cpp index 89b5f2c9be..05bafa9a82 100644 --- a/library/cpp/messagebus/test/example/client/client.cpp +++ b/library/cpp/messagebus/test/example/client/client.cpp @@ -1,5 +1,5 @@ #include <library/cpp/messagebus/test/example/common/proto.h> - + #include <util/random/random.h> using namespace NBus; diff --git a/library/cpp/messagebus/test/example/common/proto.h b/library/cpp/messagebus/test/example/common/proto.h index a151aac468..9a9a730312 100644 --- a/library/cpp/messagebus/test/example/common/proto.h +++ b/library/cpp/messagebus/test/example/common/proto.h @@ -4,7 +4,7 @@ #include <library/cpp/messagebus/ybus.h> #include <library/cpp/messagebus/protobuf/ybusbuf.h> - + namespace NCalculator { typedef ::NBus::TBusBufferMessage<TRequestSumRecord, 1> TRequestSum; typedef ::NBus::TBusBufferMessage<TRequestMulRecord, 2> TRequestMul; diff --git a/library/cpp/messagebus/test/helper/example.cpp b/library/cpp/messagebus/test/helper/example.cpp index 7c6d704042..f3c956bf83 100644 --- a/library/cpp/messagebus/test/helper/example.cpp +++ b/library/cpp/messagebus/test/helper/example.cpp @@ -1,7 +1,7 @@ #include <library/cpp/testing/unittest/registar.h> -#include "example.h" - +#include "example.h" + #include <util/generic/cast.h> using namespace NBus; diff --git a/library/cpp/messagebus/test/helper/example.h b/library/cpp/messagebus/test/helper/example.h index 26b7475308..1566b3c539 100644 --- a/library/cpp/messagebus/test/helper/example.h +++ b/library/cpp/messagebus/test/helper/example.h @@ -7,9 +7,9 @@ #include <library/cpp/messagebus/ybus.h> #include <library/cpp/messagebus/misc/test_sync.h> - -#include <util/system/event.h> - + +#include <util/system/event.h> + namespace NBus { namespace NTest { class TExampleRequest: public TBusMessage { diff --git a/library/cpp/messagebus/test/helper/example_module.h b/library/cpp/messagebus/test/helper/example_module.h index a0b295f613..03d2f92cb4 100644 --- a/library/cpp/messagebus/test/helper/example_module.h +++ b/library/cpp/messagebus/test/helper/example_module.h @@ -3,7 +3,7 @@ #include "example.h" #include <library/cpp/messagebus/oldmodule/module.h> - + namespace NBus { namespace NTest { struct TExampleModule: public TBusModule { diff --git a/library/cpp/messagebus/test/helper/fixed_port.cpp b/library/cpp/messagebus/test/helper/fixed_port.cpp index 258da0d1a5..95d8039bbd 100644 --- a/library/cpp/messagebus/test/helper/fixed_port.cpp +++ b/library/cpp/messagebus/test/helper/fixed_port.cpp @@ -1,8 +1,8 @@ -#include "fixed_port.h" - +#include "fixed_port.h" + #include <util/system/env.h> -#include <stdlib.h> +#include <stdlib.h> bool NBus::NTest::IsFixedPortTestAllowed() { // TODO: report skipped tests to test diff --git a/library/cpp/messagebus/test/helper/hanging_server.cpp b/library/cpp/messagebus/test/helper/hanging_server.cpp index a35514b00d..673489bf61 100644 --- a/library/cpp/messagebus/test/helper/hanging_server.cpp +++ b/library/cpp/messagebus/test/helper/hanging_server.cpp @@ -1,5 +1,5 @@ -#include "hanging_server.h" - +#include "hanging_server.h" + #include <util/system/yassert.h> using namespace NBus; diff --git a/library/cpp/messagebus/test/helper/hanging_server.h b/library/cpp/messagebus/test/helper/hanging_server.h index cc9fb274d8..59f5753f5a 100644 --- a/library/cpp/messagebus/test/helper/hanging_server.h +++ b/library/cpp/messagebus/test/helper/hanging_server.h @@ -1,7 +1,7 @@ #pragma once #include <library/cpp/messagebus/network.h> - + #include <util/network/sock.h> class THangingServer { diff --git a/library/cpp/messagebus/test/helper/message_handler_error.cpp b/library/cpp/messagebus/test/helper/message_handler_error.cpp index c09811ec67..ce0c0c5c74 100644 --- a/library/cpp/messagebus/test/helper/message_handler_error.cpp +++ b/library/cpp/messagebus/test/helper/message_handler_error.cpp @@ -1,5 +1,5 @@ -#include "message_handler_error.h" - +#include "message_handler_error.h" + #include <util/system/yassert.h> using namespace NBus; diff --git a/library/cpp/messagebus/test/helper/object_count_check.h b/library/cpp/messagebus/test/helper/object_count_check.h index 1c4756e58c..cd54d9547b 100644 --- a/library/cpp/messagebus/test/helper/object_count_check.h +++ b/library/cpp/messagebus/test/helper/object_count_check.h @@ -12,10 +12,10 @@ #include <util/generic/object_counter.h> #include <util/system/type_name.h> -#include <util/stream/output.h> - -#include <typeinfo> +#include <util/stream/output.h> +#include <typeinfo> + struct TObjectCountCheck { bool Enabled; diff --git a/library/cpp/messagebus/test/perftest/perftest.cpp b/library/cpp/messagebus/test/perftest/perftest.cpp index 8489319278..b66725049a 100644 --- a/library/cpp/messagebus/test/perftest/perftest.cpp +++ b/library/cpp/messagebus/test/perftest/perftest.cpp @@ -8,7 +8,7 @@ #include <library/cpp/messagebus/oldmodule/module.h> #include <library/cpp/messagebus/protobuf/ybusbuf.h> #include <library/cpp/messagebus/www/www.h> - + #include <library/cpp/deprecated/threadable/threadable.h> #include <library/cpp/execprofile/profile.h> #include <library/cpp/getopt/opt.h> diff --git a/library/cpp/messagebus/test/perftest/simple_proto.cpp b/library/cpp/messagebus/test/perftest/simple_proto.cpp index 19d6c15b9d..601aa50a79 100644 --- a/library/cpp/messagebus/test/perftest/simple_proto.cpp +++ b/library/cpp/messagebus/test/perftest/simple_proto.cpp @@ -1,8 +1,8 @@ -#include "simple_proto.h" +#include "simple_proto.h" #include <util/generic/cast.h> -#include <typeinfo> +#include <typeinfo> using namespace NBus; diff --git a/library/cpp/messagebus/test/ut/locator_uniq_ut.cpp b/library/cpp/messagebus/test/ut/locator_uniq_ut.cpp index 3fdd175d73..058e164559 100644 --- a/library/cpp/messagebus/test/ut/locator_uniq_ut.cpp +++ b/library/cpp/messagebus/test/ut/locator_uniq_ut.cpp @@ -2,7 +2,7 @@ #include <library/cpp/messagebus/test_utils.h> #include <library/cpp/messagebus/ybus.h> - + class TLocatorRegisterUniqTest: public TTestBase { UNIT_TEST_SUITE(TLocatorRegisterUniqTest); UNIT_TEST(TestRegister); diff --git a/library/cpp/messagebus/test/ut/module_client_one_way_ut.cpp b/library/cpp/messagebus/test/ut/module_client_one_way_ut.cpp index 4083cf3b7b..848bc332f8 100644 --- a/library/cpp/messagebus/test/ut/module_client_one_way_ut.cpp +++ b/library/cpp/messagebus/test/ut/module_client_one_way_ut.cpp @@ -5,7 +5,7 @@ #include <library/cpp/messagebus/misc/test_sync.h> #include <library/cpp/messagebus/oldmodule/module.h> - + using namespace NBus; using namespace NBus::NTest; diff --git a/library/cpp/messagebus/test/ut/module_client_ut.cpp b/library/cpp/messagebus/test/ut/module_client_ut.cpp index ebfe185cc6..cf3c7befc7 100644 --- a/library/cpp/messagebus/test/ut/module_client_ut.cpp +++ b/library/cpp/messagebus/test/ut/module_client_ut.cpp @@ -1,6 +1,6 @@ #include <library/cpp/testing/unittest/registar.h> -#include "count_down_latch.h" +#include "count_down_latch.h" #include "moduletest.h" #include <library/cpp/messagebus/test/helper/example.h> @@ -10,10 +10,10 @@ #include <library/cpp/messagebus/misc/test_sync.h> #include <library/cpp/messagebus/oldmodule/module.h> - -#include <util/generic/cast.h> -#include <util/system/event.h> - + +#include <util/generic/cast.h> +#include <util/system/event.h> + using namespace NBus; using namespace NBus::NTest; diff --git a/library/cpp/messagebus/test/ut/module_server_ut.cpp b/library/cpp/messagebus/test/ut/module_server_ut.cpp index 88fe1dd9b6..009bd7d489 100644 --- a/library/cpp/messagebus/test/ut/module_server_ut.cpp +++ b/library/cpp/messagebus/test/ut/module_server_ut.cpp @@ -1,17 +1,17 @@ #include <library/cpp/testing/unittest/registar.h> -#include "count_down_latch.h" +#include "count_down_latch.h" #include "moduletest.h" #include <library/cpp/messagebus/test/helper/example.h> #include <library/cpp/messagebus/test/helper/example_module.h> #include <library/cpp/messagebus/test/helper/object_count_check.h> #include <library/cpp/messagebus/test/helper/wait_for.h> - + #include <library/cpp/messagebus/oldmodule/module.h> - -#include <util/generic/cast.h> - + +#include <util/generic/cast.h> + using namespace NBus; using namespace NBus::NTest; diff --git a/library/cpp/messagebus/use_after_free_checker.cpp b/library/cpp/messagebus/use_after_free_checker.cpp index 4904e7c614..aecf1ac447 100644 --- a/library/cpp/messagebus/use_after_free_checker.cpp +++ b/library/cpp/messagebus/use_after_free_checker.cpp @@ -1,5 +1,5 @@ -#include "use_after_free_checker.h" - +#include "use_after_free_checker.h" + #include <util/system/yassert.h> namespace { diff --git a/library/cpp/messagebus/use_after_free_checker.h b/library/cpp/messagebus/use_after_free_checker.h index 590b076156..92856e00f8 100644 --- a/library/cpp/messagebus/use_after_free_checker.h +++ b/library/cpp/messagebus/use_after_free_checker.h @@ -1,7 +1,7 @@ #pragma once #include <util/system/platform.h> -#include <util/system/types.h> +#include <util/system/types.h> class TUseAfterFreeChecker { private: diff --git a/library/cpp/messagebus/use_count_checker.cpp b/library/cpp/messagebus/use_count_checker.cpp index c6243ea21f..acc35a5a02 100644 --- a/library/cpp/messagebus/use_count_checker.cpp +++ b/library/cpp/messagebus/use_count_checker.cpp @@ -1,6 +1,6 @@ -#include "use_count_checker.h" - -#include <util/generic/utility.h> +#include "use_count_checker.h" + +#include <util/generic/utility.h> #include <util/system/yassert.h> TUseCountChecker::TUseCountChecker() { diff --git a/library/cpp/messagebus/vector_swaps.h b/library/cpp/messagebus/vector_swaps.h index b920bcf03e..f6eb6b7801 100644 --- a/library/cpp/messagebus/vector_swaps.h +++ b/library/cpp/messagebus/vector_swaps.h @@ -2,11 +2,11 @@ #include <util/generic/array_ref.h> #include <util/generic/noncopyable.h> -#include <util/generic/utility.h> +#include <util/generic/utility.h> #include <util/system/yassert.h> -#include <stdlib.h> - +#include <stdlib.h> + template <typename T, class A = std::allocator<T>> class TVectorSwaps : TNonCopyable { private: diff --git a/library/cpp/messagebus/www/html_output.h b/library/cpp/messagebus/www/html_output.h index 27e77adefa..6dbd24687f 100644 --- a/library/cpp/messagebus/www/html_output.h +++ b/library/cpp/messagebus/www/html_output.h @@ -1,8 +1,8 @@ #pragma once -#include "concat_strings.h" - -#include <util/generic/string.h> +#include "concat_strings.h" + +#include <util/generic/string.h> #include <util/stream/output.h> #include <library/cpp/html/pcdata/pcdata.h> #include <util/system/tls.h> diff --git a/library/cpp/messagebus/www/www.cpp b/library/cpp/messagebus/www/www.cpp index 62ec241d85..85d5e13cd8 100644 --- a/library/cpp/messagebus/www/www.cpp +++ b/library/cpp/messagebus/www/www.cpp @@ -1,11 +1,11 @@ -#include "www.h" +#include "www.h" -#include "concat_strings.h" -#include "html_output.h" +#include "concat_strings.h" +#include "html_output.h" #include <library/cpp/messagebus/remote_connection_status.h> #include <library/cpp/monlib/deprecated/json/writer.h> - + #include <library/cpp/archive/yarchive.h> #include <library/cpp/http/fetch/httpfsm.h> #include <library/cpp/http/fetch/httpheader.h> @@ -13,11 +13,11 @@ #include <library/cpp/json/writer/json.h> #include <library/cpp/uri/http_url.h> -#include <util/string/cast.h> -#include <util/string/printf.h> -#include <util/system/mutex.h> +#include <util/string/cast.h> +#include <util/string/printf.h> +#include <util/system/mutex.h> -#include <utility> +#include <utility> using namespace NBus; using namespace NBus::NPrivate; diff --git a/library/cpp/messagebus/www/www.h b/library/cpp/messagebus/www/www.h index 6cd652b477..ee1f629447 100644 --- a/library/cpp/messagebus/www/www.h +++ b/library/cpp/messagebus/www/www.h @@ -2,8 +2,8 @@ #include <library/cpp/messagebus/ybus.h> #include <library/cpp/messagebus/oldmodule/module.h> - -#include <util/generic/ptr.h> + +#include <util/generic/ptr.h> #include <util/generic/string.h> #include <library/cpp/cgiparam/cgiparam.h> diff --git a/library/cpp/messagebus/ybus.h b/library/cpp/messagebus/ybus.h index de21ad8521..c2fe735f26 100644 --- a/library/cpp/messagebus/ybus.h +++ b/library/cpp/messagebus/ybus.h @@ -8,30 +8,30 @@ #include "handler.h" #include "handler_impl.h" #include "local_flags.h" -#include "locator.h" +#include "locator.h" #include "message.h" -#include "message_status.h" -#include "network.h" -#include "queue_config.h" -#include "remote_connection_status.h" +#include "message_status.h" +#include "network.h" +#include "queue_config.h" +#include "remote_connection_status.h" #include "session.h" -#include "session_config.h" -#include "socket_addr.h" +#include "session_config.h" +#include "socket_addr.h" #include <library/cpp/messagebus/actor/executor.h> #include <library/cpp/messagebus/scheduler/scheduler.h> - + #include <library/cpp/codecs/codecs.h> - -#include <util/generic/array_ref.h> + +#include <util/generic/array_ref.h> #include <util/generic/buffer.h> #include <util/generic/noncopyable.h> -#include <util/generic/ptr.h> +#include <util/generic/ptr.h> #include <util/stream/input.h> #include <util/system/atomic.h> #include <util/system/condvar.h> #include <util/system/type_name.h> -#include <util/system/event.h> +#include <util/system/event.h> #include <util/system/mutex.h> namespace NBus { diff --git a/library/cpp/threading/future/core/future-inl.h b/library/cpp/threading/future/core/future-inl.h index 5fd4296a93..7f44059a01 100644 --- a/library/cpp/threading/future/core/future-inl.h +++ b/library/cpp/threading/future/core/future-inl.h @@ -167,20 +167,20 @@ namespace NThreading { } void SetException(std::exception_ptr e) { - bool success = TrySetException(std::move(e)); - if (Y_UNLIKELY(!success)) { - ythrow TFutureException() << "value already set"; - } - } - - bool TrySetException(std::exception_ptr e) { + bool success = TrySetException(std::move(e)); + if (Y_UNLIKELY(!success)) { + ythrow TFutureException() << "value already set"; + } + } + + bool TrySetException(std::exception_ptr e) { TSystemEvent* readyEvent; TCallbackList<T> callbacks; with_lock (StateLock) { int state = AtomicGet(State); if (Y_UNLIKELY(state != NotReady)) { - return false; + return false; } Exception = std::move(e); @@ -201,8 +201,8 @@ namespace NThreading { callback(temp); } } - - return true; + + return true; } template <typename F> @@ -353,20 +353,20 @@ namespace NThreading { } void SetException(std::exception_ptr e) { - bool success = TrySetException(std::move(e)); - if (Y_UNLIKELY(!success)) { - ythrow TFutureException() << "value already set"; - } - } - - bool TrySetException(std::exception_ptr e) { + bool success = TrySetException(std::move(e)); + if (Y_UNLIKELY(!success)) { + ythrow TFutureException() << "value already set"; + } + } + + bool TrySetException(std::exception_ptr e) { TSystemEvent* readyEvent = nullptr; TCallbackList<void> callbacks; with_lock (StateLock) { int state = AtomicGet(State); if (Y_UNLIKELY(state != NotReady)) { - return false; + return false; } Exception = std::move(e); @@ -387,8 +387,8 @@ namespace NThreading { callback(temp); } } - - return true; + + return true; } template <typename F> @@ -834,12 +834,12 @@ namespace NThreading { } template <typename T> - inline bool TPromise<T>::TrySetException(std::exception_ptr e) { - EnsureInitialized(); - return State->TrySetException(std::move(e)); - } - - template <typename T> + inline bool TPromise<T>::TrySetException(std::exception_ptr e) { + EnsureInitialized(); + return State->TrySetException(std::move(e)); + } + + template <typename T> inline TFuture<T> TPromise<T>::GetFuture() const { EnsureInitialized(); return TFuture<T>(State); @@ -912,11 +912,11 @@ namespace NThreading { State->SetException(std::move(e)); } - inline bool TPromise<void>::TrySetException(std::exception_ptr e) { - EnsureInitialized(); - return State->TrySetException(std::move(e)); - } - + inline bool TPromise<void>::TrySetException(std::exception_ptr e) { + EnsureInitialized(); + return State->TrySetException(std::move(e)); + } + inline TFuture<void> TPromise<void>::GetFuture() const { EnsureInitialized(); return TFuture<void>(State); diff --git a/library/cpp/threading/future/core/future.h b/library/cpp/threading/future/core/future.h index 2e82bb953e..a4a1012352 100644 --- a/library/cpp/threading/future/core/future.h +++ b/library/cpp/threading/future/core/future.h @@ -216,7 +216,7 @@ namespace NThreading { bool HasException() const; void SetException(const TString& e); void SetException(std::exception_ptr e); - bool TrySetException(std::exception_ptr e); + bool TrySetException(std::exception_ptr e); TFuture<T> GetFuture() const; operator TFuture<T>() const; @@ -256,7 +256,7 @@ namespace NThreading { bool HasException() const; void SetException(const TString& e); void SetException(std::exception_ptr e); - bool TrySetException(std::exception_ptr e); + bool TrySetException(std::exception_ptr e); TFuture<void> GetFuture() const; operator TFuture<void>() const; diff --git a/library/cpp/threading/future/future_ut.cpp b/library/cpp/threading/future/future_ut.cpp index 05950a568d..63fb4604be 100644 --- a/library/cpp/threading/future/future_ut.cpp +++ b/library/cpp/threading/future/future_ut.cpp @@ -507,18 +507,18 @@ namespace { UNIT_ASSERT(!promise.TrySetValue(42)); } - Y_UNIT_TEST(HandlingRepetitiveSetException) { - TPromise<int> promise = NewPromise<int>(); - promise.SetException("test"); - UNIT_CHECK_GENERATED_EXCEPTION(promise.SetException("test"), TFutureException); - } - - Y_UNIT_TEST(HandlingRepetitiveTrySetException) { - TPromise<int> promise = NewPromise<int>(); - UNIT_ASSERT(promise.TrySetException(std::make_exception_ptr("test"))); - UNIT_ASSERT(!promise.TrySetException(std::make_exception_ptr("test"))); - } - + Y_UNIT_TEST(HandlingRepetitiveSetException) { + TPromise<int> promise = NewPromise<int>(); + promise.SetException("test"); + UNIT_CHECK_GENERATED_EXCEPTION(promise.SetException("test"), TFutureException); + } + + Y_UNIT_TEST(HandlingRepetitiveTrySetException) { + TPromise<int> promise = NewPromise<int>(); + UNIT_ASSERT(promise.TrySetException(std::make_exception_ptr("test"))); + UNIT_ASSERT(!promise.TrySetException(std::make_exception_ptr("test"))); + } + Y_UNIT_TEST(ShouldAllowToMakeFutureWithException) { auto future1 = MakeErrorFuture<void>(std::make_exception_ptr(TFutureException())); diff --git a/library/cpp/ya.make b/library/cpp/ya.make index 8c1193b007..6a7bd206bd 100644 --- a/library/cpp/ya.make +++ b/library/cpp/ya.make @@ -1,6 +1,6 @@ -OWNER(g:cpp-contrib) - -RECURSE( +OWNER(g:cpp-contrib) + +RECURSE( accurate_accumulate accurate_accumulate/benchmark accurate_accumulate/benchmark/metrics @@ -417,8 +417,8 @@ RECURSE( yson_pull yson_pull/ut yt - zipatch -) + zipatch +) IF (OS_LINUX) RECURSE( @@ -437,7 +437,7 @@ IF (OS_WINDOWS) ) ELSE() RECURSE( - fuse + fuse sse/ut tf xdelta3 |