diff options
Diffstat (limited to 'cpp/src/qpid/client/ConnectionImpl.h')
-rw-r--r-- | cpp/src/qpid/client/ConnectionImpl.h | 7 |
1 files changed, 5 insertions, 2 deletions
diff --git a/cpp/src/qpid/client/ConnectionImpl.h b/cpp/src/qpid/client/ConnectionImpl.h index 1fe8ac4653..bf8226a776 100644 --- a/cpp/src/qpid/client/ConnectionImpl.h +++ b/cpp/src/qpid/client/ConnectionImpl.h @@ -43,6 +43,8 @@ class ConnectionImpl : public framing::FrameHandler, { typedef std::map<uint16_t, boost::weak_ptr<SessionCore> > SessionMap; + typedef std::vector<boost::shared_ptr<SessionCore> > SessionVector; + SessionMap sessions; ConnectionHandler handler; boost::shared_ptr<Connector> connector; @@ -51,6 +53,9 @@ class ConnectionImpl : public framing::FrameHandler, bool isClosed; bool isClosing; + template <class F> void detachAll(const F&); + + SessionVector closeInternal(const sys::Mutex::ScopedLock&); void incoming(framing::AMQFrame& frame); void closed(uint16_t, const std::string&); void idleOut(); @@ -58,8 +63,6 @@ class ConnectionImpl : public framing::FrameHandler, void shutdown(); bool setClosing(); - template <class F> void forChannels(F functor); - public: typedef boost::shared_ptr<ConnectionImpl> shared_ptr; |