@@ -391,10 +391,10 @@ void ThreadExecutor::reportInternalChildErr(const std::string &childname, const
391391
392392#elif defined(THREADING_MODEL_THREAD)
393393
394- class ThreadExecutor ::LogWriter : public ErrorLogger
394+ class ThreadExecutor ::SyncLogForwarder : public ErrorLogger
395395{
396396public:
397- LogWriter (ThreadExecutor &threadExecutor)
397+ SyncLogForwarder (ThreadExecutor &threadExecutor)
398398 : mThreadExecutor (threadExecutor), mProcessedFiles (0 ), mTotalFiles (0 ), mProcessedSize (0 ), mTotalFileSize (0 ) {
399399
400400 mItNextFile = threadExecutor.mFiles .begin ();
@@ -475,11 +475,11 @@ unsigned int ThreadExecutor::check()
475475 std::vector<std::future<unsigned int >> threadFutures;
476476 threadFutures.reserve (mSettings .jobs );
477477
478- LogWriter logwriter (*this );
478+ SyncLogForwarder logforwarder (*this );
479479
480480 for (unsigned int i = 0 ; i < mSettings .jobs ; ++i) {
481481 try {
482- threadFutures.emplace_back (std::async (std::launch::async, threadProc, &logwriter ));
482+ threadFutures.emplace_back (std::async (std::launch::async, threadProc, &logforwarder ));
483483 }
484484 catch (const std::system_error &e) {
485485 std::cerr << " #### ThreadExecutor::check exception :" << e.what () << std::endl;
@@ -492,51 +492,51 @@ unsigned int ThreadExecutor::check()
492492 });
493493}
494494
495- unsigned int STDCALL ThreadExecutor::threadProc (LogWriter* logWriter )
495+ unsigned int STDCALL ThreadExecutor::threadProc (SyncLogForwarder* logForwarder )
496496{
497497 unsigned int result = 0 ;
498498
499- std::map<std::string, std::size_t >::const_iterator &itFile = logWriter ->mItNextFile ;
500- std::list<ImportProject::FileSettings>::const_iterator &itFileSettings = logWriter ->mItNextFileSettings ;
499+ std::map<std::string, std::size_t >::const_iterator &itFile = logForwarder ->mItNextFile ;
500+ std::list<ImportProject::FileSettings>::const_iterator &itFileSettings = logForwarder ->mItNextFileSettings ;
501501
502502 // guard static members of CppCheck against concurrent access
503- logWriter ->mFileSync .lock ();
503+ logForwarder ->mFileSync .lock ();
504504
505505 for (;;) {
506- if (itFile == logWriter ->mThreadExecutor .mFiles .end () && itFileSettings == logWriter ->mThreadExecutor .mSettings .project .fileSettings .end ()) {
507- logWriter ->mFileSync .unlock ();
506+ if (itFile == logForwarder ->mThreadExecutor .mFiles .end () && itFileSettings == logForwarder ->mThreadExecutor .mSettings .project .fileSettings .end ()) {
507+ logForwarder ->mFileSync .unlock ();
508508 break ;
509509 }
510510
511- CppCheck fileChecker (*logWriter , false , CppCheckExecutor::executeCommand);
512- fileChecker.settings () = logWriter ->mThreadExecutor .mSettings ;
511+ CppCheck fileChecker (*logForwarder , false , CppCheckExecutor::executeCommand);
512+ fileChecker.settings () = logForwarder ->mThreadExecutor .mSettings ;
513513
514514 std::size_t fileSize = 0 ;
515- if (itFile != logWriter ->mThreadExecutor .mFiles .end ()) {
515+ if (itFile != logForwarder ->mThreadExecutor .mFiles .end ()) {
516516 const std::string &file = itFile->first ;
517517 fileSize = itFile->second ;
518518 ++itFile;
519519
520- logWriter ->mFileSync .unlock ();
520+ logForwarder ->mFileSync .unlock ();
521521
522522 // Read file from a file
523523 result += fileChecker.check (file);
524524 } else { // file settings..
525525 const ImportProject::FileSettings &fs = *itFileSettings;
526526 ++itFileSettings;
527- logWriter ->mFileSync .unlock ();
527+ logForwarder ->mFileSync .unlock ();
528528 result += fileChecker.check (fs);
529- if (logWriter ->mThreadExecutor .mSettings .clangTidy )
529+ if (logForwarder ->mThreadExecutor .mSettings .clangTidy )
530530 fileChecker.analyseClangTidy (fs);
531531 }
532532
533- logWriter ->mFileSync .lock ();
533+ logForwarder ->mFileSync .lock ();
534534
535- logWriter ->mProcessedSize += fileSize;
536- logWriter ->mProcessedFiles ++;
537- if (!logWriter ->mThreadExecutor .mSettings .quiet ) {
538- std::lock_guard<std::mutex> lg (logWriter ->mReportSync );
539- CppCheckExecutor::reportStatus (logWriter ->mProcessedFiles , logWriter ->mTotalFiles , logWriter ->mProcessedSize , logWriter ->mTotalFileSize );
535+ logForwarder ->mProcessedSize += fileSize;
536+ logForwarder ->mProcessedFiles ++;
537+ if (!logForwarder ->mThreadExecutor .mSettings .quiet ) {
538+ std::lock_guard<std::mutex> lg (logForwarder ->mReportSync );
539+ CppCheckExecutor::reportStatus (logForwarder ->mProcessedFiles , logForwarder ->mTotalFiles , logForwarder ->mProcessedSize , logForwarder ->mTotalFileSize );
540540 }
541541 }
542542 return result;
0 commit comments