diff options
author | platypus179 <platypus179@yandex-team.ru> | 2022-02-10 16:49:46 +0300 |
---|---|---|
committer | Daniil Cherednik <dcherednik@yandex-team.ru> | 2022-02-10 16:49:46 +0300 |
commit | cac99863f10ca292a64df9f7edb958ad22a02f86 (patch) | |
tree | 5d5cb817648f650d76cf1076100726fd9b8448e8 /library/cpp/http/io/stream.cpp | |
parent | 2cd8af5a38e7de1bbb2a78b578853f5229cbf0c4 (diff) | |
download | ydb-cac99863f10ca292a64df9f7edb958ad22a02f86.tar.gz |
Restoring authorship annotation for <platypus179@yandex-team.ru>. Commit 2 of 2.
Diffstat (limited to 'library/cpp/http/io/stream.cpp')
-rw-r--r-- | library/cpp/http/io/stream.cpp | 26 |
1 files changed, 13 insertions, 13 deletions
diff --git a/library/cpp/http/io/stream.cpp b/library/cpp/http/io/stream.cpp index 9a5ff8d0af..6689be684f 100644 --- a/library/cpp/http/io/stream.cpp +++ b/library/cpp/http/io/stream.cpp @@ -7,7 +7,7 @@ #include <util/stream/length.h> #include <util/stream/multi.h> #include <util/stream/null.h> -#include <util/stream/tee.h> +#include <util/stream/tee.h> #include <util/system/compat.h> #include <util/system/yassert.h> @@ -623,10 +623,10 @@ public: return FirstLine_; } - inline size_t SentSize() const noexcept { - return SizeCalculator_.Length(); - } - + inline size_t SentSize() const noexcept { + return SizeCalculator_.Length(); + } + private: static inline bool IsResponse(const TString& s) noexcept { return strnicmp(s.data(), "HTTP/", 5) == 0; @@ -835,8 +835,8 @@ private: Output_ = Streams_.Add(new TChunkedOutput(Output_)); } - Output_ = Streams_.Add(new TTeeOutput(Output_, &SizeCalculator_)); - + Output_ = Streams_.Add(new TTeeOutput(Output_, &SizeCalculator_)); + if (IsBodyEncodingEnabled() && encoder) { Output_ = Streams_.Add((*encoder)(Output_).Release()); } @@ -872,8 +872,8 @@ private: bool CompressionHeaderEnabled_; bool Finished_; - - TSizeCalculator SizeCalculator_; + + TSizeCalculator SizeCalculator_; }; THttpOutput::THttpOutput(IOutputStream* slave) @@ -962,10 +962,10 @@ const TString& THttpOutput::FirstLine() const noexcept { return Impl_->FirstLine(); } -size_t THttpOutput::SentSize() const noexcept { - return Impl_->SentSize(); -} - +size_t THttpOutput::SentSize() const noexcept { + return Impl_->SentSize(); +} + unsigned ParseHttpRetCode(const TStringBuf& ret) { const TStringBuf code = StripString(StripString(ret.After(' ')).Before(' ')); |