execute_process: Restore termination of processes on timeout

Since commit 5420639a8d (cmExecuteProcessCommand: Replace cmsysProcess
with cmUVProcessChain, 2023-06-01, v3.28.0-rc1~138^2~8) we have not
actually terminated child processes on an `execute_process` timeout.
Similarly for other migrations from cmsysProcess to cmUVProcessChain.

Teach cmUVProcessChain clients that implement timeouts to actually
terminate remaining child processes when the timeout is reached.

Fixes: #27378
This commit is contained in:
Brad King
2025-11-11 09:06:49 -05:00
parent 253b2b8c7b
commit e2cfc61e5e
6 changed files with 30 additions and 0 deletions

View File

@@ -982,6 +982,7 @@ bool cmCTestBuildHandler::RunMakeCommand(const std::string& command,
break;
}
} else {
chain.Terminate();
cmCTestOptionalLog(this->CTest, WARNING,
"There was a timeout" << std::endl, this->Quiet);
}

View File

@@ -1179,6 +1179,7 @@ bool cmCTest::RunMakeCommand(const std::string& command, std::string& output,
break;
}
} else {
chain.Terminate();
cmCTestLog(this, WARNING, "There was a timeout" << std::endl);
}
@@ -1351,6 +1352,8 @@ bool cmCTest::RunTest(const std::vector<std::string>& argv,
cmCTestLog(this, HANDLER_VERBOSE_OUTPUT, outerr << std::endl);
} break;
}
} else {
chain.Terminate();
}
return result;
@@ -3611,6 +3614,7 @@ bool cmCTest::RunCommand(std::vector<std::string> const& args,
bool result = true;
if (timedOut) {
chain.Terminate();
const char* error_str = "Process terminated due to timeout\n";
cmCTestLog(this, ERROR_MESSAGE, error_str << std::endl);
stdErr->append(error_str, strlen(error_str));

View File

@@ -391,6 +391,9 @@ bool cmExecuteProcessCommand(std::vector<std::string> const& args,
!(chain.Finished() && outputData.Finished && errorData.Finished)) {
uv_run(&chain.GetLoop(), UV_RUN_ONCE);
}
if (timedOut) {
chain.Terminate();
}
if (!arguments.OutputQuiet &&
(arguments.OutputVariable.empty() || arguments.EchoOutputVariable)) {
processOutput.DecodeText(std::string(), strdata, 1);

View File

@@ -696,6 +696,7 @@ bool cmSystemTools::RunSingleCommand(std::vector<std::string> const& command,
bool result = true;
if (timedOut) {
chain.Terminate();
const char* error_str = "Process terminated due to timeout\n";
if (outputflag != OUTPUT_NONE) {
std::cerr << error_str << std::endl;

View File

@@ -12,6 +12,8 @@
#include <cm3p/uv.h>
#include "cmsys/Process.h"
#include "cm_fileno.hxx"
#include "cmGetPipes.h"
@@ -58,6 +60,7 @@ struct cmUVProcessChain::InternalData
const cmUVProcessChainBuilder::ProcessConfiguration& config, bool first,
bool last);
void Finish();
void Terminate();
};
cmUVProcessChainBuilder::cmUVProcessChainBuilder() = default;
@@ -388,6 +391,15 @@ void cmUVProcessChain::InternalData::Finish()
this->Valid = true;
}
void cmUVProcessChain::InternalData::Terminate()
{
for (std::unique_ptr<ProcessData> const& p : this->Processes) {
if (!p->ProcessStatus.Finished) {
cmsysProcess_KillPID(static_cast<unsigned long>(p->Process->pid));
}
}
}
cmUVProcessChain::cmUVProcessChain()
: Data(cm::make_unique<InternalData>())
{
@@ -472,6 +484,11 @@ bool cmUVProcessChain::Finished() const
return this->Data->ProcessesCompleted >= this->Data->Processes.size();
}
void cmUVProcessChain::Terminate()
{
this->Data->Terminate();
}
std::pair<cmUVProcessChain::ExceptionCode, std::string>
cmUVProcessChain::Status::GetException() const
{

View File

@@ -116,6 +116,10 @@ public:
const Status& GetStatus(std::size_t index) const;
bool Finished() const;
/** Terminate any remaining child processes.
Call this only after exiting the event loop, and at most once. */
void Terminate();
private:
friend class cmUVProcessChainBuilder;