From 3767d7e49e80c268c60ee247b3526b986eb7fc17 Mon Sep 17 00:00:00 2001 From: Gordon Sim Date: Thu, 21 Feb 2008 17:40:42 +0000 Subject: Start moving towards final 0-10 spec: * marked preview spec as 99-0 to distinguish it from 0-10 (which will now be used for the final version) * modified python client to treat 99-0 as 0-10 for now * modified broker to have two paths for the two different versions: 99-0 uses PreviewConnection, PreviewConnectionHandler and PreviewSessionHandler which are straight copy & pastes of the Connection, ConnectionHandler and SessionHandler now associated with 0-10 (so we can migrate the 0-10 path to the final spec without affecting clients working with the preview version) git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@629883 13f79535-47bb-0310-9956-ffa450edef68 --- cpp/src/qpid/broker/SessionState.cpp | 14 +++++++------- 1 file changed, 7 insertions(+), 7 deletions(-) (limited to 'cpp/src/qpid/broker/SessionState.cpp') diff --git a/cpp/src/qpid/broker/SessionState.cpp b/cpp/src/qpid/broker/SessionState.cpp index 80fafe0386..b6c59cfb3b 100644 --- a/cpp/src/qpid/broker/SessionState.cpp +++ b/cpp/src/qpid/broker/SessionState.cpp @@ -20,8 +20,8 @@ */ #include "SessionState.h" #include "SessionManager.h" -#include "SessionHandler.h" -#include "Connection.h" +#include "SessionContext.h" +#include "ConnectionState.h" #include "Broker.h" #include "SemanticHandler.h" #include "qpid/framing/reply_exceptions.h" @@ -37,7 +37,7 @@ using qpid::management::Manageable; using qpid::management::Args; SessionState::SessionState( - SessionManager* f, SessionHandler* h, uint32_t timeout_, uint32_t ack) + SessionManager* f, SessionContext* h, uint32_t timeout_, uint32_t ack) : framing::SessionState(ack, timeout_ > 0), factory(f), handler(h), id(true), timeout(timeout_), broker(h->getConnection().broker), @@ -76,7 +76,7 @@ SessionState::~SessionState() { mgmtObject->resourceDestroy (); } -SessionHandler* SessionState::getHandler() { +SessionContext* SessionState::getHandler() { return handler; } @@ -85,7 +85,7 @@ AMQP_ClientProxy& SessionState::getProxy() { return getHandler()->getProxy(); } -Connection& SessionState::getConnection() { +ConnectionState& SessionState::getConnection() { assert(isAttached()); return getHandler()->getConnection(); } @@ -100,7 +100,7 @@ void SessionState::detach() { } } -void SessionState::attach(SessionHandler& h) { +void SessionState::attach(SessionContext& h) { { Mutex::ScopedLock l(lock); handler = &h; @@ -141,7 +141,7 @@ Manageable::status_t SessionState::ManagementMethod (uint32_t methodId, case management::Session::METHOD_DETACH : if (handler != 0) { - handler->localSuspend (); + handler->detach(); } status = Manageable::STATUS_OK; break; -- cgit v1.2.1