aboutsummaryrefslogtreecommitdiffstats
path: root/util/stream/input.cpp
diff options
context:
space:
mode:
authoraosipenko <aosipenko@yandex-team.ru>2022-02-10 16:48:08 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:48:08 +0300
commit948fd24d47d4b3b7815aaef1686aea00ef3f4288 (patch)
tree8ad4c39c2a5f8b341bc02e3b0c5e8f26c40373cb /util/stream/input.cpp
parentd2eb4aae699fa2f6901bf32d22eec019c8f29838 (diff)
downloadydb-948fd24d47d4b3b7815aaef1686aea00ef3f4288.tar.gz
Restoring authorship annotation for <aosipenko@yandex-team.ru>. Commit 1 of 2.
Diffstat (limited to 'util/stream/input.cpp')
-rw-r--r--util/stream/input.cpp16
1 files changed, 8 insertions, 8 deletions
diff --git a/util/stream/input.cpp b/util/stream/input.cpp
index 6e8170f2f9..27bdfb404e 100644
--- a/util/stream/input.cpp
+++ b/util/stream/input.cpp
@@ -81,7 +81,7 @@ void IInputStream::LoadOrFail(void* buf, size_t len) {
size_t IInputStream::ReadLine(TString& st) {
const size_t ret = ReadTo(st, '\n');
- if (ret && !st.empty() && st.back() == '\r') {
+ if (ret && !st.empty() && st.back() == '\r') {
st.pop_back();
}
@@ -170,7 +170,7 @@ namespace {
const size_t ret = fread(buf, 1, len, F_);
if (ret < len && ferror(F_)) {
- ythrow TSystemError() << "can not read from stdin";
+ ythrow TSystemError() << "can not read from stdin";
}
return ret;
@@ -192,7 +192,7 @@ namespace {
size_t DoReadTo(TString& st, char ch) override {
auto&& guard = Guard(M_);
-
+
(void)guard;
const auto r = getdelim(&B_, &L_, ch, F_);
@@ -200,22 +200,22 @@ namespace {
if (r < 0) {
if (ferror(F_)) {
ythrow TSystemError() << "can not read from stdin";
- }
+ }
st.clear();
return 0;
- }
+ }
st.AssignNoAlias(B_, r);
if (st && st.back() == ch) {
st.pop_back();
- }
+ }
return r;
- }
-
+ }
+
TAdaptiveLock M_;
char* B_ = nullptr;
size_t L_ = 0;