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
commit69e3c43df1c96bc2ac8946bf4dfb1f5fc438ff7f (patch)
treeb222e5ac2e2e98872661c51ccceee5da0d291e13 /util/stream/input.cpp
parent948fd24d47d4b3b7815aaef1686aea00ef3f4288 (diff)
downloadydb-69e3c43df1c96bc2ac8946bf4dfb1f5fc438ff7f.tar.gz
Restoring authorship annotation for <aosipenko@yandex-team.ru>. Commit 2 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 27bdfb404e..6e8170f2f9 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;