aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/http/server/http.cpp
diff options
context:
space:
mode:
authoranelyubin <anelyubin@yandex-team.ru>2022-02-10 16:49:39 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:49:39 +0300
commit8d333d5e773f6b0ef31e7b3c92339af7e71413f6 (patch)
treebe79c5bb4a39ab3410c17c33f1aff87810558f54 /library/cpp/http/server/http.cpp
parentad8c15be8c1a4f48a52390f23cb735060461684e (diff)
downloadydb-8d333d5e773f6b0ef31e7b3c92339af7e71413f6.tar.gz
Restoring authorship annotation for <anelyubin@yandex-team.ru>. Commit 1 of 2.
Diffstat (limited to 'library/cpp/http/server/http.cpp')
-rw-r--r--library/cpp/http/server/http.cpp34
1 files changed, 17 insertions, 17 deletions
diff --git a/library/cpp/http/server/http.cpp b/library/cpp/http/server/http.cpp
index 128583bdd7..05da4d9f97 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() {
}