diff options
author | aosipenko <aosipenko@yandex-team.ru> | 2022-02-10 16:48:08 +0300 |
---|---|---|
committer | Daniil Cherednik <dcherednik@yandex-team.ru> | 2022-02-10 16:48:08 +0300 |
commit | 948fd24d47d4b3b7815aaef1686aea00ef3f4288 (patch) | |
tree | 8ad4c39c2a5f8b341bc02e3b0c5e8f26c40373cb /util/stream/input.cpp | |
parent | d2eb4aae699fa2f6901bf32d22eec019c8f29838 (diff) | |
download | ydb-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.cpp | 16 |
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; |