Directory: | ./ |
---|---|
File: | tmp_project/PhoenixSocket/src/PGenericSocket_impl.h |
Date: | 2025-03-14 12:18:05 |
Exec | Total | Coverage | |
---|---|---|---|
Lines: | 61 | 70 | 87.1% |
Branches: | 32 | 47 | 68.1% |
Line | Branch | Exec | Source |
---|---|---|---|
1 | /*************************************** | ||
2 | Auteur : Pierre Aubert | ||
3 | Mail : pierre.aubert@lapp.in2p3.fr | ||
4 | Licence : CeCILL-C | ||
5 | ****************************************/ | ||
6 | |||
7 | #ifndef __PGENERIC_SOCKET_H_IMPL__ | ||
8 | #define __PGENERIC_SOCKET_H_IMPL__ | ||
9 | |||
10 | #include "PGenericSocket.h" | ||
11 | |||
12 | ///Default constructor of PGenericSocket | ||
13 | /** @param mode : Mode of the Socket (no mock, mock, mock_record) | ||
14 | */ | ||
15 | template<typename _TBackend, typename _TMockBackend> | ||
16 | 19 | PGenericSocket<_TBackend, _TMockBackend>::PGenericSocket(PSocketMode::PSocketMode mode){ | |
17 | 19 | initialisationPGenericSocket(mode); | |
18 | 19 | } | |
19 | |||
20 | ///Destructor of PGenericSocket | ||
21 | template<typename _TBackend, typename _TMockBackend> | ||
22 | 76 | PGenericSocket<_TBackend, _TMockBackend>::~PGenericSocket(){ | |
23 | 38 | close(); | |
24 | 76 | } | |
25 | |||
26 | ///Create a client socket | ||
27 | /** @param param : extra customisable parameters for the creation of the socket (depends on the backend) | ||
28 | * @param mockParam : parameters of mock backend | ||
29 | * @return true if the socket has been created, false otherwise | ||
30 | */ | ||
31 | template<typename _TBackend, typename _TMockBackend> | ||
32 | 11 | bool PGenericSocket<_TBackend, _TMockBackend>::createClientSocket(const typename _TBackend::Param & param, const typename _TMockBackend::Param & mockParam){ | |
33 | 11 | bool b(true); | |
34 |
2/2✓ Branch 0 taken 9 times.
✓ Branch 1 taken 2 times.
|
11 | if(p_mode != PSocketMode::NO_MOCK){ |
35 | 9 | b &= _TMockBackend::createClientSocket(p_mockSocket, mockParam); | |
36 | } | ||
37 |
2/2✓ Branch 0 taken 2 times.
✓ Branch 1 taken 9 times.
|
11 | if(p_mode != PSocketMode::MOCK){ |
38 | 2 | b &= _TBackend::createClientSocket(p_socket, param); | |
39 | } | ||
40 | 11 | return b; | |
41 | } | ||
42 | |||
43 | ///Create a server socket | ||
44 | /** @param param : extra customisable parameters for the creation of the socket (depends on the backend) | ||
45 | * @param mockParam : parameters of mock backend | ||
46 | * @return true if the socket has been created, false otherwise | ||
47 | */ | ||
48 | template<typename _TBackend, typename _TMockBackend> | ||
49 | 8 | bool PGenericSocket<_TBackend, _TMockBackend>::createServerSocket(const typename _TBackend::Param & param, const typename _TMockBackend::Param & mockParam){ | |
50 | 8 | bool b(true); | |
51 |
2/2✓ Branch 0 taken 6 times.
✓ Branch 1 taken 2 times.
|
8 | if(p_mode != PSocketMode::NO_MOCK){ |
52 | 6 | b &= _TMockBackend::createServerSocket(p_mockSocket, mockParam); | |
53 | } | ||
54 |
2/2✓ Branch 0 taken 2 times.
✓ Branch 1 taken 6 times.
|
8 | if(p_mode != PSocketMode::MOCK){ |
55 | 2 | b &= _TBackend::createServerSocket(p_socket, param); | |
56 | } | ||
57 | 8 | return b; | |
58 | } | ||
59 | |||
60 | ///Send message on the given socket | ||
61 | /** @param msg : message to be sent | ||
62 | * @param flag : flags to be used to send the message (BLOCK, NON_BLOCK, etc) | ||
63 | * @return true on success, false otherwise | ||
64 | */ | ||
65 | template<typename _TBackend, typename _TMockBackend> | ||
66 | 20 | bool PGenericSocket<_TBackend, _TMockBackend>::sendMsg(typename _TBackend::Message & msg, PSendFlag::PSendFlag flag){ | |
67 | 20 | size_t dataSize(msg.size()); | |
68 | 20 | bool b(true); | |
69 |
2/2✓ Branch 0 taken 10 times.
✓ Branch 1 taken 10 times.
|
20 | if(p_mode != PSocketMode::NO_MOCK){ |
70 | 10 | typename _TMockBackend::Message vecTmp; | |
71 |
1/1✓ Branch 1 taken 10 times.
|
10 | _TMockBackend::msgResize(vecTmp, dataSize); |
72 |
2/2✓ Branch 1 taken 10 times.
✓ Branch 4 taken 10 times.
|
10 | memcpy(_TMockBackend::msgData(vecTmp), _TBackend::msgData(msg), dataSize); |
73 |
1/1✓ Branch 1 taken 10 times.
|
10 | b &= _TMockBackend::send(p_mockSocket, vecTmp, flag); |
74 | 10 | } | |
75 |
2/2✓ Branch 0 taken 10 times.
✓ Branch 1 taken 10 times.
|
20 | if(p_mode != PSocketMode::MOCK){ |
76 | 10 | b &= _TBackend::send(p_socket, msg, flag); | |
77 | } | ||
78 | 20 | return b; | |
79 | } | ||
80 | |||
81 | ///Recieve message from the given socket | ||
82 | /** @param msg : message to be recieved | ||
83 | * @param flag : flags to be used to send the message (BLOCK, NON_BLOCK, etc) | ||
84 | * @return true on success, false otherwise | ||
85 | */ | ||
86 | template<typename _TBackend, typename _TMockBackend> | ||
87 | 20 | bool PGenericSocket<_TBackend, _TMockBackend>::recvMsg(typename _TBackend::Message & msg, PRecvFlag::PRecvFlag flag){ | |
88 | 20 | bool b(true); | |
89 |
2/2✓ Branch 0 taken 10 times.
✓ Branch 1 taken 10 times.
|
20 | if(p_mode == PSocketMode::NO_MOCK){ //Normal mode |
90 | 10 | b &= _TBackend::recv(p_socket, msg, flag); | |
91 |
1/2✓ Branch 0 taken 10 times.
✗ Branch 1 not taken.
|
10 | }else if(p_mode == PSocketMode::MOCK){ //Mock mode |
92 | 10 | typename _TMockBackend::Message msgMock; | |
93 |
1/1✓ Branch 1 taken 10 times.
|
10 | b &= _TMockBackend::recv(p_mockSocket, msgMock, flag); |
94 |
1/2✓ Branch 0 taken 10 times.
✗ Branch 1 not taken.
|
10 | if(b){ |
95 |
1/1✓ Branch 1 taken 10 times.
|
10 | size_t dataSize(_TMockBackend::msgSize(msgMock)); |
96 |
1/1✓ Branch 1 taken 10 times.
|
10 | _TBackend::msgResize(msg, dataSize); |
97 |
2/2✓ Branch 1 taken 10 times.
✓ Branch 4 taken 10 times.
|
10 | memcpy(_TBackend::msgData(msg), _TMockBackend::msgData(msgMock), dataSize); |
98 | } | ||
99 | 10 | }else{ //Mock record mode | |
100 | ✗ | b &= _TBackend::recv(p_socket, msg, flag); | |
101 | ✗ | if(b){ | |
102 | ✗ | typename _TMockBackend::Message msgMock; | |
103 | ✗ | size_t dataSize(_TBackend::msgSize(msg)); | |
104 | ✗ | _TMockBackend::msgResize(msgMock, dataSize); | |
105 | ✗ | memcpy(_TMockBackend::msgData(msgMock), _TBackend::msgData(msg), dataSize); | |
106 | ✗ | b &= _TMockBackend::recv(p_mockSocket, msgMock, flag); | |
107 | } | ||
108 | } | ||
109 | 20 | return b; | |
110 | } | ||
111 | |||
112 | ///Close the socket | ||
113 | template<typename _TBackend, typename _TMockBackend> | ||
114 | 19 | void PGenericSocket<_TBackend, _TMockBackend>::close(){ | |
115 |
2/2✓ Branch 0 taken 15 times.
✓ Branch 1 taken 4 times.
|
19 | if(p_mode == PSocketMode::MOCK){ |
116 | 15 | _TMockBackend::close(p_mockSocket); | |
117 |
1/2✓ Branch 0 taken 4 times.
✗ Branch 1 not taken.
|
4 | }else if(p_mode == PSocketMode::NO_MOCK){ |
118 | 4 | _TBackend::close(p_socket); | |
119 | }else{ | ||
120 | ✗ | _TMockBackend::close(p_mockSocket); | |
121 | ✗ | _TBackend::close(p_socket); | |
122 | } | ||
123 | 19 | } | |
124 | |||
125 | ///Say if the Socket is connected | ||
126 | /** @return true if the current socket is connected (or both in record mode) | ||
127 | */ | ||
128 | template<typename _TBackend, typename _TMockBackend> | ||
129 | 4 | bool PGenericSocket<_TBackend, _TMockBackend>::isConnected() const{ | |
130 | 4 | bool b(true); | |
131 |
2/2✓ Branch 0 taken 2 times.
✓ Branch 1 taken 2 times.
|
4 | if(p_mode != PSocketMode::NO_MOCK){ |
132 | 2 | b &= _TMockBackend::isConnected(p_mockSocket); | |
133 | } | ||
134 |
2/2✓ Branch 0 taken 2 times.
✓ Branch 1 taken 2 times.
|
4 | if(p_mode != PSocketMode::MOCK){ |
135 | 2 | b &= _TBackend::isConnected(p_socket); | |
136 | } | ||
137 | 4 | return b; | |
138 | } | ||
139 | |||
140 | ///Initialisation function of the class PGenericSocket | ||
141 | /** @param mode : Mode of the Socket (no mock, mock, mock_record) | ||
142 | */ | ||
143 | template<typename _TBackend, typename _TMockBackend> | ||
144 | 19 | void PGenericSocket<_TBackend, _TMockBackend>::initialisationPGenericSocket(PSocketMode::PSocketMode mode){ | |
145 | 19 | p_mode = mode; | |
146 | 19 | } | |
147 | |||
148 | |||
149 | #endif | ||
150 | |||
151 | |||
152 | |||
153 |