GCC Code Coverage Report

Directory: ./
File: src/MessageManager.cpp
Date: 2025-09-18 10:27:59
Exec Total Coverage
Lines: 36 43 83.7%
Branches: 30 64 46.9%
Line Branch Exec Source
1 /*****************************************************************************
2 *
3 * Copyright (C) 2022 Florian Pose <fp@igh.de>
4 *
5 * This file is part of the QtPdCom library.
6 *
7 * The QtPdCom library is free software: you can redistribute it and/or modify
8 * it under the terms of the GNU Lesser General Public License as published by
9 * the Free Software Foundation, either version 3 of the License, or (at your
10 * option) any later version.
11 *
12 * The QtPdCom library is distributed in the hope that it will be useful, but
13 * WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY
14 * or FITNESS FOR A PARTICULAR PURPOSE. See the GNU Lesser General Public
15 * License for more details.
16 *
17 * You should have received a copy of the GNU Lesser General Public License
18 * along with the QtPdCom Library. If not, see <http://www.gnu.org/licenses/>.
19 *
20 ****************************************************************************/
21
22 #include "MessageManager.h"
23
24 #include <QDebug>
25
26 using QtPdCom::MessageManager;
27
28 /****************************************************************************/
29
30
1/2
✓ Branch 2 taken 16 times.
✗ Branch 3 not taken.
 16 MessageManager::MessageManager()
31 {
32 16 }
33
34 /****************************************************************************/
35
36 32 MessageManager::~MessageManager()
37 {
38 16 reset();
39 16 }
40
41 /****************************************************************************/
42
43 37 void MessageManager::reset()
44 {
45 37 emit processResetSignal();
46
1/2
✗ Branch 1 not taken.
✓ Branch 2 taken 37 times.
 37 while (!activeMessageQueue.empty())
47 ✗ activeMessageQueue.dequeue().reportCanceled();
48 ✗ while (!getMessageQueue.empty())
49 ✗ getMessageQueue.dequeue().reportCanceled();
50 37 }
51
52 /****************************************************************************/
53
54 24 void MessageManager::processMessage(PdCom::Message message)
55 {
56
1/2
✓ Branch 3 taken 24 times.
✗ Branch 4 not taken.
 24 emit processMessageSignal(message);
57 24 }
58
59 /****************************************************************************/
60
61 13 QtPdCom::MessageFuture MessageManager::getMessageQt(uint32_t seqNo)
62 {
63
1/2
✓ Branch 2 taken 13 times.
✗ Branch 3 not taken.
 26 MessageFutureInterface promise;
64
1/2
✓ Branch 1 taken 13 times.
✗ Branch 2 not taken.
 13 getMessageQueue.push_back(promise);
65
1/2
✓ Branch 1 taken 13 times.
✗ Branch 2 not taken.
 13 promise.reportStarted();
66
1/2
✓ Branch 1 taken 13 times.
✗ Branch 2 not taken.
 13 PdCom::MessageManagerBase::getMessage(seqNo);
67
1/2
✓ Branch 1 taken 13 times.
✗ Branch 2 not taken.
 26 return promise.future();
68 }
69
70 /****************************************************************************/
71
72 13 void MessageManager::getMessageReply(PdCom::Message message)
73 {
74
1/2
✗ Branch 1 not taken.
✓ Branch 2 taken 13 times.
 13 if (getMessageQueue.empty())
75 ✗ return;
76
77
2/4
✓ Branch 2 taken 13 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 13 times.
✗ Branch 6 not taken.
 26 auto promise = getMessageQueue.dequeue();
78
2/4
✓ Branch 1 taken 13 times.
✗ Branch 2 not taken.
✗ Branch 3 not taken.
✓ Branch 4 taken 13 times.
 13 if (promise.isCanceled())
79 ✗ return;
80
1/2
✓ Branch 1 taken 13 times.
✗ Branch 2 not taken.
 13 promise.reportResult(message);
81
2/4
✓ Branch 1 taken 13 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 13 times.
✗ Branch 5 not taken.
 13 promise.reportFinished();
82 }
83
84 /****************************************************************************/
85
86 5 QtPdCom::MessageListFuture MessageManager::activeMessagesQt()
87 {
88
1/2
✓ Branch 2 taken 5 times.
✗ Branch 3 not taken.
 10 MessageListFutureInterface promise;
89
1/2
✓ Branch 1 taken 5 times.
✗ Branch 2 not taken.
 5 activeMessageQueue.push_back(promise);
90
1/2
✓ Branch 1 taken 5 times.
✗ Branch 2 not taken.
 5 promise.reportStarted();
91
1/2
✓ Branch 1 taken 5 times.
✗ Branch 2 not taken.
 5 PdCom::MessageManagerBase::activeMessages();
92
1/2
✓ Branch 1 taken 5 times.
✗ Branch 2 not taken.
 10 return promise.future();
93 }
94
95 /****************************************************************************/
96
97 5 void MessageManager::activeMessagesReply(
98 std::vector<PdCom::Message> messageList)
99 {
100
1/2
✗ Branch 1 not taken.
✓ Branch 2 taken 5 times.
 5 if (activeMessageQueue.empty())
101 ✗ return;
102
103
2/4
✓ Branch 2 taken 5 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 5 times.
✗ Branch 6 not taken.
 10 auto promise = activeMessageQueue.dequeue();
104
2/4
✓ Branch 1 taken 5 times.
✗ Branch 2 not taken.
✗ Branch 3 not taken.
✓ Branch 4 taken 5 times.
 5 if (promise.isCanceled())
105 ✗ return;
106
1/2
✓ Branch 1 taken 5 times.
✗ Branch 2 not taken.
 5 promise.reportResult(messageList);
107
2/4
✓ Branch 1 taken 5 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 5 times.
✗ Branch 5 not taken.
 5 promise.reportFinished();
108 }
109
110 /****************************************************************************/
111