diff options
author | Alan Conway <aconway@apache.org> | 2009-10-27 17:55:44 +0000 |
---|---|---|
committer | Alan Conway <aconway@apache.org> | 2009-10-27 17:55:44 +0000 |
commit | a77294d7570a35513fcee77f2500ff3f023fc5d8 (patch) | |
tree | 2c3be2642f7f8bdf13886f97d07009357c33f092 /qpid/cpp/src/tests/PartialFailure.cpp | |
parent | 9ae1fd0253cc08e8b324bc93cb007f644b4a2b8a (diff) | |
download | qpid-python-a77294d7570a35513fcee77f2500ff3f023fc5d8.tar.gz |
Make Session::close and Connection::close no-throw
close() will often be called in destructors and so should not throw exceptions.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@830268 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/cpp/src/tests/PartialFailure.cpp')
-rw-r--r-- | qpid/cpp/src/tests/PartialFailure.cpp | 28 |
1 files changed, 28 insertions, 0 deletions
diff --git a/qpid/cpp/src/tests/PartialFailure.cpp b/qpid/cpp/src/tests/PartialFailure.cpp index 5de8ecb189..b5772607b2 100644 --- a/qpid/cpp/src/tests/PartialFailure.cpp +++ b/qpid/cpp/src/tests/PartialFailure.cpp @@ -102,6 +102,10 @@ QPID_AUTO_TEST_CASE(testCoincidentErrors) { try { Client c11(cluster[1], "c11"); ++alive; } catch (...) {} BOOST_CHECK_EQUAL(alive, 1); + + // Close inside ScopedSuppressLogging to avoid warnings + c0.close(); + c1.close(); } } @@ -138,6 +142,11 @@ QPID_AUTO_TEST_CASE(testNormalErrors) { BOOST_CHECK_EQUAL(3u, knownBrokerPorts(c2.connection, 3).size()); BOOST_CHECK_EQUAL(c2.subs.get("c0", TIMEOUT).getData(), "stay"); BOOST_CHECK_EQUAL(c2.subs.get("c1", TIMEOUT).getData(), "stay"); + + // Close inside ScopedSuppressLogging to avoid warnings + c0.close(); + c1.close(); + c2.close(); } } @@ -166,6 +175,11 @@ QPID_AUTO_TEST_CASE(testErrorAfterJoin) { BOOST_CHECK_THROW(c0.session.messageTransfer(content=pMessage("xxx", "q")), TransportFailure); BOOST_CHECK_EQUAL(1u, knownBrokerPorts(c2.connection, 1).size()); + + // Close inside ScopedSuppressLogging to avoid warnings + c0.close(); + c1.close(); + c2.close(); } } @@ -196,6 +210,11 @@ QPID_AUTO_TEST_CASE(testSinglePartialFailure) { c0.session.messageTransfer(content=pMessage("c", "q")); BOOST_CHECK_EQUAL(c0.session.queueQuery("q").getMessageCount(), 5u); BOOST_CHECK_EQUAL(1u, knownBrokerPorts(c0.connection, 1).size()); + + // Close inside ScopedSuppressLogging to avoid warnings + c0.close(); + c1.close(); + c2.close(); } } @@ -224,6 +243,12 @@ QPID_AUTO_TEST_CASE(testMultiPartialFailure) { // FIXME aconway 2009-06-30: This check fails sporadically with 2 != 3. // It should pass reliably. // BOOST_CHECK_EQUAL(2u, knownBrokerPorts(c0.connection, 2).size()); + + // Close inside ScopedSuppressLogging to avoid warnings + c0.close(); + c1.close(); + c2.close(); + c3.close(); } } @@ -254,6 +279,9 @@ QPID_AUTO_TEST_CASE(testPartialFailureMemberLeaves) { Client c00(cluster[0], "c00"); // Old connection is dead. BOOST_CHECK_EQUAL(c00.session.queueQuery("q").getMessageCount(), 1u); BOOST_CHECK_EQUAL(1u, knownBrokerPorts(c00.connection, 1).size()); + + // Close inside ScopedSuppressLogging to avoid warnings + c0.close(); } } #endif |