Restoring authorship annotation for <yazevnul@yandex-team.ru>. Commit 1 of 2.

25 files changed, 118 insertions, 118 deletions

diff --git a/library/cpp/actors/core/actor_coroutine_ut.cpp b/library/cpp/actors/core/actor_coroutine_ut.cpp
index 951512b877..cbbb332635 100644
--- a/library/cpp/actors/core/actor_coroutine_ut.cpp
+++ b/library/cpp/actors/core/actor_coroutine_ut.cpp
@@ -11,7 +11,7 @@
 
 using namespace NActors;
 
-Y_UNIT_TEST_SUITE(ActorCoro) {
+Y_UNIT_TEST_SUITE(ActorCoro) { 
     enum {
         Begin = EventSpaceBegin(TEvents::ES_USERSPACE),
         Request,
@@ -127,7 +127,7 @@ Y_UNIT_TEST_SUITE(ActorCoro) {
         actorSystem.Stop();
     }
 
-    Y_UNIT_TEST(Basic) {
+    Y_UNIT_TEST(Basic) { 
         if (NSan::TSanIsOn()) {
             // TODO https://st.yandex-team.ru/DEVTOOLS-3154
             return;
@@ -135,7 +135,7 @@ Y_UNIT_TEST_SUITE(ActorCoro) {
         Check(MakeHolder<TEvEnough>());
     }
 
-    Y_UNIT_TEST(PoisonPill) {
+    Y_UNIT_TEST(PoisonPill) { 
         Check(MakeHolder<TEvents::TEvPoisonPill>());
     }
 }
diff --git a/library/cpp/actors/core/actorid.h b/library/cpp/actors/core/actorid.h
index d972b1a0ff..4b35790ab8 100644
--- a/library/cpp/actors/core/actorid.h
+++ b/library/cpp/actors/core/actorid.h
@@ -1,7 +1,7 @@
 #pragma once
 
 #include "defs.h"
-#include <util/stream/output.h> // for IOutputStream
+#include <util/stream/output.h> // for IOutputStream 
 #include <util/generic/hash.h>
 
 namespace NActors {
@@ -175,7 +175,7 @@ namespace NActors {
         };
 
         TString ToString() const;
-        void Out(IOutputStream& o) const;
+        void Out(IOutputStream& o) const; 
         bool Parse(const char* buf, ui32 sz);
     };
 
diff --git a/library/cpp/actors/core/callstack.cpp b/library/cpp/actors/core/callstack.cpp
index 9297c1a079..2819999aa2 100644
--- a/library/cpp/actors/core/callstack.cpp
+++ b/library/cpp/actors/core/callstack.cpp
@@ -5,11 +5,11 @@
 
 namespace NActors {
     namespace {
-        void (*PreviousFormatBackTrace)(IOutputStream*) = 0;
+        void (*PreviousFormatBackTrace)(IOutputStream*) = 0; 
         ui32 ActorBackTraceEnableCounter = 0;
     }
 
-    void ActorFormatBackTrace(IOutputStream* out) {
+    void ActorFormatBackTrace(IOutputStream* out) { 
         TStringStream str;
         PreviousFormatBackTrace(&str);
         str << Endl;
diff --git a/library/cpp/actors/core/event_pb_ut.cpp b/library/cpp/actors/core/event_pb_ut.cpp
index a16c3092b3..56f5adb401 100644
--- a/library/cpp/actors/core/event_pb_ut.cpp
+++ b/library/cpp/actors/core/event_pb_ut.cpp
@@ -3,7 +3,7 @@
 #include <library/cpp/testing/unittest/registar.h>
 #include <library/cpp/actors/protos/unittests.pb.h>
 
-Y_UNIT_TEST_SUITE(TEventSerialization) {
+Y_UNIT_TEST_SUITE(TEventSerialization) { 
     struct TMockEvent: public NActors::IEventBase {
         TBigMessage* msg;
         bool
@@ -24,7 +24,7 @@ Y_UNIT_TEST_SUITE(TEventSerialization) {
         };
     };
 
-    Y_UNIT_TEST(Coroutine) {
+    Y_UNIT_TEST(Coroutine) { 
         TString strA(507, 'a');
         TString strB(814, 'b');
         TString strC(198, 'c');
diff --git a/library/cpp/actors/core/executor_pool_basic.cpp b/library/cpp/actors/core/executor_pool_basic.cpp
index 4dce16939a..f9709a4c78 100644
--- a/library/cpp/actors/core/executor_pool_basic.cpp
+++ b/library/cpp/actors/core/executor_pool_basic.cpp
@@ -323,7 +323,7 @@ namespace NActors {
     void TBasicExecutorPool::SetRealTimeMode() const {
 // TODO: musl-libc version of `sched_param` struct is for some reason different from pthread
 // version in Ubuntu 12.04
-#if defined(_linux_) && !defined(_musl_)
+#if defined(_linux_) && !defined(_musl_) 
         if (RealtimePriority != 0) {
             pthread_t threadSelf = pthread_self();
             sched_param param = {RealtimePriority};
diff --git a/library/cpp/actors/core/executor_thread.cpp b/library/cpp/actors/core/executor_thread.cpp
index 446b651efd..9f155c30bc 100644
--- a/library/cpp/actors/core/executor_thread.cpp
+++ b/library/cpp/actors/core/executor_thread.cpp
@@ -475,7 +475,7 @@ namespace NActors {
         else if (state == TExecutionState::FreeExecuting)
             AtomicStore(&ExecutionState, (ui32)TExecutionState::FreeLeaving);
         else
-            Y_FAIL();
+            Y_FAIL(); 
         AtomicBarrier();
     }
 
diff --git a/library/cpp/actors/core/executor_thread.h b/library/cpp/actors/core/executor_thread.h
index 9d3c573f0d..0ecc640438 100644
--- a/library/cpp/actors/core/executor_thread.h
+++ b/library/cpp/actors/core/executor_thread.h
@@ -14,7 +14,7 @@
 
 namespace NActors {
 
-    class TExecutorThread: public ISimpleThread {
+    class TExecutorThread: public ISimpleThread { 
     public:
         static constexpr TDuration DEFAULT_TIME_PER_MAILBOX =
             TDuration::MilliSeconds(10);
diff --git a/library/cpp/actors/core/log.cpp b/library/cpp/actors/core/log.cpp
index 5f63b5af58..8879083f19 100644
--- a/library/cpp/actors/core/log.cpp
+++ b/library/cpp/actors/core/log.cpp
@@ -236,7 +236,7 @@ namespace NActors {
     }
 
     void TLoggerActor::HandleIgnoredEvent(TLogIgnored::TPtr& ev, const NActors::TActorContext& ctx) {
-        Y_UNUSED(ev);
+        Y_UNUSED(ev); 
         LogIgnoredCount(ctx.Now());
         IgnoredCount = 0;
         PassedCount = 0;
@@ -309,7 +309,7 @@ namespace NActors {
         ctx.Send(ev->Sender, new TLogComponentLevelResponse(code, explanation));
     }
 
-    void TLoggerActor::RenderComponentPriorities(IOutputStream& str) {
+    void TLoggerActor::RenderComponentPriorities(IOutputStream& str) { 
         using namespace NLog;
         HTML(str) {
             H4() {
@@ -690,7 +690,7 @@ namespace NActors {
                     isOk = true;
                 } catch (TSystemError err) {
                     // Interrupted system call
-                    Y_UNUSED(err);
+                    Y_UNUSED(err); 
                 }
             } while (!isOk);
         }
diff --git a/library/cpp/actors/core/log.h b/library/cpp/actors/core/log.h
index c11a7cf3c1..a7d8ec058a 100644
--- a/library/cpp/actors/core/log.h
+++ b/library/cpp/actors/core/log.h
@@ -252,7 +252,7 @@ namespace NActors {
         void HandleMonInfo(NMon::TEvHttpInfo::TPtr& ev, const TActorContext& ctx);
         void HandleWakeup();
         [[nodiscard]] bool OutputRecord(TInstant time, NLog::EPrio priority, NLog::EComponent component, const TString& formatted) noexcept;
-        void RenderComponentPriorities(IOutputStream& str);
+        void RenderComponentPriorities(IOutputStream& str); 
         void LogIgnoredCount(TInstant now);
         void WriteMessageStat(const NLog::TEvLog& ev);
         static const char* FormatLocalTimestamp(TInstant time, char* buf);
diff --git a/library/cpp/actors/core/log_settings.cpp b/library/cpp/actors/core/log_settings.cpp
index f52f2fc5d2..bfc5143a3e 100644
--- a/library/cpp/actors/core/log_settings.cpp
+++ b/library/cpp/actors/core/log_settings.cpp
@@ -50,7 +50,7 @@ namespace NActors {
 
         void TSettings::Append(EComponent minVal, EComponent maxVal, EComponentToStringFunc func) {
             Y_VERIFY(minVal >= 0, "NLog::TSettings: minVal must be non-negative");
-            Y_VERIFY(maxVal > minVal, "NLog::TSettings: maxVal must be greater than minVal");
+            Y_VERIFY(maxVal > minVal, "NLog::TSettings: maxVal must be greater than minVal"); 
 
             // update bounds
             if (!MaxVal || minVal < MinVal) {
diff --git a/library/cpp/actors/core/log_settings.h b/library/cpp/actors/core/log_settings.h
index 7fe4504edd..f8aade260a 100644
--- a/library/cpp/actors/core/log_settings.h
+++ b/library/cpp/actors/core/log_settings.h
@@ -144,13 +144,13 @@ namespace NActors {
             }
 
             inline TComponentSettings GetComponentSettings(EComponent component) const {
-                Y_VERIFY_DEBUG((component & Mask) == component);
+                Y_VERIFY_DEBUG((component & Mask) == component); 
                 // by using Mask we don't get outside of array boundaries
                 return TComponentSettings(AtomicGet(ComponentInfo[component & Mask]));
             }
 
             const char* ComponentName(EComponent component) const {
-                Y_VERIFY_DEBUG((component & Mask) == component);
+                Y_VERIFY_DEBUG((component & Mask) == component); 
                 return ComponentNames[component & Mask].data();
             }
 
diff --git a/library/cpp/actors/core/mon.h b/library/cpp/actors/core/mon.h
index c450f2338e..a159c89469 100644
--- a/library/cpp/actors/core/mon.h
+++ b/library/cpp/actors/core/mon.h
@@ -53,7 +53,7 @@ namespace NActors {
             virtual ~IEvHttpInfoRes() {
             }
 
-            virtual void Output(IOutputStream& out) const = 0;
+            virtual void Output(IOutputStream& out) const = 0; 
             virtual EContentType GetContentType() const = 0;
         };
 
@@ -66,7 +66,7 @@ namespace NActors {
             {
             }
 
-            void Output(IOutputStream& out) const override {
+            void Output(IOutputStream& out) const override { 
                 out << Answer;
             }
 
diff --git a/library/cpp/actors/core/scheduler_actor_ut.cpp b/library/cpp/actors/core/scheduler_actor_ut.cpp
index 09b7369d36..23e292cd2d 100644
--- a/library/cpp/actors/core/scheduler_actor_ut.cpp
+++ b/library/cpp/actors/core/scheduler_actor_ut.cpp
@@ -13,7 +13,7 @@
 
 using namespace NActors;
 
-Y_UNIT_TEST_SUITE(SchedulerActor) {
+Y_UNIT_TEST_SUITE(SchedulerActor) { 
     class TTestActor: public TActorBootstrapped<TTestActor> {
         TManualEvent& DoneEvent;
         TAtomic& EventsProcessed;
@@ -86,15 +86,15 @@ Y_UNIT_TEST_SUITE(SchedulerActor) {
         actorSystem.Stop();
     }
 
-    Y_UNIT_TEST(LongEvents) {
+    Y_UNIT_TEST(LongEvents) { 
         Test(10, 500);
     }
 
-    Y_UNIT_TEST(MediumEvents) {
+    Y_UNIT_TEST(MediumEvents) { 
         Test(100, 50);
     }
 
-    Y_UNIT_TEST(QuickEvents) {
+    Y_UNIT_TEST(QuickEvents) { 
         Test(1000, 5);
     }
 }
diff --git a/library/cpp/actors/dnscachelib/dnscache.cpp b/library/cpp/actors/dnscachelib/dnscache.cpp
index 649339ddb2..886637046c 100644
--- a/library/cpp/actors/dnscachelib/dnscache.cpp
+++ b/library/cpp/actors/dnscachelib/dnscache.cpp
@@ -176,7 +176,7 @@ TDnsCache::Resolve(const TString& hostname, int family, bool cacheOnly) {
 
     THostCache::iterator p;
 
-    Y_ASSERT(family == AF_INET || family == AF_INET6);
+    Y_ASSERT(family == AF_INET || family == AF_INET6); 
 
     {
         TGuard<TMutex> lock(CacheMtx);
@@ -317,7 +317,7 @@ void TDnsCache::WaitTask(TAtomic& flag) {
             }
         }
 
-        Y_ASSERT(nfds != 0);
+        Y_ASSERT(nfds != 0); 
 
         const TDuration left = TInstant(TTimeKeeper::GetTimeval()) - start;
         const TDuration wait = Max(Timeout - left, TDuration::Zero());
@@ -363,7 +363,7 @@ void TDnsCache::GHBNCallback(void* arg, int status, int, struct hostent* info) {
     TGuard<TMutex> lock(ctx->Owner->CacheMtx);
     THostCache::iterator p = ctx->Owner->HostCache.find(ctx->Hostname);
 
-    Y_ASSERT(p != ctx->Owner->HostCache.end());
+    Y_ASSERT(p != ctx->Owner->HostCache.end()); 
 
     time_t& resolved = (ctx->Family == AF_INET ? p->second.ResolvedV4 : p->second.ResolvedV6);
     time_t& notfound = (ctx->Family == AF_INET ? p->second.NotFoundV4 : p->second.NotFoundV6);
@@ -387,7 +387,7 @@ void TDnsCache::GHBNCallback(void* arg, int status, int, struct hostent* info) {
                 p->second.AddrsV6.push_back(*(struct in6_addr*)(info->h_addr_list[i]));
             }
         } else {
-            Y_FAIL("unknown address type in ares callback");
+            Y_FAIL("unknown address type in ares callback"); 
         }
         resolved = TTimeKeeper::GetTime();
         notfound = 0;
@@ -403,7 +403,7 @@ void TDnsCache::GHBACallback(void* arg, int status, int, struct hostent* info) {
     TGuard<TMutex> lock(ctx->Owner->CacheMtx);
     TAddrCache::iterator p = ctx->Owner->AddrCache.find(ctx->Addr);
 
-    Y_ASSERT(p != ctx->Owner->AddrCache.end());
+    Y_ASSERT(p != ctx->Owner->AddrCache.end()); 
 
     if (status == ARES_SUCCESS) {
         p->second.Hostname = info->h_name;
diff --git a/library/cpp/actors/helpers/selfping_actor_ut.cpp b/library/cpp/actors/helpers/selfping_actor_ut.cpp
index 459635fa24..397da9d8eb 100644
--- a/library/cpp/actors/helpers/selfping_actor_ut.cpp
+++ b/library/cpp/actors/helpers/selfping_actor_ut.cpp
@@ -13,8 +13,8 @@ THolder<TTestActorRuntimeBase> CreateRuntime() {
     return runtime;
 }
 
-Y_UNIT_TEST_SUITE(TSelfPingTest) {
-    Y_UNIT_TEST(Basic)
+Y_UNIT_TEST_SUITE(TSelfPingTest) { 
+    Y_UNIT_TEST(Basic) 
     {
         auto runtime = CreateRuntime();
 
diff --git a/library/cpp/actors/http/http_ut.cpp b/library/cpp/actors/http/http_ut.cpp
index 4c922f8d0f..592a341276 100644
--- a/library/cpp/actors/http/http_ut.cpp
+++ b/library/cpp/actors/http/http_ut.cpp
@@ -37,8 +37,8 @@ void EatPartialString(TIntrusivePtr<HttpType>& request, const TString& data) {
 
 }
 
-Y_UNIT_TEST_SUITE(HttpProxy) {
-    Y_UNIT_TEST(BasicParsing) {
+Y_UNIT_TEST_SUITE(HttpProxy) { 
+    Y_UNIT_TEST(BasicParsing) { 
         NHttp::THttpIncomingRequestPtr request = new NHttp::THttpIncomingRequest();
         EatWholeString(request, "GET /test HTTP/1.1\r\nHost: test\r\nSome-Header: 32344\r\n\r\n");
         UNIT_ASSERT_EQUAL(request->Stage, NHttp::THttpIncomingRequest::EParseStage::Done);
@@ -50,7 +50,7 @@ Y_UNIT_TEST_SUITE(HttpProxy) {
         UNIT_ASSERT_EQUAL(request->Headers, "Host: test\r\nSome-Header: 32344\r\n\r\n");
     }
 
-    Y_UNIT_TEST(BasicParsingChunkedBody) {
+    Y_UNIT_TEST(BasicParsingChunkedBody) { 
         NHttp::THttpOutgoingRequestPtr request = nullptr; //new NHttp::THttpOutgoingRequest();
         NHttp::THttpIncomingResponsePtr response = new NHttp::THttpIncomingResponse(request);
         EatWholeString(response, "HTTP/1.1 200 OK\r\nConnection: close\r\nTransfer-Encoding: chunked\r\n\r\n4\r\nthis\r\n4\r\n is \r\n5\r\ntest.\r\n0\r\n\r\n");
@@ -94,7 +94,7 @@ Y_UNIT_TEST_SUITE(HttpProxy) {
         UNIT_ASSERT_VALUES_EQUAL(compressedBody, response->Body);
     }
 
-    Y_UNIT_TEST(BasicPartialParsing) {
+    Y_UNIT_TEST(BasicPartialParsing) { 
         NHttp::THttpIncomingRequestPtr request = new NHttp::THttpIncomingRequest();
         EatPartialString(request, "GET /test HTTP/1.1\r\nHost: test\r\nSome-Header: 32344\r\n\r\n");
         UNIT_ASSERT_EQUAL(request->Stage, NHttp::THttpIncomingRequest::EParseStage::Done);
@@ -106,7 +106,7 @@ Y_UNIT_TEST_SUITE(HttpProxy) {
         UNIT_ASSERT_EQUAL(request->Headers, "Host: test\r\nSome-Header: 32344\r\n\r\n");
     }
 
-    Y_UNIT_TEST(BasicPartialParsingChunkedBody) {
+    Y_UNIT_TEST(BasicPartialParsingChunkedBody) { 
         NHttp::THttpOutgoingRequestPtr request = nullptr; //new NHttp::THttpOutgoingRequest();
         NHttp::THttpIncomingResponsePtr response = new NHttp::THttpIncomingResponse(request);
         EatPartialString(response, "HTTP/1.1 200 OK\r\nConnection: close\r\nTransfer-Encoding: chunked\r\n\r\n4\r\nthis\r\n4\r\n is \r\n5\r\ntest.\r\n0\r\n\r\n");
@@ -119,7 +119,7 @@ Y_UNIT_TEST_SUITE(HttpProxy) {
         UNIT_ASSERT_EQUAL(response->Body, "this is test.");
     }
 
-    Y_UNIT_TEST(AdvancedParsing) {
+    Y_UNIT_TEST(AdvancedParsing) { 
         NHttp::THttpIncomingRequestPtr request = new NHttp::THttpIncomingRequest();
         EatWholeString(request, "GE");
         EatWholeString(request, "T");
@@ -140,7 +140,7 @@ Y_UNIT_TEST_SUITE(HttpProxy) {
         UNIT_ASSERT_EQUAL(request->Headers, "Host: test\r\nSome-Header: 32344\r\n\r\n");
     }
 
-    Y_UNIT_TEST(AdvancedPartialParsing) {
+    Y_UNIT_TEST(AdvancedPartialParsing) { 
         NHttp::THttpIncomingRequestPtr request = new NHttp::THttpIncomingRequest();
         EatPartialString(request, "GE");
         EatPartialString(request, "T");
@@ -174,7 +174,7 @@ Y_UNIT_TEST_SUITE(HttpProxy) {
         UNIT_ASSERT_VALUES_EQUAL(requestData, "GET /data/url HTTP/1.1\r\nHost: www.yandex.ru\r\nAccept: */*\r\nCookie: cookie1=123456; cookie2=45678;\r\n");
     }
 
-    Y_UNIT_TEST(BasicRunning) {
+    Y_UNIT_TEST(BasicRunning) { 
         NActors::TTestActorRuntimeBase actorSystem;
         TPortManager portManager;
         TIpPort port = portManager.GetTcpPort();
@@ -304,7 +304,7 @@ CRA/5XcX13GJwHHj6LCoc3sL7mt8qV9HKY2AOZ88mpObzISZxgPpdKCfjsrdm63V
         UNIT_ASSERT_EQUAL(response->Response->Body, "passed");
     }
 
-    /*Y_UNIT_TEST(AdvancedRunning) {
+    /*Y_UNIT_TEST(AdvancedRunning) { 
         THolder<NActors::TActorSystemSetup> setup = MakeHolder<NActors::TActorSystemSetup>();
         setup->NodeId = 1;
         setup->ExecutorsCount = 1;
diff --git a/library/cpp/actors/interconnect/ut_fat/main.cpp b/library/cpp/actors/interconnect/ut_fat/main.cpp
index 5d19bc3003..c399254904 100644
--- a/library/cpp/actors/interconnect/ut_fat/main.cpp
+++ b/library/cpp/actors/interconnect/ut_fat/main.cpp
@@ -15,7 +15,7 @@
 #include <util/system/atomic.h>
 #include <util/generic/set.h>
 
-Y_UNIT_TEST_SUITE(InterconnectUnstableConnection) {
+Y_UNIT_TEST_SUITE(InterconnectUnstableConnection) { 
     using namespace NActors;
 
     class TSenderActor: public TSenderBaseActor {
@@ -99,7 +99,7 @@ Y_UNIT_TEST_SUITE(InterconnectUnstableConnection) {
         }
     };
 
-    Y_UNIT_TEST(InterconnectTestWithProxyUnsureUndelivered) {
+    Y_UNIT_TEST(InterconnectTestWithProxyUnsureUndelivered) { 
         ui32 numNodes = 2;
         double bandWidth = 1000000;
         ui16 flags = IEventHandle::FlagTrackDelivery | IEventHandle::FlagGenerateUnsureUndelivered;
@@ -115,7 +115,7 @@ Y_UNIT_TEST_SUITE(InterconnectUnstableConnection) {
         NanoSleep(30ULL * 1000 * 1000 * 1000);
     }
 
-    Y_UNIT_TEST(InterconnectTestWithProxy) {
+    Y_UNIT_TEST(InterconnectTestWithProxy) { 
         ui32 numNodes = 2;
         double bandWidth = 1000000;
         ui16 flags = IEventHandle::FlagTrackDelivery;
diff --git a/library/cpp/actors/testlib/test_runtime.cpp b/library/cpp/actors/testlib/test_runtime.cpp
index 6fa25b9965..d876229f1f 100644
--- a/library/cpp/actors/testlib/test_runtime.cpp
+++ b/library/cpp/actors/testlib/test_runtime.cpp
@@ -95,7 +95,7 @@ namespace NActors {
         }
 
         STFUNC(StateFunc) {
-            Y_UNUSED(ctx);
+            Y_UNUSED(ctx); 
             TGuard<TMutex> guard(Runtime->Mutex);
             bool verbose = (Runtime->CurrentDispatchContext ? !Runtime->CurrentDispatchContext->Options->Quiet : true) && VERBOSE;
             if (Runtime->BlockedOutput.find(ev->Sender) != Runtime->BlockedOutput.end()) {
@@ -109,7 +109,7 @@ namespace NActors {
 
             if (!Runtime->EventFilterFunc(*Runtime, ev)) {
                 ui32 nodeId = ev->GetRecipientRewrite().NodeId();
-                Y_VERIFY(nodeId != 0);
+                Y_VERIFY(nodeId != 0); 
                 ui32 mailboxHint = ev->GetRecipientRewrite().Hint();
                 Runtime->GetMailbox(nodeId, mailboxHint).Send(ev);
                 Runtime->MailboxesHasEvents.Signal();
@@ -128,7 +128,7 @@ namespace NActors {
 
     void TEventMailBox::Send(TAutoPtr<IEventHandle> ev) {
         IEventHandle* ptr = ev.Get();
-        Y_VERIFY(ptr);
+        Y_VERIFY(ptr); 
 #ifdef DEBUG_ORDER_EVENTS
         ui64 counter = NextToSend++;
         TrackSent[ptr] = counter;
@@ -142,7 +142,7 @@ namespace NActors {
 #ifdef DEBUG_ORDER_EVENTS
         auto it = TrackSent.find(result.Get());
         if (it != TrackSent.end()) {
-            Y_VERIFY(ExpectedReceive == it->second);
+            Y_VERIFY(ExpectedReceive == it->second); 
             TrackSent.erase(result.Get());
             ++ExpectedReceive;
         }
@@ -239,18 +239,18 @@ namespace NActors {
             : Runtime(runtime)
             , Node(node)
         {
-            Y_UNUSED(Runtime);
+            Y_UNUSED(Runtime); 
         }
 
         void Prepare(TActorSystem *actorSystem, volatile ui64 *currentTimestamp, volatile ui64 *currentMonotonic) override {
-            Y_UNUSED(actorSystem);
+            Y_UNUSED(actorSystem); 
             Node->ActorSystemTimestamp = currentTimestamp;
             Node->ActorSystemMonotonic = currentMonotonic;
         }
 
         void PrepareSchedules(NSchedulerQueue::TReader **readers, ui32 scheduleReadersCount) override {
-            Y_UNUSED(readers);
-            Y_UNUSED(scheduleReadersCount);
+            Y_UNUSED(readers); 
+            Y_UNUSED(scheduleReadersCount); 
         }
 
         void Start() override {
@@ -284,8 +284,8 @@ namespace NActors {
         // for threads
         ui32 GetReadyActivation(TWorkerContext& wctx, ui64 revolvingCounter) override {
             Y_UNUSED(wctx);
-            Y_UNUSED(revolvingCounter);
-            Y_FAIL();
+            Y_UNUSED(revolvingCounter); 
+            Y_FAIL(); 
         }
 
         void ReclaimMailbox(TMailboxType::EType mailboxType, ui32 hint, TWorkerId workerId, ui64 revolvingCounter) override {
@@ -357,7 +357,7 @@ namespace NActors {
 
             if (!Runtime->EventFilterFunc(*Runtime, ev)) {
                 ui32 nodeId = ev->GetRecipientRewrite().NodeId();
-                Y_VERIFY(nodeId != 0);
+                Y_VERIFY(nodeId != 0); 
                 TNodeDataBase* node = Runtime->Nodes[nodeId].Get();
 
                 if (!AllowSendFrom(node, ev)) {
@@ -394,12 +394,12 @@ namespace NActors {
         }
 
         void ScheduleActivation(ui32 activation) override {
-            Y_UNUSED(activation);
+            Y_UNUSED(activation); 
         }
 
         void ScheduleActivationEx(ui32 activation, ui64 revolvingCounter) override {
-            Y_UNUSED(activation);
-            Y_UNUSED(revolvingCounter);
+            Y_UNUSED(activation); 
+            Y_UNUSED(revolvingCounter); 
         }
 
         TActorId Register(IActor *actor, TMailboxType::EType mailboxType, ui64 revolvingCounter,
@@ -413,9 +413,9 @@ namespace NActors {
 
         // lifecycle stuff
         void Prepare(TActorSystem *actorSystem, NSchedulerQueue::TReader **scheduleReaders, ui32 *scheduleSz) override {
-            Y_UNUSED(actorSystem);
-            Y_UNUSED(scheduleReaders);
-            Y_UNUSED(scheduleSz);
+            Y_UNUSED(actorSystem); 
+            Y_UNUSED(scheduleReaders); 
+            Y_UNUSED(scheduleSz); 
         }
 
         void Start() override {
@@ -433,7 +433,7 @@ namespace NActors {
 
         // generic
         TAffinity* Affinity() const override {
-            Y_FAIL();
+            Y_FAIL(); 
         }
 
     private:
@@ -553,20 +553,20 @@ namespace NActors {
     }
 
     TTestActorRuntimeBase::EEventAction TTestActorRuntimeBase::DefaultObserverFunc(TTestActorRuntimeBase& runtime, TAutoPtr<IEventHandle>& event) {
-        Y_UNUSED(runtime);
-        Y_UNUSED(event);
+        Y_UNUSED(runtime); 
+        Y_UNUSED(event); 
         return EEventAction::PROCESS;
     }
 
     void TTestActorRuntimeBase::DroppingScheduledEventsSelector(TTestActorRuntimeBase& runtime, TScheduledEventsList& scheduledEvents, TEventsList& queue) {
-        Y_UNUSED(runtime);
-        Y_UNUSED(queue);
+        Y_UNUSED(runtime); 
+        Y_UNUSED(queue); 
         scheduledEvents.clear();
     }
 
     bool TTestActorRuntimeBase::DefaultFilterFunc(TTestActorRuntimeBase& runtime, TAutoPtr<IEventHandle>& event) {
-        Y_UNUSED(runtime);
-        Y_UNUSED(event);
+        Y_UNUSED(runtime); 
+        Y_UNUSED(event); 
         return false;
     }
 
@@ -618,7 +618,7 @@ namespace NActors {
             }
         }
 
-        void Print(IOutputStream& stream, const TString& prefix) {
+        void Print(IOutputStream& stream, const TString& prefix) { 
             for (auto it = Children.begin(); it != Children.end(); ++it) {
                 bool lastChild = (std::next(it) == Children.end());
                 TString connectionPrefix = lastChild ? "└─ " : "├─ ";
@@ -628,7 +628,7 @@ namespace NActors {
             }
         }
 
-        void Print(IOutputStream& stream) {
+        void Print(IOutputStream& stream) { 
             stream << Name << " (" << Count << ")\n";
             Print(stream, TString());
         }
@@ -726,8 +726,8 @@ namespace NActors {
     }
 
     void TTestActorRuntimeBase::AddLocalService(const TActorId& actorId, const TActorSetupCmd& cmd, ui32 nodeIndex) {
-        Y_VERIFY(!IsInitialized);
-        Y_VERIFY(nodeIndex < NodeCount);
+        Y_VERIFY(!IsInitialized); 
+        Y_VERIFY(nodeIndex < NodeCount); 
         auto node = Nodes[nodeIndex + FirstNodeId];
         if (!node) {
             node = GetNodeFactory().CreateNode();
@@ -793,7 +793,7 @@ namespace NActors {
 
     TInstant TTestActorRuntimeBase::GetCurrentTime() const {
         TGuard<TMutex> guard(Mutex);
-        Y_VERIFY(!UseRealThreads);
+        Y_VERIFY(!UseRealThreads); 
         return TInstant::MicroSeconds(CurrentTimestamp);
     }
 
@@ -804,7 +804,7 @@ namespace NActors {
             Cerr << "UpdateCurrentTime(" << counter << "," << newTime << ")\n";
         }
         TGuard<TMutex> guard(Mutex);
-        Y_VERIFY(!UseRealThreads);
+        Y_VERIFY(!UseRealThreads); 
         if (newTime.MicroSeconds() > CurrentTimestamp) {
             CurrentTimestamp = newTime.MicroSeconds();
             for (auto& kv : Nodes) {
@@ -819,12 +819,12 @@ namespace NActors {
     }
 
     TIntrusivePtr<ITimeProvider> TTestActorRuntimeBase::GetTimeProvider() {
-        Y_VERIFY(!UseRealThreads);
+        Y_VERIFY(!UseRealThreads); 
         return TimeProvider;
     }
 
     ui32 TTestActorRuntimeBase::GetNodeId(ui32 index) const {
-        Y_VERIFY(index < NodeCount);
+        Y_VERIFY(index < NodeCount); 
         return FirstNodeId + index;
     }
 
@@ -859,11 +859,11 @@ namespace NActors {
 
     TActorId TTestActorRuntimeBase::Register(IActor* actor, ui32 nodeIndex, ui32 poolId, TMailboxType::EType mailboxType,
         ui64 revolvingCounter, const TActorId& parentId) {
-        Y_VERIFY(nodeIndex < NodeCount);
+        Y_VERIFY(nodeIndex < NodeCount); 
         TGuard<TMutex> guard(Mutex);
         TNodeDataBase* node = Nodes[FirstNodeId + nodeIndex].Get();
         if (UseRealThreads) {
-            Y_VERIFY(poolId < node->ExecutorPools.size());
+            Y_VERIFY(poolId < node->ExecutorPools.size()); 
             return node->ExecutorPools[poolId]->Register(actor, mailboxType, revolvingCounter, parentId);
         }
 
@@ -927,11 +927,11 @@ namespace NActors {
 
     TActorId TTestActorRuntimeBase::Register(IActor *actor, ui32 nodeIndex, ui32 poolId, TMailboxHeader *mailbox, ui32 hint,
         const TActorId& parentId) {
-        Y_VERIFY(nodeIndex < NodeCount);
+        Y_VERIFY(nodeIndex < NodeCount); 
         TGuard<TMutex> guard(Mutex);
         TNodeDataBase* node = Nodes[FirstNodeId + nodeIndex].Get();
         if (UseRealThreads) {
-            Y_VERIFY(poolId < node->ExecutorPools.size());
+            Y_VERIFY(poolId < node->ExecutorPools.size()); 
             return node->ExecutorPools[poolId]->Register(actor, mailbox, hint, parentId);
         }
 
@@ -951,7 +951,7 @@ namespace NActors {
 
     TActorId TTestActorRuntimeBase::RegisterService(const TActorId& serviceId, const TActorId& actorId, ui32 nodeIndex) {
         TGuard<TMutex> guard(Mutex);
-        Y_VERIFY(nodeIndex < NodeCount);
+        Y_VERIFY(nodeIndex < NodeCount); 
         TNodeDataBase* node = Nodes[FirstNodeId + nodeIndex].Get();
         if (!UseRealThreads) {
             IActor* actor = FindActor(actorId, node);
@@ -964,7 +964,7 @@ namespace NActors {
 
     TActorId TTestActorRuntimeBase::AllocateEdgeActor(ui32 nodeIndex) {
         TGuard<TMutex> guard(Mutex);
-        Y_VERIFY(nodeIndex < NodeCount);
+        Y_VERIFY(nodeIndex < NodeCount); 
         TActorId edgeActor = Register(new TEdgeActor(this), nodeIndex);
         EdgeActors.insert(edgeActor);
         EdgeActorByMailbox[TEventMailboxId(edgeActor.NodeId(), edgeActor.Hint())] = edgeActor;
@@ -983,7 +983,7 @@ namespace NActors {
 
     TEventsList TTestActorRuntimeBase::CaptureMailboxEvents(ui32 hint, ui32 nodeId) {
         TGuard<TMutex> guard(Mutex);
-        Y_VERIFY(nodeId >= FirstNodeId && nodeId < FirstNodeId + NodeCount);
+        Y_VERIFY(nodeId >= FirstNodeId && nodeId < FirstNodeId + NodeCount); 
         TEventsList result;
         GetMailbox(nodeId, hint).Capture(result);
         return result;
@@ -992,7 +992,7 @@ namespace NActors {
     void TTestActorRuntimeBase::PushFront(TAutoPtr<IEventHandle>& ev) {
         TGuard<TMutex> guard(Mutex);
         ui32 nodeId = ev->GetRecipientRewrite().NodeId();
-        Y_VERIFY(nodeId != 0);
+        Y_VERIFY(nodeId != 0); 
         GetMailbox(nodeId, ev->GetRecipientRewrite().Hint()).PushFront(ev);
     }
 
@@ -1002,7 +1002,7 @@ namespace NActors {
             if (*rit) {
                 auto& ev = *rit;
                 ui32 nodeId = ev->GetRecipientRewrite().NodeId();
-                Y_VERIFY(nodeId != 0);
+                Y_VERIFY(nodeId != 0); 
                 GetMailbox(nodeId, ev->GetRecipientRewrite().Hint()).PushFront(ev);
             }
         }
@@ -1012,7 +1012,7 @@ namespace NActors {
 
     void TTestActorRuntimeBase::PushMailboxEventsFront(ui32 hint, ui32 nodeId, TEventsList& events) {
         TGuard<TMutex> guard(Mutex);
-        Y_VERIFY(nodeId >= FirstNodeId && nodeId < FirstNodeId + NodeCount);
+        Y_VERIFY(nodeId >= FirstNodeId && nodeId < FirstNodeId + NodeCount); 
         TEventsList result;
         GetMailbox(nodeId, hint).PushFront(events);
         events.clear();
@@ -1081,7 +1081,7 @@ namespace NActors {
                     Runtime.GetMailbox(edgeActor.NodeId(), edgeActor.Hint()).Capture(events);
                     auto mboxId = TEventMailboxId(edgeActor.NodeId(), edgeActor.Hint());
                     auto storeIt = Store.find(mboxId);
-                    Y_VERIFY(storeIt == Store.end());
+                    Y_VERIFY(storeIt == Store.end()); 
                     storeIt = Store.insert(std::make_pair(mboxId, new TEventMailBox)).first;
                     storeIt->second->PushFront(events);
                     if (!events.empty())
@@ -1213,13 +1213,13 @@ namespace NActors {
                                             break;
                                         }
                                         default:
-                                            Y_FAIL("Unknown action");
+                                            Y_FAIL("Unknown action"); 
                                     }
                                 }
                             }
 
                         }
-                        Y_VERIFY(mboxIt != currentMailboxes.end());
+                        Y_VERIFY(mboxIt != currentMailboxes.end()); 
                         if (!isIgnored && !CurrentDispatchContext->PrevContext && !restrictedMailboxes &&
                                 mboxIt->second->IsEmpty() &&
                                 mboxIt->second->IsScheduledEmpty() &&
@@ -1230,7 +1230,7 @@ namespace NActors {
                         if (mboxIt == currentMailboxes.end()) {
                             mboxIt = currentMailboxes.begin();
                         }
-                        Y_VERIFY(endWithMboxIt != currentMailboxes.end());
+                        Y_VERIFY(endWithMboxIt != currentMailboxes.end()); 
                         if (mboxIt == endWithMboxIt) {
                             break;
                         }
@@ -1384,14 +1384,14 @@ namespace NActors {
 
     void TTestActorRuntimeBase::Send(IEventHandle* ev, ui32 senderNodeIndex, bool viaActorSystem) {
         TGuard<TMutex> guard(Mutex);
-        Y_VERIFY(senderNodeIndex < NodeCount, "senderNodeIndex# %" PRIu32 " < NodeCount# %" PRIu32,
+        Y_VERIFY(senderNodeIndex < NodeCount, "senderNodeIndex# %" PRIu32 " < NodeCount# %" PRIu32, 
             senderNodeIndex, NodeCount);
         SendInternal(ev, senderNodeIndex, viaActorSystem);
     }
 
     void TTestActorRuntimeBase::Schedule(IEventHandle* ev, const TDuration& duration, ui32 nodeIndex) {
         TGuard<TMutex> guard(Mutex);
-        Y_VERIFY(nodeIndex < NodeCount);
+        Y_VERIFY(nodeIndex < NodeCount); 
         ui32 nodeId = FirstNodeId + nodeIndex;
         ui32 mailboxHint = ev->GetRecipientRewrite().Hint();
         TInstant deadline = TInstant::MicroSeconds(CurrentTimestamp) + duration;
@@ -1416,7 +1416,7 @@ namespace NActors {
 
     TActorId TTestActorRuntimeBase::GetLocalServiceId(const TActorId& serviceId, ui32 nodeIndex) {
         TGuard<TMutex> guard(Mutex);
-        Y_VERIFY(nodeIndex < NodeCount);
+        Y_VERIFY(nodeIndex < NodeCount); 
         TNodeDataBase* node = Nodes[FirstNodeId + nodeIndex].Get();
         return node->ActorSystem->LookupLocalService(serviceId);
     }
@@ -1456,15 +1456,15 @@ namespace NActors {
                 }
             }
 
-            Y_VERIFY(dispatchCount < 1000, "Hard limit to prevent endless loop");
+            Y_VERIFY(dispatchCount < 1000, "Hard limit to prevent endless loop"); 
         }
     }
 
     TActorId TTestActorRuntimeBase::GetInterconnectProxy(ui32 nodeIndexFrom, ui32 nodeIndexTo) {
         TGuard<TMutex> guard(Mutex);
-        Y_VERIFY(nodeIndexFrom < NodeCount);
-        Y_VERIFY(nodeIndexTo < NodeCount);
-        Y_VERIFY(nodeIndexFrom != nodeIndexTo);
+        Y_VERIFY(nodeIndexFrom < NodeCount); 
+        Y_VERIFY(nodeIndexTo < NodeCount); 
+        Y_VERIFY(nodeIndexFrom != nodeIndexTo); 
         TNodeDataBase* node = Nodes[FirstNodeId + nodeIndexFrom].Get();
         return node->ActorSystem->InterconnectProxy(FirstNodeId + nodeIndexTo);
     }
@@ -1483,13 +1483,13 @@ namespace NActors {
     IActor* TTestActorRuntimeBase::FindActor(const TActorId& actorId, ui32 nodeIndex) const {
         TGuard<TMutex> guard(Mutex);
         if (nodeIndex == Max<ui32>()) {
-            Y_VERIFY(actorId.NodeId());
+            Y_VERIFY(actorId.NodeId()); 
             nodeIndex = actorId.NodeId() - FirstNodeId;
         }
 
-        Y_VERIFY(nodeIndex < NodeCount);
+        Y_VERIFY(nodeIndex < NodeCount); 
         auto nodeIt = Nodes.find(FirstNodeId + nodeIndex);
-        Y_VERIFY(nodeIt != Nodes.end());
+        Y_VERIFY(nodeIt != Nodes.end()); 
         TNodeDataBase* node = nodeIt->second.Get();
         return FindActor(actorId, node);
     }
@@ -1516,7 +1516,7 @@ namespace NActors {
 
     TIntrusivePtr<NMonitoring::TDynamicCounters> TTestActorRuntimeBase::GetDynamicCounters(ui32 nodeIndex) {
         TGuard<TMutex> guard(Mutex);
-        Y_VERIFY(nodeIndex < NodeCount);
+        Y_VERIFY(nodeIndex < NodeCount); 
         ui32 nodeId = FirstNodeId + nodeIndex;
         TNodeDataBase* node = Nodes[nodeId].Get();
         return node->DynamicCounters;
@@ -1527,7 +1527,7 @@ namespace NActors {
     }
 
     void TTestActorRuntimeBase::SendInternal(IEventHandle* ev, ui32 nodeIndex, bool viaActorSystem) {
-        Y_VERIFY(nodeIndex < NodeCount);
+        Y_VERIFY(nodeIndex < NodeCount); 
         ui32 nodeId = FirstNodeId + nodeIndex;
         TNodeDataBase* node = Nodes[nodeId].Get();
         ui32 targetNode = ev->GetRecipientRewrite().NodeId();
@@ -1536,7 +1536,7 @@ namespace NActors {
             targetNodeIndex = nodeIndex;
         } else {
             targetNodeIndex = targetNode - FirstNodeId;
-            Y_VERIFY(targetNodeIndex < NodeCount);
+            Y_VERIFY(targetNodeIndex < NodeCount); 
         }
 
         if (viaActorSystem || UseRealThreads || ev->GetRecipientRewrite().IsService() || (targetNodeIndex != nodeIndex)) {
@@ -1544,7 +1544,7 @@ namespace NActors {
             return;
         }
 
-        Y_VERIFY(!ev->GetRecipientRewrite().IsService() && (targetNodeIndex == nodeIndex));
+        Y_VERIFY(!ev->GetRecipientRewrite().IsService() && (targetNodeIndex == nodeIndex)); 
         TAutoPtr<IEventHandle> evHolder(ev);
 
         if (!AllowSendFrom(node, evHolder)) {
@@ -1705,7 +1705,7 @@ namespace NActors {
         for (auto& x : Nodes) {
             return x.second->ActorSystem.Get();
         }
-        Y_FAIL("Don't use this method.");
+        Y_FAIL("Don't use this method."); 
     }
 
     TActorSystem* TTestActorRuntimeBase::GetActorSystem(ui32 nodeId) {
@@ -1785,7 +1785,7 @@ namespace NActors {
             , ReplyChecker(createReplyChecker())
         {
             if (IsSync) {
-                Y_VERIFY(!runtime->IsRealThreads());
+                Y_VERIFY(!runtime->IsRealThreads()); 
             }
         }
 
@@ -1811,7 +1811,7 @@ namespace NActors {
         }
 
         STFUNC(Reply) {
-            Y_VERIFY(!HasReply);
+            Y_VERIFY(!HasReply); 
             IEventHandle *requestEv = Context->Queue->Head();
             TActorId originalSender = requestEv->Sender;
             HasReply = !ReplyChecker->IsWaitingForMoreResponses(ev.Get());
diff --git a/library/cpp/actors/testlib/test_runtime.h b/library/cpp/actors/testlib/test_runtime.h
index 26e3b45c98..ee85ddadfa 100644
--- a/library/cpp/actors/testlib/test_runtime.h
+++ b/library/cpp/actors/testlib/test_runtime.h
@@ -292,7 +292,7 @@ namespace NActors {
             handle.Destroy();
             const ui32 eventType = TEvent::EventType;
             WaitForEdgeEvents([&](TTestActorRuntimeBase& runtime, TAutoPtr<IEventHandle>& event) {
-                Y_UNUSED(runtime);
+                Y_UNUSED(runtime); 
                 if (event->GetTypeRewrite() != eventType)
                     return false;
 
@@ -306,7 +306,7 @@ namespace NActors {
             }, {}, simTimeout);
 
             if (simTimeout == TDuration::Max())
-                Y_VERIFY(handle);
+                Y_VERIFY(handle); 
 
             if (handle) {
                 return reinterpret_cast<TAutoPtr<TEventHandle<TEvent>>&>(handle)->Get();
diff --git a/library/cpp/actors/util/affinity.cpp b/library/cpp/actors/util/affinity.cpp
index cc1b6e70ec..95ff465f37 100644
--- a/library/cpp/actors/util/affinity.cpp
+++ b/library/cpp/actors/util/affinity.cpp
@@ -12,7 +12,7 @@ public:
     TImpl() {
 #ifdef _linux_
         int ar = sched_getaffinity(0, sizeof(cpu_set_t), &Mask);
-        Y_VERIFY_DEBUG(ar == 0);
+        Y_VERIFY_DEBUG(ar == 0); 
 #endif
     }
 
@@ -33,7 +33,7 @@ public:
     void Set() const {
 #ifdef _linux_
         int ar = sched_setaffinity(0, sizeof(cpu_set_t), &Mask);
-        Y_VERIFY_DEBUG(ar == 0);
+        Y_VERIFY_DEBUG(ar == 0); 
 #endif
     }
 
diff --git a/library/cpp/actors/util/queue_oneone_inplace.h b/library/cpp/actors/util/queue_oneone_inplace.h
index d7ec8bb21c..e00f05b20d 100644
--- a/library/cpp/actors/util/queue_oneone_inplace.h
+++ b/library/cpp/actors/util/queue_oneone_inplace.h
@@ -48,7 +48,7 @@ public:
     }
 
     ~TOneOneQueueInplace() {
-        Y_VERIFY_DEBUG(Head() == 0);
+        Y_VERIFY_DEBUG(Head() == 0); 
         delete ReadFrom;
     }
 
diff --git a/library/cpp/actors/util/ticket_lock.h b/library/cpp/actors/util/ticket_lock.h
index 3b1fa80393..bf0e3d795b 100644
--- a/library/cpp/actors/util/ticket_lock.h
+++ b/library/cpp/actors/util/ticket_lock.h
@@ -23,7 +23,7 @@ public:
         ui32 revolves = 0;
         const ui32 ticket = AtomicUi32Increment(&TicketIn) - 1;
         while (ticket != AtomicLoad(&TicketOut)) {
-            Y_VERIFY_DEBUG(ticket >= AtomicLoad(&TicketOut));
+            Y_VERIFY_DEBUG(ticket >= AtomicLoad(&TicketOut)); 
             SpinLockPause();
             ++revolves;
         }
diff --git a/library/cpp/actors/util/unordered_cache.h b/library/cpp/actors/util/unordered_cache.h
index 76f036c0cf..06e4571452 100644
--- a/library/cpp/actors/util/unordered_cache.h
+++ b/library/cpp/actors/util/unordered_cache.h
@@ -100,7 +100,7 @@ private:
     }
 
     void WriteOne(TLockedWriter& lock, T x) {
-        Y_VERIFY_DEBUG(x != 0);
+        Y_VERIFY_DEBUG(x != 0); 
 
         const ui32 pos = AtomicLoad(&lock.Slot->WritePosition);
         if (pos != TChunk::EntriesCount) {
@@ -127,7 +127,7 @@ public:
     }
 
     ~TUnorderedCache() {
-        Y_VERIFY(!Pop(0));
+        Y_VERIFY(!Pop(0)); 
 
         for (ui64 i = 0; i < Concurrency; ++i) {
             if (ReadSlots[i].ReadFrom) {
diff --git a/library/cpp/actors/wilson/wilson_event.h b/library/cpp/actors/wilson/wilson_event.h
index 7d89c33b51..1810582675 100644
--- a/library/cpp/actors/wilson/wilson_event.h
+++ b/library/cpp/actors/wilson/wilson_event.h
@@ -76,7 +76,7 @@ namespace NWilson {
         using TParamPack = N##EVENT_NAME##Params::TParamPack;    \
         TParamPack ParamPack;                                    \
                                                                  \
-        void Output(IOutputStream& str) {                        \
+        void Output(IOutputStream& str) {                        \ 
             str << #EVENT_NAME << "{";                           \
             __UNROLL_PARAMS(__OUTPUT_PARAM, ##__VA_ARGS__)       \
             str << "}";                                          \
diff --git a/library/cpp/actors/wilson/wilson_trace.h b/library/cpp/actors/wilson/wilson_trace.h
index 3d1ca50562..997d7e2462 100644
--- a/library/cpp/actors/wilson/wilson_trace.h
+++ b/library/cpp/actors/wilson/wilson_trace.h
@@ -101,7 +101,7 @@ namespace NWilson {
         }
 
         // Output trace id into a string stream
-        void Output(IOutputStream& s, const TTraceId& parentTraceId) const {
+        void Output(IOutputStream& s, const TTraceId& parentTraceId) const { 
             union {
                 ui8 buffer[3 * sizeof(ui64)];
                 struct {
@@ -122,7 +122,7 @@ namespace NWilson {
         }
 
         // output just span id into stream
-        void OutputSpanId(IOutputStream& s) const {
+        void OutputSpanId(IOutputStream& s) const { 
             const size_t base64size = Base64EncodeBufSize(sizeof(SpanId));
             char base64[base64size];
             char* end = Base64Encode(base64, reinterpret_cast<const ui8*>(&SpanId), sizeof(SpanId));