aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/actors/http
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
commit38b4bd28ca420294f532ac7ca6b2770d60e3dfd0 (patch)
tree7570cb7cabf97af7ecb6ffe485e8037d516daa29 /library/cpp/actors/http
parenta0ffafe83b7d6229709a32fa942c71d672ac989c (diff)
downloadydb-38b4bd28ca420294f532ac7ca6b2770d60e3dfd0.tar.gz
Restoring authorship annotation for <timestep@yandex-team.ru>. Commit 1 of 2.
Diffstat (limited to 'library/cpp/actors/http')
-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
4 files changed, 8 insertions, 8 deletions
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));