aboutsummaryrefslogtreecommitdiffstats
path: root/util/stream
diff options
context:
space:
mode:
authorsmikler <smikler@yandex-team.ru>2022-02-10 16:49:32 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:49:32 +0300
commite4f0fd4ab53ca40eb91e750cf3e7f76c21e930db (patch)
treeafee3c8173a0960bf439959f26e7624d1212e11a /util/stream
parent1503061b80644305b2e6dd1327b57118e35ebd31 (diff)
downloadydb-e4f0fd4ab53ca40eb91e750cf3e7f76c21e930db.tar.gz
Restoring authorship annotation for <smikler@yandex-team.ru>. Commit 1 of 2.
Diffstat (limited to 'util/stream')
-rw-r--r--util/stream/input.cpp10
-rw-r--r--util/stream/input.h2
2 files changed, 6 insertions, 6 deletions
diff --git a/util/stream/input.cpp b/util/stream/input.cpp
index 6e8170f2f9f..dbded82306d 100644
--- a/util/stream/input.cpp
+++ b/util/stream/input.cpp
@@ -72,12 +72,12 @@ size_t IInputStream::Load(void* buf_in, size_t len) {
}
void IInputStream::LoadOrFail(void* buf, size_t len) {
- const size_t realLen = Load(buf, len);
+ const size_t realLen = Load(buf, len);
if (Y_UNLIKELY(realLen != len)) {
- ythrow yexception() << "Failed to read required number of bytes from stream! Expected: " << len << ", gained: " << realLen << "!";
- }
-}
-
+ ythrow yexception() << "Failed to read required number of bytes from stream! Expected: " << len << ", gained: " << realLen << "!";
+ }
+}
+
size_t IInputStream::ReadLine(TString& st) {
const size_t ret = ReadTo(st, '\n');
diff --git a/util/stream/input.h b/util/stream/input.h
index f0d5807ed27..ed2b98c33f5 100644
--- a/util/stream/input.h
+++ b/util/stream/input.h
@@ -82,7 +82,7 @@ public:
* signals end of stream.
*/
size_t Load(void* buf, size_t len);
-
+
/**
* Reads the requested amount of data from the stream, or fails with an
* exception if unable to do so.