aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/actors
diff options
context:
space:
mode:
authortimestep <timestep@yandex-team.ru>2022-02-10 16:49:17 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:49:17 +0300
commit30f4921b0fa8722e5531e72cb40a93b526f6973a (patch)
tree5d5cb817648f650d76cf1076100726fd9b8448e8 /library/cpp/actors
parent38b4bd28ca420294f532ac7ca6b2770d60e3dfd0 (diff)
downloadydb-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.h2
-rw-r--r--library/cpp/actors/core/actor_coroutine_ut.cpp4
-rw-r--r--library/cpp/actors/core/ask.cpp2
-rw-r--r--library/cpp/actors/core/ask_ut.cpp12
-rw-r--r--library/cpp/actors/core/event_pb_payload_ut.cpp2
-rw-r--r--library/cpp/actors/core/scheduler_actor_ut.cpp2
-rw-r--r--library/cpp/actors/dnscachelib/dnscache.cpp8
-rw-r--r--library/cpp/actors/http/http_proxy_incoming.cpp2
-rw-r--r--library/cpp/actors/http/http_proxy_outgoing.cpp4
-rw-r--r--library/cpp/actors/http/http_proxy_sock_impl.h4
-rw-r--r--library/cpp/actors/http/http_ut.cpp6
-rw-r--r--library/cpp/actors/testlib/test_runtime.h4
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,