Removed test_30_presettled_overflow since that test case  is already covered in system_tests_delivery_counts.OneRouterLinkCountersTest  testMethod=test_06_large_message_released
@@ -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)
