diff options
author | ekrokhalev <[email protected]> | 2022-02-10 16:50:10 +0300 |
---|---|---|
committer | Daniil Cherednik <[email protected]> | 2022-02-10 16:50:10 +0300 |
commit | 8d3a5b9c70bfb823a30242286328d6017b82b9ce (patch) | |
tree | 5d5cb817648f650d76cf1076100726fd9b8448e8 /util/stream/pipe.cpp | |
parent | 1c01ed5294724fda060c1f0bd674b315fe249598 (diff) |
Restoring authorship annotation for <[email protected]>. Commit 2 of 2.
Diffstat (limited to 'util/stream/pipe.cpp')
-rw-r--r-- | util/stream/pipe.cpp | 56 |
1 files changed, 28 insertions, 28 deletions
diff --git a/util/stream/pipe.cpp b/util/stream/pipe.cpp index 556c5766d72..51be1934a75 100644 --- a/util/stream/pipe.cpp +++ b/util/stream/pipe.cpp @@ -82,40 +82,40 @@ void TPipeOutput::Close() { } } -TPipedBase::TPipedBase(PIPEHANDLE fd) - : Handle_(fd) -{ -} - +TPipedBase::TPipedBase(PIPEHANDLE fd) + : Handle_(fd) +{ +} + TPipedBase::~TPipedBase() { if (Handle_.IsOpen()) { - Handle_.Close(); + Handle_.Close(); } -} - +} + TPipedInput::TPipedInput(PIPEHANDLE fd) - : TPipedBase(fd) -{ -} - + : TPipedBase(fd) +{ +} + TPipedInput::~TPipedInput() = default; - -size_t TPipedInput::DoRead(void* buf, size_t len) { + +size_t TPipedInput::DoRead(void* buf, size_t len) { if (!Handle_.IsOpen()) { - return 0; + return 0; } return Handle_.Read(buf, len); -} - -TPipedOutput::TPipedOutput(PIPEHANDLE fd) - : TPipedBase(fd) -{ -} - +} + +TPipedOutput::TPipedOutput(PIPEHANDLE fd) + : TPipedBase(fd) +{ +} + TPipedOutput::~TPipedOutput() = default; - -void TPipedOutput::DoWrite(const void* buf, size_t len) { - if (!Handle_.IsOpen() || static_cast<ssize_t>(len) != Handle_.Write(buf, len)) { - ythrow TSystemError() << "pipe writing failed"; - } -} + +void TPipedOutput::DoWrite(const void* buf, size_t len) { + if (!Handle_.IsOpen() || static_cast<ssize_t>(len) != Handle_.Write(buf, len)) { + ythrow TSystemError() << "pipe writing failed"; + } +} |