summaryrefslogtreecommitdiff
path: root/java/src/IceInternal/LocatorTable.java
diff options
context:
space:
mode:
authorBernard Normier <bernard@zeroc.com>2007-02-01 17:09:49 +0000
committerBernard Normier <bernard@zeroc.com>2007-02-01 17:09:49 +0000
commitabada90e3f84dc703b8ddc9efcbed8a946fadead (patch)
tree2c6f9dccd510ea97cb927a7bd635422efaae547a /java/src/IceInternal/LocatorTable.java
parentremoving trace message (diff)
downloadice-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.java102
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();