|
|
|
|
@ -1571,7 +1571,7 @@ class UdpBlackBoxHarnessTest(unittest.TestCase):
|
|
|
|
|
self.assertEqual(quench.packet[4:7], bytes_3(91))
|
|
|
|
|
self.assertEqual(quench.packet[7:11], bytes_4(stream_id))
|
|
|
|
|
|
|
|
|
|
def test_fbp_eleven_hops_is_accepted(self):
|
|
|
|
|
def test_fbp_twenty_hops_is_accepted(self):
|
|
|
|
|
require_udp_integration_enabled()
|
|
|
|
|
|
|
|
|
|
stream_id = 0x01020310
|
|
|
|
|
@ -1593,7 +1593,7 @@ class UdpBlackBoxHarnessTest(unittest.TestCase):
|
|
|
|
|
),
|
|
|
|
|
source_server=9991,
|
|
|
|
|
source_rptr=1001,
|
|
|
|
|
hops=10,
|
|
|
|
|
hops=19,
|
|
|
|
|
)
|
|
|
|
|
captured = master_b.recv(timeout=2.0)
|
|
|
|
|
finally:
|
|
|
|
|
@ -1624,7 +1624,7 @@ class UdpBlackBoxHarnessTest(unittest.TestCase):
|
|
|
|
|
),
|
|
|
|
|
source_server=9991,
|
|
|
|
|
source_rptr=1001,
|
|
|
|
|
hops=11,
|
|
|
|
|
hops=20,
|
|
|
|
|
)
|
|
|
|
|
quench = fbp_peer.recv_opcode(b"BCSQ", timeout=2.0)
|
|
|
|
|
with self.assertRaises(socket.timeout):
|
|
|
|
|
|