diff options
-rw-r--r-- | qpid/cpp/src/qpid/broker/SessionState.cpp | 5 | ||||
-rw-r--r-- | qpid/cpp/src/qpid/broker/SessionState.h | 10 |
2 files changed, 11 insertions, 4 deletions
diff --git a/qpid/cpp/src/qpid/broker/SessionState.cpp b/qpid/cpp/src/qpid/broker/SessionState.cpp index ee9646931e..742dbe9be8 100644 --- a/qpid/cpp/src/qpid/broker/SessionState.cpp +++ b/qpid/cpp/src/qpid/broker/SessionState.cpp @@ -445,8 +445,6 @@ void SessionState::addPendingExecutionSync() boost::intrusive_ptr<AsyncCompletion::Callback> SessionState::IncompleteIngressMsgXfer::clone() { - boost::intrusive_ptr<SessionState::IncompleteIngressMsgXfer> cb(new SessionState::IncompleteIngressMsgXfer(session, msg)); - // Optimization: this routine is *only* invoked when the message needs to be asynchronously completed. // If the client is pending the message.transfer completion, flush now to force immediate write to journal. if (requiresSync) @@ -457,7 +455,8 @@ SessionState::IncompleteIngressMsgXfer::clone() pending = true; completerContext->addPendingMessage(msg); } - return cb; + + return boost::intrusive_ptr<SessionState::IncompleteIngressMsgXfer>(new SessionState::IncompleteIngressMsgXfer(*this)); } diff --git a/qpid/cpp/src/qpid/broker/SessionState.h b/qpid/cpp/src/qpid/broker/SessionState.h index b43df0c0aa..506af85c47 100644 --- a/qpid/cpp/src/qpid/broker/SessionState.h +++ b/qpid/cpp/src/qpid/broker/SessionState.h @@ -256,7 +256,15 @@ class SessionState : public qpid::SessionState, requiresAccept(m->requiresAccept()), requiresSync(m->getFrames().getMethod()->isSync()), pending(false) {} - virtual ~IncompleteIngressMsgXfer() {}; + IncompleteIngressMsgXfer( const IncompleteIngressMsgXfer& x ) + : AsyncCommandContext(x.session, x.msg->getCommandId()), + session(x.session), + msg(x.msg), + requiresAccept(x.requiresAccept), + requiresSync(x.requiresSync), + pending(x.pending) {} + + virtual ~IncompleteIngressMsgXfer() {}; virtual void completed(bool); virtual boost::intrusive_ptr<AsyncCompletion::Callback> clone(); |