aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/http/server/http.cpp
diff options
context:
space:
mode:
authorcherenkov-p-a <cherenkov-p-a@yandex-team.ru>2022-02-10 16:49:39 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:49:39 +0300
commit8124e2bb214b063687e0d77c900150c727e16782 (patch)
tree5d5cb817648f650d76cf1076100726fd9b8448e8 /library/cpp/http/server/http.cpp
parent9011d1fa16370ec024d20180d440f7ae6fd0e1c8 (diff)
downloadydb-8124e2bb214b063687e0d77c900150c727e16782.tar.gz
Restoring authorship annotation for <cherenkov-p-a@yandex-team.ru>. Commit 2 of 2.
Diffstat (limited to 'library/cpp/http/server/http.cpp')
-rw-r--r--library/cpp/http/server/http.cpp8
1 files changed, 4 insertions, 4 deletions
diff --git a/library/cpp/http/server/http.cpp b/library/cpp/http/server/http.cpp
index 12bf48a354..128583bdd7 100644
--- a/library/cpp/http/server/http.cpp
+++ b/library/cpp/http/server/http.cpp
@@ -68,7 +68,7 @@ public:
bool Reject_ = false;
TInstant LastUsed;
TInstant AcceptMoment;
- size_t ReceivedRequests = 0;
+ size_t ReceivedRequests = 0;
};
class THttpServer::TImpl {
@@ -597,7 +597,7 @@ void TClientConnection::OnPollEvent(TInstant now) {
void TClientConnection::Activate(TInstant now) noexcept {
HttpServ_->Connections->Erase(this, now);
LastUsed = now;
- ++ReceivedRequests;
+ ++ReceivedRequests;
}
void TClientConnection::DeActivate() {
@@ -690,8 +690,8 @@ void TClientRequest::Process(void* ThreadSpecificResource) {
HttpConn_.Reset(new THttpServerConn(Socket()));
}
- auto maxRequestsPerConnection = HttpServ()->Options().MaxRequestsPerConnection;
- HttpConn_->Output()->EnableKeepAlive(HttpServ()->Options().KeepAliveEnabled && (!maxRequestsPerConnection || Conn_->ReceivedRequests < maxRequestsPerConnection));
+ auto maxRequestsPerConnection = HttpServ()->Options().MaxRequestsPerConnection;
+ HttpConn_->Output()->EnableKeepAlive(HttpServ()->Options().KeepAliveEnabled && (!maxRequestsPerConnection || Conn_->ReceivedRequests < maxRequestsPerConnection));
HttpConn_->Output()->EnableCompression(HttpServ()->Options().CompressionEnabled);
}