aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/binsaver/buffered_io.h
diff options
context:
space:
mode:
authorshakurov <shakurov@yandex-team.ru>2022-02-10 16:49:23 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:49:23 +0300
commit296627beeba9eb1fbc3cc1ff3dbae3ff192fb2a8 (patch)
tree5d5cb817648f650d76cf1076100726fd9b8448e8 /library/cpp/binsaver/buffered_io.h
parent6750fac04a33847862ab7bfb19145f6f91207be6 (diff)
downloadydb-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.h46
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;