diff options
author | nikitamorozov <nikitamorozov@yandex-team.ru> | 2022-02-10 16:49:20 +0300 |
---|---|---|
committer | Daniil Cherednik <dcherednik@yandex-team.ru> | 2022-02-10 16:49:20 +0300 |
commit | 523d26598d9784601932189f7fceb34d61bf7641 (patch) | |
tree | 5d5cb817648f650d76cf1076100726fd9b8448e8 /util/stream/zerocopy_output.cpp | |
parent | 2342f2b56e674c21307fcb92a37853f950224d31 (diff) | |
download | ydb-523d26598d9784601932189f7fceb34d61bf7641.tar.gz |
Restoring authorship annotation for <nikitamorozov@yandex-team.ru>. Commit 2 of 2.
Diffstat (limited to 'util/stream/zerocopy_output.cpp')
-rw-r--r-- | util/stream/zerocopy_output.cpp | 36 |
1 files changed, 18 insertions, 18 deletions
diff --git a/util/stream/zerocopy_output.cpp b/util/stream/zerocopy_output.cpp index 97777724d1..23600ef6e1 100644 --- a/util/stream/zerocopy_output.cpp +++ b/util/stream/zerocopy_output.cpp @@ -1,18 +1,18 @@ -#include "zerocopy_output.h" - -#include <util/generic/utility.h> - -void IZeroCopyOutput::DoWrite(const void* buf, size_t len) { - void* ptr = nullptr; - size_t writtenBytes = 0; - while (writtenBytes < len) { - size_t bufferSize = DoNext(&ptr); - Y_ASSERT(ptr && bufferSize > 0); - size_t toWrite = Min(bufferSize, len - writtenBytes); - memcpy(ptr, static_cast<const char*>(buf) + writtenBytes, toWrite); - writtenBytes += toWrite; - if (toWrite < bufferSize) { - DoUndo(bufferSize - toWrite); - } - } -} +#include "zerocopy_output.h" + +#include <util/generic/utility.h> + +void IZeroCopyOutput::DoWrite(const void* buf, size_t len) { + void* ptr = nullptr; + size_t writtenBytes = 0; + while (writtenBytes < len) { + size_t bufferSize = DoNext(&ptr); + Y_ASSERT(ptr && bufferSize > 0); + size_t toWrite = Min(bufferSize, len - writtenBytes); + memcpy(ptr, static_cast<const char*>(buf) + writtenBytes, toWrite); + writtenBytes += toWrite; + if (toWrite < bufferSize) { + DoUndo(bufferSize - toWrite); + } + } +} |