87 input_identity, _ = self.
recv(input_socket)
90 output_identity, _ = self.
recv(output_socket)
93 self.
assertMonitoring(distributor_monitoring_socket,
"input.socket_state",
"connected")
94 self.
assertMonitoring(distributor_monitoring_socket,
"input.socket_connects", 1)
95 self.
assertMonitoring(distributor_monitoring_socket,
"input.socket_disconnects", 0)
96 self.
assertMonitoring(distributor_monitoring_socket,
"output.ready_queue_size", 20)
97 self.
assertMonitoring(distributor_monitoring_socket,
"output.registered_workers", 1)
99 self.
assertMonitoring(collector_monitoring_socket,
"input.registered_workers", 1)
100 self.
assertMonitoring(collector_monitoring_socket,
"output.ready_queue_size", 20)
101 self.
assertMonitoring(collector_monitoring_socket,
"output.registered_workers", 1)
103 self.
assertMonitoring(final_collector_monitoring_socket,
"input.registered_workers", 1)
110 input_socket.send_multipart([input_identity, self.
event_data])
112 self.
assertMonitoring(distributor_monitoring_socket,
"input.socket_state",
"connected")
113 self.
assertMonitoring(distributor_monitoring_socket,
"input.socket_connects", 1)
114 self.
assertMonitoring(distributor_monitoring_socket,
"input.socket_disconnects", 0)
115 self.
assertMonitoring(distributor_monitoring_socket,
"output.ready_queue_size", 20)
116 self.
assertMonitoring(distributor_monitoring_socket,
"output.registered_workers", 1)
117 self.
assertMonitoring(distributor_monitoring_socket,
"output.sent_events", 20)
119 self.
assertMonitoring(collector_monitoring_socket,
"input.registered_workers", 1)
120 self.
assertMonitoring(collector_monitoring_socket,
"input.received_events", 20)
121 self.
assertMonitoring(collector_monitoring_socket,
"output.ready_queue_size", 20)
122 self.
assertMonitoring(collector_monitoring_socket,
"output.registered_workers", 1)
123 self.
assertMonitoring(collector_monitoring_socket,
"output.sent_events", 20)
125 self.
assertMonitoring(final_collector_monitoring_socket,
"input.registered_workers", 1)
126 self.
assertMonitoring(final_collector_monitoring_socket,
"input.received_events", 20)
127 self.
assertMonitoring(final_collector_monitoring_socket,
"output.sent_events", 20)
133 while output_socket.poll(0):
134 _, msg = self.
recv(output_socket)
139 self.assertEqual(len(buffer), 122638 * 20)
142 self.
send(distributor_monitoring_socket,
"l")
144 self.
assertMonitoring(distributor_monitoring_socket,
"input.socket_state",
"connected")
145 self.
assertMonitoring(distributor_monitoring_socket,
"input.socket_connects", 1)
146 self.
assertMonitoring(distributor_monitoring_socket,
"input.socket_disconnects", 0)
147 self.
assertMonitoring(distributor_monitoring_socket,
"output.ready_queue_size", 20)
148 self.
assertMonitoring(distributor_monitoring_socket,
"output.registered_workers", 1)
150 self.
assertMonitoring(collector_monitoring_socket,
"input.registered_workers", 1)
151 self.
assertMonitoring(collector_monitoring_socket,
"input.received_events", 20)
152 self.
assertMonitoring(collector_monitoring_socket,
"output.ready_queue_size", 20)
153 self.
assertMonitoring(collector_monitoring_socket,
"output.registered_workers", 1)
154 self.
assertMonitoring(collector_monitoring_socket,
"input.received_stop_messages", 1)
155 self.
assertMonitoring(collector_monitoring_socket,
"input.all_stop_messages", 1)
157 self.
assertMonitoring(final_collector_monitoring_socket,
"input.registered_workers", 1)
158 self.
assertMonitoring(final_collector_monitoring_socket,
"input.received_events", 20)
159 self.
assertMonitoring(final_collector_monitoring_socket,
"input.received_stop_messages", 1)
160 self.
assertMonitoring(final_collector_monitoring_socket,
"input.all_stop_messages", 1)
170 self.
send(distributor_monitoring_socket,
"l")
172 self.
assertMonitoring(distributor_monitoring_socket,
"input.socket_state",
"connected")
173 self.
assertMonitoring(distributor_monitoring_socket,
"input.socket_connects", 1)
174 self.
assertMonitoring(distributor_monitoring_socket,
"input.socket_disconnects", 0)
175 self.
assertMonitoring(distributor_monitoring_socket,
"output.ready_queue_size", 20)
176 self.
assertMonitoring(distributor_monitoring_socket,
"output.registered_workers", 1)
178 self.
assertMonitoring(collector_monitoring_socket,
"input.registered_workers", 1)
179 self.
assertMonitoring(collector_monitoring_socket,
"input.received_events", 20)
180 self.
assertMonitoring(collector_monitoring_socket,
"output.ready_queue_size", 20)
181 self.
assertMonitoring(collector_monitoring_socket,
"output.registered_workers", 1)
182 self.
assertMonitoring(collector_monitoring_socket,
"input.received_stop_messages", 1)
183 self.
assertMonitoring(collector_monitoring_socket,
"input.all_stop_messages", 1)
185 self.
assertMonitoring(final_collector_monitoring_socket,
"input.registered_workers", 1)
186 self.
assertMonitoring(final_collector_monitoring_socket,
"input.received_events", 20)
187 self.
assertMonitoring(final_collector_monitoring_socket,
"input.received_stop_messages", 1)
188 self.
assertMonitoring(final_collector_monitoring_socket,
"input.all_stop_messages", 1)
195 self.
send(distributor_monitoring_socket,
"n")
196 self.
send(collector_monitoring_socket,
"n")
197 self.
send(final_collector_monitoring_socket,
"n")
199 self.
assertMonitoring(distributor_monitoring_socket,
"input.socket_state",
"connected")
200 self.
assertMonitoring(distributor_monitoring_socket,
"input.socket_connects", 1)
201 self.
assertMonitoring(distributor_monitoring_socket,
"input.socket_disconnects", 0)
202 self.
assertMonitoring(distributor_monitoring_socket,
"output.ready_queue_size", 20)
203 self.
assertMonitoring(distributor_monitoring_socket,
"output.registered_workers", 1)
205 self.
assertMonitoring(collector_monitoring_socket,
"input.registered_workers", 1)
206 self.
assertMonitoring(collector_monitoring_socket,
"input.received_events", 20)
207 self.
assertMonitoring(collector_monitoring_socket,
"output.ready_queue_size", 20)
208 self.
assertMonitoring(collector_monitoring_socket,
"output.registered_workers", 1)
209 self.
assertMonitoring(collector_monitoring_socket,
"input.received_stop_messages", 0)
210 self.
assertMonitoring(collector_monitoring_socket,
"input.all_stop_messages", 0)
212 self.
assertMonitoring(final_collector_monitoring_socket,
"input.registered_workers", 1)
213 self.
assertMonitoring(final_collector_monitoring_socket,
"input.received_events", 20)
214 self.
assertMonitoring(final_collector_monitoring_socket,
"input.received_stop_messages", 0)
215 self.
assertMonitoring(final_collector_monitoring_socket,
"input.all_stop_messages", 0)
219 input_socket.send_multipart([input_identity, self.
event_data])
221 self.
assertMonitoring(distributor_monitoring_socket,
"input.socket_state",
"connected")
222 self.
assertMonitoring(distributor_monitoring_socket,
"input.socket_connects", 1)
223 self.
assertMonitoring(distributor_monitoring_socket,
"input.socket_disconnects", 0)
224 self.
assertMonitoring(distributor_monitoring_socket,
"output.ready_queue_size", 20)
225 self.
assertMonitoring(distributor_monitoring_socket,
"output.registered_workers", 1)
226 self.
assertMonitoring(distributor_monitoring_socket,
"output.sent_events", 40)
228 self.
assertMonitoring(collector_monitoring_socket,
"input.registered_workers", 1)
229 self.
assertMonitoring(collector_monitoring_socket,
"input.received_events", 40)
230 self.
assertMonitoring(collector_monitoring_socket,
"output.ready_queue_size", 20)
231 self.
assertMonitoring(collector_monitoring_socket,
"output.registered_workers", 1)
232 self.
assertMonitoring(collector_monitoring_socket,
"output.sent_events", 40)
234 self.
assertMonitoring(final_collector_monitoring_socket,
"input.registered_workers", 1)
235 self.
assertMonitoring(final_collector_monitoring_socket,
"input.received_events", 40)
236 self.
assertMonitoring(final_collector_monitoring_socket,
"output.sent_events", 40)
244 while output_socket.poll(0):
245 _, msg = self.
recv(output_socket)
250 self.assertEqual(len(buffer), 122638 * 20)
253 self.
send(distributor_monitoring_socket,
"x")