diff options
author | Benoit Foucher <benoit@zeroc.com> | 2012-07-24 12:57:37 +0200 |
---|---|---|
committer | Benoit Foucher <benoit@zeroc.com> | 2012-07-24 12:57:37 +0200 |
commit | d771cf4c126b7a650689f79005369053845d87aa (patch) | |
tree | 4f9a272efecade58965529ed740f92eaf2af24b2 /cpp/src/Ice/ConnectionFactory.cpp | |
parent | Initial metrics (diff) | |
download | ice-d771cf4c126b7a650689f79005369053845d87aa.tar.bz2 ice-d771cf4c126b7a650689f79005369053845d87aa.tar.xz ice-d771cf4c126b7a650689f79005369053845d87aa.zip |
More work
Diffstat (limited to 'cpp/src/Ice/ConnectionFactory.cpp')
-rwxr-xr-x | cpp/src/Ice/ConnectionFactory.cpp | 15 |
1 files changed, 15 insertions, 0 deletions
diff --git a/cpp/src/Ice/ConnectionFactory.cpp b/cpp/src/Ice/ConnectionFactory.cpp index 21e642ce572..1508e3cc911 100755 --- a/cpp/src/Ice/ConnectionFactory.cpp +++ b/cpp/src/Ice/ConnectionFactory.cpp @@ -125,6 +125,14 @@ IceInternal::OutgoingConnectionFactory::destroy() } void +IceInternal::OutgoingConnectionFactory::updateConnectionObservers() +{ + IceUtil::Monitor<IceUtil::Mutex>::Lock sync(*this); + for_each(_connections.begin(), _connections.end(), + Ice::secondVoidMemFun<const ConnectorPtr, ConnectionI>(&ConnectionI::updateObserver)); +} + +void IceInternal::OutgoingConnectionFactory::waitUntilFinished() { multimap<ConnectorPtr, ConnectionIPtr> connections; @@ -1199,6 +1207,13 @@ IceInternal::IncomingConnectionFactory::destroy() } void +IceInternal::IncomingConnectionFactory::updateConnectionObservers() +{ + IceUtil::Monitor<IceUtil::Mutex>::Lock sync(*this); + for_each(_connections.begin(), _connections.end(), Ice::voidMemFun(&ConnectionI::updateObserver)); +} + +void IceInternal::IncomingConnectionFactory::waitUntilHolding() const { set<ConnectionIPtr> connections; |