GCC Code Coverage Report

Directory: ./
File: TESTS/TEST_BACKEND_ERRORS/main_sender_errors.cpp
Date: 2026-01-23 17:10:06
Exec Total Coverage
Lines: 38 38 100.0%
Functions: 5 5 100.0%
Branches: 76 85 89.4%
Line Branch Exec Source
1 #include <iostream>
2 #include <thread>
3 #include <chrono>
4 #include <string>
5 #include <zmq.hpp>
6 #include <unistd.h>
7 #include "data_stream_assert.h"
8 #include "PGenericSocketManager.h"
9 #include "PZmqBackend.h"
10
11 typedef PGenericSocketManager<std::string, PZmqBackend, PMockBackend> SocketManager;
12 typedef SocketManager::Backend Backend;
13 typedef SocketManager::Mock Mock;
14
15 // Test 1: EAGAIN - Socket not ready in non-blocking mode
16 1 void test_eagain() {
17
2/2
✓ Branch 0 (2→3) taken 1 times.
✓ Branch 2 (3→4) taken 1 times.
 1 std::cout << "\n1. Test EAGAIN (socket not ready):" << std::endl;
18
1/1
✓ Branch 0 (4→5) taken 1 times.
 1 SocketManager manager(PSocketMode::NO_MOCK);
19
20
11/14
✓ Branch 0 (7→8) taken 1 times.
✓ Branch 2 (10→11) taken 1 times.
✓ Branch 4 (13→14) taken 1 times.
✓ Branch 6 (14→15) taken 1 times.
✓ Branch 8 (17→18) taken 1 times.
✓ Branch 10 (18→19) taken 1 times.
✓ Branch 12 (21→22) taken 1 times.
✓ Branch 14 (24→25) taken 1 times.
✓ Branch 16 (25→26) taken 1 times.
✓ Branch 18 (26→27) taken 1 times.
✗ Branch 20 (30→31) not taken.
✓ Branch 21 (30→32) taken 1 times.
✗ Branch 22 (79→80) not taken.
✗ Branch 23 (79→81) not taken.
 11 data_stream_assert(manager.addServerSocket("sender", PSocketParam{"localhost", 5560}, Backend::server(), "./", Mock::server()));
21
22 1 size_t data = 42;
23
2/2
✓ Branch 0 (43→44) taken 1 times.
✓ Branch 2 (44→45) taken 1 times.
 1 PSendStatus::PSendStatus status = manager.sendData("sender", data, PSendFlag::NON_BLOCK);
24
25
5/5
✓ Branch 0 (47→48) taken 1 times.
✓ Branch 2 (48→49) taken 1 times.
✓ Branch 4 (49→50) taken 1 times.
✓ Branch 6 (50→51) taken 1 times.
✓ Branch 8 (51→52) taken 1 times.
 1 std::cout << " Send status: " << statusToStr(status) << " should be SOCKET_NOT_AVAILABLE" << std::endl;
26
4/4
✓ Branch 0 (55→56) taken 1 times.
✓ Branch 2 (58→59) taken 1 times.
✓ Branch 4 (61→62) taken 1 times.
✓ Branch 6 (62→63) taken 1 times.
 5 data_stream_assert(status == PSendStatus::SOCKET_NOT_AVAILABLE);
27 1 }
28
29 // Test 2: ENOTSOCK - Socket closed/invalid
30 1 void test_broken_socket() {
31
2/2
✓ Branch 0 (2→3) taken 1 times.
✓ Branch 2 (3→4) taken 1 times.
 1 std::cout << "\n2. Test broken socket:" << std::endl;
32
1/1
✓ Branch 0 (4→5) taken 1 times.
 1 SocketManager manager(PSocketMode::NO_MOCK);
33
34 // Add socket then remove it
35
11/14
✓ Branch 0 (7→8) taken 1 times.
✓ Branch 2 (10→11) taken 1 times.
✓ Branch 4 (13→14) taken 1 times.
✓ Branch 6 (14→15) taken 1 times.
✓ Branch 8 (17→18) taken 1 times.
✓ Branch 10 (18→19) taken 1 times.
✓ Branch 12 (21→22) taken 1 times.
✓ Branch 14 (24→25) taken 1 times.
✓ Branch 16 (25→26) taken 1 times.
✓ Branch 18 (26→27) taken 1 times.
✗ Branch 20 (30→31) not taken.
✓ Branch 21 (30→32) taken 1 times.
✗ Branch 22 (92→93) not taken.
✗ Branch 23 (92→94) not taken.
 12 data_stream_assert(manager.addServerSocket("sender", PSocketParam{"localhost", 5561}, Backend::server(), "./", Mock::server()));
36
3/3
✓ Branch 0 (43→44) taken 1 times.
✓ Branch 2 (44→45) taken 1 times.
✓ Branch 4 (45→46) taken 1 times.
 2 manager.getSocket("sender")->close();
37
2/2
✓ Branch 0 (50→51) taken 1 times.
✓ Branch 2 (51→52) taken 1 times.
 1 manager.removeSocket("sender");
38
39 1 size_t data = 42;
40
2/2
✓ Branch 0 (56→57) taken 1 times.
✓ Branch 2 (57→58) taken 1 times.
 1 PSendStatus::PSendStatus status = manager.sendData("sender", data, PSendFlag::NON_BLOCK);
41
42
5/5
✓ Branch 0 (60→61) taken 1 times.
✓ Branch 2 (61→62) taken 1 times.
✓ Branch 4 (62→63) taken 1 times.
✓ Branch 6 (63→64) taken 1 times.
✓ Branch 8 (64→65) taken 1 times.
 1 std::cout << " Send status: " << statusToStr(status) << " should be BROKEN_SOCKET" << std::endl;
43
4/4
✓ Branch 0 (68→69) taken 1 times.
✓ Branch 2 (71→72) taken 1 times.
✓ Branch 4 (74→75) taken 1 times.
✓ Branch 6 (75→76) taken 1 times.
 5 data_stream_assert(status == PSendStatus::BROKEN_SOCKET);
44 1 }
45
46 // Test 3: Test with SUB socket (ENOTSUP equivalent)
47 1 void test_wrong_socket_type() {
48
2/2
✓ Branch 0 (2→3) taken 1 times.
✓ Branch 2 (3→4) taken 1 times.
 1 std::cout << "\n3. Test wrong socket type:" << std::endl;
49
1/1
✓ Branch 0 (4→5) taken 1 times.
 1 SocketManager manager(PSocketMode::NO_MOCK);
50
51
11/14
✓ Branch 0 (7→8) taken 1 times.
✓ Branch 2 (10→11) taken 1 times.
✓ Branch 4 (13→14) taken 1 times.
✓ Branch 6 (14→15) taken 1 times.
✓ Branch 8 (17→18) taken 1 times.
✓ Branch 10 (18→19) taken 1 times.
✓ Branch 12 (21→22) taken 1 times.
✓ Branch 14 (24→25) taken 1 times.
✓ Branch 16 (25→26) taken 1 times.
✓ Branch 18 (26→27) taken 1 times.
✗ Branch 20 (30→31) not taken.
✓ Branch 21 (30→32) taken 1 times.
✗ Branch 22 (63→64) not taken.
✗ Branch 23 (63→65) not taken.
 11 data_stream_assert(manager.addClientSocket("receiver", PSocketParam{"localhost", 5562}, Backend::client(), "./", Mock::client()));
52 1 size_t data = 42;
53
2/2
✓ Branch 0 (43→44) taken 1 times.
✓ Branch 2 (44→45) taken 1 times.
 1 PSendStatus::PSendStatus status = manager.sendData("receiver", data, PSendFlag::NON_BLOCK);
54
5/5
✓ Branch 0 (47→48) taken 1 times.
✓ Branch 2 (48→49) taken 1 times.
✓ Branch 4 (49→50) taken 1 times.
✓ Branch 6 (50→51) taken 1 times.
✓ Branch 8 (51→52) taken 1 times.
 1 std::cout << " Send status: " << statusToStr(status) << " should be BROKEN_BACKEND" << std::endl;
55 1 }
56
57 1 void testSendErrors() {
58 1 std::cout << "=== Test error cases when sending via Backend Manager ===" << std::endl;
59
60 1 test_eagain();
61 1 test_broken_socket();
62 1 test_wrong_socket_type();
63
64 1 std::cout << "\n✓ All backend sender tests passed" << std::endl;
65 1 }
66
67 1 int main() {
68 1 testSendErrors();
69 1 return 0;
70 }
71