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 | 778e51ba091dc39e7b7fcab2b9cf4dbedfb6f2b5 (patch) | |
| tree | be835aa92c6248212e705f25388ebafcf84bc7a1 /library/cpp | |
| parent | 194cae0e8855b11be2005e1eff12c660c3ee9774 (diff) | |
| download | ydb-778e51ba091dc39e7b7fcab2b9cf4dbedfb6f2b5.tar.gz | |
Restoring authorship annotation for <kikht@yandex-team.ru>. Commit 2 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 c5231e42d3..6dc997076d 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 87601ae3d6..329872cfde 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 f8793e0b61..7ae6f74051 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 0c1258e3b1..61164fa56b 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 6669512b5b..64a38619c2 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 0eeb162aea..57cb010bf2 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 6c481bfb6f..5006ff68ae 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 c799eee6a7..6aa1404f4d 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 6d6b394a51..9b8f20298a 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 4329aabd77..b76ab55bfa 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 b6d33c7c0e..7a2227a458 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 538b2196f0..7292d8be53 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 df6b53557d..9865996532 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 6346756d85..ec5706f7c7 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 b0dd1bb933..bdb379b3a9 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 325d8bb397..f0b7cd90e4 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 9df0453931..31d35931d2 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 1860f544ff..675d92f5b0 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 bce931ff1d..048480f255 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 bda58de407..bebb6a888c 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 12efbfc89e..e4b218a7ca 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 dc7281e02f..d24dde284a 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 b534dbde7b..206bb7c96a 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 c27ea26b77..92b1df9969 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 4e189ccfde..962ac538e2 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 2d43cc014b..b79c0cc355 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 9b6796d36b..07580ce18a 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 ae2107b251..b1df64ddc1 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 470b8fa102..d9411bb5db 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 ddc783aa9d..fca228d82e 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 87ef125bd8..beb6850f26 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 131476182c..05f99e94ca 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 ebefee7918..32a0001d41 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 93a5c5d992..ed060b0101 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 f8462cc8d4..f685135bed 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 6fc2c1837b..d5b0a53b0c 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 5171806e74..31d60c60f1 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 1cef09d63d..333bd52934 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 3c8496d6a3..60002c68a6 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 70fb02e575..6593f04cc3 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 5c2567e495..c8592145c7 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 6ee63a30fa..bca1fde50e 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 7e01f2d035..373f4c0e13 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 fc92d6917c..f937cefad0 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 aa67b6ae40..8128d3154d 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 ad0a30e232..877e533f76 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 fc3f126443..f589283188 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 7ca49fda3f..e38a35c426 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 39ca346748..f8556a3fce 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 1bd0096654..c54cd5ab71 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 465e630c4b..e62728b265 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 01e3b5440b..bfa7ed8e9b 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 783cbeeb94..005ca10c65 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 29f567b355..04d9343f6a 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 0a1e094824..e4be1180b0 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 dea9af70a5..9b4e2fd270 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 cf9816be1a..e1878960b3 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 d69ba3fdcb..891c8f5bb2 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 b3be955ab5..e8ba2fdd31 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 eb6923f1bb..9598651329 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 5f9bae04e8..3474d62705 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 "ybus.h" + +#include <util/generic/singleton.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 ac4a602cc1..401621f933 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 ec8648711f..36ecfebc93 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 2752f79ac9..be3f4f20b8 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 6554d160d7..304bedae5a 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 a3a8b6e7e6..cc4bd76ea3 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 9fe8dc7620..f1798419db 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 6b8ec2b2a6..24bd778799 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 df79bfcbd9..8d1c4a5d52 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 787952affe..7c38801d62 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 87c2f47982..5e26e7e1e5 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 4d1433164e..63415b3737 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 48f2f0ebc9..57b4267ea5 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 a133fe8a9f..500841dd5b 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 31e820b030..83b984ca6e 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 26e2d00724..61a33584a5 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 a8bcecd18c..f6dd7fceb6 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 cd651a390f..0f289717a2 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 df0fa14379..d4545e05aa 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 012586f4b1..f5d0b4cac9 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 71d3ba2cee..1a7a1f8674 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 5c7d0bb85b..2ae85a87b1 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 cb15157a0d..f2b146bf29 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 f4d538d101..ba5a5e41cf 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 f89a69e9ff..a098437d53 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 bf669a11f5..7d8778bcda 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 6277c807bc..d387de7574 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 3caee731dd..05f7de1319 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 d2e36093dc..5ef5ceeece 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 689718b65e..d4199c4c98 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 0a39c6b1b1..1628114391 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 2b02c17435..51d75762f6 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 43f860b731..33b565fa1c 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 6d9144cf3e..0a291cdea6 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 05d2d6e02f..1b3618558b 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 88995e36f8..5d4b13d664 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 68060e62e7..7c11399f1b 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 0fe3700b96..c0fcb27252 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 980b6b2abf..22edbd8c6b 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 e91470d3a3..724f6b7530 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 051618afe0..8c7a6db3a8 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 557cc2e03d..fe80b7d2f9 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 b2f98a19f2..3bc421944f 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 9758235195..7160d0dae9 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 c5601e5511..f877ed4257 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 c3850d7d90..286ca3c86f 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 18cb3ebd39..22932569db 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 91e343e171..4538947368 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 a79fc01587..2c48b2a287 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 e3c725df5f..5db10e51ea 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 a87ca51e42..74be34ded9 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 c4f6dbf33d..63d7f20646 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 638e3b6f7b..6abbf88a60 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_server_session.h" + +#include "remote_connection.h" +#include "remote_server_connection.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 99f1db1715..6094a3586e 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 8673c10ef5..de714fd342 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 c01d8f0b33..afcc0de55d 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 0fe005c82e..d0c23c94c4 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 3136011e9c..e81ffd3186 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 ff96320435..46a7ece6a8 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 f5a75615c1..fb12ab7c22 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 29fa554630..ddf9f360c4 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 "remote_server_session.h" +#include "misc/weak_ptr.h" + +#include <util/generic/cast.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 3dcfedace6..90ef246ff8 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 1068dd7a15..33322b1910 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 ef28c30cef..23aca618b1 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 b4b2a19dce..a4e2bfa8b2 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 10104c1d9a..86bd7110ae 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 b82fa24ae3..c1b3a28fbe 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 98b157c3d1..959eafe689 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 606b33fa2b..783bb62a86 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 1b856c7d61..efefc87340 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 8fc2362ee6..7d168844ed 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 c965259740..8e891d66b3 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 05bafa9a82..89b5f2c9be 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 9a9a730312..a151aac468 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 f3c956bf83..7c6d704042 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 1566b3c539..26b7475308 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 03d2f92cb4..a0b295f613 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 95d8039bbd..258da0d1a5 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 673489bf61..a35514b00d 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 59f5753f5a..cc9fb274d8 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 ce0c0c5c74..c09811ec67 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 cd54d9547b..1c4756e58c 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 <util/stream/output.h> + +#include <typeinfo> -#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 b66725049a..8489319278 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 601aa50a79..19d6c15b9d 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 058e164559..3fdd175d73 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 848bc332f8..4083cf3b7b 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 cf3c7befc7..ebfe185cc6 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 009bd7d489..88fe1dd9b6 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 aecf1ac447..4904e7c614 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 92856e00f8..590b076156 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 acc35a5a02..c6243ea21f 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 f6eb6b7801..b920bcf03e 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 6dbd24687f..27e77adefa 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 85d5e13cd8..62ec241d85 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 ee1f629447..6cd652b477 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 c2fe735f26..de21ad8521 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 7f44059a01..5fd4296a93 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 a4a1012352..2e82bb953e 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 63fb4604be..05950a568d 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 6a7bd206bd..8c1193b007 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 |