You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ac...@apache.org on 2010/11/15 18:30:18 UTC

svn commit: r1035361 - /qpid/trunk/qpid/python/qpid/tests/messaging/endpoints.py

Author: aconway
Date: Mon Nov 15 17:30:18 2010
New Revision: 1035361

URL: http://svn.apache.org/viewvc?rev=1035361&view=rev
Log:
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.

Modified:
    qpid/trunk/qpid/python/qpid/tests/messaging/endpoints.py

Modified: qpid/trunk/qpid/python/qpid/tests/messaging/endpoints.py
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/python/qpid/tests/messaging/endpoints.py?rev=1035361&r1=1035360&r2=1035361&view=diff
==============================================================================
--- qpid/trunk/qpid/python/qpid/tests/messaging/endpoints.py (original)
+++ qpid/trunk/qpid/python/qpid/tests/messaging/endpoints.py Mon Nov 15 17:30:18 2010
@@ -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)
 



---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project:      http://qpid.apache.org
Use/Interact: mailto:commits-subscribe@qpid.apache.org