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 | 38b4bd28ca420294f532ac7ca6b2770d60e3dfd0 (patch) | |
tree | 7570cb7cabf97af7ecb6ffe485e8037d516daa29 /library | |
parent | a0ffafe83b7d6229709a32fa942c71d672ac989c (diff) | |
download | ydb-38b4bd28ca420294f532ac7ca6b2770d60e3dfd0.tar.gz |
Restoring authorship annotation for <timestep@yandex-team.ru>. Commit 1 of 2.
Diffstat (limited to 'library')
45 files changed, 89 insertions, 89 deletions
diff --git a/library/cpp/actors/core/actor_coroutine.h b/library/cpp/actors/core/actor_coroutine.h index 6bcb768eaf..71f020bc12 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 951512b877..9456ce67a1 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 0054c9a906..7ba8d15e47 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 e72ebdba9b..3bf54035d4 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 eab007bc15..8d0d50d885 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 09b7369d36..fff059ef94 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 649339ddb2..0c9e5b8c35 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 80fe2af53d..a464a5d81a 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 d9189dba8a..16584916a7 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 bf8c71d05a..caaa2b7e2f 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 4c922f8d0f..aa2edf2492 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 26e3b45c98..a05e292911 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, diff --git a/library/cpp/codecs/greedy_dict/gd_builder.cpp b/library/cpp/codecs/greedy_dict/gd_builder.cpp index 561bfbca01..11072e889d 100644 --- a/library/cpp/codecs/greedy_dict/gd_builder.cpp +++ b/library/cpp/codecs/greedy_dict/gd_builder.cpp @@ -11,7 +11,7 @@ namespace NGreedyDict { void TDictBuilder::RebuildCounts(ui32 maxcand, bool final) { if (!Current) { - Current = MakeHolder<TEntrySet>(); + Current = MakeHolder<TEntrySet>(); Current->InitWithAlpha(); } @@ -24,7 +24,7 @@ namespace NGreedyDict { CompoundCountsPool.Clear(); if (!final) { - CompoundCounts = MakeHolder<TCompoundCounts>(&CompoundCountsPool); + CompoundCounts = MakeHolder<TCompoundCounts>(&CompoundCountsPool); CompoundCounts->reserve(maxcand); } diff --git a/library/cpp/containers/comptrie/pattern_searcher.h b/library/cpp/containers/comptrie/pattern_searcher.h index caab51dc1c..e9c45e2b2e 100644 --- a/library/cpp/containers/comptrie/pattern_searcher.h +++ b/library/cpp/containers/comptrie/pattern_searcher.h @@ -42,7 +42,7 @@ public: public: TCompactPatternSearcherBuilder() { - TBase::Impl = MakeHolder<TCompactPatternSearcherBuilderImpl>(); + TBase::Impl = MakeHolder<TCompactPatternSearcherBuilderImpl>(); } bool Add(const TSymbol* key, size_t keyLength, const TData& value) { diff --git a/library/cpp/coroutine/engine/cont_poller.h b/library/cpp/coroutine/engine/cont_poller.h index b638b2df1a..2211ef3a9f 100644 --- a/library/cpp/coroutine/engine/cont_poller.h +++ b/library/cpp/coroutine/engine/cont_poller.h @@ -111,7 +111,7 @@ namespace NCoro { T* Get(size_t index) { TRef& ret = Lst_.Get(index); if (!ret) { - ret = TRef(new (&Pool_) TValue()); + ret = TRef(new (&Pool_) TValue()); } return ret.Get(); } diff --git a/library/cpp/coroutine/listener/listen.cpp b/library/cpp/coroutine/listener/listen.cpp index 3d4e711d1d..d327847bcb 100644 --- a/library/cpp/coroutine/listener/listen.cpp +++ b/library/cpp/coroutine/listener/listen.cpp @@ -234,10 +234,10 @@ public: switch (sa.Sa->sa_family) { case AF_INET: - L_.PushBack(new TOneSocketListener(this, MakeHolder<TIPv4Addr>(*sa.In))); + L_.PushBack(new TOneSocketListener(this, MakeHolder<TIPv4Addr>(*sa.In))); break; case AF_INET6: - L_.PushBack(new TOneSocketListener(this, MakeHolder<TIPv6Addr>(*sa.In6))); + L_.PushBack(new TOneSocketListener(this, MakeHolder<TIPv6Addr>(*sa.In6))); break; default: ythrow yexception() << TStringBuf("unknown protocol"); @@ -245,12 +245,12 @@ public: } inline void Bind(const TIpAddress& addr) { - L_.PushBack(new TOneSocketListener(this, MakeHolder<TIPv4Addr>(addr))); + L_.PushBack(new TOneSocketListener(this, MakeHolder<TIPv4Addr>(addr))); } inline void Bind(const TNetworkAddress& addr) { for (TNetworkAddress::TIterator it = addr.Begin(); it != addr.End(); ++it) { - L_.PushBack(new TOneSocketListener(this, MakeHolder<TStoredAddrInfo>(&*it, addr))); + L_.PushBack(new TOneSocketListener(this, MakeHolder<TStoredAddrInfo>(&*it, addr))); } } diff --git a/library/cpp/digest/md5/md5_medium_ut.cpp b/library/cpp/digest/md5/md5_medium_ut.cpp index a940c5cb66..33e6fea0a2 100644 --- a/library/cpp/digest/md5/md5_medium_ut.cpp +++ b/library/cpp/digest/md5/md5_medium_ut.cpp @@ -6,7 +6,7 @@ Y_UNIT_TEST_SUITE(TMD5MediumTest) { Y_UNIT_TEST(TestOverflow) { if (sizeof(size_t) > sizeof(unsigned int)) { const size_t maxUi32 = (size_t)Max<unsigned int>(); - TArrayHolder<char> buf(new char[maxUi32]); + TArrayHolder<char> buf(new char[maxUi32]); memset(buf.Get(), 0, maxUi32); diff --git a/library/cpp/getopt/small/completer_command.cpp b/library/cpp/getopt/small/completer_command.cpp index 5e593eec7e..8621bce58e 100644 --- a/library/cpp/getopt/small/completer_command.cpp +++ b/library/cpp/getopt/small/completer_command.cpp @@ -160,6 +160,6 @@ namespace NLastGetopt { }; THolder<TMainClassArgs> MakeCompletionMod(const TModChooser* modChooser, TString command, TString modName) { - return MakeHolder<TCompleterMode>(modChooser, std::move(command), std::move(modName)); + return MakeHolder<TCompleterMode>(modChooser, std::move(command), std::move(modName)); } } diff --git a/library/cpp/getopt/small/modchooser.cpp b/library/cpp/getopt/small/modchooser.cpp index 2fa5cfd070..3af79856aa 100644 --- a/library/cpp/getopt/small/modchooser.cpp +++ b/library/cpp/getopt/small/modchooser.cpp @@ -89,12 +89,12 @@ void TModChooser::AddMode(const TString& mode, const TMainFunctionRawPtrV func, } void TModChooser::AddMode(const TString& mode, const TMainFunctionPtr func, const TString& description, bool hidden, bool noCompletion) { - Wrappers.push_back(MakeHolder<PtrWrapper>(func)); + Wrappers.push_back(MakeHolder<PtrWrapper>(func)); AddMode(mode, Wrappers.back().Get(), description, hidden, noCompletion); } void TModChooser::AddMode(const TString& mode, const TMainFunctionPtrV func, const TString& description, bool hidden, bool noCompletion) { - Wrappers.push_back(MakeHolder<PtrvWrapper>(func)); + Wrappers.push_back(MakeHolder<PtrvWrapper>(func)); AddMode(mode, Wrappers.back().Get(), description, hidden, noCompletion); } @@ -103,11 +103,11 @@ void TModChooser::AddMode(const TString& mode, TMainClass* func, const TString& ythrow yexception() << "TMode '" << mode << "' already exists in TModChooser."; } - Modes[mode] = UnsortedModes.emplace_back(MakeHolder<TMode>(mode, func, description, hidden, noCompletion)).Get(); + Modes[mode] = UnsortedModes.emplace_back(MakeHolder<TMode>(mode, func, description, hidden, noCompletion)).Get(); } void TModChooser::AddMode(const TString& mode, TMainClassV* func, const TString& description, bool hidden, bool noCompletion) { - Wrappers.push_back(MakeHolder<ClassWrapper>(func)); + Wrappers.push_back(MakeHolder<ClassWrapper>(func)); AddMode(mode, Wrappers.back().Get(), description, hidden, noCompletion); } diff --git a/library/cpp/http/server/http_ut.cpp b/library/cpp/http/server/http_ut.cpp index cc62bb988e..b8da3c4c35 100644 --- a/library/cpp/http/server/http_ut.cpp +++ b/library/cpp/http/server/http_ut.cpp @@ -167,7 +167,7 @@ Y_UNIT_TEST_SUITE(THttpServerTest) { THolder<TSocket> singleReqSocket; if (KeepAliveConnection) { if (!KeepAlivedSocket) { - KeepAlivedSocket = MakeHolder<TSocket>(TNetworkAddress("localhost", Port), TDuration::Seconds(10)); + KeepAlivedSocket = MakeHolder<TSocket>(TNetworkAddress("localhost", Port), TDuration::Seconds(10)); } s = KeepAlivedSocket.Get(); } else { @@ -711,7 +711,7 @@ Y_UNIT_TEST_SUITE(THttpServerTest) { for (size_t i = 0; i < 3; ++i) { auto func = [&server, port, keepAlive]() { server.BusyThread(); - THolder<TTestRequest> r = MakeHolder<TTestRequest>(port); + THolder<TTestRequest> r = MakeHolder<TTestRequest>(port); r->KeepAliveConnection = keepAlive; r->Execute(); }; diff --git a/library/cpp/logger/element_ut.cpp b/library/cpp/logger/element_ut.cpp index 32edc52dfb..03a7b2eb36 100644 --- a/library/cpp/logger/element_ut.cpp +++ b/library/cpp/logger/element_ut.cpp @@ -22,14 +22,14 @@ UNIT_TEST_SUITE_REGISTRATION(TLogElementTest); void TLogElementTest::TestMoveCtor() { TStringStream output; - TLog log(MakeHolder<TStreamLogBackend>(&output)); + TLog log(MakeHolder<TStreamLogBackend>(&output)); - THolder<TLogElement> src = MakeHolder<TLogElement>(&log); + THolder<TLogElement> src = MakeHolder<TLogElement>(&log); TString message = "Hello, World!"; (*src) << message; - THolder<TLogElement> dst = MakeHolder<TLogElement>(std::move(*src)); + THolder<TLogElement> dst = MakeHolder<TLogElement>(std::move(*src)); src.Destroy(); UNIT_ASSERT(output.Str() == ""); diff --git a/library/cpp/logger/global/global.cpp b/library/cpp/logger/global/global.cpp index 9fbd10f666..1532ee2d57 100644 --- a/library/cpp/logger/global/global.cpp +++ b/library/cpp/logger/global/global.cpp @@ -19,7 +19,7 @@ void DoInitGlobalLog(const TString& logType, const int logLevel, const bool rota } void DoInitGlobalLog(THolder<TLogBackend> backend, THolder<ILoggerFormatter> formatter) { - DoInitGlobalLog(THolder(new TGlobalLog(std::move(backend))), std::move(formatter)); + DoInitGlobalLog(THolder(new TGlobalLog(std::move(backend))), std::move(formatter)); } bool GlobalLogInitialized() { diff --git a/library/cpp/logger/log.cpp b/library/cpp/logger/log.cpp index e1d70cc3d2..4073ae924f 100644 --- a/library/cpp/logger/log.cpp +++ b/library/cpp/logger/log.cpp @@ -208,7 +208,7 @@ bool TLog::OpenLog(const char* path, ELogPriority lp) { if (path) { ResetBackend(CreateLogBackend(path, lp)); } else { - ResetBackend(MakeHolder<TStreamLogBackend>(&Cerr)); + ResetBackend(MakeHolder<TStreamLogBackend>(&Cerr)); } return true; diff --git a/library/cpp/logger/log_ut.cpp b/library/cpp/logger/log_ut.cpp index 8de46f17f5..be750de918 100644 --- a/library/cpp/logger/log_ut.cpp +++ b/library/cpp/logger/log_ut.cpp @@ -62,7 +62,7 @@ void TLogTest::TestFile() { void TLogTest::TestThreaded() { { TFileLogBackend fb(LOGFILE); - TLog log(THolder(new TThreadedLogBackend(&fb))); + TLog log(THolder(new TThreadedLogBackend(&fb))); int v1 = 12; unsigned v2 = 34; @@ -106,7 +106,7 @@ void TLogTest::TestThreadedWithOverflow() { TFakeLogBackend fb; { - TLog log(THolder(new TThreadedLogBackend(&fb, 2))); + TLog log(THolder(new TThreadedLogBackend(&fb, 2))); auto guard = fb.Guard(); log.AddLog("first write"); @@ -118,7 +118,7 @@ void TLogTest::TestThreadedWithOverflow() { { ui32 overflows = 0; - TLog log(THolder(new TThreadedLogBackend(&fb, 2, [&overflows] { ++overflows; }))); + TLog log(THolder(new TThreadedLogBackend(&fb, 2, [&overflows] { ++overflows; }))); auto guard = fb.Guard(); log.AddLog("first write"); @@ -134,7 +134,7 @@ void TLogTest::TestThreadedWithOverflow() { void TLogTest::TestNoFlush() { { TFileLogBackend fb(LOGFILE); - TLog log(THolder(new TThreadedLogBackend(&fb))); + TLog log(THolder(new TThreadedLogBackend(&fb))); int v1 = 12; unsigned v2 = 34; @@ -154,7 +154,7 @@ void TLogTest::TestFormat() { TStringStream data; { - TLog log(THolder(new TStreamLogBackend(&data))); + TLog log(THolder(new TStreamLogBackend(&data))); log << "qw" << " " @@ -169,7 +169,7 @@ void TLogTest::TestWrite() { TString test; { - TLog log(THolder(new TStreamLogBackend(&data))); + TLog log(THolder(new TStreamLogBackend(&data))); for (size_t i = 0; i < 1000; ++i) { TVector<char> buf(i, (char)i); diff --git a/library/cpp/logger/system.cpp b/library/cpp/logger/system.cpp index 42233f63d2..25e3d8fd4e 100644 --- a/library/cpp/logger/system.cpp +++ b/library/cpp/logger/system.cpp @@ -76,7 +76,7 @@ namespace { class TSysLogInstance: public TLog { public: inline TSysLogInstance() - : TLog(MakeHolder<TStreamLogBackend>(&Cnull)) + : TLog(MakeHolder<TStreamLogBackend>(&Cnull)) { } }; diff --git a/library/cpp/logger/system.h b/library/cpp/logger/system.h index b8c60b3023..545e0be377 100644 --- a/library/cpp/logger/system.h +++ b/library/cpp/logger/system.h @@ -8,8 +8,8 @@ #define YSYSLOGINIT_FLAGS(ident, facility, flags) \ struct TLogIniter { \ TLogIniter() { \ - SysLogInstance().ResetBackend(THolder<TLogBackend>( \ - (ident) ? (TLogBackend*)(new TSysLogBackend((ident), (facility), (flags))) : (TLogBackend*)(new TNullLogBackend())));\ + SysLogInstance().ResetBackend(THolder<TLogBackend>( \ + (ident) ? (TLogBackend*)(new TSysLogBackend((ident), (facility), (flags))) : (TLogBackend*)(new TNullLogBackend())));\ } \ } Y_CAT(loginit, __LINE__); diff --git a/library/cpp/lwtrace/mon/mon_lwtrace.cpp b/library/cpp/lwtrace/mon/mon_lwtrace.cpp index a61ee9ce22..ac5b63a5c8 100644 --- a/library/cpp/lwtrace/mon/mon_lwtrace.cpp +++ b/library/cpp/lwtrace/mon/mon_lwtrace.cpp @@ -4672,7 +4672,7 @@ private: }; void RegisterPages(NMonitoring::TMonService2* mon, bool allowUnsafe) { - THolder<NLwTraceMonPage::TLWTraceMonPage> p = MakeHolder<NLwTraceMonPage::TLWTraceMonPage>(allowUnsafe); + THolder<NLwTraceMonPage::TLWTraceMonPage> p = MakeHolder<NLwTraceMonPage::TLWTraceMonPage>(allowUnsafe); mon->Register(p.Release()); #define WWW_STATIC_FILE(file, type) \ diff --git a/library/cpp/messagebus/moved_ut.cpp b/library/cpp/messagebus/moved_ut.cpp index c1a07cce7e..df91f00287 100644 --- a/library/cpp/messagebus/moved_ut.cpp +++ b/library/cpp/messagebus/moved_ut.cpp @@ -4,7 +4,7 @@ Y_UNIT_TEST_SUITE(TMovedTest) { Y_UNIT_TEST(Simple) { - TMoved<THolder<int>> h1(MakeHolder<int>(10)); + TMoved<THolder<int>> h1(MakeHolder<int>(10)); TMoved<THolder<int>> h2 = h1; UNIT_ASSERT(!*h1); UNIT_ASSERT(!!*h2); diff --git a/library/cpp/monlib/dynamic_counters/encode.cpp b/library/cpp/monlib/dynamic_counters/encode.cpp index ffa48d276e..265a505fb6 100644 --- a/library/cpp/monlib/dynamic_counters/encode.cpp +++ b/library/cpp/monlib/dynamic_counters/encode.cpp @@ -98,9 +98,9 @@ namespace NMonitoring { THolder<ICountableConsumer> CreateEncoder(IOutputStream* out, EFormat format, TCountableBase::EVisibility vis) { switch (format) { case EFormat::JSON: - return MakeHolder<TConsumer>(NMonitoring::EncoderJson(out), vis); + return MakeHolder<TConsumer>(NMonitoring::EncoderJson(out), vis); case EFormat::SPACK: - return MakeHolder<TConsumer>(NMonitoring::EncoderSpackV1( + return MakeHolder<TConsumer>(NMonitoring::EncoderSpackV1( out, NMonitoring::ETimePrecision::SECONDS, NMonitoring::ECompression::ZSTD), vis); diff --git a/library/cpp/monlib/encode/fake/fake.cpp b/library/cpp/monlib/encode/fake/fake.cpp index 69d691361a..6400366235 100644 --- a/library/cpp/monlib/encode/fake/fake.cpp +++ b/library/cpp/monlib/encode/fake/fake.cpp @@ -46,6 +46,6 @@ namespace NMonitoring { }; IMetricEncoderPtr EncoderFake() { - return MakeHolder<TFakeEncoder>(); + return MakeHolder<TFakeEncoder>(); } } diff --git a/library/cpp/monlib/encode/protobuf/protobuf_encoder.cpp b/library/cpp/monlib/encode/protobuf/protobuf_encoder.cpp index 2d11b9d5ba..c272deb676 100644 --- a/library/cpp/monlib/encode/protobuf/protobuf_encoder.cpp +++ b/library/cpp/monlib/encode/protobuf/protobuf_encoder.cpp @@ -238,11 +238,11 @@ namespace NMonitoring { } IMetricEncoderPtr EncoderProtobuf(NProto::TSingleSamplesList* samples) { - return MakeHolder<TSingleSamplesEncoder>(samples); + return MakeHolder<TSingleSamplesEncoder>(samples); } IMetricEncoderPtr EncoderProtobuf(NProto::TMultiSamplesList* samples) { - return MakeHolder<TMultiSamplesEncoder>(samples); + return MakeHolder<TMultiSamplesEncoder>(samples); } } diff --git a/library/cpp/monlib/encode/spack/compression.cpp b/library/cpp/monlib/encode/spack/compression.cpp index 0d2152fc85..52ac65bc86 100644 --- a/library/cpp/monlib/encode/spack/compression.cpp +++ b/library/cpp/monlib/encode/spack/compression.cpp @@ -353,11 +353,11 @@ namespace NMonitoring { case ECompression::IDENTITY: return nullptr; case ECompression::ZLIB: - return MakeHolder<TFramedDecompressStream<TZlibCodec, TAdler32>>(in); + return MakeHolder<TFramedDecompressStream<TZlibCodec, TAdler32>>(in); case ECompression::ZSTD: - return MakeHolder<TFramedDecompressStream<TZstdCodec, TXxHash32>>(in); + return MakeHolder<TFramedDecompressStream<TZstdCodec, TXxHash32>>(in); case ECompression::LZ4: - return MakeHolder<TFramedDecompressStream<TLz4Codec, TXxHash32>>(in); + return MakeHolder<TFramedDecompressStream<TLz4Codec, TXxHash32>>(in); case ECompression::UNKNOWN: return nullptr; } @@ -369,11 +369,11 @@ namespace NMonitoring { case ECompression::IDENTITY: return nullptr; case ECompression::ZLIB: - return MakeHolder<TFramedCompressStream<TZlibCodec, TAdler32>>(out); + return MakeHolder<TFramedCompressStream<TZlibCodec, TAdler32>>(out); case ECompression::ZSTD: - return MakeHolder<TFramedCompressStream<TZstdCodec, TXxHash32>>(out); + return MakeHolder<TFramedCompressStream<TZstdCodec, TXxHash32>>(out); case ECompression::LZ4: - return MakeHolder<TFramedCompressStream<TLz4Codec, TXxHash32>>(out); + return MakeHolder<TFramedCompressStream<TLz4Codec, TXxHash32>>(out); case ECompression::UNKNOWN: return nullptr; } diff --git a/library/cpp/monlib/encode/text/text_encoder.cpp b/library/cpp/monlib/encode/text/text_encoder.cpp index 10336261f0..00b0598e24 100644 --- a/library/cpp/monlib/encode/text/text_encoder.cpp +++ b/library/cpp/monlib/encode/text/text_encoder.cpp @@ -220,7 +220,7 @@ namespace NMonitoring { } IMetricEncoderPtr EncoderText(IOutputStream* out, bool humanReadableTs) { - return MakeHolder<TEncoderText>(out, humanReadableTs); + return MakeHolder<TEncoderText>(out, humanReadableTs); } } diff --git a/library/cpp/monlib/metrics/fake.cpp b/library/cpp/monlib/metrics/fake.cpp index b6f5e37af8..6a149a93c3 100644 --- a/library/cpp/monlib/metrics/fake.cpp +++ b/library/cpp/monlib/metrics/fake.cpp @@ -84,7 +84,7 @@ namespace NMonitoring { { TWriteGuard g{Lock_}; - IMetricPtr metric = MakeHolder<TMetric>(std::forward<Args>(args)...); + IMetricPtr metric = MakeHolder<TMetric>(std::forward<Args>(args)...); // decltype(Metrics_)::iterator breaks build on windows THashMap<ILabelsPtr, IMetricPtr>::iterator it; diff --git a/library/cpp/monlib/metrics/histogram_collector_explicit.cpp b/library/cpp/monlib/metrics/histogram_collector_explicit.cpp index 377fc233ef..867846980c 100644 --- a/library/cpp/monlib/metrics/histogram_collector_explicit.cpp +++ b/library/cpp/monlib/metrics/histogram_collector_explicit.cpp @@ -50,6 +50,6 @@ namespace NMonitoring { Y_ENSURE(IsSorted(bounds.begin(), bounds.end()), "bounds for explicit histogram must be sorted"); - return MakeHolder<TExplicitHistogramCollector>(bounds); + return MakeHolder<TExplicitHistogramCollector>(bounds); } } diff --git a/library/cpp/monlib/metrics/histogram_collector_linear.cpp b/library/cpp/monlib/metrics/histogram_collector_linear.cpp index f8ad86f3a4..f845f9d386 100644 --- a/library/cpp/monlib/metrics/histogram_collector_linear.cpp +++ b/library/cpp/monlib/metrics/histogram_collector_linear.cpp @@ -62,6 +62,6 @@ namespace NMonitoring { << ", but got: " << bucketsCount); Y_ENSURE(bucketWidth >= 1, "bucketWidth must be >= 1, got: " << bucketWidth); - return MakeHolder<TLinearHistogramCollector>(bucketsCount, startValue, bucketWidth); + return MakeHolder<TLinearHistogramCollector>(bucketsCount, startValue, bucketWidth); } } diff --git a/library/cpp/monlib/service/auth.cpp b/library/cpp/monlib/service/auth.cpp index ddabcfbbf7..2a068970ea 100644 --- a/library/cpp/monlib/service/auth.cpp +++ b/library/cpp/monlib/service/auth.cpp @@ -15,7 +15,7 @@ namespace { } // namespace THolder<IAuthProvider> CreateFakeAuth() { - return MakeHolder<TFakeAuthProvider>(); + return MakeHolder<TFakeAuthProvider>(); } diff --git a/library/cpp/monlib/service/pages/index_mon_page.cpp b/library/cpp/monlib/service/pages/index_mon_page.cpp index 83ff8b529a..84d36d1be0 100644 --- a/library/cpp/monlib/service/pages/index_mon_page.cpp +++ b/library/cpp/monlib/service/pages/index_mon_page.cpp @@ -44,7 +44,7 @@ void TIndexMonPage::Output(IMonHttpRequest& request) { } } if (found) { - THolder<IMonHttpRequest> child(request.MakeChild(found.Get(), TString{pathInfo})); + THolder<IMonHttpRequest> child(request.MakeChild(found.Get(), TString{pathInfo})); found->Output(*child); } else { request.Output() << HTTPNOTFOUND; diff --git a/library/cpp/openssl/io/stream.cpp b/library/cpp/openssl/io/stream.cpp index 0b4be38c0e..f7aad42067 100644 --- a/library/cpp/openssl/io/stream.cpp +++ b/library/cpp/openssl/io/stream.cpp @@ -282,11 +282,11 @@ public: TBuiltinCerts() { TString c = NResource::Find("/builtin/cacert"); - TBioPtr cbio(BIO_new_mem_buf(c.data(), c.size())); + TBioPtr cbio(BIO_new_mem_buf(c.data(), c.size())); Y_ENSURE_EX(cbio, TSslError() << "BIO_new_mem_buf"); while (true) { - TX509Ptr cert(PEM_read_bio_X509(cbio.Get(), nullptr, nullptr, nullptr)); + TX509Ptr cert(PEM_read_bio_X509(cbio.Get(), nullptr, nullptr, nullptr)); if (!cert) { break; } @@ -304,7 +304,7 @@ public: } TOpenSslX509StorePtr GetX509Store() const { - TOpenSslX509StorePtr store(X509_STORE_new()); + TOpenSslX509StorePtr store(X509_STORE_new()); for (const TX509Ptr& c : Certs) { if (0 == X509_STORE_add_cert(store.Get(), c.Get())) { diff --git a/library/cpp/protobuf/json/json_output_create.cpp b/library/cpp/protobuf/json/json_output_create.cpp index 378e4ea65a..40f5d4c6ad 100644 --- a/library/cpp/protobuf/json/json_output_create.cpp +++ b/library/cpp/protobuf/json/json_output_create.cpp @@ -6,27 +6,27 @@ namespace NProtobufJson { TJsonMapOutputPtr CreateJsonMapOutput(IOutputStream& out, const NJson::TJsonWriterConfig& config) { - return MakeHolder<TJsonWriterOutput>(&out, config); + return MakeHolder<TJsonWriterOutput>(&out, config); } TJsonMapOutputPtr CreateJsonMapOutput(NJson::TJsonWriter& writer) { - return MakeHolder<TBaseJsonWriterOutput>(writer); + return MakeHolder<TBaseJsonWriterOutput>(writer); } TJsonMapOutputPtr CreateJsonMapOutput(TString& str, const TProto2JsonConfig& config) { - return MakeHolder<TJsonStringWriterOutput>(&str, config); + return MakeHolder<TJsonStringWriterOutput>(&str, config); } TJsonMapOutputPtr CreateJsonMapOutput(TStringStream& out, const TProto2JsonConfig& config) { - return MakeHolder<TJsonWriterOutput>(&out, config); + return MakeHolder<TJsonWriterOutput>(&out, config); } TJsonMapOutputPtr CreateJsonMapOutput(IOutputStream& out, const TProto2JsonConfig& config) { - return MakeHolder<TJsonWriterOutput>(&out, config); + return MakeHolder<TJsonWriterOutput>(&out, config); } TJsonMapOutputPtr CreateJsonMapOutput(NJson::TJsonValue& json) { - return MakeHolder<TJsonValueOutput>(json); + return MakeHolder<TJsonValueOutput>(json); } } diff --git a/library/cpp/scheme/scimpl_protobuf.cpp b/library/cpp/scheme/scimpl_protobuf.cpp index 0c99122c69..64a03a661d 100644 --- a/library/cpp/scheme/scimpl_protobuf.cpp +++ b/library/cpp/scheme/scimpl_protobuf.cpp @@ -316,7 +316,7 @@ namespace NSc { auto mutableField = reflection->GetMutableRepeatedFieldRef<Message>(&msg, field); for (const auto& value : fieldValue.GetDict()) { - THolder<Message> entry(mutableField.NewMessage()); + THolder<Message> entry(mutableField.NewMessage()); auto entryDesc = entry->GetDescriptor(); auto keyField = entryDesc->FindFieldByNumber(1); auto valueField = entryDesc->FindFieldByNumber(2); diff --git a/library/cpp/testing/unittest/registar.h b/library/cpp/testing/unittest/registar.h index 44517a0092..c19fbf9dd2 100644 --- a/library/cpp/testing/unittest/registar.h +++ b/library/cpp/testing/unittest/registar.h @@ -939,7 +939,7 @@ public: \ static void AddTest(const char* name, \ const std::function<void(NUnitTest::TTestContext&)>& body, bool forceFork) \ { \ - Tests().push_back([=]{ return MakeHolder<NUnitTest::TBaseTestCase>(name, body, forceFork); }); \ + Tests().push_back([=]{ return MakeHolder<NUnitTest::TBaseTestCase>(name, body, forceFork); }); \ } \ \ static void AddTest(TTestCaseFactory testCaseFactory) { \ diff --git a/library/cpp/testing/unittest/utmain.cpp b/library/cpp/testing/unittest/utmain.cpp index 305bc6b40f..c5d8e0cf7b 100644 --- a/library/cpp/testing/unittest/utmain.cpp +++ b/library/cpp/testing/unittest/utmain.cpp @@ -725,7 +725,7 @@ int NUnitTest::RunMain(int argc, char** argv) { processor.SetTraceProcessor(new TTraceWriterProcessor(argv[i], OpenAlways | ForAppend)); } else if (strcmp(name, "--list-path") == 0) { ++i; - listFile = MakeHolder<TFixedBufferFileOutput>(argv[i]); + listFile = MakeHolder<TFixedBufferFileOutput>(argv[i]); listStream = listFile.Get(); } else if (strcmp(name, "--test-param") == 0) { ++i; diff --git a/library/cpp/threading/equeue/equeue_ut.cpp b/library/cpp/threading/equeue/equeue_ut.cpp index 9cf2aced44..f80cef8646 100644 --- a/library/cpp/threading/equeue/equeue_ut.cpp +++ b/library/cpp/threading/equeue/equeue_ut.cpp @@ -15,7 +15,7 @@ Y_UNIT_TEST_SUITE(TElasticQueueTest) { struct TQueueSetup { TQueueSetup() { - Queue.Reset(new TElasticQueue(MakeHolder<TSimpleThreadPool>())); + Queue.Reset(new TElasticQueue(MakeHolder<TSimpleThreadPool>())); Queue->Start(ThreadCount, MaxQueueSize); } ~TQueueSetup() { diff --git a/library/cpp/yson/node/node.cpp b/library/cpp/yson/node/node.cpp index b39e070718..2c305d812e 100644 --- a/library/cpp/yson/node/node.cpp +++ b/library/cpp/yson/node/node.cpp @@ -846,7 +846,7 @@ void TNode::AssureList() void TNode::CreateAttributes() { - Attributes_ = MakeHolder<TNode>(); + Attributes_ = MakeHolder<TNode>(); Attributes_->Value_ = TMapType(); } |