mirror of
https://github.com/Kitware/CMake.git
synced 2026-01-12 01:09:47 -06:00
bcbb212df7
Wide use of CMake 3.28.{1,0[-rcN]} has uncovered some hangs and crashes
in libuv SIGCHLD handling on some platforms, particularly in virtualization
environments on macOS hosts. Although the bug does not seem to be in CMake,
we can restore stability in the CMake 3.28 release series for users of such
platforms by reverting our new uses of libuv for process execution.
Revert implementation changes merged by commit 4771544386 (Merge topic
'replace-cmsysprocess-with-cmuvprocesschain', 2023-09-06, v3.28.0-rc1~138),
but keep test suite updates.
Issue: #25414, #25500, #25562, #25589
87 lines
2.4 KiB
C++
87 lines
2.4 KiB
C++
/* Distributed under the OSI-approved BSD 3-Clause License. See accompanying
|
|
file Copyright.txt or https://cmake.org/licensing for details. */
|
|
#include "cmProcessTools.h"
|
|
|
|
#include <ostream>
|
|
|
|
#include "cmsys/Process.h"
|
|
|
|
#include "cmProcessOutput.h"
|
|
|
|
void cmProcessTools::RunProcess(struct cmsysProcess_s* cp, OutputParser* out,
|
|
OutputParser* err, Encoding encoding)
|
|
{
|
|
cmsysProcess_Execute(cp);
|
|
char* data = nullptr;
|
|
int length = 0;
|
|
int p;
|
|
cmProcessOutput processOutput(encoding);
|
|
std::string strdata;
|
|
while ((out || err) &&
|
|
(p = cmsysProcess_WaitForData(cp, &data, &length, nullptr))) {
|
|
if (out && p == cmsysProcess_Pipe_STDOUT) {
|
|
processOutput.DecodeText(data, length, strdata, 1);
|
|
if (!out->Process(strdata.c_str(), static_cast<int>(strdata.size()))) {
|
|
out = nullptr;
|
|
}
|
|
} else if (err && p == cmsysProcess_Pipe_STDERR) {
|
|
processOutput.DecodeText(data, length, strdata, 2);
|
|
if (!err->Process(strdata.c_str(), static_cast<int>(strdata.size()))) {
|
|
err = nullptr;
|
|
}
|
|
}
|
|
}
|
|
if (out) {
|
|
processOutput.DecodeText(std::string(), strdata, 1);
|
|
if (!strdata.empty()) {
|
|
out->Process(strdata.c_str(), static_cast<int>(strdata.size()));
|
|
}
|
|
}
|
|
if (err) {
|
|
processOutput.DecodeText(std::string(), strdata, 2);
|
|
if (!strdata.empty()) {
|
|
err->Process(strdata.c_str(), static_cast<int>(strdata.size()));
|
|
}
|
|
}
|
|
cmsysProcess_WaitForExit(cp, nullptr);
|
|
}
|
|
|
|
cmProcessTools::LineParser::LineParser(char sep, bool ignoreCR)
|
|
: Separator(sep)
|
|
, IgnoreCR(ignoreCR)
|
|
{
|
|
}
|
|
|
|
void cmProcessTools::LineParser::SetLog(std::ostream* log, const char* prefix)
|
|
{
|
|
this->Log = log;
|
|
this->Prefix = prefix ? prefix : "";
|
|
}
|
|
|
|
bool cmProcessTools::LineParser::ProcessChunk(const char* first, int length)
|
|
{
|
|
const char* last = first + length;
|
|
for (const char* c = first; c != last; ++c) {
|
|
if (*c == this->Separator || *c == '\0') {
|
|
this->LineEnd = *c;
|
|
|
|
// Log this line.
|
|
if (this->Log && this->Prefix) {
|
|
*this->Log << this->Prefix << this->Line << "\n";
|
|
}
|
|
|
|
// Hand this line to the subclass implementation.
|
|
if (!this->ProcessLine()) {
|
|
this->Line.clear();
|
|
return false;
|
|
}
|
|
|
|
this->Line.clear();
|
|
} else if (*c != '\r' || !this->IgnoreCR) {
|
|
// Append this character to the line under construction.
|
|
this->Line.append(1, *c);
|
|
}
|
|
}
|
|
return true;
|
|
}
|