aboutsummaryrefslogtreecommitdiffstats
path: root/util/system/shellcommand.cpp
diff options
context:
space:
mode:
authorAlexander Fokin <apfokin@gmail.com>2022-02-10 16:45:38 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:45:38 +0300
commit863a59a65247c24db7cb06789bc5cf79d04da32f (patch)
tree139dc000c8cd4a40f5659e421b7c75135d080307 /util/system/shellcommand.cpp
parentf64e95a9eb9ab03240599eb9581c5a9102426a96 (diff)
downloadydb-863a59a65247c24db7cb06789bc5cf79d04da32f.tar.gz
Restoring authorship annotation for Alexander Fokin <apfokin@gmail.com>. Commit 1 of 2.
Diffstat (limited to 'util/system/shellcommand.cpp')
-rw-r--r--util/system/shellcommand.cpp22
1 files changed, 11 insertions, 11 deletions
diff --git a/util/system/shellcommand.cpp b/util/system/shellcommand.cpp
index b1989b5c8c..1cebdec47b 100644
--- a/util/system/shellcommand.cpp
+++ b/util/system/shellcommand.cpp
@@ -24,7 +24,7 @@
#include <grp.h>
#include <sys/wait.h>
-using TPid = pid_t;
+using TPid = pid_t;
using TWaitResult = pid_t;
using TExitStatus = int;
#define WAIT_PROCEED 0
@@ -39,7 +39,7 @@ using TGetGroupListGid = gid_t;
#include "winint.h"
-using TPid = HANDLE;
+using TPid = HANDLE;
using TWaitResult = DWORD;
using TExitStatus = DWORD;
#define WAIT_PROCEED WAIT_TIMEOUT
@@ -190,7 +190,7 @@ using REALPIPEHANDLE = PIPEHANDLE;
class TShellCommand::TImpl
: public TAtomicRefCount<TShellCommand::TImpl> {
private:
- TPid Pid;
+ TPid Pid;
TString Command;
TList<TString> Arguments;
TString WorkDir;
@@ -367,11 +367,11 @@ public:
}
inline TProcessId GetPid() const {
-#if defined(_win_)
- return GetProcessId(Pid);
-#else
+#if defined(_win_)
+ return GetProcessId(Pid);
+#else
return Pid;
-#endif
+#endif
}
inline TFileHandle& GetInputHandle() {
@@ -949,10 +949,10 @@ void TShellCommand::TImpl::Communicate(TProcessInfo* pi) {
}
/// @todo factor out (poll + wfmo)
#if defined(_unix_)
- bool haveIn = false;
- bool haveOut = false;
- bool haveErr = false;
-
+ bool haveIn = false;
+ bool haveOut = false;
+ bool haveErr = false;
+
if (!input && pi->InputFd.IsOpen()) {
DBG(Cerr << "closing input stream..." << Endl);
pi->InputFd.Close();