/proc/self/cwd/test/mocks/network/mocks.cc
Line | Count | Source (jump to first uncovered line) |
1 | | #include "mocks.h" |
2 | | |
3 | | #include <cstdint> |
4 | | |
5 | | #include "envoy/buffer/buffer.h" |
6 | | #include "envoy/server/listener_manager.h" |
7 | | |
8 | | #include "source/common/network/address_impl.h" |
9 | | #include "source/common/network/io_socket_handle_impl.h" |
10 | | #include "source/common/network/udp_listener_impl.h" |
11 | | #include "source/common/network/utility.h" |
12 | | |
13 | | #include "test/test_common/printers.h" |
14 | | |
15 | | #include "gmock/gmock.h" |
16 | | #include "gtest/gtest.h" |
17 | | |
18 | | using testing::_; |
19 | | using testing::Invoke; |
20 | | using testing::Return; |
21 | | using testing::ReturnPointee; |
22 | | using testing::ReturnRef; |
23 | | using testing::SaveArg; |
24 | | |
25 | | namespace Envoy { |
26 | | namespace Network { |
27 | | |
28 | | MockUdpListenerConfig::MockUdpListenerConfig(uint32_t concurrency) |
29 | 0 | : udp_listener_worker_router_(std::make_unique<UdpListenerWorkerRouterImpl>(concurrency)) { |
30 | 0 | ON_CALL(*this, listenerWorkerRouter(_)).WillByDefault(ReturnRef(*udp_listener_worker_router_)); |
31 | 0 | ON_CALL(*this, config()).WillByDefault(ReturnRef(config_)); |
32 | 0 | } |
33 | 0 | MockUdpListenerConfig::~MockUdpListenerConfig() = default; |
34 | | |
35 | | MockListenerConfig::MockListenerConfig() |
36 | 1 | : socket_(std::make_shared<testing::NiceMock<MockListenSocket>>()) { |
37 | 1 | socket_factories_.emplace_back(std::make_unique<MockListenSocketFactory>()); |
38 | 1 | ON_CALL(*this, filterChainFactory()).WillByDefault(ReturnRef(filter_chain_factory_)); |
39 | 1 | ON_CALL(*this, listenSocketFactories()).WillByDefault(ReturnRef(socket_factories_)); |
40 | 1 | ON_CALL(*static_cast<MockListenSocketFactory*>(socket_factories_[0].get()), localAddress()) |
41 | 1 | .WillByDefault(ReturnRef(socket_->connectionInfoProvider().localAddress())); |
42 | 1 | ON_CALL(*static_cast<MockListenSocketFactory*>(socket_factories_[0].get()), getListenSocket(_)) |
43 | 1 | .WillByDefault(Return(socket_)); |
44 | 1 | ON_CALL(*this, listenerScope()).WillByDefault(ReturnRef(*store_.rootScope())); |
45 | 1 | ON_CALL(*this, name()).WillByDefault(ReturnRef(name_)); |
46 | 1 | ON_CALL(*this, maxConnectionsToAcceptPerSocketEvent()) |
47 | 1 | .WillByDefault(Return(Network::DefaultMaxConnectionsToAcceptPerSocketEvent)); |
48 | 1 | ON_CALL(*this, ignoreGlobalConnLimit()).WillByDefault(Return(false)); |
49 | 1 | ON_CALL(*this, bindToPort()).WillByDefault(Return(true)); |
50 | 1 | } |
51 | 1 | MockListenerConfig::~MockListenerConfig() = default; |
52 | | |
53 | 1 | MockActiveDnsQuery::MockActiveDnsQuery() = default; |
54 | 1 | MockActiveDnsQuery::~MockActiveDnsQuery() = default; |
55 | | |
56 | 1 | MockDnsResolver::MockDnsResolver() { |
57 | 1 | ON_CALL(*this, resolve(_, _, _)).WillByDefault(Return(&active_query_)); |
58 | 1 | } |
59 | | |
60 | 1 | MockDnsResolver::~MockDnsResolver() = default; |
61 | | |
62 | 0 | MockAddressResolver::MockAddressResolver() { |
63 | 0 | ON_CALL(*this, name()).WillByDefault(Return("envoy.mock.resolver")); |
64 | 0 | } |
65 | | |
66 | 0 | MockAddressResolver::~MockAddressResolver() = default; |
67 | | |
68 | 5.27k | MockReadFilterCallbacks::MockReadFilterCallbacks() { |
69 | 5.27k | ON_CALL(*this, connection()).WillByDefault(ReturnRef(connection_)); |
70 | 5.27k | ON_CALL(*this, upstreamHost()).WillByDefault(ReturnPointee(&host_)); |
71 | 5.27k | ON_CALL(*this, upstreamHost(_)).WillByDefault(SaveArg<0>(&host_)); |
72 | 5.27k | } Envoy::Network::MockReadFilterCallbacks::MockReadFilterCallbacks() Line | Count | Source | 68 | 5.27k | MockReadFilterCallbacks::MockReadFilterCallbacks() { | 69 | 5.27k | ON_CALL(*this, connection()).WillByDefault(ReturnRef(connection_)); | 70 | 5.27k | ON_CALL(*this, upstreamHost()).WillByDefault(ReturnPointee(&host_)); | 71 | 5.27k | ON_CALL(*this, upstreamHost(_)).WillByDefault(SaveArg<0>(&host_)); | 72 | 5.27k | } |
Unexecuted instantiation: Envoy::Network::MockReadFilterCallbacks::MockReadFilterCallbacks() |
73 | | |
74 | 5.27k | MockReadFilterCallbacks::~MockReadFilterCallbacks() = default; |
75 | | |
76 | 0 | MockReadFilter::MockReadFilter() { |
77 | 0 | ON_CALL(*this, onData(_, _)).WillByDefault(Return(FilterStatus::StopIteration)); |
78 | 0 | EXPECT_CALL(*this, initializeReadFilterCallbacks(_)) |
79 | 0 | .WillOnce( |
80 | 0 | Invoke([this](ReadFilterCallbacks& callbacks) -> void { callbacks_ = &callbacks; })); |
81 | 0 | } |
82 | | |
83 | 0 | MockReadFilter::~MockReadFilter() = default; |
84 | | |
85 | 1 | MockWriteFilterCallbacks::MockWriteFilterCallbacks() { |
86 | 1 | ON_CALL(*this, connection()).WillByDefault(ReturnRef(connection_)); |
87 | 1 | } Envoy::Network::MockWriteFilterCallbacks::MockWriteFilterCallbacks() Line | Count | Source | 85 | 1 | MockWriteFilterCallbacks::MockWriteFilterCallbacks() { | 86 | 1 | ON_CALL(*this, connection()).WillByDefault(ReturnRef(connection_)); | 87 | 1 | } |
Unexecuted instantiation: Envoy::Network::MockWriteFilterCallbacks::MockWriteFilterCallbacks() |
88 | | |
89 | 1 | MockWriteFilterCallbacks::~MockWriteFilterCallbacks() = default; |
90 | | |
91 | 0 | MockWriteFilter::MockWriteFilter() { |
92 | 0 | EXPECT_CALL(*this, initializeWriteFilterCallbacks(_)) |
93 | 0 | .WillOnce(Invoke( |
94 | 0 | [this](WriteFilterCallbacks& callbacks) -> void { write_callbacks_ = &callbacks; })); |
95 | 0 | } |
96 | 0 | MockWriteFilter::~MockWriteFilter() = default; |
97 | | |
98 | 0 | MockFilter::MockFilter() { |
99 | 0 | EXPECT_CALL(*this, initializeReadFilterCallbacks(_)) |
100 | 0 | .WillOnce( |
101 | 0 | Invoke([this](ReadFilterCallbacks& callbacks) -> void { callbacks_ = &callbacks; })); |
102 | 0 | EXPECT_CALL(*this, initializeWriteFilterCallbacks(_)) |
103 | 0 | .WillOnce(Invoke( |
104 | 0 | [this](WriteFilterCallbacks& callbacks) -> void { write_callbacks_ = &callbacks; })); |
105 | 0 | } |
106 | | |
107 | 0 | MockFilter::~MockFilter() = default; |
108 | | |
109 | 0 | MockTcpListenerCallbacks::MockTcpListenerCallbacks() = default; |
110 | 0 | MockTcpListenerCallbacks::~MockTcpListenerCallbacks() = default; |
111 | | |
112 | 0 | MockUdpListenerCallbacks::MockUdpListenerCallbacks() = default; |
113 | 0 | MockUdpListenerCallbacks::~MockUdpListenerCallbacks() = default; |
114 | | |
115 | 4.11k | MockDrainDecision::MockDrainDecision() = default; |
116 | 4.11k | MockDrainDecision::~MockDrainDecision() = default; |
117 | | |
118 | 0 | MockListenerFilter::~MockListenerFilter() { destroy_(); } |
119 | | |
120 | | MockListenerFilterCallbacks::MockListenerFilterCallbacks() |
121 | 1.52k | : filter_state_(StreamInfo::FilterStateImpl(StreamInfo::FilterState::LifeSpan::FilterChain)) { |
122 | 1.52k | ON_CALL(*this, filterState()).WillByDefault(ReturnRef(filter_state_)); |
123 | 1.52k | ON_CALL(*this, socket()).WillByDefault(ReturnRef(socket_)); |
124 | 1.52k | } |
125 | 1.52k | MockListenerFilterCallbacks::~MockListenerFilterCallbacks() = default; |
126 | | |
127 | 0 | MockListenerFilterManager::MockListenerFilterManager() = default; |
128 | 0 | MockListenerFilterManager::~MockListenerFilterManager() = default; |
129 | | |
130 | 1 | MockFilterChain::MockFilterChain() = default; |
131 | 1 | MockFilterChain::~MockFilterChain() = default; |
132 | | |
133 | 0 | MockFilterChainInfo::MockFilterChainInfo() { |
134 | 0 | ON_CALL(*this, name()).WillByDefault(Invoke([this]() { |
135 | 0 | return absl::string_view{filter_chain_name_}; |
136 | 0 | })); |
137 | 0 | } |
138 | | |
139 | 0 | MockFilterChainManager::MockFilterChainManager() = default; |
140 | 0 | MockFilterChainManager::~MockFilterChainManager() = default; |
141 | | |
142 | 3 | MockFilterChainFactory::MockFilterChainFactory() { |
143 | 3 | ON_CALL(*this, createListenerFilterChain(_)).WillByDefault(Return(true)); |
144 | 3 | } |
145 | 3 | MockFilterChainFactory::~MockFilterChainFactory() = default; |
146 | | |
147 | | MockListenSocket::MockListenSocket() |
148 | | : io_handle_(std::make_unique<NiceMock<MockIoHandle>>()), |
149 | | connection_info_provider_(std::make_shared<ConnectionInfoSetterImpl>( |
150 | 1 | std::make_shared<Address::Ipv4Instance>(80), nullptr)) { |
151 | 1 | ON_CALL(*this, options()).WillByDefault(ReturnRef(options_)); |
152 | 1 | ON_CALL(*this, ioHandle()).WillByDefault(ReturnRef(*io_handle_)); |
153 | 1 | ON_CALL(testing::Const(*this), ioHandle()).WillByDefault(ReturnRef(*io_handle_)); |
154 | 1 | ON_CALL(*this, close()).WillByDefault(Invoke([this]() { socket_is_open_ = false; })); |
155 | 1 | ON_CALL(testing::Const(*this), isOpen()).WillByDefault(Invoke([this]() { |
156 | 0 | return socket_is_open_; |
157 | 0 | })); |
158 | 1 | ON_CALL(*this, ipVersion()) |
159 | 1 | .WillByDefault(Return(connection_info_provider_->localAddress()->ip()->version())); |
160 | 1 | ON_CALL(*this, duplicate()).WillByDefault(Invoke([]() { |
161 | 0 | return std::make_unique<NiceMock<MockListenSocket>>(); |
162 | 0 | })); |
163 | 1 | } |
164 | | |
165 | 0 | MockSocketOption::MockSocketOption() { |
166 | 0 | ON_CALL(*this, setOption(_, _)).WillByDefault(Return(true)); |
167 | 0 | } |
168 | | |
169 | 0 | MockSocketOption::~MockSocketOption() = default; |
170 | | |
171 | | MockConnectionSocket::MockConnectionSocket() |
172 | | : io_handle_(std::make_unique<IoSocketHandleImpl>()), |
173 | | connection_info_provider_( |
174 | | std::make_shared<ConnectionInfoSetterImpl>(std::make_shared<Address::Ipv4Instance>(80), |
175 | 3.04k | std::make_shared<Address::Ipv4Instance>(80))) { |
176 | 3.04k | ON_CALL(*this, ioHandle()).WillByDefault(ReturnRef(*io_handle_)); |
177 | 3.04k | ON_CALL(testing::Const(*this), ioHandle()).WillByDefault(ReturnRef(*io_handle_)); |
178 | 3.04k | ON_CALL(*this, ipVersion()) |
179 | 3.04k | .WillByDefault(Return(connection_info_provider_->localAddress()->ip()->version())); |
180 | 3.04k | } Envoy::Network::MockConnectionSocket::MockConnectionSocket() Line | Count | Source | 175 | 3.04k | std::make_shared<Address::Ipv4Instance>(80))) { | 176 | 3.04k | ON_CALL(*this, ioHandle()).WillByDefault(ReturnRef(*io_handle_)); | 177 | 3.04k | ON_CALL(testing::Const(*this), ioHandle()).WillByDefault(ReturnRef(*io_handle_)); | 178 | 3.04k | ON_CALL(*this, ipVersion()) | 179 | 3.04k | .WillByDefault(Return(connection_info_provider_->localAddress()->ip()->version())); | 180 | 3.04k | } |
Unexecuted instantiation: Envoy::Network::MockConnectionSocket::MockConnectionSocket() |
181 | | |
182 | 3.04k | MockConnectionSocket::~MockConnectionSocket() = default; |
183 | | |
184 | 0 | MockListener::MockListener() = default; |
185 | | |
186 | 0 | MockListener::~MockListener() { onDestroy(); } |
187 | | |
188 | 0 | MockConnectionHandler::MockConnectionHandler() { |
189 | 0 | ON_CALL(*this, incNumConnections()).WillByDefault(Invoke([this]() { |
190 | 0 | ++num_handler_connections_; |
191 | 0 | })); |
192 | 0 | ON_CALL(*this, decNumConnections()).WillByDefault(Invoke([this]() { |
193 | 0 | --num_handler_connections_; |
194 | 0 | })); |
195 | 0 | ON_CALL(*this, numConnections()).WillByDefault(Invoke([this]() { |
196 | 0 | return num_handler_connections_; |
197 | 0 | })); |
198 | 0 | } Unexecuted instantiation: Envoy::Network::MockConnectionHandler::MockConnectionHandler() Unexecuted instantiation: Envoy::Network::MockConnectionHandler::MockConnectionHandler() |
199 | 0 | MockConnectionHandler::~MockConnectionHandler() = default; |
200 | | |
201 | 0 | MockUdpListenerWorkerRouter::~MockUdpListenerWorkerRouter() = default; |
202 | | |
203 | 0 | MockIp::MockIp() = default; |
204 | 0 | MockIp::~MockIp() = default; |
205 | | |
206 | | MockResolvedAddress::MockResolvedAddress(const std::string& logical, const std::string& physical) |
207 | 0 | : logical_(logical), physical_(physical) {} |
208 | 0 | MockResolvedAddress::~MockResolvedAddress() = default; |
209 | | |
210 | 0 | MockTransportSocketCallbacks::MockTransportSocketCallbacks() { |
211 | 0 | ON_CALL(*this, connection()).WillByDefault(ReturnRef(connection_)); |
212 | 0 | } |
213 | 0 | MockTransportSocketCallbacks::~MockTransportSocketCallbacks() = default; |
214 | | |
215 | 0 | MockUdpPacketWriter::MockUdpPacketWriter() = default; |
216 | 0 | MockUdpPacketWriter::~MockUdpPacketWriter() = default; |
217 | | |
218 | 0 | MockUdpListener::MockUdpListener() { |
219 | 0 | ON_CALL(*this, dispatcher()).WillByDefault(ReturnRef(dispatcher_)); |
220 | 0 | } Unexecuted instantiation: Envoy::Network::MockUdpListener::MockUdpListener() Unexecuted instantiation: Envoy::Network::MockUdpListener::MockUdpListener() |
221 | | |
222 | 0 | MockUdpListener::~MockUdpListener() { onDestroy(); } |
223 | | |
224 | 0 | MockUdpReadFilterCallbacks::MockUdpReadFilterCallbacks() { |
225 | 0 | ON_CALL(*this, udpListener()).WillByDefault(ReturnRef(udp_listener_)); |
226 | 0 | } |
227 | | |
228 | 0 | MockUdpReadFilterCallbacks::~MockUdpReadFilterCallbacks() = default; |
229 | | |
230 | | MockUdpListenerReadFilter::MockUdpListenerReadFilter(UdpReadFilterCallbacks& callbacks) |
231 | 0 | : UdpListenerReadFilter(callbacks) {} |
232 | 0 | MockUdpListenerReadFilter::~MockUdpListenerReadFilter() = default; |
233 | | |
234 | 0 | MockUdpListenerFilterManager::MockUdpListenerFilterManager() = default; |
235 | 0 | MockUdpListenerFilterManager::~MockUdpListenerFilterManager() = default; |
236 | | |
237 | 0 | MockConnectionBalancer::MockConnectionBalancer() = default; |
238 | 0 | MockConnectionBalancer::~MockConnectionBalancer() = default; |
239 | | |
240 | 0 | MockListenerFilterMatcher::MockListenerFilterMatcher() = default; |
241 | 0 | MockListenerFilterMatcher::~MockListenerFilterMatcher() = default; |
242 | | |
243 | | } // namespace Network |
244 | | } // namespace Envoy |