aboutsummaryrefslogtreecommitdiffstats
path: root/util/stream/zerocopy.cpp
diff options
context:
space:
mode:
authorAlexander Fokin <apfokin@gmail.com>2022-02-10 16:45:38 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:45:38 +0300
commit863a59a65247c24db7cb06789bc5cf79d04da32f (patch)
tree139dc000c8cd4a40f5659e421b7c75135d080307 /util/stream/zerocopy.cpp
parentf64e95a9eb9ab03240599eb9581c5a9102426a96 (diff)
downloadydb-863a59a65247c24db7cb06789bc5cf79d04da32f.tar.gz
Restoring authorship annotation for Alexander Fokin <apfokin@gmail.com>. Commit 1 of 2.
Diffstat (limited to 'util/stream/zerocopy.cpp')
-rw-r--r--util/stream/zerocopy.cpp38
1 files changed, 19 insertions, 19 deletions
diff --git a/util/stream/zerocopy.cpp b/util/stream/zerocopy.cpp
index dc2982ad55..4cf08b2aad 100644
--- a/util/stream/zerocopy.cpp
+++ b/util/stream/zerocopy.cpp
@@ -1,36 +1,36 @@
-#include "zerocopy.h"
+#include "zerocopy.h"
#include "output.h"
IZeroCopyInput::~IZeroCopyInput() = default;
size_t IZeroCopyInput::DoRead(void* buf, size_t len) {
- const void* ptr;
- size_t result = DoNext(&ptr, len);
+ const void* ptr;
+ size_t result = DoNext(&ptr, len);
if (result) {
memcpy(buf, ptr, result);
}
- return result;
-}
-
+ return result;
+}
+
ui64 IZeroCopyInput::DoReadAll(IOutputStream& out) {
- ui64 result = 0;
+ ui64 result = 0;
const void* ptr;
-
- while (size_t len = Next(&ptr)) {
- out.Write(ptr, len);
- result += len;
- }
-
- return result;
-}
-
+
+ while (size_t len = Next(&ptr)) {
+ out.Write(ptr, len);
+ result += len;
+ }
+
+ return result;
+}
+
size_t IZeroCopyInput::DoSkip(size_t len) {
- const void* ptr;
+ const void* ptr;
- return DoNext(&ptr, len);
-}
+ return DoNext(&ptr, len);
+}
IZeroCopyInputFastReadTo::~IZeroCopyInputFastReadTo() = default;