diff options
author | Alan Conway <aconway@apache.org> | 2007-11-01 00:38:58 +0000 |
---|---|---|
committer | Alan Conway <aconway@apache.org> | 2007-11-01 00:38:58 +0000 |
commit | 6ff9cc1db2af388c9fe00c140f555f7c30c5df6d (patch) | |
tree | 0b8e872f26627b5ebdcc882238e9ad256785cd22 /qpid/cpp/src/tests/SessionState.cpp | |
parent | 04cc6a2f5225e8894b4a8173b5a6ffd59a00184d (diff) | |
download | qpid-python-6ff9cc1db2af388c9fe00c140f555f7c30c5df6d.tar.gz |
Preparation for session thread safety overhaul:
- simplified SessionState, responsibility for protocol states now in Handlers
- qpid::RefCounted, qpid::intrusive_ptr reference counting support.
- build boost unit tests as single exe, speeds up testing.
- fixed leak in AsynchIOAcceptor.cpp
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@590869 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/cpp/src/tests/SessionState.cpp')
-rw-r--r-- | qpid/cpp/src/tests/SessionState.cpp | 11 |
1 files changed, 9 insertions, 2 deletions
diff --git a/qpid/cpp/src/tests/SessionState.cpp b/qpid/cpp/src/tests/SessionState.cpp index 19a146c759..f021861cd4 100644 --- a/qpid/cpp/src/tests/SessionState.cpp +++ b/qpid/cpp/src/tests/SessionState.cpp @@ -18,9 +18,9 @@ #include "qpid/framing/SessionState.h" -#define BOOST_AUTO_TEST_MAIN -#include <boost/test/auto_unit_test.hpp> #include <boost/bind.hpp> +#include <boost/test/auto_unit_test.hpp> +BOOST_AUTO_TEST_SUITE(SessionState); using namespace std; using namespace qpid::framing; @@ -97,16 +97,21 @@ BOOST_AUTO_TEST_CASE(testReplay) { // Replay of all frames. SessionState session(100); sent(session, "abc"); + session.suspend(); session.resuming(); session.receivedAck(-1); BOOST_CHECK_EQUAL(replayChars(session.replay()), "abc"); // Replay with acks session.receivedAck(0); // ack a. + session.suspend(); + session.resuming(); session.receivedAck(1); // ack b. BOOST_CHECK_EQUAL(replayChars(session.replay()), "c"); // Replay after further frames. sent(session, "def"); + session.suspend(); + session.resuming(); session.receivedAck(3); BOOST_CHECK_EQUAL(replayChars(session.replay()), "ef"); @@ -135,3 +140,5 @@ BOOST_AUTO_TEST_CASE(testReceived) { BOOST_CHECK(!s3.received(f)); BOOST_CHECK_EQUAL(5u, *s3.received(f)); } + +BOOST_AUTO_TEST_SUITE_END(); |