summaryrefslogtreecommitdiff
path: root/js/src/Ice/Instance.js
diff options
context:
space:
mode:
Diffstat (limited to 'js/src/Ice/Instance.js')
-rw-r--r--js/src/Ice/Instance.js892
1 files changed, 446 insertions, 446 deletions
diff --git a/js/src/Ice/Instance.js b/js/src/Ice/Instance.js
index 0f7b1a8ff27..a9ac546729b 100644
--- a/js/src/Ice/Instance.js
+++ b/js/src/Ice/Instance.js
@@ -7,533 +7,533 @@
//
// **********************************************************************
-(function(global){
- require("Ice/Class");
- require("Ice/AsyncResultBase");
- require("Ice/Debug");
- require("Ice/DefaultsAndOverrides");
- require("Ice/EndpointFactoryManager");
- require("Ice/HashMap");
- require("Ice/ImplicitContextI");
- require("Ice/IdentityUtil");
- require("Ice/LocatorManager");
- require("Ice/Logger");
- require("Ice/ObjectAdapterFactory");
- require("Ice/ObjectFactoryManager");
- require("Ice/OutgoingConnectionFactory");
- require("Ice/Promise");
- require("Ice/Properties");
- require("Ice/ProxyFactory");
- require("Ice/RetryQueue");
- require("Ice/RouterManager");
- require("Ice/Timer");
- require("Ice/TraceLevels");
- require("Ice/Reference");
- require("Ice/LocalException");
- require("Ice/Exception");
- require("Ice/ProcessLogger");
- require("Ice/ACM");
+var Ice = require("../Ice/ModuleRegistry").Ice;
+Ice.__M.require(module, "Ice",
+ [
+ "../Ice/Class",
+ "../Ice/AsyncResultBase",
+ "../Ice/Debug",
+ "../Ice/DefaultsAndOverrides",
+ "../Ice/EndpointFactoryManager",
+ "../Ice/HashMap",
+ "../Ice/ImplicitContextI",
+ "../Ice/IdentityUtil",
+ "../Ice/LocatorManager",
+ "../Ice/Logger",
+ "../Ice/ObjectAdapterFactory",
+ "../Ice/ObjectFactoryManager",
+ "../Ice/OutgoingConnectionFactory",
+ "../Ice/Promise",
+ "../Ice/Properties",
+ "../Ice/ProxyFactory",
+ "../Ice/RetryQueue",
+ "../Ice/RouterManager",
+ "../Ice/Timer",
+ "../Ice/TraceLevels",
+ "../Ice/Reference",
+ "../Ice/LocalException",
+ "../Ice/Exception",
+ "../Ice/ProcessLogger",
+ "../Ice/ACM"
+ ]);
- //
- // We don't load the endpoint factories here, instead the Ice.js
- // file for NodeJS loads the TcpEndpointFactory and the Ice.js
- // file for the web browser includes the IceWS endpoint factory.
- //
- //require("Ice/TcpEndpointFactory");
- //require("Ice/WSEndpointFactory");
-
- var Ice = global.Ice || {};
-
- var AsyncResultBase = Ice.AsyncResultBase;
- var Debug = Ice.Debug;
- var DefaultsAndOverrides = Ice.DefaultsAndOverrides;
- var EndpointFactoryManager = Ice.EndpointFactoryManager;
- var HashMap = Ice.HashMap;
- var ImplicitContextI = Ice.ImplicitContextI;
- var LocatorManager = Ice.LocatorManager;
- var Logger = Ice.Logger;
- var ObjectAdapterFactory = Ice.ObjectAdapterFactory;
- var ObjectFactoryManager = Ice.ObjectFactoryManager;
- var OutgoingConnectionFactory = Ice.OutgoingConnectionFactory;
- var Promise = Ice.Promise;
- var Properties = Ice.Properties;
- var ProxyFactory = Ice.ProxyFactory;
- var RetryQueue = Ice.RetryQueue;
- var RouterManager = Ice.RouterManager;
- var Timer = Ice.Timer;
- var TraceLevels = Ice.TraceLevels;
- var ReferenceFactory = Ice.ReferenceFactory;
- var ACMConfig = Ice.ACMConfig;
-
- var StateActive = 0;
- var StateDestroyInProgress = 1;
- var StateDestroyed = 2;
+//
+// We don't load the endpoint factories here, instead the Ice.js
+// file for NodeJS loads the TcpEndpointFactory and the Ice.js
+// file for the web browser includes the IceWS endpoint factory.
+//
+//require("Ice/TcpEndpointFactory");
+//require("Ice/WSEndpointFactory");
+
+var AsyncResultBase = Ice.AsyncResultBase;
+var Debug = Ice.Debug;
+var DefaultsAndOverrides = Ice.DefaultsAndOverrides;
+var EndpointFactoryManager = Ice.EndpointFactoryManager;
+var HashMap = Ice.HashMap;
+var ImplicitContextI = Ice.ImplicitContextI;
+var LocatorManager = Ice.LocatorManager;
+var Logger = Ice.Logger;
+var ObjectAdapterFactory = Ice.ObjectAdapterFactory;
+var ObjectFactoryManager = Ice.ObjectFactoryManager;
+var OutgoingConnectionFactory = Ice.OutgoingConnectionFactory;
+var Promise = Ice.Promise;
+var Properties = Ice.Properties;
+var ProxyFactory = Ice.ProxyFactory;
+var RetryQueue = Ice.RetryQueue;
+var RouterManager = Ice.RouterManager;
+var Timer = Ice.Timer;
+var TraceLevels = Ice.TraceLevels;
+var ReferenceFactory = Ice.ReferenceFactory;
+var ACMConfig = Ice.ACMConfig;
+
+var StateActive = 0;
+var StateDestroyInProgress = 1;
+var StateDestroyed = 2;
- //
- // Instance - only for use by Communicator
- //
- var Instance = Ice.Class({
- __init__: function(initData)
+//
+// Instance - only for use by Communicator
+//
+var Instance = Ice.Class({
+ __init__: function(initData)
+ {
+ this._state = StateActive;
+ this._initData = initData;
+
+ this._traceLevels = null;
+ this._defaultsAndOverrides = null;
+ this._messageSizeMax = null;
+ this._clientACM = null;
+ this._implicitContext = null;
+ this._routerManager = null;
+ this._locatorManager = null;
+ this._referenceFactory = null;
+ this._proxyFactory = null;
+ this._outgoingConnectionFactory = null;
+ this._servantFactoryManager = null;
+ this._objectAdapterFactory = null;
+ this._protocolSupport = null;
+ this._retryQueue = null;
+ this._endpointHostResolver = null;
+ this._endpointFactoryManager = null;
+ },
+ initializationData: function()
+ {
+ //
+ // No check for destruction. It must be possible to access the
+ // initialization data after destruction.
+ //
+ // This value is immutable.
+ //
+ return this._initData;
+ },
+ traceLevels: function()
+ {
+ // This value is immutable.
+ Debug.assert(this._traceLevels !== null);
+ return this._traceLevels;
+ },
+ defaultsAndOverrides: function()
+ {
+ // This value is immutable.
+ Debug.assert(this._defaultsAndOverrides !== null);
+ return this._defaultsAndOverrides;
+ },
+ routerManager: function()
+ {
+ if(this._state === StateDestroyed)
{
- this._state = StateActive;
- this._initData = initData;
-
- this._traceLevels = null;
- this._defaultsAndOverrides = null;
- this._messageSizeMax = null;
- this._clientACM = null;
- this._implicitContext = null;
- this._routerManager = null;
- this._locatorManager = null;
- this._referenceFactory = null;
- this._proxyFactory = null;
- this._outgoingConnectionFactory = null;
- this._servantFactoryManager = null;
- this._objectAdapterFactory = null;
- this._protocolSupport = null;
- this._retryQueue = null;
- this._endpointHostResolver = null;
- this._endpointFactoryManager = null;
- },
- initializationData: function()
+ throw new Ice.CommunicatorDestroyedException();
+ }
+
+ Debug.assert(this._routerManager !== null);
+ return this._routerManager;
+ },
+ locatorManager: function()
+ {
+ if(this._state === StateDestroyed)
{
- //
- // No check for destruction. It must be possible to access the
- // initialization data after destruction.
- //
- // This value is immutable.
- //
- return this._initData;
- },
- traceLevels: function()
+ throw new Ice.CommunicatorDestroyedException();
+ }
+
+ Debug.assert(this._locatorManager !== null);
+ return this._locatorManager;
+ },
+ referenceFactory: function()
+ {
+ if(this._state === StateDestroyed)
{
- // This value is immutable.
- Debug.assert(this._traceLevels !== null);
- return this._traceLevels;
- },
- defaultsAndOverrides: function()
+ throw new Ice.CommunicatorDestroyedException();
+ }
+
+ Debug.assert(this._referenceFactory !== null);
+ return this._referenceFactory;
+ },
+ proxyFactory: function()
+ {
+ if(this._state === StateDestroyed)
{
- // This value is immutable.
- Debug.assert(this._defaultsAndOverrides !== null);
- return this._defaultsAndOverrides;
- },
- routerManager: function()
+ throw new Ice.CommunicatorDestroyedException();
+ }
+
+ Debug.assert(this._proxyFactory !== null);
+ return this._proxyFactory;
+ },
+ outgoingConnectionFactory: function()
+ {
+ if(this._state === StateDestroyed)
{
- if(this._state === StateDestroyed)
- {
- throw new Ice.CommunicatorDestroyedException();
- }
-
- Debug.assert(this._routerManager !== null);
- return this._routerManager;
- },
- locatorManager: function()
+ throw new Ice.CommunicatorDestroyedException();
+ }
+
+ Debug.assert(this._outgoingConnectionFactory !== null);
+ return this._outgoingConnectionFactory;
+ },
+ preferIPv6: function()
+ {
+ return this._preferIPv6;
+ },
+ servantFactoryManager: function()
+ {
+ if(this._state === StateDestroyed)
{
- if(this._state === StateDestroyed)
- {
- throw new Ice.CommunicatorDestroyedException();
- }
-
- Debug.assert(this._locatorManager !== null);
- return this._locatorManager;
- },
- referenceFactory: function()
+ throw new Ice.CommunicatorDestroyedException();
+ }
+
+ Debug.assert(this._servantFactoryManager !== null);
+ return this._servantFactoryManager;
+ },
+ objectAdapterFactory: function()
+ {
+ if(this._state === StateDestroyed)
{
- if(this._state === StateDestroyed)
- {
- throw new Ice.CommunicatorDestroyedException();
- }
-
- Debug.assert(this._referenceFactory !== null);
- return this._referenceFactory;
- },
- proxyFactory: function()
+ throw new Ice.CommunicatorDestroyedException();
+ }
+
+ Debug.assert(this._objectAdapterFactory !== null);
+ return this._objectAdapterFactory;
+ },
+ protocolSupport: function()
+ {
+ if(this._state == StateDestroyed)
{
- if(this._state === StateDestroyed)
- {
- throw new Ice.CommunicatorDestroyedException();
- }
-
- Debug.assert(this._proxyFactory !== null);
- return this._proxyFactory;
- },
- outgoingConnectionFactory: function()
+ throw new Ice.CommunicatorDestroyedException();
+ }
+
+ return this._protocolSupport;
+ },
+ retryQueue: function()
+ {
+ if(this._state === StateDestroyed)
{
- if(this._state === StateDestroyed)
- {
- throw new Ice.CommunicatorDestroyedException();
- }
-
- Debug.assert(this._outgoingConnectionFactory !== null);
- return this._outgoingConnectionFactory;
- },
- preferIPv6: function()
+ throw new Ice.CommunicatorDestroyedException();
+ }
+
+ Debug.assert(this._retryQueue !== null);
+ return this._retryQueue;
+ },
+ timer: function()
+ {
+ if(this._state === StateDestroyed)
{
- return this._preferIPv6;
- },
- servantFactoryManager: function()
+ throw new Ice.CommunicatorDestroyedException();
+ }
+
+ Debug.assert(this._timer !== null);
+ return this._timer;
+ },
+ endpointFactoryManager: function()
+ {
+ if(this._state === StateDestroyed)
{
- if(this._state === StateDestroyed)
- {
- throw new Ice.CommunicatorDestroyedException();
- }
-
- Debug.assert(this._servantFactoryManager !== null);
- return this._servantFactoryManager;
- },
- objectAdapterFactory: function()
+ throw new Ice.CommunicatorDestroyedException();
+ }
+
+ Debug.assert(this._endpointFactoryManager !== null);
+ return this._endpointFactoryManager;
+ },
+ messageSizeMax: function()
+ {
+ // This value is immutable.
+ return this._messageSizeMax;
+ },
+ clientACM: function()
+ {
+ // This value is immutable.
+ return this._clientACM;
+ },
+ getImplicitContext: function()
+ {
+ return this._implicitContext;
+ },
+ stringToIdentity: function(s)
+ {
+ return Ice.stringToIdentity(s);
+ },
+ identityToString: function(ident)
+ {
+ return Ice.identityToString(ident);
+ },
+
+ setDefaultLocator: function(locator)
+ {
+ if(this._state == StateDestroyed)
{
- if(this._state === StateDestroyed)
- {
- throw new Ice.CommunicatorDestroyedException();
- }
-
- Debug.assert(this._objectAdapterFactory !== null);
- return this._objectAdapterFactory;
- },
- protocolSupport: function()
+ throw new Ice.CommunicatorDestroyedException();
+ }
+
+ this._referenceFactory = this._referenceFactory.setDefaultLocator(locator);
+ },
+ setDefaultRouter: function(router)
+ {
+ if(this._state == StateDestroyed)
{
- if(this._state == StateDestroyed)
- {
- throw new Ice.CommunicatorDestroyedException();
- }
+ throw new Ice.CommunicatorDestroyedException();
+ }
+
+ this._referenceFactory = this._referenceFactory.setDefaultRouter(router);
+ },
+ setLogger: function(logger)
+ {
+ this._initData.logger = logger;
+ },
+ finishSetup: function(communicator, promise)
+ {
+ //
+ // If promise == null, it means the caller is requesting a synchronous setup.
+ // Otherwise, we resolve the promise after all initialization is complete.
+ //
- return this._protocolSupport;
- },
- retryQueue: function()
+ try
{
- if(this._state === StateDestroyed)
- {
- throw new Ice.CommunicatorDestroyedException();
- }
+ this._timer = new Timer();
- Debug.assert(this._retryQueue !== null);
- return this._retryQueue;
- },
- timer: function()
- {
- if(this._state === StateDestroyed)
+ if(this._initData.properties === null)
{
- throw new Ice.CommunicatorDestroyedException();
+ this._initData.properties = Properties.createProperties();
}
- Debug.assert(this._timer !== null);
- return this._timer;
- },
- endpointFactoryManager: function()
- {
- if(this._state === StateDestroyed)
+ if(this._initData.logger === null)
{
- throw new Ice.CommunicatorDestroyedException();
+ this._initData.logger = Ice.getProcessLogger();
}
- Debug.assert(this._endpointFactoryManager !== null);
- return this._endpointFactoryManager;
- },
- messageSizeMax: function()
- {
- // This value is immutable.
- return this._messageSizeMax;
- },
- clientACM: function()
- {
- // This value is immutable.
- return this._clientACM;
- },
- getImplicitContext: function()
- {
- return this._implicitContext;
- },
- stringToIdentity: function(s)
- {
- return Ice.stringToIdentity(s);
- },
- identityToString: function(ident)
- {
- return Ice.identityToString(ident);
- },
+ this._traceLevels = new TraceLevels(this._initData.properties);
- setDefaultLocator: function(locator)
- {
- if(this._state == StateDestroyed)
+ this._defaultsAndOverrides = new DefaultsAndOverrides(this._initData.properties, this._initData.logger);
+
+ var defMessageSizeMax = 1024;
+ var num = this._initData.properties.getPropertyAsIntWithDefault("Ice.MessageSizeMax", defMessageSizeMax);
+ if(num < 1)
{
- throw new Ice.CommunicatorDestroyedException();
+ this._messageSizeMax = defMessageSizeMax * 1024; // Ignore non-sensical values.
}
-
- this._referenceFactory = this._referenceFactory.setDefaultLocator(locator);
- },
- setDefaultRouter: function(router)
- {
- if(this._state == StateDestroyed)
+ else if(num > 0x7fffffff / 1024)
{
- throw new Ice.CommunicatorDestroyedException();
+ this._messageSizeMax = 0x7fffffff;
+ }
+ else
+ {
+ this._messageSizeMax = num * 1024; // Property is in kilobytes, _messageSizeMax in bytes
}
- this._referenceFactory = this._referenceFactory.setDefaultRouter(router);
- },
- setLogger: function(logger)
- {
- this._initData.logger = logger;
- },
- finishSetup: function(communicator, promise)
- {
- //
- // If promise == null, it means the caller is requesting a synchronous setup.
- // Otherwise, we resolve the promise after all initialization is complete.
- //
+ this._clientACM = new ACMConfig(this._initData.properties, this._initData.logger, "Ice.ACM.Client",
+ new ACMConfig(this._initData.properties, this._initData.logger,
+ "Ice.ACM", new ACMConfig()));
- try
- {
- this._timer = new Timer();
+ this._implicitContext =
+ ImplicitContextI.create(this._initData.properties.getProperty("Ice.ImplicitContext"));
- if(this._initData.properties === null)
- {
- this._initData.properties = Properties.createProperties();
- }
+ this._routerManager = new RouterManager();
- if(this._initData.logger === null)
- {
- this._initData.logger = Ice.getProcessLogger();
- }
+ this._locatorManager = new LocatorManager(this._initData.properties);
- this._traceLevels = new TraceLevels(this._initData.properties);
+ this._referenceFactory = new ReferenceFactory(this, communicator);
- this._defaultsAndOverrides = new DefaultsAndOverrides(this._initData.properties, this._initData.logger);
+ this._proxyFactory = new ProxyFactory(this);
- var defMessageSizeMax = 1024;
- var num = this._initData.properties.getPropertyAsIntWithDefault("Ice.MessageSizeMax", defMessageSizeMax);
- if(num < 1)
- {
- this._messageSizeMax = defMessageSizeMax * 1024; // Ignore non-sensical values.
- }
- else if(num > 0x7fffffff / 1024)
- {
- this._messageSizeMax = 0x7fffffff;
- }
- else
- {
- this._messageSizeMax = num * 1024; // Property is in kilobytes, _messageSizeMax in bytes
- }
+ this._endpointFactoryManager = new EndpointFactoryManager(this);
- this._clientACM = new ACMConfig(this._initData.properties, this._initData.logger, "Ice.ACM.Client",
- new ACMConfig(this._initData.properties, this._initData.logger,
- "Ice.ACM", new ACMConfig()));
+ if(typeof(Ice.TcpEndpointFactory) !== "undefined")
+ {
+ this._endpointFactoryManager.add(new Ice.TcpEndpointFactory(this));
+ }
- this._implicitContext =
- ImplicitContextI.create(this._initData.properties.getProperty("Ice.ImplicitContext"));
+ if(typeof(Ice.WSEndpointFactory) !== "undefined")
+ {
+ this._endpointFactoryManager.add(new Ice.WSEndpointFactory(this, false));
+ this._endpointFactoryManager.add(new Ice.WSEndpointFactory(this, true));
+ }
- this._routerManager = new RouterManager();
+ this._outgoingConnectionFactory = new OutgoingConnectionFactory(communicator, this);
+ this._servantFactoryManager = new ObjectFactoryManager();
- this._locatorManager = new LocatorManager(this._initData.properties);
+ this._objectAdapterFactory = new ObjectAdapterFactory(this, communicator);
- this._referenceFactory = new ReferenceFactory(this, communicator);
+ this._retryQueue = new RetryQueue(this);
- this._proxyFactory = new ProxyFactory(this);
+ //
+ // 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.
+ //
+ var router = Ice.RouterPrx.uncheckedCast(this._proxyFactory.propertyToProxy("Ice.Default.Router"));
+ if(router !== null)
+ {
+ this._referenceFactory = this._referenceFactory.setDefaultRouter(router);
+ }
- this._endpointFactoryManager = new EndpointFactoryManager(this);
+ var loc = Ice.LocatorPrx.uncheckedCast(this._proxyFactory.propertyToProxy("Ice.Default.Locator"));
+ if(loc !== null)
+ {
+ this._referenceFactory = this._referenceFactory.setDefaultLocator(loc);
+ }
- if(typeof(Ice.TcpEndpointFactory) !== "undefined")
+ if(promise !== null)
+ {
+ promise.succeed(communicator);
+ }
+ }
+ catch(ex)
+ {
+ if(promise !== null)
+ {
+ if(ex instanceof Ice.LocalException)
{
- this._endpointFactoryManager.add(new Ice.TcpEndpointFactory(this));
+ this.destroy().finally(function()
+ {
+ promise.fail(ex);
+ });
}
-
- if(typeof(Ice.WSEndpointFactory) !== "undefined")
+ else
{
- this._endpointFactoryManager.add(new Ice.WSEndpointFactory(this, false));
- this._endpointFactoryManager.add(new Ice.WSEndpointFactory(this, true));
+ promise.fail(ex);
}
+ }
+ else
+ {
+ if(ex instanceof Ice.LocalException)
+ {
+ this.destroy();
+ }
+ throw ex;
+ }
+ }
+ },
+ //
+ // Only for use by Ice.CommunicatorI
+ //
+ destroy: function()
+ {
+ var promise = new AsyncResultBase(null, "destroy", null, this, null);
- this._outgoingConnectionFactory = new OutgoingConnectionFactory(communicator, this);
- this._servantFactoryManager = new ObjectFactoryManager();
-
- this._objectAdapterFactory = new ObjectAdapterFactory(this, communicator);
+ //
+ // If the _state is not StateActive then the instance is
+ // either being destroyed, or has already been destroyed.
+ //
+ if(this._state != StateActive)
+ {
+ promise.succeed(promise);
+ return promise;
+ }
- this._retryQueue = new RetryQueue(this);
+ //
+ // We cannot set state to StateDestroyed otherwise instance
+ // methods called during the destroy process (such as
+ // outgoingConnectionFactory() from
+ // ObjectAdapterI::deactivate() will cause an exception.
+ //
+ this._state = StateDestroyInProgress;
- //
- // 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.
- //
- var router = Ice.RouterPrx.uncheckedCast(this._proxyFactory.propertyToProxy("Ice.Default.Router"));
- if(router !== null)
+ var self = this;
+ Ice.Promise.try(
+ function()
+ {
+ if(self._objectAdapterFactory)
{
- this._referenceFactory = this._referenceFactory.setDefaultRouter(router);
+ return self._objectAdapterFactory.shutdown();
}
-
- var loc = Ice.LocatorPrx.uncheckedCast(this._proxyFactory.propertyToProxy("Ice.Default.Locator"));
- if(loc !== null)
+ }
+ ).then(
+ function()
+ {
+ if(self._outgoingConnectionFactory !== null)
{
- this._referenceFactory = this._referenceFactory.setDefaultLocator(loc);
+ self._outgoingConnectionFactory.destroy();
}
- if(promise !== null)
+ if(self._objectAdapterFactory !== null)
{
- promise.succeed(communicator);
+ return self._objectAdapterFactory.destroy();
}
}
- catch(ex)
+ ).then(
+ function()
{
- if(promise !== null)
+ if(self._outgoingConnectionFactory !== null)
{
- if(ex instanceof Ice.LocalException)
- {
- this.destroy().finally(function()
- {
- promise.fail(ex);
- });
- }
- else
- {
- promise.fail(ex);
- }
- }
- else
- {
- if(ex instanceof Ice.LocalException)
- {
- this.destroy();
- }
- throw ex;
+ return self._outgoingConnectionFactory.waitUntilFinished();
}
}
- },
- //
- // Only for use by Ice.CommunicatorI
- //
- destroy: function()
- {
- var promise = new AsyncResultBase(null, "destroy", null, this, null);
-
- //
- // If the _state is not StateActive then the instance is
- // either being destroyed, or has already been destroyed.
- //
- if(this._state != StateActive)
+ ).then(
+ function()
{
- promise.succeed(promise);
- return promise;
- }
+ if(self._retryQueue)
+ {
+ self._retryQueue.destroy();
+ }
- //
- // We cannot set state to StateDestroyed otherwise instance
- // methods called during the destroy process (such as
- // outgoingConnectionFactory() from
- // ObjectAdapterI::deactivate() will cause an exception.
- //
- this._state = StateDestroyInProgress;
+ self._objectAdapterFactory = null;
+ self._outgoingConnectionFactory = null;
+ self._retryQueue = null;
- var self = this;
- Ice.Promise.try(
- function()
+ if(self._timer)
{
- if(self._objectAdapterFactory)
- {
- return self._objectAdapterFactory.shutdown();
- }
+ self._timer.destroy();
+ self._timer = null;
}
- ).then(
- function()
- {
- if(self._outgoingConnectionFactory !== null)
- {
- self._outgoingConnectionFactory.destroy();
- }
- if(self._objectAdapterFactory !== null)
- {
- return self._objectAdapterFactory.destroy();
- }
- }
- ).then(
- function()
+ if(self._servantFactoryManager)
{
- if(self._outgoingConnectionFactory !== null)
- {
- return self._outgoingConnectionFactory.waitUntilFinished();
- }
+ self._servantFactoryManager.destroy();
+ self._servantFactoryManager = null;
}
- ).then(
- function()
- {
- if(self._retryQueue)
- {
- self._retryQueue.destroy();
- }
-
- self._objectAdapterFactory = null;
- self._outgoingConnectionFactory = null;
- self._retryQueue = null;
-
- if(self._timer)
- {
- self._timer.destroy();
- self._timer = null;
- }
-
- if(self._servantFactoryManager)
- {
- self._servantFactoryManager.destroy();
- self._servantFactoryManager = null;
- }
- if(self._referenceFactory)
- {
- //self._referenceFactory.destroy(); // No destroy function defined.
- self._referenceFactory = null;
- }
+ if(self._referenceFactory)
+ {
+ //self._referenceFactory.destroy(); // No destroy function defined.
+ self._referenceFactory = null;
+ }
- // self._proxyFactory.destroy(); // No destroy function defined.
- self._proxyFactory = null;
+ // self._proxyFactory.destroy(); // No destroy function defined.
+ self._proxyFactory = null;
- if(self._routerManager)
- {
- self._routerManager.destroy();
- self._routerManager = null;
- }
+ if(self._routerManager)
+ {
+ self._routerManager.destroy();
+ self._routerManager = null;
+ }
- if(self._locatorManager)
- {
- self._locatorManager.destroy();
- self._locatorManager = null;
- }
+ if(self._locatorManager)
+ {
+ self._locatorManager.destroy();
+ self._locatorManager = null;
+ }
- if(self._endpointFactoryManager)
- {
- self._endpointFactoryManager.destroy();
- self._endpointFactoryManager = null;
- }
+ if(self._endpointFactoryManager)
+ {
+ self._endpointFactoryManager.destroy();
+ self._endpointFactoryManager = null;
+ }
- self._state = StateDestroyed;
+ self._state = StateDestroyed;
- if(self._initData.properties.getPropertyAsInt("Ice.Warn.UnusedProperties") > 0)
+ if(self._initData.properties.getPropertyAsInt("Ice.Warn.UnusedProperties") > 0)
+ {
+ var unusedProperties = self._initData.properties.getUnusedProperties();
+ if(unusedProperties.length > 0)
{
- var unusedProperties = self._initData.properties.getUnusedProperties();
- if(unusedProperties.length > 0)
+ var message = [];
+ message.push("The following properties were set but never read:");
+ for(var i = 0; i < unusedProperties.length; ++i)
{
- var message = [];
- message.push("The following properties were set but never read:");
- for(var i = 0; i < unusedProperties.length; ++i)
- {
- message.push("\n ");
- message.push(unusedProperties[i]);
- }
- self._initData.logger.warning(message.join(""));
+ message.push("\n ");
+ message.push(unusedProperties[i]);
}
+ self._initData.logger.warning(message.join(""));
}
-
- promise.succeed(promise);
}
- ).exception(
- function(ex)
- {
- promise.fail(ex);
- }
- );
- return promise;
- },
- });
- Ice.Instance = Instance;
- global.Ice = Ice;
-}(typeof (global) === "undefined" ? window : global));
+ promise.succeed(promise);
+ }
+ ).exception(
+ function(ex)
+ {
+ promise.fail(ex);
+ }
+ );
+ return promise;
+ },
+});
+
+Ice.Instance = Instance;
+module.exports.Ice = Ice;
generated by cgit v1.2.3 (git 2.46.0) at 2025-08-03 23:10:31 +0000