diff options
Diffstat (limited to 'cs/src/Ice/CommunicatorI.cs')
| -rwxr-xr-x | cs/src/Ice/CommunicatorI.cs | 362 |
1 files changed, 181 insertions, 181 deletions
diff --git a/cs/src/Ice/CommunicatorI.cs b/cs/src/Ice/CommunicatorI.cs index e54fb2463a6..9b9a104df76 100755 --- a/cs/src/Ice/CommunicatorI.cs +++ b/cs/src/Ice/CommunicatorI.cs @@ -9,197 +9,197 @@ namespace Ice { - + sealed class CommunicatorI : LocalObjectImpl, Communicator { - public void destroy() - { - instance_.destroy(); + public void destroy() + { + instance_.destroy(); lock(this) { destroyed_ = true; } - } - - public void shutdown() - { - instance_.objectAdapterFactory().shutdown(); - } - - public void waitForShutdown() - { - instance_.objectAdapterFactory().waitForShutdown(); - } - - public bool isShutdown() - { - return instance_.objectAdapterFactory().isShutdown(); - } - - public Ice.ObjectPrx stringToProxy(string s) - { - return instance_.proxyFactory().stringToProxy(s); - } - - public string proxyToString(Ice.ObjectPrx proxy) - { - return instance_.proxyFactory().proxyToString(proxy); - } - - public Ice.ObjectPrx propertyToProxy(string s) - { - return instance_.proxyFactory().propertyToProxy(s); - } - - public Ice.Identity stringToIdentity(string s) - { - return instance_.stringToIdentity(s); - } - - public string identityToString(Ice.Identity ident) - { - return instance_.identityToString(ident); - } - - public ObjectAdapter createObjectAdapter(string name) - { - return instance_.objectAdapterFactory().createObjectAdapter(name, "", null); - } - - public ObjectAdapter createObjectAdapterWithEndpoints(string name, string endpoints) - { - return instance_.objectAdapterFactory().createObjectAdapter(name, endpoints, null); - } - - public ObjectAdapter createObjectAdapterWithRouter(string name, RouterPrx router) - { - return instance_.objectAdapterFactory().createObjectAdapter(name, "", router); - } - - public void addObjectFactory(ObjectFactory factory, string id) - { - instance_.servantFactoryManager().add(factory, id); - } - - public ObjectFactory findObjectFactory(string id) - { - return instance_.servantFactoryManager().find(id); - } - - public Properties getProperties() - { - return instance_.initializationData().properties; - } - - public Logger getLogger() - { - return instance_.initializationData().logger; - } - - public Stats getStats() - { - return instance_.initializationData().stats; - } - - public RouterPrx getDefaultRouter() - { - return instance_.referenceFactory().getDefaultRouter(); - } - - public void setDefaultRouter(RouterPrx router) - { - instance_.referenceFactory().setDefaultRouter(router); - } - - public LocatorPrx getDefaultLocator() - { - return instance_.referenceFactory().getDefaultLocator(); - } - - public void setDefaultLocator(LocatorPrx locator) - { - instance_.referenceFactory().setDefaultLocator(locator); - } - - public Ice.Context getDefaultContext() - { - return instance_.getDefaultContext(); - } - - public void setDefaultContext(Ice.Context ctx) - { - instance_.setDefaultContext(ctx); - } - - public ImplicitContext getImplicitContext() - { - return instance_.getImplicitContext(); - } - - public PluginManager getPluginManager() - { - return instance_.pluginManager(); - } - - public void flushBatchRequests() - { - instance_.flushBatchRequests(); - } - - internal CommunicatorI(InitializationData initData) - { - instance_ = new IceInternal.Instance(this, initData); - } - + } + + public void shutdown() + { + instance_.objectAdapterFactory().shutdown(); + } + + public void waitForShutdown() + { + instance_.objectAdapterFactory().waitForShutdown(); + } + + public bool isShutdown() + { + return instance_.objectAdapterFactory().isShutdown(); + } + + public Ice.ObjectPrx stringToProxy(string s) + { + return instance_.proxyFactory().stringToProxy(s); + } + + public string proxyToString(Ice.ObjectPrx proxy) + { + return instance_.proxyFactory().proxyToString(proxy); + } + + public Ice.ObjectPrx propertyToProxy(string s) + { + return instance_.proxyFactory().propertyToProxy(s); + } + + public Ice.Identity stringToIdentity(string s) + { + return instance_.stringToIdentity(s); + } + + public string identityToString(Ice.Identity ident) + { + return instance_.identityToString(ident); + } + + public ObjectAdapter createObjectAdapter(string name) + { + return instance_.objectAdapterFactory().createObjectAdapter(name, "", null); + } + + public ObjectAdapter createObjectAdapterWithEndpoints(string name, string endpoints) + { + return instance_.objectAdapterFactory().createObjectAdapter(name, endpoints, null); + } + + public ObjectAdapter createObjectAdapterWithRouter(string name, RouterPrx router) + { + return instance_.objectAdapterFactory().createObjectAdapter(name, "", router); + } + + public void addObjectFactory(ObjectFactory factory, string id) + { + instance_.servantFactoryManager().add(factory, id); + } + + public ObjectFactory findObjectFactory(string id) + { + return instance_.servantFactoryManager().find(id); + } + + public Properties getProperties() + { + return instance_.initializationData().properties; + } + + public Logger getLogger() + { + return instance_.initializationData().logger; + } + + public Stats getStats() + { + return instance_.initializationData().stats; + } + + public RouterPrx getDefaultRouter() + { + return instance_.referenceFactory().getDefaultRouter(); + } + + public void setDefaultRouter(RouterPrx router) + { + instance_.referenceFactory().setDefaultRouter(router); + } + + public LocatorPrx getDefaultLocator() + { + return instance_.referenceFactory().getDefaultLocator(); + } + + public void setDefaultLocator(LocatorPrx locator) + { + instance_.referenceFactory().setDefaultLocator(locator); + } + + public Ice.Context getDefaultContext() + { + return instance_.getDefaultContext(); + } + + public void setDefaultContext(Ice.Context ctx) + { + instance_.setDefaultContext(ctx); + } + + public ImplicitContext getImplicitContext() + { + return instance_.getImplicitContext(); + } + + public PluginManager getPluginManager() + { + return instance_.pluginManager(); + } + + public void flushBatchRequests() + { + instance_.flushBatchRequests(); + } + + internal CommunicatorI(InitializationData initData) + { + instance_ = new IceInternal.Instance(this, initData); + } + #if DEBUG - ~CommunicatorI() - { - lock(this) - { - if(!destroyed_) - { - if(!System.Environment.HasShutdownStarted) - { - instance_.initializationData().logger.warning( - "Ice::Communicator::destroy() has not been called"); - } - else - { - System.Console.Error.WriteLine("Ice::Communicator::destroy() has not been called"); - } - } - } - } + ~CommunicatorI() + { + lock(this) + { + if(!destroyed_) + { + if(!System.Environment.HasShutdownStarted) + { + instance_.initializationData().logger.warning( + "Ice::Communicator::destroy() has not been called"); + } + else + { + System.Console.Error.WriteLine("Ice::Communicator::destroy() has not been called"); + } + } + } + } #endif - // - // Certain initialization tasks need to be completed after the - // constructor. - // - internal void finishSetup(ref string[] args) - { - try - { - instance_.finishSetup(ref args); - } - catch(System.Exception) - { - instance_.destroy(); + // + // Certain initialization tasks need to be completed after the + // constructor. + // + internal void finishSetup(ref string[] args) + { + try + { + instance_.finishSetup(ref args); + } + catch(System.Exception) + { + instance_.destroy(); destroyed_ = true; - throw; - } - } - - // - // For use by Util.getInstance() - // - internal IceInternal.Instance getInstance() - { - return instance_; - } - - private IceInternal.Instance instance_; - private bool destroyed_ = false; + throw; + } + } + + // + // For use by Util.getInstance() + // + internal IceInternal.Instance getInstance() + { + return instance_; + } + + private IceInternal.Instance instance_; + private bool destroyed_ = false; } } |