diff options
author | Benoit Foucher <benoit@zeroc.com> | 2012-10-19 11:45:11 +0200 |
---|---|---|
committer | Benoit Foucher <benoit@zeroc.com> | 2012-10-19 11:45:11 +0200 |
commit | 558f4594241fba26f0b99357b4df234d49d72ae9 (patch) | |
tree | 163a535827720b99bdc32f3eeb68ce5e7aedbc9b /cpp/src/Ice/Instance.cpp | |
parent | Fixed ICE-4817: set default ACM timeout on registry OAs (diff) | |
download | ice-558f4594241fba26f0b99357b4df234d49d72ae9.tar.bz2 ice-558f4594241fba26f0b99357b4df234d49d72ae9.tar.xz ice-558f4594241fba26f0b99357b4df234d49d72ae9.zip |
Fixed ICE-3627 and ICE-3370: use of new async API and removed mono workaround in Network.cs
Diffstat (limited to 'cpp/src/Ice/Instance.cpp')
-rw-r--r-- | cpp/src/Ice/Instance.cpp | 30 |
1 files changed, 21 insertions, 9 deletions
diff --git a/cpp/src/Ice/Instance.cpp b/cpp/src/Ice/Instance.cpp index 69c14b31901..7180cc89500 100644 --- a/cpp/src/Ice/Instance.cpp +++ b/cpp/src/Ice/Instance.cpp @@ -124,21 +124,33 @@ public: void updateConnectionObservers() { - _instance->outgoingConnectionFactory()->updateConnectionObservers(); - _instance->objectAdapterFactory()->updateObservers(&ObjectAdapterI::updateConnectionObservers); + try + { + _instance->outgoingConnectionFactory()->updateConnectionObservers(); + _instance->objectAdapterFactory()->updateObservers(&ObjectAdapterI::updateConnectionObservers); + } + catch(const Ice::CommunicatorDestroyedException&) + { + } } void updateThreadObservers() { - _instance->clientThreadPool()->updateObservers(); - ThreadPoolPtr serverThreadPool = _instance->serverThreadPool(false); - if(serverThreadPool) + try + { + _instance->clientThreadPool()->updateObservers(); + ThreadPoolPtr serverThreadPool = _instance->serverThreadPool(false); + if(serverThreadPool) + { + serverThreadPool->updateObservers(); + } + _instance->objectAdapterFactory()->updateObservers(&ObjectAdapterI::updateThreadObservers); + _instance->endpointHostResolver()->updateObserver(); + theCollector->updateObserver(_instance->initializationData().observer); + } + catch(const Ice::CommunicatorDestroyedException&) { - serverThreadPool->updateObservers(); } - _instance->objectAdapterFactory()->updateObservers(&ObjectAdapterI::updateThreadObservers); - _instance->endpointHostResolver()->updateObserver(); - theCollector->updateObserver(_instance->initializationData().observer); } private: |