GCC Code Coverage Report

Directory: ./
File: TESTS/TEST_BACKEND_ERRORS/main_sender_errors.cpp
Date: 2026-06-23 10:44:39
Exec Total Coverage
Lines: 40 40 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, PZmqSocketGenerator, PMockSocketGenerator> 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
1/1
✓ Branch 0 (5→6) taken 1 times.
 1 Backend::Param clientParam = Backend::client();
20 1 clientParam.immediate = 1; //EAGAIN if no peer connected
21
22
10/13
✓ Branch 0 (8→9) taken 1 times.
✓ Branch 2 (11→12) taken 1 times.
✓ Branch 4 (14→15) taken 1 times.
✓ Branch 6 (15→16) taken 1 times.
✓ Branch 8 (18→19) taken 1 times.
✓ Branch 10 (21→22) taken 1 times.
✓ Branch 12 (24→25) taken 1 times.
✓ Branch 14 (25→26) taken 1 times.
✓ Branch 16 (26→27) taken 1 times.
✗ Branch 18 (30→31) not taken.
✓ Branch 19 (30→32) taken 1 times.
✗ Branch 20 (79→80) not taken.
✗ Branch 21 (79→81) not taken.
 11 data_stream_assert(manager.addClientSocket("sender", PSocketParam{"localhost", 5575}, clientParam, "./", Mock::client()));
23
24 1 size_t data = 42;
25
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);
26
27
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;
28
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);
29 1 }
30
31 // Test 2: ENOTSOCK - Socket closed/invalid
32 1 void test_broken_socket() {
33
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;
34
1/1
✓ Branch 0 (4→5) taken 1 times.
 1 SocketManager manager(PSocketMode::NO_MOCK);
35
36 // Add socket then remove it
37
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.addClientSocket("sender", PSocketParam{"localhost", 5561}, Backend::client(), "./", Mock::client()));
38
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();
39
2/2
✓ Branch 0 (50→51) taken 1 times.
✓ Branch 2 (51→52) taken 1 times.
 1 manager.removeSocket("sender");
40
41 1 size_t data = 42;
42
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);
43
44
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;
45
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);
46 1 }
47
48 // Test 3: Test with SUB socket (ENOTSUP equivalent)
49 1 void test_wrong_socket_type() {
50
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;
51
1/1
✓ Branch 0 (4→5) taken 1 times.
 1 SocketManager manager(PSocketMode::NO_MOCK);
52
53
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.addServerSocket("receiver", PSocketParam{"localhost", 5562}, Backend::server(), "./", Mock::server()));
54 1 size_t data = 42;
55
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);
56
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;
57 1 }
58
59 1 void testSendErrors() {
60 1 std::cout << "=== Test error cases when sending via Backend Manager ===" << std::endl;
61
62 1 test_eagain();
63 1 test_broken_socket();
64 1 test_wrong_socket_type();
65
66 1 std::cout << "\n✓ All backend sender tests passed" << std::endl;
67 1 }
68
69 1 int main() {
70 1 testSendErrors();
71 1 return 0;
72 }
73