summaryrefslogtreecommitdiff
path: root/cs/src/Ice/Instance.cs
diff options
context:
space:
mode:
Diffstat (limited to 'cs/src/Ice/Instance.cs')
-rwxr-xr-xcs/src/Ice/Instance.cs1282
1 files changed, 641 insertions, 641 deletions
diff --git a/cs/src/Ice/Instance.cs b/cs/src/Ice/Instance.cs
index 072952951db..c066024d5bd 100755
--- a/cs/src/Ice/Instance.cs
+++ b/cs/src/Ice/Instance.cs
@@ -14,283 +14,283 @@ namespace IceInternal
public sealed class Instance
{
- public bool destroyed()
- {
- return _state == StateDestroyed;
- }
+ public bool destroyed()
+ {
+ return _state == StateDestroyed;
+ }
- public Ice.InitializationData initializationData()
- {
- //
- // No check for destruction. It must be possible to access the
- // initialization data after destruction.
- //
- // No mutex lock, immutable.
- //
- return _initData;
- }
-
- public TraceLevels traceLevels()
- {
- // No mutex lock, immutable.
- return _traceLevels;
- }
-
- public DefaultsAndOverrides defaultsAndOverrides()
- {
- // No mutex lock, immutable.
- return _defaultsAndOverrides;
- }
-
- public RouterManager routerManager()
- {
- lock(this)
- {
- if(_state == StateDestroyed)
- {
- throw new Ice.CommunicatorDestroyedException();
- }
-
- return _routerManager;
- }
- }
-
- public LocatorManager locatorManager()
- {
- lock(this)
- {
- if(_state == StateDestroyed)
- {
- throw new Ice.CommunicatorDestroyedException();
- }
-
- return _locatorManager;
- }
- }
-
- public ReferenceFactory referenceFactory()
- {
- lock(this)
- {
- if(_state == StateDestroyed)
- {
- throw new Ice.CommunicatorDestroyedException();
- }
-
- return _referenceFactory;
- }
- }
-
- public ProxyFactory proxyFactory()
- {
- lock(this)
- {
- if(_state == StateDestroyed)
- {
- throw new Ice.CommunicatorDestroyedException();
- }
-
- return _proxyFactory;
- }
- }
-
- public OutgoingConnectionFactory outgoingConnectionFactory()
- {
- lock(this)
- {
- if(_state == StateDestroyed)
- {
- throw new Ice.CommunicatorDestroyedException();
- }
-
- return _outgoingConnectionFactory;
- }
- }
-
- public ConnectionMonitor connectionMonitor()
- {
- lock(this)
- {
- if(_state == StateDestroyed)
- {
- throw new Ice.CommunicatorDestroyedException();
- }
-
- return _connectionMonitor;
- }
- }
-
- public ObjectFactoryManager servantFactoryManager()
- {
- lock(this)
- {
- if(_state == StateDestroyed)
- {
- throw new Ice.CommunicatorDestroyedException();
- }
-
- return _servantFactoryManager;
- }
- }
-
- public ObjectAdapterFactory objectAdapterFactory()
- {
- lock(this)
- {
- if(_state == StateDestroyed)
- {
- throw new Ice.CommunicatorDestroyedException();
- }
-
- return _objectAdapterFactory;
- }
- }
-
- public ThreadPool clientThreadPool()
- {
- lock(this)
- {
- if(_state == StateDestroyed)
- {
- throw new Ice.CommunicatorDestroyedException();
- }
-
- if(_clientThreadPool == null) // Lazy initialization.
- {
- _clientThreadPool = new ThreadPool(this, "Ice.ThreadPool.Client", 0);
- }
-
- return _clientThreadPool;
- }
- }
-
- public ThreadPool serverThreadPool()
- {
- lock(this)
- {
- if(_state == StateDestroyed)
- {
- throw new Ice.CommunicatorDestroyedException();
- }
-
- if(_serverThreadPool == null)
- // Lazy initialization.
- {
- int timeout = _initData.properties.getPropertyAsInt("Ice.ServerIdleTime");
- _serverThreadPool = new ThreadPool(this, "Ice.ThreadPool.Server", timeout);
- }
-
- return _serverThreadPool;
- }
- }
+ public Ice.InitializationData initializationData()
+ {
+ //
+ // No check for destruction. It must be possible to access the
+ // initialization data after destruction.
+ //
+ // No mutex lock, immutable.
+ //
+ return _initData;
+ }
+
+ public TraceLevels traceLevels()
+ {
+ // No mutex lock, immutable.
+ return _traceLevels;
+ }
+
+ public DefaultsAndOverrides defaultsAndOverrides()
+ {
+ // No mutex lock, immutable.
+ return _defaultsAndOverrides;
+ }
+
+ public RouterManager routerManager()
+ {
+ lock(this)
+ {
+ if(_state == StateDestroyed)
+ {
+ throw new Ice.CommunicatorDestroyedException();
+ }
+
+ return _routerManager;
+ }
+ }
+
+ public LocatorManager locatorManager()
+ {
+ lock(this)
+ {
+ if(_state == StateDestroyed)
+ {
+ throw new Ice.CommunicatorDestroyedException();
+ }
+
+ return _locatorManager;
+ }
+ }
+
+ public ReferenceFactory referenceFactory()
+ {
+ lock(this)
+ {
+ if(_state == StateDestroyed)
+ {
+ throw new Ice.CommunicatorDestroyedException();
+ }
+
+ return _referenceFactory;
+ }
+ }
+
+ public ProxyFactory proxyFactory()
+ {
+ lock(this)
+ {
+ if(_state == StateDestroyed)
+ {
+ throw new Ice.CommunicatorDestroyedException();
+ }
+
+ return _proxyFactory;
+ }
+ }
+
+ public OutgoingConnectionFactory outgoingConnectionFactory()
+ {
+ lock(this)
+ {
+ if(_state == StateDestroyed)
+ {
+ throw new Ice.CommunicatorDestroyedException();
+ }
+
+ return _outgoingConnectionFactory;
+ }
+ }
+
+ public ConnectionMonitor connectionMonitor()
+ {
+ lock(this)
+ {
+ if(_state == StateDestroyed)
+ {
+ throw new Ice.CommunicatorDestroyedException();
+ }
+
+ return _connectionMonitor;
+ }
+ }
+
+ public ObjectFactoryManager servantFactoryManager()
+ {
+ lock(this)
+ {
+ if(_state == StateDestroyed)
+ {
+ throw new Ice.CommunicatorDestroyedException();
+ }
+
+ return _servantFactoryManager;
+ }
+ }
+
+ public ObjectAdapterFactory objectAdapterFactory()
+ {
+ lock(this)
+ {
+ if(_state == StateDestroyed)
+ {
+ throw new Ice.CommunicatorDestroyedException();
+ }
+
+ return _objectAdapterFactory;
+ }
+ }
+
+ public ThreadPool clientThreadPool()
+ {
+ lock(this)
+ {
+ if(_state == StateDestroyed)
+ {
+ throw new Ice.CommunicatorDestroyedException();
+ }
+
+ if(_clientThreadPool == null) // Lazy initialization.
+ {
+ _clientThreadPool = new ThreadPool(this, "Ice.ThreadPool.Client", 0);
+ }
+
+ return _clientThreadPool;
+ }
+ }
+
+ public ThreadPool serverThreadPool()
+ {
+ lock(this)
+ {
+ if(_state == StateDestroyed)
+ {
+ throw new Ice.CommunicatorDestroyedException();
+ }
+
+ if(_serverThreadPool == null)
+ // Lazy initialization.
+ {
+ int timeout = _initData.properties.getPropertyAsInt("Ice.ServerIdleTime");
+ _serverThreadPool = new ThreadPool(this, "Ice.ThreadPool.Server", timeout);
+ }
+
+ return _serverThreadPool;
+ }
+ }
- public bool threadPerConnection()
- {
- // No mutex lock, immutable.
- return _threadPerConnection;
- }
+ public bool threadPerConnection()
+ {
+ // No mutex lock, immutable.
+ return _threadPerConnection;
+ }
- public EndpointFactoryManager endpointFactoryManager()
- {
- lock(this)
- {
- if(_state == StateDestroyed)
- {
- throw new Ice.CommunicatorDestroyedException();
- }
-
- return _endpointFactoryManager;
- }
- }
-
- public Ice.PluginManager pluginManager()
- {
- lock(this)
- {
- if(_state == StateDestroyed)
- {
- throw new Ice.CommunicatorDestroyedException();
- }
-
- return _pluginManager;
- }
- }
-
- public int messageSizeMax()
- {
- // No mutex lock, immutable.
- return _messageSizeMax;
- }
-
- public int clientACM()
- {
- // No mutex lock, immutable.
- return _clientACM;
- }
-
- public int serverACM()
- {
- // No mutex lock, immutable.
- return _serverACM;
- }
-
- public void setDefaultContext(Ice.Context ctx)
- {
- lock(this)
- {
- if(_state == StateDestroyed)
- {
- throw new Ice.CommunicatorDestroyedException();
- }
-
- if(ctx == null || ctx.Count == 0)
- {
- _defaultContext = _emptyContext;
- }
- else
- {
- _defaultContext = (Ice.Context)ctx.Clone();
- }
- }
- }
+ public EndpointFactoryManager endpointFactoryManager()
+ {
+ lock(this)
+ {
+ if(_state == StateDestroyed)
+ {
+ throw new Ice.CommunicatorDestroyedException();
+ }
+
+ return _endpointFactoryManager;
+ }
+ }
+
+ public Ice.PluginManager pluginManager()
+ {
+ lock(this)
+ {
+ if(_state == StateDestroyed)
+ {
+ throw new Ice.CommunicatorDestroyedException();
+ }
+
+ return _pluginManager;
+ }
+ }
+
+ public int messageSizeMax()
+ {
+ // No mutex lock, immutable.
+ return _messageSizeMax;
+ }
+
+ public int clientACM()
+ {
+ // No mutex lock, immutable.
+ return _clientACM;
+ }
+
+ public int serverACM()
+ {
+ // No mutex lock, immutable.
+ return _serverACM;
+ }
+
+ public void setDefaultContext(Ice.Context ctx)
+ {
+ lock(this)
+ {
+ if(_state == StateDestroyed)
+ {
+ throw new Ice.CommunicatorDestroyedException();
+ }
+
+ if(ctx == null || ctx.Count == 0)
+ {
+ _defaultContext = _emptyContext;
+ }
+ else
+ {
+ _defaultContext = (Ice.Context)ctx.Clone();
+ }
+ }
+ }
- public Ice.Context getDefaultContext()
- {
- lock(this)
- {
- if(_state == StateDestroyed)
- {
- throw new Ice.CommunicatorDestroyedException();
- }
-
- return (Ice.Context)_defaultContext.Clone();
- }
- }
+ public Ice.Context getDefaultContext()
+ {
+ lock(this)
+ {
+ if(_state == StateDestroyed)
+ {
+ throw new Ice.CommunicatorDestroyedException();
+ }
+
+ return (Ice.Context)_defaultContext.Clone();
+ }
+ }
- public Ice.ImplicitContextI getImplicitContext()
- {
- return _implicitContext;
- }
+ public Ice.ImplicitContextI getImplicitContext()
+ {
+ return _implicitContext;
+ }
- public void flushBatchRequests()
- {
- OutgoingConnectionFactory connectionFactory;
- ObjectAdapterFactory adapterFactory;
-
- lock(this)
- {
- if(_state == StateDestroyed)
- {
- throw new Ice.CommunicatorDestroyedException();
- }
-
- connectionFactory = _outgoingConnectionFactory;
- adapterFactory = _objectAdapterFactory;
- }
-
- connectionFactory.flushBatchRequests();
- adapterFactory.flushBatchRequests();
- }
+ public void flushBatchRequests()
+ {
+ OutgoingConnectionFactory connectionFactory;
+ ObjectAdapterFactory adapterFactory;
+
+ lock(this)
+ {
+ if(_state == StateDestroyed)
+ {
+ throw new Ice.CommunicatorDestroyedException();
+ }
+
+ connectionFactory = _outgoingConnectionFactory;
+ adapterFactory = _objectAdapterFactory;
+ }
+
+ connectionFactory.flushBatchRequests();
+ adapterFactory.flushBatchRequests();
+ }
public Ice.Identity stringToIdentity(string s)
{
@@ -301,385 +301,385 @@ namespace IceInternal
{
return Ice.Util.identityToString(ident);
}
-
- //
- // Only for use by Ice.CommunicatorI
- //
- public Instance(Ice.Communicator communicator, Ice.InitializationData initData)
- {
- _state = StateActive;
- _initData = initData;
-
- try
- {
- if(_initData.properties == null)
- {
- _initData.properties = Ice.Util.createProperties();
- }
+
+ //
+ // Only for use by Ice.CommunicatorI
+ //
+ public Instance(Ice.Communicator communicator, Ice.InitializationData initData)
+ {
+ _state = StateActive;
+ _initData = initData;
+
+ try
+ {
+ if(_initData.properties == null)
+ {
+ _initData.properties = Ice.Util.createProperties();
+ }
- lock(_staticLock)
- {
- if(!_oneOffDone)
- {
- string stdOut = _initData.properties.getProperty("Ice.StdOut");
- string stdErr = _initData.properties.getProperty("Ice.StdErr");
-
- System.IO.StreamWriter outStream = null;
-
- if(stdOut.Length > 0)
- {
- try
- {
- outStream = System.IO.File.AppendText(stdOut);
- }
- catch(System.IO.IOException ex)
- {
- Ice.FileException fe = new Ice.FileException(ex);
- fe.path = stdOut;
- throw fe;
- }
- outStream.AutoFlush = true;
- System.Console.Out.Close();
- System.Console.SetOut(outStream);
- }
- if(stdErr.Length > 0)
- {
- if(stdErr.Equals(stdOut))
- {
- System.Console.SetError(outStream);
- }
- else
- {
- System.IO.StreamWriter errStream = null;
- try
- {
- errStream = System.IO.File.AppendText(stdErr);
- }
- catch(System.IO.IOException ex)
- {
- Ice.FileException fe = new Ice.FileException(ex);
- fe.path = stdErr;
- throw fe;
- }
- errStream.AutoFlush = true;
- System.Console.Error.Close();
- System.Console.SetError(errStream);
- }
- }
+ lock(_staticLock)
+ {
+ if(!_oneOffDone)
+ {
+ string stdOut = _initData.properties.getProperty("Ice.StdOut");
+ string stdErr = _initData.properties.getProperty("Ice.StdErr");
+
+ System.IO.StreamWriter outStream = null;
+
+ if(stdOut.Length > 0)
+ {
+ try
+ {
+ outStream = System.IO.File.AppendText(stdOut);
+ }
+ catch(System.IO.IOException ex)
+ {
+ Ice.FileException fe = new Ice.FileException(ex);
+ fe.path = stdOut;
+ throw fe;
+ }
+ outStream.AutoFlush = true;
+ System.Console.Out.Close();
+ System.Console.SetOut(outStream);
+ }
+ if(stdErr.Length > 0)
+ {
+ if(stdErr.Equals(stdOut))
+ {
+ System.Console.SetError(outStream);
+ }
+ else
+ {
+ System.IO.StreamWriter errStream = null;
+ try
+ {
+ errStream = System.IO.File.AppendText(stdErr);
+ }
+ catch(System.IO.IOException ex)
+ {
+ Ice.FileException fe = new Ice.FileException(ex);
+ fe.path = stdErr;
+ throw fe;
+ }
+ errStream.AutoFlush = true;
+ System.Console.Error.Close();
+ System.Console.SetError(errStream);
+ }
+ }
- _oneOffDone = true;
- }
- }
-
- if(_initData.logger == null)
- {
- if(_initData.properties.getPropertyAsInt("Ice.UseSyslog") > 0)
- {
- _initData.logger = new Ice.SysLoggerI(_initData.properties.getProperty("Ice.ProgramName"));
- }
- else
- {
- _initData.logger = Ice.Util.getProcessLogger();
- }
- }
-
- _traceLevels = new TraceLevels(_initData.properties);
-
- _defaultsAndOverrides = new DefaultsAndOverrides(_initData.properties);
-
- {
- const int defaultMessageSizeMax = 1024;
- int num =
- _initData.properties.getPropertyAsIntWithDefault("Ice.MessageSizeMax", defaultMessageSizeMax);
- if(num < 1)
- {
- _messageSizeMax = defaultMessageSizeMax * 1024; // Ignore stupid values.
- }
- else if(num > 0x7fffffff / 1024)
- {
- _messageSizeMax = 0x7fffffff;
- }
- else
- {
- _messageSizeMax = num * 1024; // Property is in kilobytes, _messageSizeMax in bytes
- }
- }
-
- //
- // Client ACM enabled by default. Server ACM disabled by default.
- //
- _clientACM = _initData.properties.getPropertyAsIntWithDefault("Ice.ACM.Client", 60);
- _serverACM = _initData.properties.getPropertyAsInt("Ice.ACM.Server");
+ _oneOffDone = true;
+ }
+ }
+
+ if(_initData.logger == null)
+ {
+ if(_initData.properties.getPropertyAsInt("Ice.UseSyslog") > 0)
+ {
+ _initData.logger = new Ice.SysLoggerI(_initData.properties.getProperty("Ice.ProgramName"));
+ }
+ else
+ {
+ _initData.logger = Ice.Util.getProcessLogger();
+ }
+ }
+
+ _traceLevels = new TraceLevels(_initData.properties);
+
+ _defaultsAndOverrides = new DefaultsAndOverrides(_initData.properties);
+
+ {
+ const int defaultMessageSizeMax = 1024;
+ int num =
+ _initData.properties.getPropertyAsIntWithDefault("Ice.MessageSizeMax", defaultMessageSizeMax);
+ if(num < 1)
+ {
+ _messageSizeMax = defaultMessageSizeMax * 1024; // Ignore stupid values.
+ }
+ else if(num > 0x7fffffff / 1024)
+ {
+ _messageSizeMax = 0x7fffffff;
+ }
+ else
+ {
+ _messageSizeMax = num * 1024; // Property is in kilobytes, _messageSizeMax in bytes
+ }
+ }
+
+ //
+ // Client ACM enabled by default. Server ACM disabled by default.
+ //
+ _clientACM = _initData.properties.getPropertyAsIntWithDefault("Ice.ACM.Client", 60);
+ _serverACM = _initData.properties.getPropertyAsInt("Ice.ACM.Server");
- _implicitContext = Ice.ImplicitContextI.create(_initData.properties.getProperty("Ice.ImplicitContext"));
+ _implicitContext = Ice.ImplicitContextI.create(_initData.properties.getProperty("Ice.ImplicitContext"));
- _threadPerConnection = _initData.properties.getPropertyAsInt("Ice.ThreadPerConnection") > 0;
+ _threadPerConnection = _initData.properties.getPropertyAsInt("Ice.ThreadPerConnection") > 0;
- _routerManager = new RouterManager();
-
- _locatorManager = new LocatorManager();
-
- _referenceFactory = new ReferenceFactory(this, communicator);
-
- _proxyFactory = new ProxyFactory(this);
-
- _endpointFactoryManager = new EndpointFactoryManager(this);
- EndpointFactory tcpEndpointFactory = new TcpEndpointFactory(this);
- _endpointFactoryManager.add(tcpEndpointFactory);
- EndpointFactory udpEndpointFactory = new UdpEndpointFactory(this);
- _endpointFactoryManager.add(udpEndpointFactory);
-
- _pluginManager = new Ice.PluginManagerI(communicator);
+ _routerManager = new RouterManager();
+
+ _locatorManager = new LocatorManager();
+
+ _referenceFactory = new ReferenceFactory(this, communicator);
+
+ _proxyFactory = new ProxyFactory(this);
+
+ _endpointFactoryManager = new EndpointFactoryManager(this);
+ EndpointFactory tcpEndpointFactory = new TcpEndpointFactory(this);
+ _endpointFactoryManager.add(tcpEndpointFactory);
+ EndpointFactory udpEndpointFactory = new UdpEndpointFactory(this);
+ _endpointFactoryManager.add(udpEndpointFactory);
+
+ _pluginManager = new Ice.PluginManagerI(communicator);
- _defaultContext = _emptyContext;
-
- _outgoingConnectionFactory = new OutgoingConnectionFactory(this);
-
- _servantFactoryManager = new ObjectFactoryManager();
-
- _objectAdapterFactory = new ObjectAdapterFactory(this, communicator);
- }
- catch(Ice.LocalException)
- {
- destroy();
- throw;
- }
- }
-
- public void finishSetup(ref string[] args)
- {
- //
- // Load plug-ins.
- //
- Ice.PluginManagerI pluginManagerImpl = (Ice.PluginManagerI)_pluginManager;
- pluginManagerImpl.loadPlugins(ref args);
- Ice.Logger logger = pluginManagerImpl.getLogger();
- if(logger != null)
- {
- _initData.logger = logger;
- }
-
- //
- // Get default router and locator proxies. Don't move this
- // initialization before the plug-in initialization!!! The proxies
- // might depend on endpoint factories to be installed by plug-ins.
- //
- _referenceFactory.setDefaultRouter(Ice.RouterPrxHelper.uncheckedCast(
- _proxyFactory.propertyToProxy("Ice.Default.Router")));
-
- _referenceFactory.setDefaultLocator(Ice.LocatorPrxHelper.uncheckedCast(
- _proxyFactory.propertyToProxy("Ice.Default.Locator")));
-
- //
- // Show process id if requested (but only once).
- //
- lock(this)
- {
- if(!_printProcessIdDone && _initData.properties.getPropertyAsInt("Ice.PrintProcessId") > 0)
- {
- using(Process p = Process.GetCurrentProcess())
- {
- System.Console.WriteLine(p.Id);
- }
- _printProcessIdDone = true;
- }
- }
+ _defaultContext = _emptyContext;
+
+ _outgoingConnectionFactory = new OutgoingConnectionFactory(this);
+
+ _servantFactoryManager = new ObjectFactoryManager();
+
+ _objectAdapterFactory = new ObjectAdapterFactory(this, communicator);
+ }
+ catch(Ice.LocalException)
+ {
+ destroy();
+ throw;
+ }
+ }
+
+ public void finishSetup(ref string[] args)
+ {
+ //
+ // Load plug-ins.
+ //
+ Ice.PluginManagerI pluginManagerImpl = (Ice.PluginManagerI)_pluginManager;
+ pluginManagerImpl.loadPlugins(ref args);
+ Ice.Logger logger = pluginManagerImpl.getLogger();
+ if(logger != null)
+ {
+ _initData.logger = logger;
+ }
+
+ //
+ // Get default router and locator proxies. Don't move this
+ // initialization before the plug-in initialization!!! The proxies
+ // might depend on endpoint factories to be installed by plug-ins.
+ //
+ _referenceFactory.setDefaultRouter(Ice.RouterPrxHelper.uncheckedCast(
+ _proxyFactory.propertyToProxy("Ice.Default.Router")));
+
+ _referenceFactory.setDefaultLocator(Ice.LocatorPrxHelper.uncheckedCast(
+ _proxyFactory.propertyToProxy("Ice.Default.Locator")));
+
+ //
+ // Show process id if requested (but only once).
+ //
+ lock(this)
+ {
+ if(!_printProcessIdDone && _initData.properties.getPropertyAsInt("Ice.PrintProcessId") > 0)
+ {
+ using(Process p = Process.GetCurrentProcess())
+ {
+ System.Console.WriteLine(p.Id);
+ }
+ _printProcessIdDone = true;
+ }
+ }
- //
- // Start connection monitor if necessary.
- //
- int interval = 0;
- if(_clientACM > 0 && _serverACM > 0)
- {
- if(_clientACM < _serverACM)
- {
- interval = _clientACM;
- }
- else
- {
- interval = _serverACM;
- }
- }
- else if(_clientACM > 0)
- {
- interval = _clientACM;
- }
- else if(_serverACM > 0)
- {
- interval = _serverACM;
- }
- interval = _initData.properties.getPropertyAsIntWithDefault("Ice.MonitorConnections", interval);
- if(interval > 0)
- {
- _connectionMonitor = new ConnectionMonitor(this, interval);
- }
-
- //
- // Thread pool initialization is now lazy initialization in
- // clientThreadPool() and serverThreadPool().
- //
- }
-
- //
- // Only for use by Ice.CommunicatorI
- //
- public bool destroy()
- {
- lock(this)
- {
- //
- // If the _state is not StateActive then the instance is
- // either being destroyed, or has already been destroyed.
- //
- if(_state != StateActive)
- {
- return false;
- }
-
- //
- // We cannot set state to StateDestroyed otherwise instance
- // methods called during the destroy process (such as
- // outgoingConnectionFactory() from
- // ObjectAdapterI::deactivate() will cause an exception.
- //
- _state = StateDestroyInProgress;
- }
-
- if(_objectAdapterFactory != null)
- {
- _objectAdapterFactory.shutdown();
- }
-
- if(_outgoingConnectionFactory != null)
- {
- _outgoingConnectionFactory.destroy();
- }
-
- if(_objectAdapterFactory != null)
- {
- _objectAdapterFactory.destroy();
- }
-
- if(_outgoingConnectionFactory != null)
- {
- _outgoingConnectionFactory.waitUntilFinished();
- }
-
- ThreadPool serverThreadPool = null;
- ThreadPool clientThreadPool = null;
-
- lock(this)
- {
- _objectAdapterFactory = null;
-
- _outgoingConnectionFactory = null;
-
- if(_connectionMonitor != null)
- {
- _connectionMonitor.destroy();
- _connectionMonitor = null;
- }
-
- if(_serverThreadPool != null)
- {
- _serverThreadPool.destroy();
- serverThreadPool = _serverThreadPool;
- _serverThreadPool = null;
- }
-
- if(_clientThreadPool != null)
- {
- _clientThreadPool.destroy();
- clientThreadPool = _clientThreadPool;
- _clientThreadPool = null;
- }
-
- if(_servantFactoryManager != null)
- {
- _servantFactoryManager.destroy();
- _servantFactoryManager = null;
- }
-
- if(_referenceFactory != null)
- {
- _referenceFactory.destroy();
- _referenceFactory = null;
- }
-
- // No destroy function defined.
- // _proxyFactory.destroy();
- _proxyFactory = null;
-
- if(_routerManager != null)
- {
- _routerManager.destroy();
- _routerManager = null;
- }
-
- if(_locatorManager != null)
- {
- _locatorManager.destroy();
- _locatorManager = null;
- }
-
- if(_endpointFactoryManager != null)
- {
- _endpointFactoryManager.destroy();
- _endpointFactoryManager = null;
- }
-
- if(_pluginManager != null)
- {
- _pluginManager.destroy();
- _pluginManager = null;
- }
-
- _state = StateDestroyed;
- }
-
- //
- // Join with the thread pool threads outside the
- // synchronization.
- //
- if(clientThreadPool != null)
- {
- clientThreadPool.joinWithAllThreads();
- }
- if(serverThreadPool != null)
- {
- serverThreadPool.joinWithAllThreads();
- }
+ //
+ // Start connection monitor if necessary.
+ //
+ int interval = 0;
+ if(_clientACM > 0 && _serverACM > 0)
+ {
+ if(_clientACM < _serverACM)
+ {
+ interval = _clientACM;
+ }
+ else
+ {
+ interval = _serverACM;
+ }
+ }
+ else if(_clientACM > 0)
+ {
+ interval = _clientACM;
+ }
+ else if(_serverACM > 0)
+ {
+ interval = _serverACM;
+ }
+ interval = _initData.properties.getPropertyAsIntWithDefault("Ice.MonitorConnections", interval);
+ if(interval > 0)
+ {
+ _connectionMonitor = new ConnectionMonitor(this, interval);
+ }
+
+ //
+ // Thread pool initialization is now lazy initialization in
+ // clientThreadPool() and serverThreadPool().
+ //
+ }
+
+ //
+ // Only for use by Ice.CommunicatorI
+ //
+ public bool destroy()
+ {
+ lock(this)
+ {
+ //
+ // If the _state is not StateActive then the instance is
+ // either being destroyed, or has already been destroyed.
+ //
+ if(_state != StateActive)
+ {
+ return false;
+ }
+
+ //
+ // We cannot set state to StateDestroyed otherwise instance
+ // methods called during the destroy process (such as
+ // outgoingConnectionFactory() from
+ // ObjectAdapterI::deactivate() will cause an exception.
+ //
+ _state = StateDestroyInProgress;
+ }
+
+ if(_objectAdapterFactory != null)
+ {
+ _objectAdapterFactory.shutdown();
+ }
+
+ if(_outgoingConnectionFactory != null)
+ {
+ _outgoingConnectionFactory.destroy();
+ }
+
+ if(_objectAdapterFactory != null)
+ {
+ _objectAdapterFactory.destroy();
+ }
+
+ if(_outgoingConnectionFactory != null)
+ {
+ _outgoingConnectionFactory.waitUntilFinished();
+ }
+
+ ThreadPool serverThreadPool = null;
+ ThreadPool clientThreadPool = null;
+
+ lock(this)
+ {
+ _objectAdapterFactory = null;
+
+ _outgoingConnectionFactory = null;
+
+ if(_connectionMonitor != null)
+ {
+ _connectionMonitor.destroy();
+ _connectionMonitor = null;
+ }
+
+ if(_serverThreadPool != null)
+ {
+ _serverThreadPool.destroy();
+ serverThreadPool = _serverThreadPool;
+ _serverThreadPool = null;
+ }
+
+ if(_clientThreadPool != null)
+ {
+ _clientThreadPool.destroy();
+ clientThreadPool = _clientThreadPool;
+ _clientThreadPool = null;
+ }
+
+ if(_servantFactoryManager != null)
+ {
+ _servantFactoryManager.destroy();
+ _servantFactoryManager = null;
+ }
+
+ if(_referenceFactory != null)
+ {
+ _referenceFactory.destroy();
+ _referenceFactory = null;
+ }
+
+ // No destroy function defined.
+ // _proxyFactory.destroy();
+ _proxyFactory = null;
+
+ if(_routerManager != null)
+ {
+ _routerManager.destroy();
+ _routerManager = null;
+ }
+
+ if(_locatorManager != null)
+ {
+ _locatorManager.destroy();
+ _locatorManager = null;
+ }
+
+ if(_endpointFactoryManager != null)
+ {
+ _endpointFactoryManager.destroy();
+ _endpointFactoryManager = null;
+ }
+
+ if(_pluginManager != null)
+ {
+ _pluginManager.destroy();
+ _pluginManager = null;
+ }
+
+ _state = StateDestroyed;
+ }
+
+ //
+ // Join with the thread pool threads outside the
+ // synchronization.
+ //
+ if(clientThreadPool != null)
+ {
+ clientThreadPool.joinWithAllThreads();
+ }
+ if(serverThreadPool != null)
+ {
+ serverThreadPool.joinWithAllThreads();
+ }
- return true;
- }
-
- private const int StateActive = 0;
- private const int StateDestroyInProgress = 1;
- private const int StateDestroyed = 2;
- private int _state;
- private Ice.InitializationData _initData; // Immutable, not reset by destroy().
- private TraceLevels _traceLevels; // Immutable, not reset by destroy().
- private DefaultsAndOverrides _defaultsAndOverrides; // Immutable, not reset by destroy().
- private int _messageSizeMax; // Immutable, not reset by destroy().
- private int _clientACM; // Immutable, not reset by destroy().
- private int _serverACM; // Immutable, not reset by destroy().
- private Ice.ImplicitContextI _implicitContext; // Immutable
- private RouterManager _routerManager;
- private LocatorManager _locatorManager;
- private ReferenceFactory _referenceFactory;
- private ProxyFactory _proxyFactory;
- private OutgoingConnectionFactory _outgoingConnectionFactory;
- private ConnectionMonitor _connectionMonitor;
- private ObjectFactoryManager _servantFactoryManager;
- private ObjectAdapterFactory _objectAdapterFactory;
- private ThreadPool _clientThreadPool;
- private ThreadPool _serverThreadPool;
- private bool _threadPerConnection;
- private EndpointFactoryManager _endpointFactoryManager;
- private Ice.PluginManager _pluginManager;
+ return true;
+ }
+
+ private const int StateActive = 0;
+ private const int StateDestroyInProgress = 1;
+ private const int StateDestroyed = 2;
+ private int _state;
+ private Ice.InitializationData _initData; // Immutable, not reset by destroy().
+ private TraceLevels _traceLevels; // Immutable, not reset by destroy().
+ private DefaultsAndOverrides _defaultsAndOverrides; // Immutable, not reset by destroy().
+ private int _messageSizeMax; // Immutable, not reset by destroy().
+ private int _clientACM; // Immutable, not reset by destroy().
+ private int _serverACM; // Immutable, not reset by destroy().
+ private Ice.ImplicitContextI _implicitContext; // Immutable
+ private RouterManager _routerManager;
+ private LocatorManager _locatorManager;
+ private ReferenceFactory _referenceFactory;
+ private ProxyFactory _proxyFactory;
+ private OutgoingConnectionFactory _outgoingConnectionFactory;
+ private ConnectionMonitor _connectionMonitor;
+ private ObjectFactoryManager _servantFactoryManager;
+ private ObjectAdapterFactory _objectAdapterFactory;
+ private ThreadPool _clientThreadPool;
+ private ThreadPool _serverThreadPool;
+ private bool _threadPerConnection;
+ private EndpointFactoryManager _endpointFactoryManager;
+ private Ice.PluginManager _pluginManager;
private Ice.Context _defaultContext;
- private static Ice.Context _emptyContext = new Ice.Context();
- private static bool _printProcessIdDone = false;
+ private static Ice.Context _emptyContext = new Ice.Context();
+ private static bool _printProcessIdDone = false;
private static bool _oneOffDone = false;
private static System.Object _staticLock = new System.Object();
generated by cgit v1.2.3 (git 2.46.0) at 2025-08-03 14:00:51 +0000