aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/http/fetch/httpzreader.h
diff options
context:
space:
mode:
authorlapshov <lapshov@yandex-team.ru>2022-02-10 16:49:39 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:49:39 +0300
commit4f36f44b1e216dca1f44ada8d126e7b70f05da2f (patch)
treeedbdb67ebe4b9195bf7c53bbc0a963fc03ccc17e /library/cpp/http/fetch/httpzreader.h
parent8b71ce88bea710a9663bb143e4916f961c57212e (diff)
downloadydb-4f36f44b1e216dca1f44ada8d126e7b70f05da2f.tar.gz
Restoring authorship annotation for <lapshov@yandex-team.ru>. Commit 1 of 2.
Diffstat (limited to 'library/cpp/http/fetch/httpzreader.h')
-rw-r--r--library/cpp/http/fetch/httpzreader.h38
1 files changed, 19 insertions, 19 deletions
diff --git a/library/cpp/http/fetch/httpzreader.h b/library/cpp/http/fetch/httpzreader.h
index 68eb00853d6..fcb95baa56d 100644
--- a/library/cpp/http/fetch/httpzreader.h
+++ b/library/cpp/http/fetch/httpzreader.h
@@ -4,9 +4,9 @@
#include "httpparser.h"
#include "exthttpcodes.h"
-#include <util/system/defaults.h>
-#include <util/generic/yexception.h>
-
+#include <util/system/defaults.h>
+#include <util/generic/yexception.h>
+
#include <contrib/libs/zlib/zlib.h>
#include <errno.h>
@@ -35,8 +35,8 @@ public:
, MaxContSize(0)
, Buf(nullptr)
, ZErr(0)
- , ConnectionClosed(0)
- , IgnoreTrailingGarbage(true)
+ , ConnectionClosed(0)
+ , IgnoreTrailingGarbage(true)
{
memset(&Stream, 0, sizeof(Stream));
}
@@ -50,14 +50,14 @@ public:
}
}
- void SetConnectionClosed(int cc) {
- ConnectionClosed = cc;
- }
-
- void SetIgnoreTrailingGarbage(bool ignore) {
- IgnoreTrailingGarbage = ignore;
- }
-
+ void SetConnectionClosed(int cc) {
+ ConnectionClosed = cc;
+ }
+
+ void SetIgnoreTrailingGarbage(bool ignore) {
+ IgnoreTrailingGarbage = ignore;
+ }
+
int Init(
THttpHeader* H,
int parsHeader,
@@ -122,11 +122,11 @@ public:
return -1;
}
if (!IgnoreTrailingGarbage && BufSize == Stream.avail_out && Stream.avail_in > 0) {
- Header->error = EXT_HTTP_GZIPERROR;
- ZErr = EFAULT;
+ Header->error = EXT_HTTP_GZIPERROR;
+ ZErr = EFAULT;
Stream.msg = (char*)"trailing garbage";
- return -1;
- }
+ return -1;
+ }
return long(BufSize - Stream.avail_out);
case Z_NEED_DICT:
@@ -236,8 +236,8 @@ protected:
size_t CurContSize, MaxContSize;
ui8* Buf;
int ZErr;
- int ConnectionClosed;
- bool IgnoreTrailingGarbage;
+ int ConnectionClosed;
+ bool IgnoreTrailingGarbage;
};
class zlib_exception: public yexception {