This is an automated email from the ASF dual-hosted git repository.
gmurthy pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/qpid-dispatch.git
The following commit(s) were added to refs/heads/main by this push:
new 75607d1 DISPATCH-2330: Removed test_30_presettled_overflow since that
test case is already covered in
system_tests_delivery_counts.OneRouterLinkCountersTest
testMethod=test_06_large_message_released
75607d1 is described below
commit 75607d11fee7d76e681b040f805542074fc16006
Author: Ganesh Murthy <[email protected]>
AuthorDate: Wed Feb 16 10:01:08 2022 -0500
DISPATCH-2330: Removed test_30_presettled_overflow since that test case is
already covered in system_tests_delivery_counts.OneRouterLinkCountersTest
testMethod=test_06_large_message_released
---
tests/system_tests_one_router.py | 62 ----------------------------------------
1 file changed, 62 deletions(-)
diff --git a/tests/system_tests_one_router.py b/tests/system_tests_one_router.py
index ac6dcf1..d6367f2 100644
--- a/tests/system_tests_one_router.py
+++ b/tests/system_tests_one_router.py
@@ -563,11 +563,6 @@ class OneRouterTest(TestCase):
self.assertIsNone(test.error)
self.assertTrue(test.accepted_count_match)
- def test_30_presettled_overflow(self):
- test = PresettledOverflowTest(self.address)
- test.run()
- self.assertIsNone(test.error)
-
def test_31_create_unavailable_sender(self):
test = UnavailableSender(self.address)
test.run()
@@ -3325,63 +3320,6 @@ class RejectCoordinatorTest(MessagingHandler,
TransactionHandler):
Container(self).run()
-class PresettledOverflowTest(MessagingHandler):
- def __init__(self, address):
- super(PresettledOverflowTest, self).__init__(prefetch=0)
- self.address = address
- self.dest = "balanced.PresettledOverflow"
- self.error = None
- self.count = 500
- self.n_sent = 0
- self.n_received = 0
- self.last_seq = -1
-
- def timeout(self):
- self.error = "Timeout Expired: sent=%d rcvd=%d last_seq=%d" %
(self.n_sent, self.n_received, self.last_seq)
- self.conn.close()
-
- def on_start(self, event):
- self.timer = event.reactor.schedule(TIMEOUT, TestTimeout(self))
- self.conn = event.container.connect(self.address)
- self.sender = event.container.create_sender(self.conn, self.dest)
- self.receiver = event.container.create_receiver(self.conn, self.dest)
- self.receiver.flow(10)
-
- def send(self):
- while self.n_sent < self.count and self.sender.credit > 0:
- msg = Message(body={"seq": self.n_sent})
- dlv = self.sender.send(msg)
- dlv.settle()
- self.n_sent += 1
- if self.n_sent == self.count:
- self.receiver.flow(self.count)
-
- def on_sendable(self, event):
- if self.n_sent < self.count:
- self.send()
-
- def on_message(self, event):
- self.n_received += 1
- self.last_seq = event.message.body["seq"]
- if self.last_seq == self.count - 1:
- if self.n_received == self.count:
- self.error = "No deliveries were dropped"
-
- if not self.error:
- local_node = Node.connect(self.address, timeout=TIMEOUT)
- out =
local_node.query(type='org.apache.qpid.dispatch.router.link')
-
- for result in out.results:
- if result[5] == 'out' and 'balanced.PresettledOverflow' in
result[6]:
- if result[16] != 249:
- self.error = "Expected 249 dropped presettled
deliveries but got " + str(result[16])
- self.conn.close()
- self.timer.cancel()
-
- def run(self):
- Container(self).run()
-
-
class RejectDispositionTest(MessagingHandler):
def __init__(self, address):
super(RejectDispositionTest, self).__init__(auto_accept=False)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
