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 | 1c01ed5294724fda060c1f0bd674b315fe249598 (patch) | |
| tree | c21292982d2c8182cdf5753f9a49e7cda547f4d3 /util/stream/pipe.cpp | |
| parent | 9991a6195dee8db26aa7e2f5f21549fb20e25002 (diff) | |
Restoring authorship annotation for <[email protected]>. Commit 1 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 51be1934a75..556c5766d72 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"; + } +} |
