aboutsummaryrefslogtreecommitdiffstats
path: root/util/stream/buffered.cpp
diff options
context:
space:
mode:
authoriddqd <iddqd@yandex-team.ru>2022-02-10 16:49:45 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:49:45 +0300
commit07fce9c5f7771600d0b3d70e1f88fd8a7e164d85 (patch)
treee4aa4750fbb864d70f8c06cf03d2750e979ea3bf /util/stream/buffered.cpp
parentaf42068bf6cd93c976b80dd0388fa48cdf65da11 (diff)
downloadydb-07fce9c5f7771600d0b3d70e1f88fd8a7e164d85.tar.gz
Restoring authorship annotation for <iddqd@yandex-team.ru>. Commit 1 of 2.
Diffstat (limited to 'util/stream/buffered.cpp')
-rw-r--r--util/stream/buffered.cpp16
1 files changed, 8 insertions, 8 deletions
diff --git a/util/stream/buffered.cpp b/util/stream/buffered.cpp
index a00e592e1c4..de4ec8c7565 100644
--- a/util/stream/buffered.cpp
+++ b/util/stream/buffered.cpp
@@ -35,7 +35,7 @@ public:
return MemInput_.Read(buf, len);
}
- inline size_t Skip(size_t len) {
+ inline size_t Skip(size_t len) {
size_t totalSkipped = 0;
while (len) {
const size_t skipped = DoSkip(len);
@@ -45,11 +45,11 @@ public:
totalSkipped += skipped;
len -= skipped;
- }
+ }
return totalSkipped;
- }
-
+ }
+
inline size_t DoSkip(size_t len) {
if (MemInput_.Exhausted()) {
if (len > BufLen() / 2) {
@@ -131,10 +131,10 @@ size_t TBufferedInput::DoRead(void* buf, size_t len) {
return Impl_->Read(buf, len);
}
-size_t TBufferedInput::DoSkip(size_t len) {
- return Impl_->Skip(len);
-}
-
+size_t TBufferedInput::DoSkip(size_t len) {
+ return Impl_->Skip(len);
+}
+
size_t TBufferedInput::DoNext(const void** ptr, size_t len) {
return Impl_->Next(ptr, len);
}