diff options
author | Gordon Sim <gsim@apache.org> | 2008-04-24 21:07:34 +0000 |
---|---|---|
committer | Gordon Sim <gsim@apache.org> | 2008-04-24 21:07:34 +0000 |
commit | 1c86294add5cbb640aac7f458c4de693de48dd9f (patch) | |
tree | 22d7774e00c7514c4b76be5cf8b50727b74fe4e3 /cpp/src/qpid/cluster/Cluster.cpp | |
parent | 96f12949244b5af2b717156823309b66fe7bfb84 (diff) | |
download | qpid-python-1c86294add5cbb640aac7f458c4de693de48dd9f.tar.gz |
Generate c++ code from final 0-10 spec
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@651423 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid/cluster/Cluster.cpp')
-rw-r--r-- | cpp/src/qpid/cluster/Cluster.cpp | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/cpp/src/qpid/cluster/Cluster.cpp b/cpp/src/qpid/cluster/Cluster.cpp index 5152aa2e43..bca6c49c13 100644 --- a/cpp/src/qpid/cluster/Cluster.cpp +++ b/cpp/src/qpid/cluster/Cluster.cpp @@ -17,7 +17,7 @@ */ #include "Cluster.h" -#include "qpid/broker/PreviewSessionState.h" +#include "qpid/broker/SessionState.h" #include "qpid/framing/AMQFrame.h" #include "qpid/framing/ClusterNotifyBody.h" #include "qpid/log/Statement.h" @@ -32,18 +32,18 @@ namespace cluster { using namespace qpid::framing; using namespace qpid::sys; using namespace std; -using broker::PreviewSessionState; +using broker::SessionState; namespace { // Beginning of inbound chain: send to cluster. struct ClusterSendHandler : public FrameHandler { - PreviewSessionState& session; + SessionState& session; Cluster& cluster; bool busy; Monitor lock; - ClusterSendHandler(PreviewSessionState& s, Cluster& c) : session(s), cluster(c), busy(false) {} + ClusterSendHandler(SessionState& s, Cluster& c) : session(s), cluster(c), busy(false) {} void handle(AMQFrame& f) { Mutex::ScopedLock l(lock); @@ -83,11 +83,11 @@ void insert(FrameHandler::Chain& c, FrameHandler* h) { c.next = h; } -struct SessionObserver : public broker::PreviewSessionManager::Observer { +struct SessionObserver : public broker::SessionManager::Observer { Cluster& cluster; SessionObserver(Cluster& c) : cluster(c) {} - void opened(PreviewSessionState& s) { + void opened(SessionState& s) { // FIXME aconway 2008-01-29: IList for memory management. ClusterSendHandler* sender=new ClusterSendHandler(s, cluster); ClusterDeliverHandler* deliverer=new ClusterDeliverHandler(*sender, cluster); |