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

library/cpp/actors/core/actor_coroutine.h

@@ -99,7 +99,7 @@ namespace NActors {
                 return ev.GetTypeRewrite() == TEventType::EventType;
             };
             THolder<IEventHandle> event = WaitForSpecificEvent(filter, deadline);
-            return THolder<typename TEventType::THandle>(static_cast<typename TEventType::THandle*>(event ? event.Release() : nullptr)); 
+            return THolder<typename TEventType::THandle>(static_cast<typename TEventType::THandle*>(event ? event.Release() : nullptr));
         }
 
     protected: // Actor System compatibility section

library/cpp/actors/core/actor_coroutine_ut.cpp

@@ -102,7 +102,7 @@ Y_UNIT_TEST_SUITE(ActorCoro) {
     };
 
     void Check(THolder<IEventBase> && message) {
-        THolder<TActorSystemSetup> setup = MakeHolder<TActorSystemSetup>(); 
+        THolder<TActorSystemSetup> setup = MakeHolder<TActorSystemSetup>();
         setup->NodeId = 0;
         setup->ExecutorsCount = 1;
         setup->Executors.Reset(new TAutoPtr<IExecutorPool>[setup->ExecutorsCount]);
@@ -117,7 +117,7 @@ Y_UNIT_TEST_SUITE(ActorCoro) {
 
         TManualEvent doneEvent;
         TAtomic itemsProcessed = 0;
-        TActorId actor = actorSystem.Register(new TActorCoro(MakeHolder<TCoroActor>(doneEvent, itemsProcessed))); 
+        TActorId actor = actorSystem.Register(new TActorCoro(MakeHolder<TCoroActor>(doneEvent, itemsProcessed)));
         NanoSleep(3UL * 1000 * 1000 * 1000);
         actorSystem.Send(actor, message.Release());
         doneEvent.WaitI();

library/cpp/actors/core/ask.cpp

@@ -69,6 +69,6 @@ namespace NActors {
             TDuration timeout,
             const NThreading::TPromise<THolder<IEventBase>>& promise)
     {
-        return MakeHolder<TAskActor>(expectedEventType, std::move(recipient), std::move(event), timeout, promise); 
+        return MakeHolder<TAskActor>(expectedEventType, std::move(recipient), std::move(event), timeout, promise);
     }
 }

library/cpp/actors/core/ask_ut.cpp

@@ -56,7 +56,7 @@ Y_UNIT_TEST_SUITE(AskActor) {
         {
             auto fut = runtime->GetAnyNodeActorSystem()->Ask<TEvents::TEvPong>(
                 pingpong,
-                THolder(new TEvents::TEvPing)); 
+                THolder(new TEvents::TEvPing));
             runtime->DispatchEvents();
             fut.ExtractValueSync();
         }
@@ -64,7 +64,7 @@ Y_UNIT_TEST_SUITE(AskActor) {
         {
             auto fut = runtime->GetAnyNodeActorSystem()->Ask<TEvents::TEvBlob>(
                 pingpong,
-                THolder(new TEvents::TEvBlob("hello!"))); 
+                THolder(new TEvents::TEvBlob("hello!")));
             runtime->DispatchEvents();
             auto ev = fut.ExtractValueSync();
             UNIT_ASSERT_VALUES_EQUAL(ev->Blob, "hello!");
@@ -73,7 +73,7 @@ Y_UNIT_TEST_SUITE(AskActor) {
         {
             auto fut = runtime->GetAnyNodeActorSystem()->Ask<IEventBase>(
                 pingpong,
-                THolder(new TEvents::TEvPing)); 
+                THolder(new TEvents::TEvPing));
             runtime->DispatchEvents();
             auto ev = fut.ExtractValueSync();
             UNIT_ASSERT_VALUES_EQUAL(ev->Type(), TEvents::TEvPong::EventType);
@@ -87,7 +87,7 @@ Y_UNIT_TEST_SUITE(AskActor) {
         {
             auto fut = runtime->GetAnyNodeActorSystem()->Ask<TEvents::TEvBlob>(
                 pingpong,
-                THolder(new TEvents::TEvPing)); 
+                THolder(new TEvents::TEvPing));
             runtime->DispatchEvents();
             UNIT_ASSERT_EXCEPTION_CONTAINS(
                 fut.ExtractValueSync(),
@@ -103,7 +103,7 @@ Y_UNIT_TEST_SUITE(AskActor) {
         {
             auto fut = runtime->GetAnyNodeActorSystem()->Ask<TEvents::TEvPong>(
                 ping,
-                THolder(new TEvents::TEvPing), 
+                THolder(new TEvents::TEvPing),
                 TDuration::Seconds(1));
             auto start = runtime->GetCurrentTime();
             runtime->DispatchEvents({}, TDuration::Seconds(5));
@@ -117,7 +117,7 @@ Y_UNIT_TEST_SUITE(AskActor) {
         {
             auto fut = runtime->GetAnyNodeActorSystem()->Ask<IEventBase>(
                 ping,
-                THolder(new TEvents::TEvPing), 
+                THolder(new TEvents::TEvPing),
                 TDuration::Seconds(1));
             auto start = runtime->GetCurrentTime();
             runtime->DispatchEvents({}, TDuration::Seconds(5));

library/cpp/actors/core/event_pb_payload_ut.cpp

@@ -66,7 +66,7 @@ Y_UNIT_TEST_SUITE(TEventProtoWithPayload) {
         }
         UNIT_ASSERT_VALUES_EQUAL(chunkerRes, ser);
 
-        THolder<IEventBase> ev2 = THolder(TEventTo::Load(buffers)); 
+        THolder<IEventBase> ev2 = THolder(TEventTo::Load(buffers));
         TEventTo& msg2 = static_cast<TEventTo&>(*ev2);
         UNIT_ASSERT_VALUES_EQUAL(msg2.Record.GetMeta(), msg.Record.GetMeta());
         UNIT_ASSERT_EQUAL(msg2.GetPayload(msg2.Record.GetPayloadId(0)), msg.GetPayload(msg.Record.GetPayloadId(0)));

library/cpp/actors/core/scheduler_actor_ut.cpp

@@ -52,7 +52,7 @@ Y_UNIT_TEST_SUITE(SchedulerActor) {
     };
 
     void Test(TAtomicBase eventsTotalCount, ui32 scheduleDeltaMs) {
-        THolder<TActorSystemSetup> setup = MakeHolder<TActorSystemSetup>(); 
+        THolder<TActorSystemSetup> setup = MakeHolder<TActorSystemSetup>();
         setup->NodeId = 0;
         setup->ExecutorsCount = 1;
         setup->Executors.Reset(new TAutoPtr<IExecutorPool>[setup->ExecutorsCount]);

library/cpp/actors/dnscachelib/dnscache.cpp

@@ -99,7 +99,7 @@ NAddr::IRemoteAddrPtr TDnsCache::GetAddr(
             sin6.sin6_addr = addr.AddrsV6.front();
             sin6.sin6_port = HostToInet(port);
 
-            return MakeHolder<NAddr::TIPv6Addr>(sin6); 
+            return MakeHolder<NAddr::TIPv6Addr>(sin6);
         }
     }
 
@@ -108,7 +108,7 @@ NAddr::IRemoteAddrPtr TDnsCache::GetAddr(
 
         TGuard<TMutex> lock(CacheMtx);
         if (!addr.AddrsV4.empty()) {
-            return MakeHolder<NAddr::TIPv4Addr>(TIpAddress(addr.AddrsV4.front(), port)); 
+            return MakeHolder<NAddr::TIPv4Addr>(TIpAddress(addr.AddrsV4.front(), port));
         }
     }
 
@@ -124,7 +124,7 @@ void TDnsCache::GetAllAddresses(
 
         TGuard<TMutex> lock(CacheMtx);
         for (size_t i = 0; i < addr4.AddrsV4.size(); i++) {
-            addrs.push_back(MakeHolder<NAddr::TIPv4Addr>(TIpAddress(addr4.AddrsV4[i], 0))); 
+            addrs.push_back(MakeHolder<NAddr::TIPv4Addr>(TIpAddress(addr4.AddrsV4[i], 0)));
         }
     }
 
@@ -139,7 +139,7 @@ void TDnsCache::GetAllAddresses(
         for (size_t i = 0; i < addr6.AddrsV6.size(); i++) {
             sin6.sin6_addr = addr6.AddrsV6[i];
 
-            addrs.push_back(MakeHolder<NAddr::TIPv6Addr>(sin6)); 
+            addrs.push_back(MakeHolder<NAddr::TIPv6Addr>(sin6));
         }
     }
 }

library/cpp/actors/http/http_proxy_incoming.cpp

@@ -205,7 +205,7 @@ protected:
                         << ") Response: "
                         << TString(response->GetRawData()).substr(0, MAX_LOGGED_SIZE));
         }
-        THolder<TEvHttpProxy::TEvReportSensors> sensors(BuildIncomingRequestSensors(request, response)); 
+        THolder<TEvHttpProxy::TEvReportSensors> sensors(BuildIncomingRequestSensors(request, response));
         ctx.Send(Endpoint.Owner, sensors.Release());
         if (request == Requests.front() && CurrentResponse == nullptr) {
             CurrentResponse = response;

library/cpp/actors/http/http_proxy_outgoing.cpp

@@ -39,7 +39,7 @@ public:
         LOG_DEBUG_S(ctx, HttpLog, "(#" << TSocketImpl::GetRawSocket() << "," << Address << ") -> (" << Response->Status << " " << Response->Message << ")");
         ctx.Send(RequestOwner, new TEvHttpProxy::TEvHttpIncomingResponse(Request, Response));
         RequestOwner = TActorId();
-        THolder<TEvHttpProxy::TEvReportSensors> sensors(BuildOutgoingRequestSensors(Request, Response)); 
+        THolder<TEvHttpProxy::TEvReportSensors> sensors(BuildOutgoingRequestSensors(Request, Response));
         ctx.Send(Owner, sensors.Release());
         LOG_DEBUG_S(ctx, HttpLog, "(#" << TSocketImpl::GetRawSocket() << "," << Address << ") connection closed");
         Die(ctx);
@@ -50,7 +50,7 @@ public:
         if (RequestOwner) {
             ctx.Send(RequestOwner, new TEvHttpProxy::TEvHttpIncomingResponse(Request, Response, error));
             RequestOwner = TActorId();
-            THolder<TEvHttpProxy::TEvReportSensors> sensors(BuildOutgoingRequestSensors(Request, Response)); 
+            THolder<TEvHttpProxy::TEvReportSensors> sensors(BuildOutgoingRequestSensors(Request, Response));
             ctx.Send(Owner, sensors.Release());
             Die(ctx);
         }

library/cpp/actors/http/http_proxy_sock_impl.h

@@ -162,7 +162,7 @@ struct TSecureSocketImpl : TPlainSocketImpl, TSslHelpers {
     {}
 
     void InitClientSsl() {
-        Bio.Reset(BIO_new(IoMethod())); 
+        Bio.Reset(BIO_new(IoMethod()));
         BIO_set_data(Bio.Get(), this);
         BIO_set_nbio(Bio.Get(), 1);
         Ctx = CreateClientContext();
@@ -171,7 +171,7 @@ struct TSecureSocketImpl : TPlainSocketImpl, TSslHelpers {
     }
 
     void InitServerSsl(SSL_CTX* ctx) {
-        Bio.Reset(BIO_new(IoMethod())); 
+        Bio.Reset(BIO_new(IoMethod()));
         BIO_set_data(Bio.Get(), this);
         BIO_set_nbio(Bio.Get(), 1);
         Ssl = ConstructSsl(ctx, Bio.Get());