summaryrefslogtreecommitdiff
path: root/qpid/cpp/src/qpid/broker/SemanticState.h
diff options
context:
space:
mode:
authorGordon Sim <gsim@apache.org>2007-11-05 13:17:01 +0000
committerGordon Sim <gsim@apache.org>2007-11-05 13:17:01 +0000
commit48ac0f5a09c05c56bd1d91c597e6838795700c2e (patch)
tree868fc899049de940627d48f2957dc699e1f978df /qpid/cpp/src/qpid/broker/SemanticState.h
parent7c8d53c89603a399926ff487cd9a667197f6286b (diff)
downloadqpid-python-48ac0f5a09c05c56bd1d91c597e6838795700c2e.tar.gz
Suspension of one xid on a channel should allow for work on other xids to be done prior to resuming the initial xid.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@591986 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/cpp/src/qpid/broker/SemanticState.h')
-rw-r--r--qpid/cpp/src/qpid/broker/SemanticState.h2
1 files changed, 2 insertions, 0 deletions
diff --git a/qpid/cpp/src/qpid/broker/SemanticState.h b/qpid/cpp/src/qpid/broker/SemanticState.h
index 87ae937cfb..bb126287a3 100644
--- a/qpid/cpp/src/qpid/broker/SemanticState.h
+++ b/qpid/cpp/src/qpid/broker/SemanticState.h
@@ -103,6 +103,7 @@ class SemanticState : public framing::FrameHandler::Chains,
};
typedef std::map<std::string,ConsumerImpl::shared_ptr> ConsumerImplMap;
+ typedef std::map<std::string, DtxBuffer::shared_ptr> DtxBufferMap;
SessionState& session;
DeliveryAdapter& deliveryAdapter;
@@ -117,6 +118,7 @@ class SemanticState : public framing::FrameHandler::Chains,
TxBuffer::shared_ptr txBuffer;
DtxBuffer::shared_ptr dtxBuffer;
bool dtxSelected;
+ DtxBufferMap suspendedXids;
framing::AccumulatedAck accumulatedAck;
bool flowActive;