aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/http/server
diff options
context:
space:
mode:
authorjimmy <jimmy@yandex-team.ru>2022-02-10 16:49:38 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:49:38 +0300
commitaffdafdb1fc09bf0bfc384355143ee6db9e90046 (patch)
treeda80bda4720043db2e41dfd1c7fd04de32021fd3 /library/cpp/http/server
parent4e4faf8d95a4916a49f6674f3ff50e13799fbaa6 (diff)
downloadydb-affdafdb1fc09bf0bfc384355143ee6db9e90046.tar.gz
Restoring authorship annotation for <jimmy@yandex-team.ru>. Commit 1 of 2.
Diffstat (limited to 'library/cpp/http/server')
-rw-r--r--library/cpp/http/server/http.cpp16
-rw-r--r--library/cpp/http/server/http_ut.cpp8
2 files changed, 12 insertions, 12 deletions
diff --git a/library/cpp/http/server/http.cpp b/library/cpp/http/server/http.cpp
index 128583bdd7..13e3832f53 100644
--- a/library/cpp/http/server/http.cpp
+++ b/library/cpp/http/server/http.cpp
@@ -197,8 +197,8 @@ public:
ListenStartEvent.Reset();
try {
- ListenThread.Reset(new TThread(ListenSocketFunction, this));
- ListenThread->Start();
+ ListenThread.Reset(new TThread(ListenSocketFunction, this));
+ ListenThread->Start();
} catch (const yexception&) {
SaveErrorCode();
return false;
@@ -214,9 +214,9 @@ public:
Cb_->OnWait();
TGuard<TMutex> g(StopMutex);
if (ListenThread) {
- ListenThread->Join();
+ ListenThread->Join();
ListenThread.Reset(nullptr);
- }
+ }
}
void Stop() {
@@ -224,9 +224,9 @@ public:
TGuard<TMutex> g(StopMutex);
if (ListenThread) {
- ListenThread->Join();
+ ListenThread->Join();
ListenThread.Reset(nullptr);
- }
+ }
while (ConnectionCount) {
usleep(10000);
@@ -398,7 +398,7 @@ public:
}
TImpl(THttpServer* parent, ICallBack* cb, TMtpQueueRef mainWorkers, TMtpQueueRef failWorkers, const TOptions& options_)
- : Requests(mainWorkers)
+ : Requests(mainWorkers)
, FailRequests(failWorkers)
, Options_(options_)
, Cb_(cb)
@@ -442,7 +442,7 @@ public:
return Options_.MaxConnections && ((size_t)GetClientCount() >= Options_.MaxConnections);
}
- THolder<TThread> ListenThread;
+ THolder<TThread> ListenThread;
TPipeHandle ListenWakeupReadFd;
TPipeHandle ListenWakeupWriteFd;
TSystemEvent ListenStartEvent;
diff --git a/library/cpp/http/server/http_ut.cpp b/library/cpp/http/server/http_ut.cpp
index cc62bb988e..a96f4ab68b 100644
--- a/library/cpp/http/server/http_ut.cpp
+++ b/library/cpp/http/server/http_ut.cpp
@@ -329,7 +329,7 @@ Y_UNIT_TEST_SUITE(THttpServerTest) {
TEchoServer serverImpl(res);
THttpServer server(&serverImpl, THttpServer::TOptions(port).EnableKeepAlive(true).EnableCompression(true));
- for (int i = 0; i < 2; ++i) {
+ for (int i = 0; i < 2; ++i) {
UNIT_ASSERT(server.Start());
TTestRequest r(port);
@@ -362,9 +362,9 @@ Y_UNIT_TEST_SUITE(THttpServerTest) {
}
}
}
- }
-
- server.Stop();
+ }
+
+ server.Stop();
}
}