diff options
author | Bernard Normier <bernard@zeroc.com> | 2007-02-01 17:09:49 +0000 |
---|---|---|
committer | Bernard Normier <bernard@zeroc.com> | 2007-02-01 17:09:49 +0000 |
commit | abada90e3f84dc703b8ddc9efcbed8a946fadead (patch) | |
tree | 2c6f9dccd510ea97cb927a7bd635422efaae547a /java/src/IceInternal/LocatorInfo.java | |
parent | removing trace message (diff) | |
download | ice-abada90e3f84dc703b8ddc9efcbed8a946fadead.tar.bz2 ice-abada90e3f84dc703b8ddc9efcbed8a946fadead.tar.xz ice-abada90e3f84dc703b8ddc9efcbed8a946fadead.zip |
Expanded tabs into spaces
Diffstat (limited to 'java/src/IceInternal/LocatorInfo.java')
-rw-r--r-- | java/src/IceInternal/LocatorInfo.java | 540 |
1 files changed, 270 insertions, 270 deletions
diff --git a/java/src/IceInternal/LocatorInfo.java b/java/src/IceInternal/LocatorInfo.java index 4f84ab70ef9..0d54d87555a 100644 --- a/java/src/IceInternal/LocatorInfo.java +++ b/java/src/IceInternal/LocatorInfo.java @@ -13,330 +13,330 @@ public final class LocatorInfo { LocatorInfo(Ice.LocatorPrx locator, LocatorTable table) { - _locator = locator; - _table = table; + _locator = locator; + _table = table; } synchronized public void destroy() { - _locatorRegistry = null; - _table.clear(); + _locatorRegistry = null; + _table.clear(); } public boolean equals(java.lang.Object obj) { - if(this == obj) - { - return true; - } + if(this == obj) + { + return true; + } - if(obj instanceof LocatorInfo) - { - return _locator.equals(((LocatorInfo)obj)._locator); - } + if(obj instanceof LocatorInfo) + { + return _locator.equals(((LocatorInfo)obj)._locator); + } - return false; + return false; } public Ice.LocatorPrx getLocator() { - // - // No synchronization necessary, _locator is immutable. - // - return _locator; + // + // No synchronization necessary, _locator is immutable. + // + return _locator; } public synchronized Ice.LocatorRegistryPrx getLocatorRegistry() { - if(_locatorRegistry == null) // Lazy initialization - { - _locatorRegistry = _locator.getRegistry(); + if(_locatorRegistry == null) // Lazy initialization + { + _locatorRegistry = _locator.getRegistry(); - // - // The locator registry can't be located. - // - _locatorRegistry = Ice.LocatorRegistryPrxHelper.uncheckedCast(_locatorRegistry.ice_locator(null)); - } - - return _locatorRegistry; + // + // The locator registry can't be located. + // + _locatorRegistry = Ice.LocatorRegistryPrxHelper.uncheckedCast(_locatorRegistry.ice_locator(null)); + } + + return _locatorRegistry; } public EndpointI[] getEndpoints(IndirectReference ref, int ttl, Ice.BooleanHolder cached) { - EndpointI[] endpoints = null; - Ice.ObjectPrx object = null; - cached.value = true; - String adapterId = ref.getAdapterId(); - Ice.Identity identity = ref.getIdentity(); - - try - { - if(adapterId.length() > 0) - { - endpoints = _table.getAdapterEndpoints(adapterId, ttl); - if(endpoints == null) - { - cached.value = false; - - if(ref.getInstance().traceLevels().location >= 1) - { - StringBuffer s = new StringBuffer(); - s.append("searching for adapter by id\n"); - s.append("adapter = " + adapterId); - ref.getInstance().initializationData().logger.trace( - ref.getInstance().traceLevels().locationCat, s.toString()); - } + EndpointI[] endpoints = null; + Ice.ObjectPrx object = null; + cached.value = true; + String adapterId = ref.getAdapterId(); + Ice.Identity identity = ref.getIdentity(); + + try + { + if(adapterId.length() > 0) + { + endpoints = _table.getAdapterEndpoints(adapterId, ttl); + if(endpoints == null) + { + cached.value = false; + + if(ref.getInstance().traceLevels().location >= 1) + { + StringBuffer s = new StringBuffer(); + s.append("searching for adapter by id\n"); + s.append("adapter = " + adapterId); + ref.getInstance().initializationData().logger.trace( + ref.getInstance().traceLevels().locationCat, s.toString()); + } - // - // Search the adapter in the location service if we didn't - // find it in the cache. - // - object = _locator.findAdapterById(adapterId); - if(object != null) - { - endpoints = ((Ice.ObjectPrxHelperBase)object).__reference().getEndpoints(); - - if(endpoints.length > 0) - { - _table.addAdapterEndpoints(adapterId, endpoints); - } - } - } - } - else - { - boolean objectCached = true; - object = _table.getProxy(identity, ttl); - if(object == null) - { - objectCached = false; + // + // Search the adapter in the location service if we didn't + // find it in the cache. + // + object = _locator.findAdapterById(adapterId); + if(object != null) + { + endpoints = ((Ice.ObjectPrxHelperBase)object).__reference().getEndpoints(); + + if(endpoints.length > 0) + { + _table.addAdapterEndpoints(adapterId, endpoints); + } + } + } + } + else + { + boolean objectCached = true; + object = _table.getProxy(identity, ttl); + if(object == null) + { + objectCached = false; - if(ref.getInstance().traceLevels().location >= 1) - { - StringBuffer s = new StringBuffer(); - s.append("searching for object by id\n"); - s.append("object = " + ref.getInstance().identityToString(identity)); - ref.getInstance().initializationData().logger.trace( - ref.getInstance().traceLevels().locationCat, s.toString()); - } + if(ref.getInstance().traceLevels().location >= 1) + { + StringBuffer s = new StringBuffer(); + s.append("searching for object by id\n"); + s.append("object = " + ref.getInstance().identityToString(identity)); + ref.getInstance().initializationData().logger.trace( + ref.getInstance().traceLevels().locationCat, s.toString()); + } - object = _locator.findObjectById(identity); - } - - boolean endpointsCached = true; - if(object != null) - { - Reference r = ((Ice.ObjectPrxHelperBase)object).__reference(); - if(r instanceof DirectReference) - { - endpointsCached = false; - DirectReference odr = (DirectReference)r; - endpoints = odr.getEndpoints(); - } - else - { - IndirectReference oir = (IndirectReference)r; - if(oir.getAdapterId().length() > 0) - { - Ice.BooleanHolder c = new Ice.BooleanHolder(); - endpoints = getEndpoints(oir, ttl, c); - endpointsCached = c.value; - } - } - } - - if(!objectCached && endpoints != null && endpoints.length > 0) - { - _table.addProxy(identity, object); - } + object = _locator.findObjectById(identity); + } + + boolean endpointsCached = true; + if(object != null) + { + Reference r = ((Ice.ObjectPrxHelperBase)object).__reference(); + if(r instanceof DirectReference) + { + endpointsCached = false; + DirectReference odr = (DirectReference)r; + endpoints = odr.getEndpoints(); + } + else + { + IndirectReference oir = (IndirectReference)r; + if(oir.getAdapterId().length() > 0) + { + Ice.BooleanHolder c = new Ice.BooleanHolder(); + endpoints = getEndpoints(oir, ttl, c); + endpointsCached = c.value; + } + } + } + + if(!objectCached && endpoints != null && endpoints.length > 0) + { + _table.addProxy(identity, object); + } - cached.value = objectCached || endpointsCached; - } - } - catch(Ice.AdapterNotFoundException ex) - { - if(ref.getInstance().traceLevels().location >= 1) - { - StringBuffer s = new StringBuffer(); - s.append("adapter not found\n"); - s.append("adapter = " + adapterId); - ref.getInstance().initializationData().logger.trace( - ref.getInstance().traceLevels().locationCat, s.toString()); - } + cached.value = objectCached || endpointsCached; + } + } + catch(Ice.AdapterNotFoundException ex) + { + if(ref.getInstance().traceLevels().location >= 1) + { + StringBuffer s = new StringBuffer(); + s.append("adapter not found\n"); + s.append("adapter = " + adapterId); + ref.getInstance().initializationData().logger.trace( + ref.getInstance().traceLevels().locationCat, s.toString()); + } - Ice.NotRegisteredException e = new Ice.NotRegisteredException(); - e.kindOfObject = "object adapter"; - e.id = adapterId; - throw e; - } - catch(Ice.ObjectNotFoundException ex) - { - if(ref.getInstance().traceLevels().location >= 1) - { - StringBuffer s = new StringBuffer(); - s.append("object not found\n"); - s.append("object = " + ref.getInstance().identityToString(identity)); - ref.getInstance().initializationData().logger.trace( - ref.getInstance().traceLevels().locationCat, s.toString()); - } + Ice.NotRegisteredException e = new Ice.NotRegisteredException(); + e.kindOfObject = "object adapter"; + e.id = adapterId; + throw e; + } + catch(Ice.ObjectNotFoundException ex) + { + if(ref.getInstance().traceLevels().location >= 1) + { + StringBuffer s = new StringBuffer(); + s.append("object not found\n"); + s.append("object = " + ref.getInstance().identityToString(identity)); + ref.getInstance().initializationData().logger.trace( + ref.getInstance().traceLevels().locationCat, s.toString()); + } - Ice.NotRegisteredException e = new Ice.NotRegisteredException(); - e.kindOfObject = "object"; - e.id = ref.getInstance().identityToString(identity); - throw e; - } - catch(Ice.NotRegisteredException ex) - { - throw ex; - } - catch(Ice.LocalException ex) - { - if(ref.getInstance().traceLevels().location >= 1) - { - StringBuffer s = new StringBuffer(); - s.append("couldn't contact the locator to retrieve adapter endpoints\n"); - if(adapterId.length() > 0) - { - s.append("adapter = " + adapterId + "\n"); - } - else - { - s.append("object = " + ref.getInstance().identityToString(identity) + "\n"); - } - s.append("reason = " + ex); - ref.getInstance().initializationData().logger.trace( - ref.getInstance().traceLevels().locationCat, s.toString()); - } - throw ex; - } + Ice.NotRegisteredException e = new Ice.NotRegisteredException(); + e.kindOfObject = "object"; + e.id = ref.getInstance().identityToString(identity); + throw e; + } + catch(Ice.NotRegisteredException ex) + { + throw ex; + } + catch(Ice.LocalException ex) + { + if(ref.getInstance().traceLevels().location >= 1) + { + StringBuffer s = new StringBuffer(); + s.append("couldn't contact the locator to retrieve adapter endpoints\n"); + if(adapterId.length() > 0) + { + s.append("adapter = " + adapterId + "\n"); + } + else + { + s.append("object = " + ref.getInstance().identityToString(identity) + "\n"); + } + s.append("reason = " + ex); + ref.getInstance().initializationData().logger.trace( + ref.getInstance().traceLevels().locationCat, s.toString()); + } + throw ex; + } - if(ref.getInstance().traceLevels().location >= 1) - { - if(endpoints != null && endpoints.length > 0) - { - if(cached.value) - { - trace("found endpoints in locator table", ref, endpoints); - } - else - { - trace("retrieved endpoints from locator, adding to locator table", ref, endpoints); - } - } - else - { - StringBuffer s = new StringBuffer(); - s.append("no endpoints configured for "); - if(adapterId.length() > 0) - { - s.append("adapter\n"); - s.append("adapter = " + adapterId + "\n"); - } - else - { - s.append("object\n"); - s.append("object = " + ref.getInstance().identityToString(identity) + "\n"); - } - } - } + if(ref.getInstance().traceLevels().location >= 1) + { + if(endpoints != null && endpoints.length > 0) + { + if(cached.value) + { + trace("found endpoints in locator table", ref, endpoints); + } + else + { + trace("retrieved endpoints from locator, adding to locator table", ref, endpoints); + } + } + else + { + StringBuffer s = new StringBuffer(); + s.append("no endpoints configured for "); + if(adapterId.length() > 0) + { + s.append("adapter\n"); + s.append("adapter = " + adapterId + "\n"); + } + else + { + s.append("object\n"); + s.append("object = " + ref.getInstance().identityToString(identity) + "\n"); + } + } + } - return endpoints == null ? new EndpointI[0] : endpoints; + return endpoints == null ? new EndpointI[0] : endpoints; } public void clearObjectCache(IndirectReference ref) { - if(ref.getAdapterId().length() == 0) - { - Ice.ObjectPrx object = _table.removeProxy(ref.getIdentity()); - if(object != null) - { - if(((Ice.ObjectPrxHelperBase)object).__reference() instanceof IndirectReference) - { - IndirectReference oir = (IndirectReference)((Ice.ObjectPrxHelperBase)object).__reference(); - if(oir.getAdapterId().length() > 0) - { - clearCache(oir); - } - } - else - { - if(ref.getInstance().traceLevels().location >= 2) - { - trace("removed endpoints from locator table", - ref, ((Ice.ObjectPrxHelperBase)object).__reference().getEndpoints()); - } - } - } - } + if(ref.getAdapterId().length() == 0) + { + Ice.ObjectPrx object = _table.removeProxy(ref.getIdentity()); + if(object != null) + { + if(((Ice.ObjectPrxHelperBase)object).__reference() instanceof IndirectReference) + { + IndirectReference oir = (IndirectReference)((Ice.ObjectPrxHelperBase)object).__reference(); + if(oir.getAdapterId().length() > 0) + { + clearCache(oir); + } + } + else + { + if(ref.getInstance().traceLevels().location >= 2) + { + trace("removed endpoints from locator table", + ref, ((Ice.ObjectPrxHelperBase)object).__reference().getEndpoints()); + } + } + } + } } public void clearCache(IndirectReference ref) { - if(ref.getAdapterId().length() > 0) - { - EndpointI[] endpoints = _table.removeAdapterEndpoints(ref.getAdapterId()); + if(ref.getAdapterId().length() > 0) + { + EndpointI[] endpoints = _table.removeAdapterEndpoints(ref.getAdapterId()); - if(endpoints != null && ref.getInstance().traceLevels().location >= 2) - { - trace("removed endpoints from locator table\n", ref, endpoints); - } - } - else - { - Ice.ObjectPrx object = _table.removeProxy(ref.getIdentity()); - if(object != null) - { - if(((Ice.ObjectPrxHelperBase)object).__reference() instanceof IndirectReference) - { - IndirectReference oir = (IndirectReference)((Ice.ObjectPrxHelperBase)object).__reference(); - if(oir.getAdapterId().length() > 0) - { - clearCache(oir); - } - } - else - { - if(ref.getInstance().traceLevels().location >= 2) - { - trace("removed endpoints from locator table", - ref, ((Ice.ObjectPrxHelperBase)object).__reference().getEndpoints()); - } - } - } - } + if(endpoints != null && ref.getInstance().traceLevels().location >= 2) + { + trace("removed endpoints from locator table\n", ref, endpoints); + } + } + else + { + Ice.ObjectPrx object = _table.removeProxy(ref.getIdentity()); + if(object != null) + { + if(((Ice.ObjectPrxHelperBase)object).__reference() instanceof IndirectReference) + { + IndirectReference oir = (IndirectReference)((Ice.ObjectPrxHelperBase)object).__reference(); + if(oir.getAdapterId().length() > 0) + { + clearCache(oir); + } + } + else + { + if(ref.getInstance().traceLevels().location >= 2) + { + trace("removed endpoints from locator table", + ref, ((Ice.ObjectPrxHelperBase)object).__reference().getEndpoints()); + } + } + } + } } private void trace(String msg, IndirectReference ref, EndpointI[] endpoints) { - StringBuffer s = new StringBuffer(); - s.append(msg + "\n"); - if(ref.getAdapterId().length() > 0) - { - s.append("adapter = " + ref.getAdapterId() + "\n"); - } - else - { - s.append("object = " + ref.getInstance().identityToString(ref.getIdentity()) + "\n"); - } + StringBuffer s = new StringBuffer(); + s.append(msg + "\n"); + if(ref.getAdapterId().length() > 0) + { + s.append("adapter = " + ref.getAdapterId() + "\n"); + } + else + { + s.append("object = " + ref.getInstance().identityToString(ref.getIdentity()) + "\n"); + } - s.append("endpoints = "); - final int sz = endpoints.length; - for(int i = 0; i < sz; i++) - { - s.append(endpoints[i].toString()); - if(i + 1 < sz) - s.append(":"); - } + s.append("endpoints = "); + final int sz = endpoints.length; + for(int i = 0; i < sz; i++) + { + s.append(endpoints[i].toString()); + if(i + 1 < sz) + s.append(":"); + } - ref.getInstance().initializationData().logger.trace(ref.getInstance().traceLevels().locationCat, s.toString()); + ref.getInstance().initializationData().logger.trace(ref.getInstance().traceLevels().locationCat, s.toString()); } private final Ice.LocatorPrx _locator; |