diff --git a/lix/libutil/processes.cc b/lix/libutil/processes.cc index 997c00b5b..1809a3019 100644 --- a/lix/libutil/processes.cc +++ b/lix/libutil/processes.cc @@ -251,25 +251,25 @@ try { options.captureStdout = true; int status = 0; - std::string stdout; + std::string childStdout; try { auto proc = runProgram2(options); Finally const _wait([&] { proc.waitAndCheck(); }); - stdout = TRY_AWAIT(proc.getStdout()->drain()); + childStdout = TRY_AWAIT(proc.getStdout()->drain()); } catch (ExecError & e) { status = e.status; } - co_return {status, std::move(stdout)}; + co_return {status, std::move(childStdout)}; } catch (...) { co_return result::current_exception(); } -RunningProgram::RunningProgram(PathView program, Pid pid, AutoCloseFD stdout) +RunningProgram::RunningProgram(PathView program, Pid pid, AutoCloseFD childStdout) : program(program) , pid(std::move(pid)) - , stdout(stdout ? std::make_unique(std::move(stdout)) : nullptr) + , childStdout(childStdout ? std::make_unique(std::move(childStdout)) : nullptr) { } @@ -286,7 +286,7 @@ RunningProgram::~RunningProgram() std::tuple> RunningProgram::release() { - return {pid.release(), std::move(stdout)}; + return {pid.release(), std::move(childStdout)}; } int RunningProgram::kill() diff --git a/lix/libutil/processes.hh b/lix/libutil/processes.hh index 67d067be0..7a5fae3d8 100644 --- a/lix/libutil/processes.hh +++ b/lix/libutil/processes.hh @@ -109,9 +109,9 @@ struct [[nodiscard("you must call RunningProgram::wait()")]] RunningProgram private: Path program; Pid pid; - std::unique_ptr stdout; + std::unique_ptr childStdout; - RunningProgram(PathView program, Pid pid, AutoCloseFD stdout); + RunningProgram(PathView program, Pid pid, AutoCloseFD childStdout); public: RunningProgram() = default; @@ -130,12 +130,12 @@ public: std::optional getStdoutFD() const { - return stdout ? std::optional(stdout->getFD()) : std::nullopt; + return childStdout ? std::optional(childStdout->getFD()) : std::nullopt; } AsyncFdIoStream * getStdout() const { - return stdout.get(); + return childStdout.get(); }; }; diff --git a/lix/nix/daemon.cc b/lix/nix/daemon.cc index c3cd842b4..fc3ebe528 100644 --- a/lix/nix/daemon.cc +++ b/lix/nix/daemon.cc @@ -458,16 +458,16 @@ static void forwardStdioConnection(AsyncIoRoot & aio, RemoteStore & store) { auto conn = store.openConnectionWrapper(); auto connSocket = AIO().lowLevelProvider.wrapSocketFd(conn->getFD()); - auto stdin = AIO().lowLevelProvider.wrapInputFd(STDIN_FILENO); - auto stdout = AIO().lowLevelProvider.wrapOutputFd(STDOUT_FILENO); + auto asyncStdin = AIO().lowLevelProvider.wrapInputFd(STDIN_FILENO); + auto asyncStdout = AIO().lowLevelProvider.wrapOutputFd(STDOUT_FILENO); - aio.blockOn(connSocket->pumpTo(*stdout) + aio.blockOn(connSocket->pumpTo(*asyncStdout) .then([](auto) -> Result { return { std::make_exception_ptr(EndOfFile("unexpected EOF from daemon socket")) }; }) - .exclusiveJoin(stdin->pumpTo(*connSocket).then([](auto) -> Result { + .exclusiveJoin(asyncStdin->pumpTo(*connSocket).then([](auto) -> Result { return result::success(); }))); }