diff options
author | timestep <timestep@yandex-team.ru> | 2022-02-10 16:49:17 +0300 |
---|---|---|
committer | Daniil Cherednik <dcherednik@yandex-team.ru> | 2022-02-10 16:49:17 +0300 |
commit | 30f4921b0fa8722e5531e72cb40a93b526f6973a (patch) | |
tree | 5d5cb817648f650d76cf1076100726fd9b8448e8 /library/cpp/actors | |
parent | 38b4bd28ca420294f532ac7ca6b2770d60e3dfd0 (diff) | |
download | ydb-30f4921b0fa8722e5531e72cb40a93b526f6973a.tar.gz |
Restoring authorship annotation for <timestep@yandex-team.ru>. Commit 2 of 2.
Diffstat (limited to 'library/cpp/actors')
-rw-r--r-- | library/cpp/actors/core/actor_coroutine.h | 2 | ||||
-rw-r--r-- | library/cpp/actors/core/actor_coroutine_ut.cpp | 4 | ||||
-rw-r--r-- | library/cpp/actors/core/ask.cpp | 2 | ||||
-rw-r--r-- | library/cpp/actors/core/ask_ut.cpp | 12 | ||||
-rw-r--r-- | library/cpp/actors/core/event_pb_payload_ut.cpp | 2 | ||||
-rw-r--r-- | library/cpp/actors/core/scheduler_actor_ut.cpp | 2 | ||||
-rw-r--r-- | library/cpp/actors/dnscachelib/dnscache.cpp | 8 | ||||
-rw-r--r-- | library/cpp/actors/http/http_proxy_incoming.cpp | 2 | ||||
-rw-r--r-- | library/cpp/actors/http/http_proxy_outgoing.cpp | 4 | ||||
-rw-r--r-- | library/cpp/actors/http/http_proxy_sock_impl.h | 4 | ||||
-rw-r--r-- | library/cpp/actors/http/http_ut.cpp | 6 | ||||
-rw-r--r-- | library/cpp/actors/testlib/test_runtime.h | 4 |
12 files changed, 26 insertions, 26 deletions
diff --git a/library/cpp/actors/core/actor_coroutine.h b/library/cpp/actors/core/actor_coroutine.h index 71f020bc12..6bcb768eaf 100644 --- a/library/cpp/actors/core/actor_coroutine.h +++ b/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 diff --git a/library/cpp/actors/core/actor_coroutine_ut.cpp b/library/cpp/actors/core/actor_coroutine_ut.cpp index 9456ce67a1..951512b877 100644 --- a/library/cpp/actors/core/actor_coroutine_ut.cpp +++ b/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(); diff --git a/library/cpp/actors/core/ask.cpp b/library/cpp/actors/core/ask.cpp index 7ba8d15e47..0054c9a906 100644 --- a/library/cpp/actors/core/ask.cpp +++ b/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); } } diff --git a/library/cpp/actors/core/ask_ut.cpp b/library/cpp/actors/core/ask_ut.cpp index 3bf54035d4..e72ebdba9b 100644 --- a/library/cpp/actors/core/ask_ut.cpp +++ b/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)); diff --git a/library/cpp/actors/core/event_pb_payload_ut.cpp b/library/cpp/actors/core/event_pb_payload_ut.cpp index 8d0d50d885..eab007bc15 100644 --- a/library/cpp/actors/core/event_pb_payload_ut.cpp +++ b/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))); diff --git a/library/cpp/actors/core/scheduler_actor_ut.cpp b/library/cpp/actors/core/scheduler_actor_ut.cpp index fff059ef94..09b7369d36 100644 --- a/library/cpp/actors/core/scheduler_actor_ut.cpp +++ b/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]); diff --git a/library/cpp/actors/dnscachelib/dnscache.cpp b/library/cpp/actors/dnscachelib/dnscache.cpp index 0c9e5b8c35..649339ddb2 100644 --- a/library/cpp/actors/dnscachelib/dnscache.cpp +++ b/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)); } } } diff --git a/library/cpp/actors/http/http_proxy_incoming.cpp b/library/cpp/actors/http/http_proxy_incoming.cpp index a464a5d81a..80fe2af53d 100644 --- a/library/cpp/actors/http/http_proxy_incoming.cpp +++ b/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; diff --git a/library/cpp/actors/http/http_proxy_outgoing.cpp b/library/cpp/actors/http/http_proxy_outgoing.cpp index 16584916a7..d9189dba8a 100644 --- a/library/cpp/actors/http/http_proxy_outgoing.cpp +++ b/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); } diff --git a/library/cpp/actors/http/http_proxy_sock_impl.h b/library/cpp/actors/http/http_proxy_sock_impl.h index caaa2b7e2f..bf8c71d05a 100644 --- a/library/cpp/actors/http/http_proxy_sock_impl.h +++ b/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()); diff --git a/library/cpp/actors/http/http_ut.cpp b/library/cpp/actors/http/http_ut.cpp index aa2edf2492..4c922f8d0f 100644 --- a/library/cpp/actors/http/http_ut.cpp +++ b/library/cpp/actors/http/http_ut.cpp @@ -275,7 +275,7 @@ CRA/5XcX13GJwHHj6LCoc3sL7mt8qV9HKY2AOZ88mpObzISZxgPpdKCfjsrdm63V NActors::IActor* proxy = NHttp::CreateHttpProxy(sensors); NActors::TActorId proxyId = actorSystem.Register(proxy); - THolder<NHttp::TEvHttpProxy::TEvAddListeningPort> add = MakeHolder<NHttp::TEvHttpProxy::TEvAddListeningPort>(port); + THolder<NHttp::TEvHttpProxy::TEvAddListeningPort> add = MakeHolder<NHttp::TEvHttpProxy::TEvAddListeningPort>(port); ///////// https configuration add->Secure = true; add->CertificateFile = certificateFile.Name(); @@ -305,7 +305,7 @@ CRA/5XcX13GJwHHj6LCoc3sL7mt8qV9HKY2AOZ88mpObzISZxgPpdKCfjsrdm63V } /*Y_UNIT_TEST(AdvancedRunning) { - THolder<NActors::TActorSystemSetup> setup = MakeHolder<NActors::TActorSystemSetup>(); + THolder<NActors::TActorSystemSetup> setup = MakeHolder<NActors::TActorSystemSetup>(); setup->NodeId = 1; setup->ExecutorsCount = 1; setup->Executors = new TAutoPtr<NActors::IExecutorPool>[1]; @@ -320,7 +320,7 @@ CRA/5XcX13GJwHHj6LCoc3sL7mt8qV9HKY2AOZ88mpObzISZxgPpdKCfjsrdm63V NHttp::THttpProxy* outgoingProxy = new NHttp::THttpProxy(); NActors::TActorId outgoingProxyId = actorSystem.Register(outgoingProxy); - THolder<NHttp::THttpStaticStringRequest> httpRequest = MakeHolder<NHttp::THttpStaticStringRequest>("GET /test HTTP/1.1\r\n\r\n"); + THolder<NHttp::THttpStaticStringRequest> httpRequest = MakeHolder<NHttp::THttpStaticStringRequest>("GET /test HTTP/1.1\r\n\r\n"); actorSystem.Send(outgoingProxyId, new NHttp::TEvHttpProxy::TEvHttpOutgoingRequest("[::]:13337", std::move(httpRequest))); Sleep(TDuration::Minutes(60)); diff --git a/library/cpp/actors/testlib/test_runtime.h b/library/cpp/actors/testlib/test_runtime.h index a05e292911..26e3b45c98 100644 --- a/library/cpp/actors/testlib/test_runtime.h +++ b/library/cpp/actors/testlib/test_runtime.h @@ -364,7 +364,7 @@ namespace NActors { TAutoPtr<IEventHandle> handle; std::function<bool(const TEvent&)> truth = [](const TEvent&) { return true; }; GrabEdgeEventIf(handle, truth, simTimeout); - return THolder(handle ? handle->Release<TEvent>().Release() : nullptr); + return THolder(handle ? handle->Release<TEvent>().Release() : nullptr); } template<class TEvent> @@ -707,7 +707,7 @@ namespace NActors { using TReplyCheckerCreator = std::function<THolder<IReplyChecker>(void)>; inline THolder<IReplyChecker> CreateNoneReplyChecker() { - return MakeHolder<TNoneReplyChecker>(); + return MakeHolder<TNoneReplyChecker>(); } TAutoPtr<IStrandingDecoratorFactory> CreateStrandingDecoratorFactory(TTestActorRuntimeBase* runtime, |