aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/binsaver/buffered_io.cpp
diff options
context:
space:
mode:
authoryazevnul <yazevnul@yandex-team.ru>2022-02-10 16:46:46 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:46:46 +0300
commit8cbc307de0221f84c80c42dcbe07d40727537e2c (patch)
tree625d5a673015d1df891e051033e9fcde5c7be4e5 /library/cpp/binsaver/buffered_io.cpp
parent30d1ef3941e0dc835be7609de5ebee66958f215a (diff)
downloadydb-8cbc307de0221f84c80c42dcbe07d40727537e2c.tar.gz
Restoring authorship annotation for <yazevnul@yandex-team.ru>. Commit 1 of 2.
Diffstat (limited to 'library/cpp/binsaver/buffered_io.cpp')
-rw-r--r--library/cpp/binsaver/buffered_io.cpp12
1 files changed, 6 insertions, 6 deletions
diff --git a/library/cpp/binsaver/buffered_io.cpp b/library/cpp/binsaver/buffered_io.cpp
index dd88b04bc5..073ba0c46e 100644
--- a/library/cpp/binsaver/buffered_io.cpp
+++ b/library/cpp/binsaver/buffered_io.cpp
@@ -1,31 +1,31 @@
#include "buffered_io.h"
i64 IBinaryStream::LongWrite(const void* userBuffer, i64 size) {
- Y_VERIFY(size >= 0, "IBinaryStream::Write() called with a negative buffer size.");
+ Y_VERIFY(size >= 0, "IBinaryStream::Write() called with a negative buffer size.");
i64 leftToWrite = size;
while (leftToWrite != 0) {
int writeSz = static_cast<int>(Min<i64>(leftToWrite, std::numeric_limits<int>::max()));
int written = WriteImpl(userBuffer, writeSz);
- Y_ASSERT(written <= writeSz);
+ Y_ASSERT(written <= writeSz);
leftToWrite -= written;
// Assumption: if WriteImpl(buf, writeSz) returns < writeSz, the stream is
// full and there's no sense in continuing.
if (written < writeSz)
break;
}
- Y_ASSERT(size >= leftToWrite);
+ Y_ASSERT(size >= leftToWrite);
return size - leftToWrite;
}
i64 IBinaryStream::LongRead(void* userBuffer, i64 size) {
- Y_VERIFY(size >= 0, "IBinaryStream::Read() called with a negative buffer size.");
+ Y_VERIFY(size >= 0, "IBinaryStream::Read() called with a negative buffer size.");
i64 leftToRead = size;
while (leftToRead != 0) {
int readSz = static_cast<int>(Min<i64>(leftToRead, std::numeric_limits<int>::max()));
int read = ReadImpl(userBuffer, readSz);
- Y_ASSERT(read <= readSz);
+ Y_ASSERT(read <= readSz);
leftToRead -= read;
// Assumption: if ReadImpl(buf, readSz) returns < readSz, the stream is
// full and there's no sense in continuing.
@@ -34,6 +34,6 @@ i64 IBinaryStream::LongRead(void* userBuffer, i64 size) {
break;
}
}
- Y_ASSERT(size >= leftToRead);
+ Y_ASSERT(size >= leftToRead);
return size - leftToRead;
}