summaryrefslogtreecommitdiffstats
path: root/util/stream/pipe.cpp
diff options
context:
space:
mode:
authorekrokhalev <[email protected]>2022-02-10 16:50:10 +0300
committerDaniil Cherednik <[email protected]>2022-02-10 16:50:10 +0300
commit8d3a5b9c70bfb823a30242286328d6017b82b9ce (patch)
tree5d5cb817648f650d76cf1076100726fd9b8448e8 /util/stream/pipe.cpp
parent1c01ed5294724fda060c1f0bd674b315fe249598 (diff)
Restoring authorship annotation for <[email protected]>. Commit 2 of 2.
Diffstat (limited to 'util/stream/pipe.cpp')
-rw-r--r--util/stream/pipe.cpp56
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";
+ }
+}