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
commit9011d1fa16370ec024d20180d440f7ae6fd0e1c8 (patch)
treecd688a9e90e30e02212a6ecaf664209db01c4c36 /library/cpp/http/server/http.cpp
parent9700ce2289436b557831d64eb47682c8c2a30ee2 (diff)
downloadydb-9011d1fa16370ec024d20180d440f7ae6fd0e1c8.tar.gz
Restoring authorship annotation for <cherenkov-p-a@yandex-team.ru>. Commit 1 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 128583bdd7..12bf48a354 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);
}