wirenboard / wb-mqtt-smartweb / 47

Committed 31 Jul 2026 10:42AM UTC coverage: 33.897% (-0.8%) from 34.703%

Build # 47

Build Type

push

github

Committed by

web-flow

Commit Message

Use exported vars instead of MAKEFLAGS for coverage options (#40)

Coverage Stats

307 of 744 branches covered (41.26%)

501 of 1478 relevant lines covered (33.9%)

10.02 hits per line

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

0.0

/src/ThreadedCanReader.cpp

#include "ThreadedCanReader.h"

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

namespace
{
    const auto READ_TIMEOUT = std::chrono::milliseconds(1000);
}

TThreadedCanReader::TThreadedCanReader(const std::string& threadName,
                                       std::shared_ptr<CAN::IPort> canPort,
                                       size_t framesQueueMaxLength,
                                       std::function<bool(const CAN::TFrame& frame)> acceptFrame,
                                       std::function<void(const CAN::TFrame& frame)> handleFrame)
    : CanPort(canPort),
      FramesQueueMaxLength(framesQueueMaxLength),
      AcceptFrame(acceptFrame)
{
    Enabled.store(true);
    CanPort->AddHandler(this);

    Thread = std::thread([this, threadName, handleFrame]() {
        WBMQTT::SetThreadName(threadName);
        CAN::TFrame frame;
        while (Enabled.load()) {
            memset(&frame, 0, sizeof(CAN::TFrame));
            if (Get(frame)) {
                handleFrame(frame);
            }
        }
    });
}

TThreadedCanReader::~TThreadedCanReader()
{
    CanPort->RemoveHandler(this);
    Enabled.store(false);
    if (Thread.joinable()) {
        Thread.join();
    }
}

bool TThreadedCanReader::Handle(const CAN::TFrame& frame)
{
    if (!AcceptFrame(frame)) {
        return false;
    }
    std::unique_lock<std::mutex> waitLock(Mutex);
    if (Frames.size() < FramesQueueMaxLength) {
        Frames.push(frame);
        Cv.notify_all();
    }
    return true;
}

bool TThreadedCanReader::Get(CAN::TFrame& frame)
{
    std::unique_lock<std::mutex> waitLock(Mutex);
    if (Frames.empty()) {
        if (std::cv_status::timeout == Cv.wait_for(waitLock, READ_TIMEOUT)) {
            return false;
        }
    }
    frame = Frames.front();
    Frames.pop();
    return true;
}

1	#include "ThreadedCanReader.h"
2
3	#include <cstring>
4	#include <wblib/utils.h>
5
6	namespace
7	{
8	const auto READ_TIMEOUT = std::chrono::milliseconds(1000);
9	}
10
11	TThreadedCanReader::TThreadedCanReader(const std::string& threadName,	×
12	std::shared_ptr<CAN::IPort> canPort,
13	size_t framesQueueMaxLength,
14	std::function<bool(const CAN::TFrame& frame)> acceptFrame,
15	std::function<void(const CAN::TFrame& frame)> handleFrame)	×
16	: CanPort(canPort),	×
17	FramesQueueMaxLength(framesQueueMaxLength),	×
18	AcceptFrame(acceptFrame)	×
19	{
20	Enabled.store(true);	×
21	CanPort->AddHandler(this);	×
22
23	Thread = std::thread([this, threadName, handleFrame]() {	×
24	WBMQTT::SetThreadName(threadName);	×
25	CAN::TFrame frame;
26	while (Enabled.load()) {	×
27	memset(&frame, 0, sizeof(CAN::TFrame));	×
28	if (Get(frame)) {	×
29	handleFrame(frame);	×
30	}
31	}
32	});	×
33	}	×
34
35	TThreadedCanReader::~TThreadedCanReader()	×
36	{
37	CanPort->RemoveHandler(this);	×
38	Enabled.store(false);	×
39	if (Thread.joinable()) {	×
40	Thread.join();	×
41	}
42	}	×
43
44	bool TThreadedCanReader::Handle(const CAN::TFrame& frame)	×
45	{
46	if (!AcceptFrame(frame)) {	×
47	return false;	×
48	}
49	std::unique_lock<std::mutex> waitLock(Mutex);	×
50	if (Frames.size() < FramesQueueMaxLength) {	×
51	Frames.push(frame);	×
52	Cv.notify_all();	×
53	}
54	return true;	×
55	}	×
56
57	bool TThreadedCanReader::Get(CAN::TFrame& frame)	×
58	{
59	std::unique_lock<std::mutex> waitLock(Mutex);	×
60	if (Frames.empty()) {	×
61	if (std::cv_status::timeout == Cv.wait_for(waitLock, READ_TIMEOUT)) {	×
62	return false;	×
63	}
64	}
65	frame = Frames.front();	×
66	Frames.pop();	×
67	return true;	×
68	}	×

wirenboard / wb-mqtt-smartweb / 47

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