diff options
author | Alan Conway <aconway@apache.org> | 2010-11-15 17:30:18 +0000 |
---|---|---|
committer | Alan Conway <aconway@apache.org> | 2010-11-15 17:30:18 +0000 |
commit | 4d6a7b67defe883a79b9f770855ec12e6611da14 (patch) | |
tree | 0015c8a14002f0e95d3d0da75b49dfb02948599c /python | |
parent | 545f0191dfe1052ccfba4b8cdc12bd1837f6387d (diff) | |
download | qpid-python-4d6a7b67defe883a79b9f770855ec12e6611da14.tar.gz |
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
Diffstat (limited to 'python')
-rw-r--r-- | python/qpid/tests/messaging/endpoints.py | 6 |
1 files changed, 3 insertions, 3 deletions
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) |