diff options
Diffstat (limited to 'cpp/src/Ice/ObjectAdapterI.cpp')
-rw-r--r-- | cpp/src/Ice/ObjectAdapterI.cpp | 31 |
1 files changed, 11 insertions, 20 deletions
diff --git a/cpp/src/Ice/ObjectAdapterI.cpp b/cpp/src/Ice/ObjectAdapterI.cpp index 799a3e7bafa..ed798943b30 100644 --- a/cpp/src/Ice/ObjectAdapterI.cpp +++ b/cpp/src/Ice/ObjectAdapterI.cpp @@ -11,7 +11,6 @@ #include <Ice/ObjectAdapterI.h> #include <Ice/ObjectAdapterFactory.h> #include <Ice/Instance.h> -#include <Ice/ConnectionMonitor.h> #include <Ice/Proxy.h> #include <Ice/ProxyFactory.h> #include <Ice/ReferenceFactory.h> @@ -859,21 +858,13 @@ Ice::ObjectAdapterI::getServantManager() const return _servantManager; } -Ice::Int +IceInternal::ACMConfig Ice::ObjectAdapterI::getACM() const { // Not check for deactivation here! assert(_instance); // Must not be called after destroy(). - - if(_hasAcmTimeout) - { - return _acmTimeout; - } - else - { - return _instance->serverACM(); - } + return _acm; } // @@ -888,8 +879,6 @@ Ice::ObjectAdapterI::ObjectAdapterI(const InstancePtr& instance, const Communica _instance(instance), _communicator(communicator), _objectAdapterFactory(objectAdapterFactory), - _hasAcmTimeout(false), - _acmTimeout(0), _servantManager(new ServantManager(instance, name)), _activateOneOffDone(false), _name(name), @@ -909,6 +898,7 @@ Ice::ObjectAdapterI::initialize(const RouterPrx& router) if(_noConfig) { _reference = _instance->referenceFactory()->create("dummy -t", ""); + const_cast<ACMConfig&>(_acm) = _instance->serverACM(); return; } @@ -960,6 +950,9 @@ Ice::ObjectAdapterI::initialize(const RouterPrx& router) throw ex; } + const_cast<ACMConfig&>(_acm) = + ACMConfig(properties, _communicator->getLogger(), _name + ".ACM", _instance->serverACM()); + int threadPoolSize = properties->getPropertyAsInt(_name + ".ThreadPool.Size"); int threadPoolSizeMax = properties->getPropertyAsInt(_name + ".ThreadPool.SizeMax"); bool hasPriority = properties->getProperty(_name + ".ThreadPool.ThreadPriority") != ""; @@ -972,13 +965,6 @@ Ice::ObjectAdapterI::initialize(const RouterPrx& router) { _threadPool = new ThreadPool(_instance, _name + ".ThreadPool", 0); } - - _hasAcmTimeout = properties->getProperty(_name + ".ACM") != ""; - if(_hasAcmTimeout) - { - _acmTimeout = properties->getPropertyAsInt(_name + ".ACM"); - _instance->connectionMonitor()->checkIntervalForACM(_acmTimeout); - } if(!router) { @@ -1459,6 +1445,9 @@ Ice::ObjectAdapterI::filterProperties(StringSeq& unknownProps) static const string suffixes[] = { "ACM", + "ACM.Close", + "ACM.Heartbeat", + "ACM.Timeout", "AdapterId", "Endpoints", "Locator", @@ -1483,7 +1472,9 @@ Ice::ObjectAdapterI::filterProperties(StringSeq& unknownProps) "Router.Locator.PreferSecure", "Router.Locator.CollocationOptimized", "Router.Locator.LocatorCacheTimeout", + "Router.Locator.InvocationTimeout", "Router.LocatorCacheTimeout", + "Router.InvocationTimeout", "ProxyOptions", "ThreadPool.Size", "ThreadPool.SizeMax", |