From 9cb1922884c5b258c961046e6fd48e5152aa79d5 Mon Sep 17 00:00:00 2001 From: Gordon Sim Date: Wed, 14 Feb 2007 16:58:52 +0000 Subject: Added durability property to queues and pass this to broker on declare. (This change also applied on trunk) Minor update of accumulated ack and test. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@507622 13f79535-47bb-0310-9956-ffa450edef68 --- cpp/tests/AccumulatedAckTest.cpp | 34 +++++++++++++++++++++++++++++----- 1 file changed, 29 insertions(+), 5 deletions(-) (limited to 'cpp/tests') diff --git a/cpp/tests/AccumulatedAckTest.cpp b/cpp/tests/AccumulatedAckTest.cpp index da984d3e69..64c1f979c0 100644 --- a/cpp/tests/AccumulatedAckTest.cpp +++ b/cpp/tests/AccumulatedAckTest.cpp @@ -29,11 +29,38 @@ using namespace qpid::broker; class AccumulatedAckTest : public CppUnit::TestCase { CPPUNIT_TEST_SUITE(AccumulatedAckTest); + CPPUNIT_TEST(testGeneral); CPPUNIT_TEST(testCovers); CPPUNIT_TEST(testUpdateAndConsolidate); CPPUNIT_TEST_SUITE_END(); public: + void testGeneral() + { + AccumulatedAck ack; + ack.clear(); + ack.update(3,3); + ack.update(7,7); + ack.update(9,9); + ack.update(1,2); + ack.update(4,5); + ack.update(6,6); + + for(int i = 1; i <= 7; i++) CPPUNIT_ASSERT(ack.covers(i)); + CPPUNIT_ASSERT(ack.covers(9)); + + CPPUNIT_ASSERT(!ack.covers(8)); + CPPUNIT_ASSERT(!ack.covers(10)); + + ack.consolidate(); + + for(int i = 1; i <= 7; i++) CPPUNIT_ASSERT(ack.covers(i)); + CPPUNIT_ASSERT(ack.covers(9)); + + CPPUNIT_ASSERT(!ack.covers(8)); + CPPUNIT_ASSERT(!ack.covers(10)); + } + void testCovers() { AccumulatedAck ack; @@ -67,15 +94,12 @@ class AccumulatedAckTest : public CppUnit::TestCase ack.update(2, 2); ack.update(0, 5); ack.consolidate(); - CPPUNIT_ASSERT_EQUAL((u_int64_t) 5, ack.range); - CPPUNIT_ASSERT_EQUAL((size_t) 3, ack.individual.size()); + CPPUNIT_ASSERT_EQUAL((u_int64_t) 6, ack.range); + CPPUNIT_ASSERT_EQUAL((size_t) 2, ack.individual.size()); list::iterator i = ack.individual.begin(); - CPPUNIT_ASSERT_EQUAL((u_int64_t) 6, *i); - i++; CPPUNIT_ASSERT_EQUAL((u_int64_t) 8, *i); i++; CPPUNIT_ASSERT_EQUAL((u_int64_t) 10, *i); - } }; -- cgit v1.2.1