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/LocatorTable.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/LocatorTable.java')
-rw-r--r-- | java/src/IceInternal/LocatorTable.java | 102 |
1 files changed, 51 insertions, 51 deletions
diff --git a/java/src/IceInternal/LocatorTable.java b/java/src/IceInternal/LocatorTable.java index d3b1a0d34b6..5e3e986890f 100644 --- a/java/src/IceInternal/LocatorTable.java +++ b/java/src/IceInternal/LocatorTable.java @@ -18,104 +18,104 @@ final class LocatorTable synchronized void clear() { - _adapterEndpointsTable.clear(); - _objectTable.clear(); + _adapterEndpointsTable.clear(); + _objectTable.clear(); } synchronized IceInternal.EndpointI[] getAdapterEndpoints(String adapter, int ttl) { - if(ttl == 0) // Locator cache disabled. - { - return null; - } - - EndpointTableEntry entry = (EndpointTableEntry)_adapterEndpointsTable.get(adapter); - if(entry != null && checkTTL(entry.time, ttl)) - { - return entry.endpoints; - } - return null; + if(ttl == 0) // Locator cache disabled. + { + return null; + } + + EndpointTableEntry entry = (EndpointTableEntry)_adapterEndpointsTable.get(adapter); + if(entry != null && checkTTL(entry.time, ttl)) + { + return entry.endpoints; + } + return null; } synchronized void addAdapterEndpoints(String adapter, IceInternal.EndpointI[] endpoints) { - _adapterEndpointsTable.put(adapter, new EndpointTableEntry(System.currentTimeMillis(), endpoints)); + _adapterEndpointsTable.put(adapter, new EndpointTableEntry(System.currentTimeMillis(), endpoints)); } synchronized IceInternal.EndpointI[] removeAdapterEndpoints(String adapter) { - EndpointTableEntry entry = (EndpointTableEntry)_adapterEndpointsTable.remove(adapter); - return entry != null ? entry.endpoints : null; + EndpointTableEntry entry = (EndpointTableEntry)_adapterEndpointsTable.remove(adapter); + return entry != null ? entry.endpoints : null; } synchronized Ice.ObjectPrx getProxy(Ice.Identity id, int ttl) { - if(ttl == 0) // Locator cache disabled. - { - return null; - } - - ProxyTableEntry entry = (ProxyTableEntry)_objectTable.get(id); - if(entry != null && checkTTL(entry.time, ttl)) - { - return entry.proxy; - } - return null; + if(ttl == 0) // Locator cache disabled. + { + return null; + } + + ProxyTableEntry entry = (ProxyTableEntry)_objectTable.get(id); + if(entry != null && checkTTL(entry.time, ttl)) + { + return entry.proxy; + } + return null; } synchronized void addProxy(Ice.Identity id, Ice.ObjectPrx proxy) { - _objectTable.put(id, new ProxyTableEntry(System.currentTimeMillis(), proxy)); + _objectTable.put(id, new ProxyTableEntry(System.currentTimeMillis(), proxy)); } synchronized Ice.ObjectPrx removeProxy(Ice.Identity id) { - ProxyTableEntry entry = (ProxyTableEntry)_objectTable.remove(id); - return entry != null ? entry.proxy : null; + ProxyTableEntry entry = (ProxyTableEntry)_objectTable.remove(id); + return entry != null ? entry.proxy : null; } private boolean checkTTL(long time, int ttl) { - assert(ttl != 0); - if(ttl < 0) // TTL = infinite - { - return true; - } - else - { - return System.currentTimeMillis() - time <= ((long)ttl * 1000); - } + assert(ttl != 0); + if(ttl < 0) // TTL = infinite + { + return true; + } + else + { + return System.currentTimeMillis() - time <= ((long)ttl * 1000); + } } private static final class EndpointTableEntry { - public EndpointTableEntry(long time, IceInternal.EndpointI[] endpoints) + public EndpointTableEntry(long time, IceInternal.EndpointI[] endpoints) { - this.time = time; - this.endpoints = endpoints; - } + this.time = time; + this.endpoints = endpoints; + } - final public long time; - final public IceInternal.EndpointI[] endpoints; + final public long time; + final public IceInternal.EndpointI[] endpoints; }; private static final class ProxyTableEntry { - public ProxyTableEntry(long time, Ice.ObjectPrx proxy) + public ProxyTableEntry(long time, Ice.ObjectPrx proxy) { - this.time = time; - this.proxy = proxy; - } + this.time = time; + this.proxy = proxy; + } - final public long time; - final public Ice.ObjectPrx proxy; + final public long time; + final public Ice.ObjectPrx proxy; }; private java.util.HashMap _adapterEndpointsTable = new java.util.HashMap(); |