aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/http
diff options
context:
space:
mode:
authorivanmorozov <ivanmorozov@yandex-team.ru>2022-02-10 16:47:34 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:47:34 +0300
commit464ba3814a83db4f2d5327393b0b6eaf0c86bfd7 (patch)
treec0748b5dcbade83af788c0abfa89c0383d6b779c /library/cpp/http
parentcba5d9a444e2cfe105f55ccda66cd21d50440017 (diff)
downloadydb-464ba3814a83db4f2d5327393b0b6eaf0c86bfd7.tar.gz
Restoring authorship annotation for <ivanmorozov@yandex-team.ru>. Commit 2 of 2.
Diffstat (limited to 'library/cpp/http')
-rw-r--r--library/cpp/http/misc/httpreqdata.cpp10
-rw-r--r--library/cpp/http/misc/httpreqdata.h10
-rw-r--r--library/cpp/http/server/http.cpp14
-rw-r--r--library/cpp/http/server/http.h2
4 files changed, 18 insertions, 18 deletions
diff --git a/library/cpp/http/misc/httpreqdata.cpp b/library/cpp/http/misc/httpreqdata.cpp
index 204c4b7b63..f6951f68cd 100644
--- a/library/cpp/http/misc/httpreqdata.cpp
+++ b/library/cpp/http/misc/httpreqdata.cpp
@@ -65,9 +65,9 @@ const char* TBaseServerRequestData::RemoteAddr() const {
}
const char* TBaseServerRequestData::HeaderIn(TStringBuf key) const {
- auto it = HeadersIn_.find(key);
+ auto it = HeadersIn_.find(key);
- if (it == HeadersIn_.end()) {
+ if (it == HeadersIn_.end()) {
return nullptr;
}
@@ -108,7 +108,7 @@ const char* TBaseServerRequestData::Environment(const char* key) const {
}
void TBaseServerRequestData::Clear() {
- HeadersIn_.clear();
+ HeadersIn_.clear();
Addr = Path = Search = nullptr;
OrigSearch = {};
SearchLength = 0;
@@ -180,7 +180,7 @@ bool TBaseServerRequestData::Parse(const char* origReq) {
}
void TBaseServerRequestData::AddHeader(const TString& name, const TString& value) {
- HeadersIn_[name] = value;
+ HeadersIn_[name] = value;
if (stricmp(name.data(), "Host") == 0) {
size_t hostLen = strcspn(value.data(), ":");
@@ -192,5 +192,5 @@ void TBaseServerRequestData::AddHeader(const TString& name, const TString& value
void TBaseServerRequestData::SetPath(const TString& path) {
PathStorage = TBuffer(path.data(), path.size() + 1);
- Path = PathStorage.Data();
+ Path = PathStorage.Data();
}
diff --git a/library/cpp/http/misc/httpreqdata.h b/library/cpp/http/misc/httpreqdata.h
index 7fd7745314..16e59c4d78 100644
--- a/library/cpp/http/misc/httpreqdata.h
+++ b/library/cpp/http/misc/httpreqdata.h
@@ -61,11 +61,11 @@ public:
const char* HeaderIn(TStringBuf key) const;
const THttpHeadersContainer& HeadersIn() const {
- return HeadersIn_;
- }
-
+ return HeadersIn_;
+ }
+
inline size_t HeadersCount() const noexcept {
- return HeadersIn_.size();
+ return HeadersIn_.size();
}
TString HeaderByIndex(size_t n) const noexcept;
@@ -87,7 +87,7 @@ public:
void AddHeader(const TString& name, const TString& value);
private:
- TBuffer PathStorage;
+ TBuffer PathStorage;
mutable char* Addr;
TString Host;
TString Port;
diff --git a/library/cpp/http/server/http.cpp b/library/cpp/http/server/http.cpp
index 6180660246..128583bdd7 100644
--- a/library/cpp/http/server/http.cpp
+++ b/library/cpp/http/server/http.cpp
@@ -660,14 +660,14 @@ bool TClientRequest::CheckLoopback() {
return true;
}
-void TClientRequest::ReleaseConnection() {
+void TClientRequest::ReleaseConnection() {
if (Conn_ && HttpConn_ && HttpServ()->Options().KeepAliveEnabled && HttpConn_->CanBeKeepAlive() && (!HttpServ()->Options().RejectExcessConnections || !HttpServ()->MaxRequestsReached())) {
- Output().Finish();
- Conn_->DeActivate();
+ Output().Finish();
+ Conn_->DeActivate();
Y_UNUSED(Conn_.Release());
- }
-}
-
+ }
+}
+
void TClientRequest::ResetConnection() {
if (HttpConn_) {
// send RST packet to client
@@ -706,7 +706,7 @@ void TClientRequest::Process(void* ThreadSpecificResource) {
}
if (Reply(ThreadSpecificResource)) {
- ReleaseConnection();
+ ReleaseConnection();
/*
* *this will be destroyed...
diff --git a/library/cpp/http/server/http.h b/library/cpp/http/server/http.h
index e9e9c71c15..b292d38f27 100644
--- a/library/cpp/http/server/http.h
+++ b/library/cpp/http/server/http.h
@@ -126,7 +126,7 @@ public:
bool CheckLoopback();
void ProcessFailRequest(int failstate);
- void ReleaseConnection();
+ void ReleaseConnection();
void ResetConnection();