diff options
author | jimmy <jimmy@yandex-team.ru> | 2022-02-10 16:49:38 +0300 |
---|---|---|
committer | Daniil Cherednik <dcherednik@yandex-team.ru> | 2022-02-10 16:49:38 +0300 |
commit | affdafdb1fc09bf0bfc384355143ee6db9e90046 (patch) | |
tree | da80bda4720043db2e41dfd1c7fd04de32021fd3 /library/cpp/http/server | |
parent | 4e4faf8d95a4916a49f6674f3ff50e13799fbaa6 (diff) | |
download | ydb-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.cpp | 16 | ||||
-rw-r--r-- | library/cpp/http/server/http_ut.cpp | 8 |
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(); } } |