diff options
author | atayan1 <atayan1@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 | c711d9aae73052830cd54065a75b3e3739893aba (patch) | |
tree | cef06878f1e78cd17308827f661e7bd19bd96d49 /library/cpp/http/server/http.cpp | |
parent | 5ab412f19b9312abbfa362391df45d6603bb84c3 (diff) | |
download | ydb-c711d9aae73052830cd54065a75b3e3739893aba.tar.gz |
Restoring authorship annotation for <atayan1@yandex-team.ru>. Commit 1 of 2.
Diffstat (limited to 'library/cpp/http/server/http.cpp')
-rw-r--r-- | library/cpp/http/server/http.cpp | 28 |
1 files changed, 14 insertions, 14 deletions
diff --git a/library/cpp/http/server/http.cpp b/library/cpp/http/server/http.cpp index 128583bdd7..115623490e 100644 --- a/library/cpp/http/server/http.cpp +++ b/library/cpp/http/server/http.cpp @@ -52,7 +52,7 @@ namespace { class TClientConnection: public IPollAble, public TIntrusiveListItem<TClientConnection> { public: - TClientConnection(const TSocket& s, THttpServer::TImpl* serv, NAddr::IRemoteAddrRef listenerSockAddrRef); + TClientConnection(const TSocket& s, THttpServer::TImpl* serv, NAddr::IRemoteAddrRef listenerSockAddrRef); ~TClientConnection() override; void OnPollEvent(TInstant now) override; @@ -63,7 +63,7 @@ public: public: TSocket Socket_; - NAddr::IRemoteAddrRef ListenerSockAddrRef_; + NAddr::IRemoteAddrRef ListenerSockAddrRef_; THttpServer::TImpl* HttpServ_ = nullptr; bool Reject_ = false; TInstant LastUsed; @@ -153,17 +153,17 @@ public: return obj; } - void AddRequestFromSocket(const TSocket& s, TInstant now, NAddr::IRemoteAddrRef listenerSockAddrRef) { + void AddRequestFromSocket(const TSocket& s, TInstant now, NAddr::IRemoteAddrRef listenerSockAddrRef) { if (MaxRequestsReached()) { Cb_->OnMaxConn(); bool wasRemoved = Connections->RemoveOld(TInstant::Max()); if (!wasRemoved && Options_.RejectExcessConnections) { - (new TClientConnection(s, this, listenerSockAddrRef))->Reject(); + (new TClientConnection(s, this, listenerSockAddrRef))->Reject(); return; } } - auto connection = new TClientConnection(s, this, listenerSockAddrRef); + auto connection = new TClientConnection(s, this, listenerSockAddrRef); connection->LastUsed = now; connection->DeActivate(); } @@ -293,7 +293,7 @@ public: inline TListenSocket(const TSocket& s, TImpl* parent) : S_(s) , Server_(parent) - , SockAddrRef_(GetSockAddr(S_)) + , SockAddrRef_(GetSockAddr(S_)) { } @@ -307,7 +307,7 @@ public: ythrow yexception() << "accept: " << LastSystemErrorText(); } - Server_->AddRequestFromSocket(s, TInstant::Now(), SockAddrRef_); + Server_->AddRequestFromSocket(s, TInstant::Now(), SockAddrRef_); } SOCKET GetSocket() const noexcept { @@ -317,7 +317,7 @@ public: private: TSocket S_; TImpl* Server_ = nullptr; - NAddr::IRemoteAddrRef SockAddrRef_; + NAddr::IRemoteAddrRef SockAddrRef_; }; void ListenSocket() { @@ -551,9 +551,9 @@ bool THttpServer::MaxRequestsReached() const { return Impl_->MaxRequestsReached(); } -TClientConnection::TClientConnection(const TSocket& s, THttpServer::TImpl* serv, NAddr::IRemoteAddrRef listenerSockAddrRef) +TClientConnection::TClientConnection(const TSocket& s, THttpServer::TImpl* serv, NAddr::IRemoteAddrRef listenerSockAddrRef) : Socket_(s) - , ListenerSockAddrRef_(listenerSockAddrRef) + , ListenerSockAddrRef_(listenerSockAddrRef) , HttpServ_(serv) { SetNoDelay(Socket_, true); @@ -772,10 +772,10 @@ const TSocket& TClientRequest::Socket() const noexcept { return Conn_->Socket_; } -NAddr::IRemoteAddrRef TClientRequest::GetListenerSockAddrRef() const noexcept { - return Conn_->ListenerSockAddrRef_; -} - +NAddr::IRemoteAddrRef TClientRequest::GetListenerSockAddrRef() const noexcept { + return Conn_->ListenerSockAddrRef_; +} + TInstant TClientRequest::AcceptMoment() const noexcept { return Conn_->AcceptMoment; } |