aboutsummaryrefslogtreecommitdiffstats
path: root/util/stream/pipe.cpp
diff options
context:
space:
mode:
authormarakasov <marakasov@yandex-team.ru>2022-02-10 16:49:50 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:49:50 +0300
commitf4edb31a1d309efb6c243b2615a587cbbdec081d (patch)
tree5d5cb817648f650d76cf1076100726fd9b8448e8 /util/stream/pipe.cpp
parent359de4829c1d82b06fad5e0ad82470e4e9f27c89 (diff)
downloadydb-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.cpp18
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)
{