aboutsummaryrefslogtreecommitdiffstats
path: root/util/stream/pipe.h
diff options
context:
space:
mode:
authorVlad Yaroslavlev <vladon@vladon.com>2022-02-10 16:46:25 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:46:25 +0300
commit344ea37b4a345701ab0e67de2266a1c1bd7baf2d (patch)
tree1a2c5ffcf89eb53ecd79dbc9bc0a195c27404d0c /util/stream/pipe.h
parent706b83ed7de5a473436620367af31fc0ceecde07 (diff)
downloadydb-344ea37b4a345701ab0e67de2266a1c1bd7baf2d.tar.gz
Restoring authorship annotation for Vlad Yaroslavlev <vladon@vladon.com>. Commit 2 of 2.
Diffstat (limited to 'util/stream/pipe.h')
-rw-r--r--util/stream/pipe.h16
1 files changed, 8 insertions, 8 deletions
diff --git a/util/stream/pipe.h b/util/stream/pipe.h
index 8ffdbd1bdc..18525b9517 100644
--- a/util/stream/pipe.h
+++ b/util/stream/pipe.h
@@ -5,7 +5,7 @@
#include <util/system/pipe.h>
#include <util/generic/ptr.h>
-#include <util/generic/string.h>
+#include <util/generic/string.h>
/**
* @addtogroup Streams_Pipes
@@ -24,8 +24,8 @@ protected:
* @param mode Data transfer mode for the pipe. Use
* "r" for reading and "w" for writing.
*/
- TPipeBase(const TString& command, const char* mode);
- virtual ~TPipeBase();
+ TPipeBase(const TString& command, const char* mode);
+ virtual ~TPipeBase();
protected:
class TImpl;
@@ -45,7 +45,7 @@ public:
*
* @param command Command line to start a process with.
*/
- TPipeInput(const TString& command);
+ TPipeInput(const TString& command);
private:
size_t DoRead(void* buf, size_t len) override;
@@ -64,7 +64,7 @@ public:
*
* @param command Command line to start a process with.
*/
- TPipeOutput(const TString& command);
+ TPipeOutput(const TString& command);
/**
* Waits for the process to terminate and throws an exception if it ended
@@ -79,7 +79,7 @@ private:
class TPipedBase {
protected:
TPipedBase(PIPEHANDLE fd);
- virtual ~TPipedBase();
+ virtual ~TPipedBase();
protected:
TPipeHandle Handle_;
@@ -91,7 +91,7 @@ protected:
class TPipedInput: public TPipedBase, public IInputStream {
public:
TPipedInput(PIPEHANDLE fd);
- ~TPipedInput() override;
+ ~TPipedInput() override;
private:
size_t DoRead(void* buf, size_t len) override;
@@ -103,7 +103,7 @@ private:
class TPipedOutput: public TPipedBase, public IOutputStream {
public:
TPipedOutput(PIPEHANDLE fd);
- ~TPipedOutput() override;
+ ~TPipedOutput() override;
private:
void DoWrite(const void* buf, size_t len) override;