diff options
author | shakurov <shakurov@yandex-team.ru> | 2022-02-10 16:49:23 +0300 |
---|---|---|
committer | Daniil Cherednik <dcherednik@yandex-team.ru> | 2022-02-10 16:49:23 +0300 |
commit | 296627beeba9eb1fbc3cc1ff3dbae3ff192fb2a8 (patch) | |
tree | 5d5cb817648f650d76cf1076100726fd9b8448e8 /library/cpp/binsaver/buffered_io.h | |
parent | 6750fac04a33847862ab7bfb19145f6f91207be6 (diff) | |
download | ydb-296627beeba9eb1fbc3cc1ff3dbae3ff192fb2a8.tar.gz |
Restoring authorship annotation for <shakurov@yandex-team.ru>. Commit 2 of 2.
Diffstat (limited to 'library/cpp/binsaver/buffered_io.h')
-rw-r--r-- | library/cpp/binsaver/buffered_io.h | 46 |
1 files changed, 23 insertions, 23 deletions
diff --git a/library/cpp/binsaver/buffered_io.h b/library/cpp/binsaver/buffered_io.h index 80ad1a09374..75465c9c5ca 100644 --- a/library/cpp/binsaver/buffered_io.h +++ b/library/cpp/binsaver/buffered_io.h @@ -1,37 +1,37 @@ #pragma once #include <util/system/yassert.h> -#include <util/generic/utility.h> -#include <util/generic/ylimits.h> +#include <util/generic/utility.h> +#include <util/generic/ylimits.h> #include <string.h> struct IBinaryStream { virtual ~IBinaryStream() = default; ; - + inline i64 Write(const void* userBuffer, i64 size) { - if (size <= Max<int>()) { - return WriteImpl(userBuffer, static_cast<int>(size)); - } else { - return LongWrite(userBuffer, size); - } - } - + if (size <= Max<int>()) { + return WriteImpl(userBuffer, static_cast<int>(size)); + } else { + return LongWrite(userBuffer, size); + } + } + inline i64 Read(void* userBuffer, i64 size) { - if (size <= Max<int>()) { - return ReadImpl(userBuffer, static_cast<int>(size)); - } else { - return LongRead(userBuffer, size); - } - } - + if (size <= Max<int>()) { + return ReadImpl(userBuffer, static_cast<int>(size)); + } else { + return LongRead(userBuffer, size); + } + } + virtual bool IsValid() const = 0; virtual bool IsFailed() const = 0; - -private: + +private: virtual int WriteImpl(const void* userBuffer, int size) = 0; virtual int ReadImpl(void* userBuffer, int size) = 0; - + i64 LongRead(void* userBuffer, i64 size); i64 LongWrite(const void* userBuffer, i64 size); }; @@ -39,7 +39,7 @@ private: template <int N_SIZE = 16384> class TBufferedStream { char Buf[N_SIZE]; - i64 Pos, BufSize; + i64 Pos, BufSize; IBinaryStream& Stream; bool bIsReading, bIsEof, bFailed; @@ -49,13 +49,13 @@ class TBufferedStream { return; } char* dst = (char*)userBuffer; - i64 leftBytes = BufSize - Pos; + i64 leftBytes = BufSize - Pos; memcpy(dst, Buf + Pos, leftBytes); dst += leftBytes; size -= leftBytes; Pos = BufSize = 0; if (size > N_SIZE) { - i64 n = Stream.Read(dst, size); + i64 n = Stream.Read(dst, size); bFailed = Stream.IsFailed(); if (n != size) { bIsEof = true; |