wirenboard / wb-mqtt-w1 / 2

Committed 31 Jul 2026 09:52AM UTC coverage: 61.341% (+2.2%) from 59.111%

Build # 2

Build Type

Pull #36

github

Specific Base 450382

Committed by

ekateluv

Commit Message

Add missing cstdint include in test/utils.h

clang-tidy 22 in the updated devenv image no longer gets uint8_t
transitively from other standard headers.

Pull Request Pull Request #36: Use exported vars instead of MAKEFLAGS for coverage options

Coverage Stats

172 of 248 branches covered (69.35%)

311 of 507 relevant lines covered (61.34%)

9.1 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

6.67

/threaded_runner.cpp

#include "threaded_runner.h"

#include <algorithm>
#include <wblib/utils.h>

using namespace std;
using namespace WBMQTT;

IPeriodicalWorker::~IPeriodicalWorker()
{}

TThreadedPeriodicalRunner::TThreadedPeriodicalRunner(unique_ptr<IPeriodicalWorker> worker,
                                                     std::chrono::milliseconds pollInterval,
                                                     const string& threadName,
                                                     TLogger& logger)
    : Worker(move(worker)),
      Active(false)
{
    if (pollInterval.count() < 1) {
        throw invalid_argument("polling intervall must be greater than zero");
    }

    Active = true;
    WorkerThread = MakeThread(threadName, {[this, pollInterval, threadName, &logger] {
                                  logger.Log() << threadName << " Started";

                                  while (1) {
                                      Worker->RunIteration();

                                      unique_lock<mutex> lk(ActiveMutex);
                                      if (ActiveCV.wait_for(lk, pollInterval, [&] { return !Active; })) {
                                          break;
                                      }
                                  }
                                  logger.Log() << threadName << " Stopped";
                              }});
}

TThreadedPeriodicalRunner::~TThreadedPeriodicalRunner()
{
    {
        lock_guard<mutex> lock(ActiveMutex);
        if (!Active) {
            return;
        }
        Active = false;
    }
    ActiveCV.notify_one();

    if (WorkerThread->joinable()) {
        WorkerThread->join();
    }

    WorkerThread.reset();
}

1	#include "threaded_runner.h"
2
3	#include <algorithm>
4	#include <wblib/utils.h>
5
6	using namespace std;
7	using namespace WBMQTT;
8
9	IPeriodicalWorker::~IPeriodicalWorker()	12✔
10	{}	12✔
11
12	TThreadedPeriodicalRunner::TThreadedPeriodicalRunner(unique_ptr<IPeriodicalWorker> worker,	×
13	std::chrono::milliseconds pollInterval,
14	const string& threadName,
15	TLogger& logger)	×
16	: Worker(move(worker)),	×
17	Active(false)	×
18	{
19	if (pollInterval.count() < 1) {	×
20	throw invalid_argument("polling intervall must be greater than zero");	×
21	}
22
23	Active = true;	×
24	WorkerThread = MakeThread(threadName, {[this, pollInterval, threadName, &logger] {	×
25	logger.Log() << threadName << " Started";	×
26
27	while (1) {
28	Worker->RunIteration();	×
29
30	unique_lock<mutex> lk(ActiveMutex);	×
31	if (ActiveCV.wait_for(lk, pollInterval, [&] { return !Active; })) {	×
32	break;	×
33	}
34	}	×
35	logger.Log() << threadName << " Stopped";	×
36	}});	×
37	}	×
38
39	TThreadedPeriodicalRunner::~TThreadedPeriodicalRunner()	×
40	{
41	{
42	lock_guard<mutex> lock(ActiveMutex);	×
43	if (!Active) {	×
44	return;	×
45	}
46	Active = false;	×
47	}	×
48	ActiveCV.notify_one();	×
49
50	if (WorkerThread->joinable()) {	×
51	WorkerThread->join();	×
52	}
53
54	WorkerThread.reset();	×
55	}	×

wirenboard / wb-mqtt-w1 / 2

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous