Skip to content

Commit 61489f0

Browse files
committed
Add some warning about what's happening
1 parent 7325d2a commit 61489f0

File tree

1 file changed

+18
-1
lines changed

1 file changed

+18
-1
lines changed

test/modules/post/test/socket_channels.rb

Lines changed: 18 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -264,11 +264,28 @@ def test_udp_channel
264264
end
265265

266266
it '[UDP] Receives data from the peer' do
267+
print_status("[UDP] Monitoring 'Receives data from the peer' test...")
267268
client, server_client = udp_socket_pair
268269
data = Random.new.bytes(rand(10..100))
269270
server_client.send(data, 0, client.localhost, client.localport)
270-
received, _ = client.recvfrom(data.length)
271+
received = ''
272+
remaining = 20 # seconds
273+
while remaining > 0
274+
chunk, elapsed_time = Rex::Stopwatch.elapsed_time do
275+
chunk, _ = client.recvfrom(data.length)
276+
chunk
277+
end
278+
received << chunk
279+
remaining -= elapsed_time
280+
end
271281
ret = received == data
282+
unless ret
283+
print_warning("[UDP] Receives data from the peer failed in #{20} seconds")
284+
print_warning("[UDP] expected: #{data.unpack1('H*')}")
285+
if received
286+
print_warning("[UDP] received: #{received.unpack1('H*')}")
287+
end
288+
end
272289
client.close
273290
server_client.close
274291
ret

0 commit comments

Comments
 (0)