summaryrefslogtreecommitdiff
path: root/cpp/src/Ice/Instance.cpp
diff options
context:
space:
mode:
authorBenoit Foucher <benoit@zeroc.com>2012-10-19 11:45:11 +0200
committerBenoit Foucher <benoit@zeroc.com>2012-10-19 11:45:11 +0200
commit558f4594241fba26f0b99357b4df234d49d72ae9 (patch)
tree163a535827720b99bdc32f3eeb68ce5e7aedbc9b /cpp/src/Ice/Instance.cpp
parentFixed ICE-4817: set default ACM timeout on registry OAs (diff)
downloadice-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.cpp30
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: