From 4d6a7b67defe883a79b9f770855ec12e6611da14 Mon Sep 17 00:00:00 2001 From: Alan Conway Date: Mon, 15 Nov 2010 17:30:18 +0000 Subject: testReconnect: increase number of bytes read/written before failure. Increased to 2048. The original value of 1024 was causing the test to fail with a timeout when run against a cluster with a long failover URL longer than about 400 bytes. The number of test messages was also doubled to give the same number of simulated failures in the test. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1035361 13f79535-47bb-0310-9956-ffa450edef68 --- python/qpid/tests/messaging/endpoints.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) (limited to 'python') diff --git a/python/qpid/tests/messaging/endpoints.py b/python/qpid/tests/messaging/endpoints.py index 60723114fe..c303ca652a 100644 --- a/python/qpid/tests/messaging/endpoints.py +++ b/python/qpid/tests/messaging/endpoints.py @@ -126,14 +126,14 @@ class SetupTests(Base): return self.real.writing(writing) def send(self, bytes): - if self.sent_count > 1024: + if self.sent_count > 2048: raise socket.error("fake error") n = self.real.send(bytes) self.sent_count += n return n def recv(self, n): - if self.recv_count > 1024: + if self.recv_count > 2048: return "" bytes = self.real.recv(n) self.recv_count += len(bytes) @@ -155,7 +155,7 @@ class SetupTests(Base): snd = ssn.sender("test-reconnect-queue; {create: always, delete: always}") rcv = ssn.receiver(snd.target) - msgs = [self.message("testReconnect", i) for i in range(10)] + msgs = [self.message("testReconnect", i) for i in range(20)] for m in msgs: snd.send(m) -- cgit v1.2.1