: _files(files), _settings(settings), _errorLogger(errorLogger), _fileCount(0)

// Not initialized _fileSync, _errorSync, _reportSync

{

#if defined(THREADING_MODEL_FORK)

_wpipe = 0;

#elif defined(THREADING_MODEL_WIN)

_processedFiles = 0;

_totalFiles = 0;

_processedSize = 0;

_totalFileSize = 0;

#endif

{

char type = 0;

if (read(rpipe, &type, 1) <= 0) {

if (errno == EAGAIN)

return 0;

return -1;

}

if (type != REPORT_OUT && type != REPORT_ERROR && type != REPORT_INFO && type != CHILD_END) {

std::cerr << "#### You found a bug from cppcheck.\nThreadExecutor::handleRead error, type was:" << type << std::endl;

std::exit(0);

}

unsigned int len = 0;

if (read(rpipe, &len, sizeof(len)) <= 0) {

std::cerr << "#### You found a bug from cppcheck.\nThreadExecutor::handleRead error, type was:" << type << std::endl;

std::exit(0);

}

// Don't rely on incoming data being null-terminated.

// Allocate +1 element and null-terminate the buffer.

char *buf = new char[len + 1];

const ssize_t readIntoBuf = read(rpipe, buf, len);

if (readIntoBuf <= 0) {

std::cerr << "#### You found a bug from cppcheck.\nThreadExecutor::handleRead error, type was:" << type << std::endl;

std::exit(0);

}

buf[readIntoBuf] = 0;

if (type == REPORT_OUT) {

_errorLogger.reportOut(buf);

} else if (type == REPORT_ERROR || type == REPORT_INFO) {

ErrorLogger::ErrorMessage msg;

msg.deserialize(buf);

if (!_settings.nomsg.isSuppressed(msg.toSuppressionsErrorMessage())) {

// Alert only about unique errors

std::string errmsg = msg.toString(_settings.verbose);

if (std::find(_errorList.begin(), _errorList.end(), errmsg) == _errorList.end()) {

_errorList.push_back(errmsg);

if (type == REPORT_ERROR)

_errorLogger.reportErr(msg);

else

_errorLogger.reportInfo(msg);

}

}

} else if (type == CHILD_END) {

std::istringstream iss(buf);

unsigned int fileResult = 0;

iss >> fileResult;

result += fileResult;

delete [] buf;

return -1;

}

delete [] buf;

return 1;

{

#if defined(__CYGWIN__) || defined(__QNX__) // getloadavg() is unsupported on Cygwin, Qnx.

return true;

#else

if (!nchildren || !_settings.loadAverage) {

return true;

}

double sample(0);

if (getloadavg(&sample, 1) != 1) {

// disable load average checking on getloadavg error

return true;

} else if (sample < _settings.loadAverage) {

return true;

}

return false;

#endif

{

_fileCount = 0;

unsigned int result = 0;

std::size_t totalfilesize = 0;

for (std::map<std::string, std::size_t>::const_iterator i = _files.begin(); i != _files.end(); ++i) {

totalfilesize += i->second;

}

std::list<int> rpipes;

std::map<pid_t, std::string> childFile;

std::map<int, std::string> pipeFile;

std::size_t processedsize = 0;

std::map<std::string, std::size_t>::const_iterator iFile = _files.begin();

std::list<ImportProject::FileSettings>::const_iterator iFileSettings = _settings.project.fileSettings.begin();

for (;;) {

// Start a new child

size_t nchildren = rpipes.size();

if ((iFile != _files.end() || iFileSettings != _settings.project.fileSettings.end()) && nchildren < _settings.jobs && checkLoadAverage(nchildren)) {

int pipes[2];

if (pipe(pipes) == -1) {

std::cerr << "pipe() failed: "<< std::strerror(errno) << std::endl;

std::exit(EXIT_FAILURE);

}

int flags = 0;

if ((flags = fcntl(pipes[0], F_GETFL, 0)) < 0) {

std::cerr << "fcntl(F_GETFL) failed: "<< std::strerror(errno) << std::endl;

std::exit(EXIT_FAILURE);

}

if (fcntl(pipes[0], F_SETFL, flags | O_NONBLOCK) < 0) {

std::cerr << "fcntl(F_SETFL) failed: "<< std::strerror(errno) << std::endl;

std::exit(EXIT_FAILURE);

}

pid_t pid = fork();

if (pid < 0) {

// Error

std::cerr << "Failed to create child process: "<< std::strerror(errno) << std::endl;

std::exit(EXIT_FAILURE);

} else if (pid == 0) {

close(pipes[0]);

_wpipe = pipes[1];

CppCheck fileChecker(*this, false);

fileChecker.settings() = _settings;

unsigned int resultOfCheck = 0;

if (iFileSettings != _settings.project.fileSettings.end()) {

resultOfCheck = fileChecker.check(*iFileSettings);

} else if (!_fileContents.empty() && _fileContents.find(iFile->first) != _fileContents.end()) {

// File content was given as a string

resultOfCheck = fileChecker.check(iFile->first, _fileContents[ iFile->first ]);

} else {

// Read file from a file

resultOfCheck = fileChecker.check(iFile->first);

}

std::ostringstream oss;

oss << resultOfCheck;

writeToPipe(CHILD_END, oss.str());

std::exit(0);

}

close(pipes[1]);

rpipes.push_back(pipes[0]);

if (iFileSettings != _settings.project.fileSettings.end()) {

childFile[pid] = iFileSettings->filename + ' ' + iFileSettings->cfg;

pipeFile[pipes[0]] = iFileSettings->filename + ' ' + iFileSettings->cfg;

++iFileSettings;

} else {

childFile[pid] = iFile->first;

pipeFile[pipes[0]] = iFile->first;

++iFile;

}

} else if (!rpipes.empty()) {

fd_set rfds;

FD_ZERO(&rfds);

for (std::list<int>::const_iterator rp = rpipes.begin(); rp != rpipes.end(); ++rp)

FD_SET(*rp, &rfds);

struct timeval tv; // for every second polling of load average condition

tv.tv_sec = 1;

tv.tv_usec = 0;

int r = select(*std::max_element(rpipes.begin(), rpipes.end()) + 1, &rfds, nullptr, nullptr, &tv);

if (r > 0) {

std::list<int>::iterator rp = rpipes.begin();

while (rp != rpipes.end()) {

if (FD_ISSET(*rp, &rfds)) {

int readRes = handleRead(*rp, result);

if (readRes == -1) {

std::size_t size = 0;

std::map<int, std::string>::iterator p = pipeFile.find(*rp);

if (p != pipeFile.end()) {

std::string name = p->second;

pipeFile.erase(p);

std::map<std::string, std::size_t>::const_iterator fs = _files.find(name);

if (fs != _files.end()) {

size = fs->second;

}

}

_fileCount++;

processedsize += size;

if (!_settings.quiet)

CppCheckExecutor::reportStatus(_fileCount, _files.size() + _settings.project.fileSettings.size(), processedsize, totalfilesize);

close(*rp);

rp = rpipes.erase(rp);

} else

++rp;

} else

++rp;

}

}

int stat = 0;

pid_t child = waitpid(0, &stat, WNOHANG);

if (child > 0) {

std::string childname;

std::map<pid_t, std::string>::iterator c = childFile.find(child);

if (c != childFile.end()) {

childname = c->second;

childFile.erase(c);

}

if (WIFSIGNALED(stat)) {

std::ostringstream oss;

oss << "Internal error: Child process crashed with signal " << WTERMSIG(stat);

std::list<ErrorLogger::ErrorMessage::FileLocation> locations;

locations.emplace_back(childname, 0);

const ErrorLogger::ErrorMessage errmsg(locations,

emptyString,

Severity::error,

oss.str(),

"cppcheckError",

false);

if (!_settings.nomsg.isSuppressed(errmsg.toSuppressionsErrorMessage()))

_errorLogger.reportErr(errmsg);

}

}

} else {

// All done

break;

}

}

return result;

{

unsigned int len = static_cast<unsigned int>(data.length() + 1);

char *out = new char[ len + 1 + sizeof(len)];

out[0] = static_cast<char>(type);

std::memcpy(&(out[1]), &len, sizeof(len));

std::memcpy(&(out[1+sizeof(len)]), data.c_str(), len);

if (write(_wpipe, out, len + 1 + sizeof(len)) <= 0) {

delete [] out;

out = nullptr;

std::cerr << "#### ThreadExecutor::writeToPipe, Failed to write to pipe" << std::endl;

std::exit(0);

}

delete [] out;

{

HANDLE *threadHandles = new HANDLE[_settings.jobs];

_itNextFile = _files.begin();

_itNextFileSettings = _settings.project.fileSettings.begin();

_processedFiles = 0;

_processedSize = 0;

_totalFiles = _files.size() + _settings.project.fileSettings.size();

_totalFileSize = 0;

for (std::map<std::string, std::size_t>::const_iterator i = _files.begin(); i != _files.end(); ++i) {

_totalFileSize += i->second;

}

InitializeCriticalSection(&_fileSync);

InitializeCriticalSection(&_errorSync);

InitializeCriticalSection(&_reportSync);

for (unsigned int i = 0; i < _settings.jobs; ++i) {

threadHandles[i] = (HANDLE)_beginthreadex(nullptr, 0, threadProc, this, 0, nullptr);

if (!threadHandles[i]) {

std::cerr << "#### .\nThreadExecutor::check error, errno :" << errno << std::endl;

exit(EXIT_FAILURE);

}

}

const DWORD waitResult = WaitForMultipleObjects(_settings.jobs, threadHandles, TRUE, INFINITE);

if (waitResult != WAIT_OBJECT_0) {

if (waitResult == WAIT_FAILED) {

std::cerr << "#### .\nThreadExecutor::check wait failed, result: " << waitResult << " error: " << GetLastError() << std::endl;

exit(EXIT_FAILURE);

} else {

std::cerr << "#### .\nThreadExecutor::check wait failed, result: " << waitResult << std::endl;

exit(EXIT_FAILURE);

}

}

unsigned int result = 0;

for (unsigned int i = 0; i < _settings.jobs; ++i) {

DWORD exitCode;

if (!GetExitCodeThread(threadHandles[i], &exitCode)) {

std::cerr << "#### .\nThreadExecutor::check get exit code failed, error:" << GetLastError() << std::endl;

exit(EXIT_FAILURE);

}

result += exitCode;

if (!CloseHandle(threadHandles[i])) {

std::cerr << "#### .\nThreadExecutor::check close handle failed, error:" << GetLastError() << std::endl;

exit(EXIT_FAILURE);

}

}

DeleteCriticalSection(&_fileSync);

DeleteCriticalSection(&_errorSync);

DeleteCriticalSection(&_reportSync);

delete[] threadHandles;

return result;

{

unsigned int result = 0;

ThreadExecutor *threadExecutor = static_cast<ThreadExecutor*>(args);

std::map<std::string, std::size_t>::const_iterator &itFile = threadExecutor->_itNextFile;

std::list<ImportProject::FileSettings>::const_iterator &itFileSettings = threadExecutor->_itNextFileSettings;

// guard static members of CppCheck against concurrent access

EnterCriticalSection(&threadExecutor->_fileSync);

CppCheck fileChecker(*threadExecutor, false);

fileChecker.settings() = threadExecutor->_settings;

for (;;) {

if (itFile == threadExecutor->_files.end() && itFileSettings == threadExecutor->_settings.project.fileSettings.end()) {

LeaveCriticalSection(&threadExecutor->_fileSync);

break;

}

std::size_t fileSize = 0;

if (itFile != threadExecutor->_files.end()) {

const std::string &file = itFile->first;

fileSize = itFile->second;

++itFile;

LeaveCriticalSection(&threadExecutor->_fileSync);

const std::map<std::string, std::string>::const_iterator fileContent = threadExecutor->_fileContents.find(file);

if (fileContent != threadExecutor->_fileContents.end()) {

// File content was given as a string

result += fileChecker.check(file, fileContent->second);

} else {

// Read file from a file

result += fileChecker.check(file);

}

} else { // file settings..

const ImportProject::FileSettings &fs = *itFileSettings;

++itFileSettings;

LeaveCriticalSection(&threadExecutor->_fileSync);

result += fileChecker.check(fs);

}

EnterCriticalSection(&threadExecutor->_fileSync);

threadExecutor->_processedSize += fileSize;

threadExecutor->_processedFiles++;

if (!threadExecutor->_settings.quiet) {

EnterCriticalSection(&threadExecutor->_reportSync);

CppCheckExecutor::reportStatus(threadExecutor->_processedFiles, threadExecutor->_totalFiles, threadExecutor->_processedSize, threadExecutor->_totalFileSize);

LeaveCriticalSection(&threadExecutor->_reportSync);

}

}

return result;

{

EnterCriticalSection(&_reportSync);

_errorLogger.reportOut(outmsg);

LeaveCriticalSection(&_reportSync);

{

if (_settings.nomsg.isSuppressed(msg.toSuppressionsErrorMessage()))

return;

// Alert only about unique errors

bool reportError = false;

const std::string errmsg = msg.toString(_settings.verbose);

EnterCriticalSection(&_errorSync);

if (std::find(_errorList.begin(), _errorList.end(), errmsg) == _errorList.end()) {

_errorList.push_back(errmsg);

reportError = true;

}

LeaveCriticalSection(&_errorSync);

if (reportError) {

EnterCriticalSection(&_reportSync);

switch (msgType) {

case REPORT_ERROR:

_errorLogger.reportErr(msg);

break;

case REPORT_INFO:

_errorLogger.reportInfo(msg);

break;

}

LeaveCriticalSection(&_reportSync);

}