diff options
author | marakasov <marakasov@yandex-team.ru> | 2022-02-10 16:49:50 +0300 |
---|---|---|
committer | Daniil Cherednik <dcherednik@yandex-team.ru> | 2022-02-10 16:49:50 +0300 |
commit | f4edb31a1d309efb6c243b2615a587cbbdec081d (patch) | |
tree | 5d5cb817648f650d76cf1076100726fd9b8448e8 /util/stream/pipe.cpp | |
parent | 359de4829c1d82b06fad5e0ad82470e4e9f27c89 (diff) | |
download | ydb-f4edb31a1d309efb6c243b2615a587cbbdec081d.tar.gz |
Restoring authorship annotation for <marakasov@yandex-team.ru>. Commit 2 of 2.
Diffstat (limited to 'util/stream/pipe.cpp')
-rw-r--r-- | util/stream/pipe.cpp | 18 |
1 files changed, 9 insertions, 9 deletions
diff --git a/util/stream/pipe.cpp b/util/stream/pipe.cpp index b209eb9d6e..51be1934a7 100644 --- a/util/stream/pipe.cpp +++ b/util/stream/pipe.cpp @@ -72,16 +72,16 @@ void TPipeOutput::DoWrite(const void* buf, size_t len) { } } -void TPipeOutput::Close() { - int exitStatus = ::pclose(Impl_->Pipe_); +void TPipeOutput::Close() { + int exitStatus = ::pclose(Impl_->Pipe_); Impl_->Pipe_ = nullptr; - if (exitStatus == -1) { - ythrow TSystemError() << "pclose() failed"; - } else if (exitStatus != 0) { - ythrow yexception() << "subprocess exited with non-zero status(" << exitStatus << ")"; - } -} - + if (exitStatus == -1) { + ythrow TSystemError() << "pclose() failed"; + } else if (exitStatus != 0) { + ythrow yexception() << "subprocess exited with non-zero status(" << exitStatus << ")"; + } +} + TPipedBase::TPipedBase(PIPEHANDLE fd) : Handle_(fd) { |