diff options
Diffstat (limited to 'cs/src/Ice/RouterInfo.cs')
| -rwxr-xr-x | cs/src/Ice/RouterInfo.cs | 338 |
1 files changed, 169 insertions, 169 deletions
diff --git a/cs/src/Ice/RouterInfo.cs b/cs/src/Ice/RouterInfo.cs index 0addf260a22..1ee95536bdc 100755 --- a/cs/src/Ice/RouterInfo.cs +++ b/cs/src/Ice/RouterInfo.cs @@ -16,157 +16,157 @@ namespace IceInternal public sealed class RouterInfo { - internal RouterInfo(Ice.RouterPrx router) - { - _router = router; - - Debug.Assert(_router != null); - } - - public void destroy() - { - lock(this) - { - _clientEndpoints = new EndpointI[0]; - _serverEndpoints = new EndpointI[0]; - _adapter = null; - _identities.Clear(); - } - } - - public override bool Equals(System.Object obj) - { - if(object.ReferenceEquals(this, obj)) - { - return true; - } - - RouterInfo rhs = obj as RouterInfo; - return rhs == null ? false : _router.Equals(rhs._router); - } - - public override int GetHashCode() - { - return _router.GetHashCode(); - } - - public Ice.RouterPrx getRouter() - { - // - // No mutex lock necessary, _router is immutable. - // - return _router; - } - - public EndpointI[] getClientEndpoints() - { - lock(this) - { - if(_clientEndpoints == null) // Lazy initialization. - { - Ice.ObjectPrx clientProxy = _router.getClientProxy(); - if(clientProxy == null) - { - // - // Use router endpoints if getClientProxy returns nil. - // - _clientEndpoints = ((Ice.ObjectPrxHelperBase)_router).reference__().getEndpoints(); - } - else - { - clientProxy = clientProxy.ice_router(null); // The client proxy cannot be routed. - - // - // In order to avoid creating a new connection to - // the router, we must use the same timeout as the - // already existing connection. - // - try - { - clientProxy = clientProxy.ice_timeout(_router.ice_getConnection().timeout()); - } - catch(Ice.CollocationOptimizationException) - { - // Ignore - collocated router. - } - - _clientEndpoints = ((Ice.ObjectPrxHelperBase)clientProxy).reference__().getEndpoints(); - } - } - - return _clientEndpoints; - } - } - - public EndpointI[] getServerEndpoints() - { - if(_serverEndpoints == null) // Lazy initialization. - { - Ice.ObjectPrx serverProxy = _router.getServerProxy(); - if(serverProxy == null) - { - throw new Ice.NoEndpointException(); - } - - serverProxy = serverProxy.ice_router(null); // The server proxy cannot be routed. - _serverEndpoints = ((Ice.ObjectPrxHelperBase)serverProxy).reference__().getEndpoints(); - } - - return _serverEndpoints; - } - - public void addProxy(Ice.ObjectPrx proxy) - { - Debug.Assert(proxy != null); - - lock(this) - { - if(!_identities.Contains(proxy.ice_getIdentity())) - { - // - // Only add the proxy to the router if it's not already in our local map. - // - Ice.ObjectPrx[] proxies = new Ice.ObjectPrx[1]; - proxies[0] = proxy; - Ice.ObjectPrx[] evictedProxies = _router.addProxies(proxies); - - // - // If we successfully added the proxy to the router, we add it to our local map. - // - _identities.Add(proxy.ice_getIdentity()); - - // - // We also must remove whatever proxies the router evicted. - // - for(int i = 0; i < evictedProxies.Length; ++i) - { - _identities.Remove(evictedProxies[i].ice_getIdentity()); - } - } - } - } - - public void setAdapter(Ice.ObjectAdapter adapter) - { - lock(this) - { - _adapter = adapter; - } - } - - public Ice.ObjectAdapter getAdapter() - { - lock(this) - { - return _adapter; - } - } - - private readonly Ice.RouterPrx _router; - private EndpointI[] _clientEndpoints; - private EndpointI[] _serverEndpoints; - private IceUtil.Set _identities = new IceUtil.Set(); - private Ice.ObjectAdapter _adapter; + internal RouterInfo(Ice.RouterPrx router) + { + _router = router; + + Debug.Assert(_router != null); + } + + public void destroy() + { + lock(this) + { + _clientEndpoints = new EndpointI[0]; + _serverEndpoints = new EndpointI[0]; + _adapter = null; + _identities.Clear(); + } + } + + public override bool Equals(System.Object obj) + { + if(object.ReferenceEquals(this, obj)) + { + return true; + } + + RouterInfo rhs = obj as RouterInfo; + return rhs == null ? false : _router.Equals(rhs._router); + } + + public override int GetHashCode() + { + return _router.GetHashCode(); + } + + public Ice.RouterPrx getRouter() + { + // + // No mutex lock necessary, _router is immutable. + // + return _router; + } + + public EndpointI[] getClientEndpoints() + { + lock(this) + { + if(_clientEndpoints == null) // Lazy initialization. + { + Ice.ObjectPrx clientProxy = _router.getClientProxy(); + if(clientProxy == null) + { + // + // Use router endpoints if getClientProxy returns nil. + // + _clientEndpoints = ((Ice.ObjectPrxHelperBase)_router).reference__().getEndpoints(); + } + else + { + clientProxy = clientProxy.ice_router(null); // The client proxy cannot be routed. + + // + // In order to avoid creating a new connection to + // the router, we must use the same timeout as the + // already existing connection. + // + try + { + clientProxy = clientProxy.ice_timeout(_router.ice_getConnection().timeout()); + } + catch(Ice.CollocationOptimizationException) + { + // Ignore - collocated router. + } + + _clientEndpoints = ((Ice.ObjectPrxHelperBase)clientProxy).reference__().getEndpoints(); + } + } + + return _clientEndpoints; + } + } + + public EndpointI[] getServerEndpoints() + { + if(_serverEndpoints == null) // Lazy initialization. + { + Ice.ObjectPrx serverProxy = _router.getServerProxy(); + if(serverProxy == null) + { + throw new Ice.NoEndpointException(); + } + + serverProxy = serverProxy.ice_router(null); // The server proxy cannot be routed. + _serverEndpoints = ((Ice.ObjectPrxHelperBase)serverProxy).reference__().getEndpoints(); + } + + return _serverEndpoints; + } + + public void addProxy(Ice.ObjectPrx proxy) + { + Debug.Assert(proxy != null); + + lock(this) + { + if(!_identities.Contains(proxy.ice_getIdentity())) + { + // + // Only add the proxy to the router if it's not already in our local map. + // + Ice.ObjectPrx[] proxies = new Ice.ObjectPrx[1]; + proxies[0] = proxy; + Ice.ObjectPrx[] evictedProxies = _router.addProxies(proxies); + + // + // If we successfully added the proxy to the router, we add it to our local map. + // + _identities.Add(proxy.ice_getIdentity()); + + // + // We also must remove whatever proxies the router evicted. + // + for(int i = 0; i < evictedProxies.Length; ++i) + { + _identities.Remove(evictedProxies[i].ice_getIdentity()); + } + } + } + } + + public void setAdapter(Ice.ObjectAdapter adapter) + { + lock(this) + { + _adapter = adapter; + } + } + + public Ice.ObjectAdapter getAdapter() + { + lock(this) + { + return _adapter; + } + } + + private readonly Ice.RouterPrx _router; + private EndpointI[] _clientEndpoints; + private EndpointI[] _serverEndpoints; + private IceUtil.Set _identities = new IceUtil.Set(); + private Ice.ObjectAdapter _adapter; } public sealed class RouterManager @@ -175,7 +175,7 @@ namespace IceInternal { _table = new Hashtable(); } - + internal void destroy() { lock(this) @@ -187,7 +187,7 @@ namespace IceInternal _table.Clear(); } } - + // // Returns router info for a given router. Automatically creates // the router info if it doesn't exist yet. @@ -198,9 +198,9 @@ namespace IceInternal { return null; } - + Ice.RouterPrx router = Ice.RouterPrxHelper.uncheckedCast(rtr.ice_router(null)); // The router cannot be routed. - + lock(this) { RouterInfo info = (RouterInfo)_table[router]; @@ -209,7 +209,7 @@ namespace IceInternal info = new RouterInfo(router); _table[router] = info; } - + return info; } } @@ -220,22 +220,22 @@ namespace IceInternal // public RouterInfo erase(Ice.RouterPrx rtr) { - RouterInfo info = null; + RouterInfo info = null; if(rtr == null) { - Ice.RouterPrx router = Ice.RouterPrxHelper.uncheckedCast(rtr.ice_router(null)); // The router cannot be routed. - lock(this) - { - info = (RouterInfo)_table[router]; - if(info != null) - { - _table.Remove(router); - } - } - } - return info; + Ice.RouterPrx router = Ice.RouterPrxHelper.uncheckedCast(rtr.ice_router(null)); // The router cannot be routed. + lock(this) + { + info = (RouterInfo)_table[router]; + if(info != null) + { + _table.Remove(router); + } + } + } + return info; } - + private Hashtable _table; } |