aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/http/server
diff options
context:
space:
mode:
authoranelyubin <anelyubin@yandex-team.ru>2022-02-10 16:49:40 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:49:40 +0300
commit9dac44a55ede6f682527e82880847f99bd7b2d93 (patch)
tree5d5cb817648f650d76cf1076100726fd9b8448e8 /library/cpp/http/server
parent8d333d5e773f6b0ef31e7b3c92339af7e71413f6 (diff)
downloadydb-9dac44a55ede6f682527e82880847f99bd7b2d93.tar.gz
Restoring authorship annotation for <anelyubin@yandex-team.ru>. Commit 2 of 2.
Diffstat (limited to 'library/cpp/http/server')
-rw-r--r--library/cpp/http/server/http.cpp34
-rw-r--r--library/cpp/http/server/http.h2
2 files changed, 18 insertions, 18 deletions
diff --git a/library/cpp/http/server/http.cpp b/library/cpp/http/server/http.cpp
index 05da4d9f97..128583bdd7 100644
--- a/library/cpp/http/server/http.cpp
+++ b/library/cpp/http/server/http.cpp
@@ -397,15 +397,15 @@ public:
Requests->Start(Options_.nThreads, Options_.MaxQueueSize);
}
- TImpl(THttpServer* parent, ICallBack* cb, TMtpQueueRef mainWorkers, TMtpQueueRef failWorkers, const TOptions& options_)
+ TImpl(THttpServer* parent, ICallBack* cb, TMtpQueueRef mainWorkers, TMtpQueueRef failWorkers, const TOptions& options_)
: Requests(mainWorkers)
- , FailRequests(failWorkers)
- , Options_(options_)
- , Cb_(cb)
- , Parent_(parent)
- {
- }
-
+ , FailRequests(failWorkers)
+ , Options_(options_)
+ , Cb_(cb)
+ , Parent_(parent)
+ {
+ }
+
TImpl(THttpServer* parent, ICallBack* cb, const TOptions& options, IThreadFactory* factory)
: TImpl(
parent,
@@ -413,8 +413,8 @@ public:
MakeThreadPool<TSimpleThreadPool>(factory, options.UseElasticQueues, cb, options.RequestsThreadName),
MakeThreadPool<TThreadPool>(factory, options.UseElasticQueues, nullptr, options.FailRequestsThreadName),
options) {
- }
-
+ }
+
~TImpl() {
try {
Stop();
@@ -446,8 +446,8 @@ public:
TPipeHandle ListenWakeupReadFd;
TPipeHandle ListenWakeupWriteFd;
TSystemEvent ListenStartEvent;
- TMtpQueueRef Requests;
- TMtpQueueRef FailRequests;
+ TMtpQueueRef Requests;
+ TMtpQueueRef FailRequests;
TAtomic ConnectionCount = 0;
THolder<TSocketPoller> Poller;
THolder<TConnections> Connections;
@@ -487,11 +487,11 @@ THttpServer::THttpServer(ICallBack* cb, const TOptions& options, IThreadFactory*
{
}
-THttpServer::THttpServer(ICallBack* cb, TMtpQueueRef mainWorkers, TMtpQueueRef failWorkers, const TOptions& options)
- : Impl_(new TImpl(this, cb, mainWorkers, failWorkers, options))
-{
-}
-
+THttpServer::THttpServer(ICallBack* cb, TMtpQueueRef mainWorkers, TMtpQueueRef failWorkers, const TOptions& options)
+ : Impl_(new TImpl(this, cb, mainWorkers, failWorkers, options))
+{
+}
+
THttpServer::~THttpServer() {
}
diff --git a/library/cpp/http/server/http.h b/library/cpp/http/server/http.h
index 274f9c2d02..b292d38f27 100644
--- a/library/cpp/http/server/http.h
+++ b/library/cpp/http/server/http.h
@@ -65,7 +65,7 @@ public:
typedef TSimpleSharedPtr<IThreadPool> TMtpQueueRef;
THttpServer(ICallBack* cb, const TOptions& options = TOptions(), IThreadFactory* pool = nullptr);
- THttpServer(ICallBack* cb, TMtpQueueRef mainWorkers, TMtpQueueRef failWorkers, const TOptions& options = TOptions());
+ THttpServer(ICallBack* cb, TMtpQueueRef mainWorkers, TMtpQueueRef failWorkers, const TOptions& options = TOptions());
virtual ~THttpServer();
bool Start();