summaryrefslogtreecommitdiff
path: root/java/src/IceInternal/RoutableReference.java
diff options
context:
space:
mode:
authorMatthew Newhook <matthew@zeroc.com>2014-08-07 14:05:44 -0230
committerMatthew Newhook <matthew@zeroc.com>2014-08-07 14:05:44 -0230
commite3a672a438635a1173388aea9d7a2d44de358945 (patch)
tree57113ece1dd013c9687468a8dd7cc62c80136b86 /java/src/IceInternal/RoutableReference.java
parentICE-5457 added ability to set source address for connections (diff)
downloadice-e3a672a438635a1173388aea9d7a2d44de358945.tar.bz2
ice-e3a672a438635a1173388aea9d7a2d44de358945.tar.xz
ice-e3a672a438635a1173388aea9d7a2d44de358945.zip
Add @Override where possible, and remove trailing white space.
Diffstat (limited to 'java/src/IceInternal/RoutableReference.java')
-rw-r--r--java/src/IceInternal/RoutableReference.java111
1 files changed, 77 insertions, 34 deletions
diff --git a/java/src/IceInternal/RoutableReference.java b/java/src/IceInternal/RoutableReference.java
index de9d002f8b4..705aebc6475 100644
--- a/java/src/IceInternal/RoutableReference.java
+++ b/java/src/IceInternal/RoutableReference.java
@@ -11,66 +11,77 @@ package IceInternal;
public class RoutableReference extends Reference
{
+ @Override
public final EndpointI[]
getEndpoints()
{
return _endpoints;
}
+ @Override
public final String
getAdapterId()
{
return _adapterId;
}
+ @Override
public final LocatorInfo
getLocatorInfo()
{
return _locatorInfo;
}
+ @Override
public final RouterInfo
getRouterInfo()
{
return _routerInfo;
}
+ @Override
public final boolean
getCollocationOptimized()
{
return _collocationOptimized;
}
+ @Override
public final boolean
getCacheConnection()
{
return _cacheConnection;
}
+ @Override
public final boolean
getPreferSecure()
{
return _preferSecure;
}
+ @Override
public final Ice.EndpointSelectionType
getEndpointSelection()
{
return _endpointSelection;
}
+ @Override
public final int
getLocatorCacheTimeout()
{
return _locatorCacheTimeout;
}
+ @Override
public final String
getConnectionId()
{
return _connectionId;
}
+ @Override
public Reference
changeEncoding(Ice.EncodingVersion newEncoding)
{
@@ -87,6 +98,7 @@ public class RoutableReference extends Reference
return r;
}
+ @Override
public Reference
changeCompress(boolean newCompress)
{
@@ -103,6 +115,7 @@ public class RoutableReference extends Reference
return r;
}
+ @Override
public Reference
changeEndpoints(EndpointI[] newEndpoints)
{
@@ -117,6 +130,7 @@ public class RoutableReference extends Reference
return r;
}
+ @Override
public Reference
changeAdapterId(String newAdapterId)
{
@@ -127,9 +141,10 @@ public class RoutableReference extends Reference
RoutableReference r = (RoutableReference)getInstance().referenceFactory().copy(this);
r._adapterId = newAdapterId;
r._endpoints = _emptyEndpoints;
- return r;
+ return r;
}
+ @Override
public Reference
changeLocator(Ice.LocatorPrx newLocator)
{
@@ -143,6 +158,7 @@ public class RoutableReference extends Reference
return r;
}
+ @Override
public Reference
changeRouter(Ice.RouterPrx newRouter)
{
@@ -156,6 +172,7 @@ public class RoutableReference extends Reference
return r;
}
+ @Override
public Reference
changeCollocationOptimized(boolean newCollocationOptimized)
{
@@ -168,6 +185,7 @@ public class RoutableReference extends Reference
return r;
}
+ @Override
public final Reference
changeCacheConnection(boolean newCache)
{
@@ -180,6 +198,7 @@ public class RoutableReference extends Reference
return r;
}
+ @Override
public Reference
changePreferSecure(boolean newPreferSecure)
{
@@ -192,6 +211,7 @@ public class RoutableReference extends Reference
return r;
}
+ @Override
public final Reference
changeEndpointSelection(Ice.EndpointSelectionType newType)
{
@@ -204,6 +224,7 @@ public class RoutableReference extends Reference
return r;
}
+ @Override
public Reference
changeLocatorCacheTimeout(int newTimeout)
{
@@ -213,9 +234,10 @@ public class RoutableReference extends Reference
}
RoutableReference r = (RoutableReference)getInstance().referenceFactory().copy(this);
r._locatorCacheTimeout = newTimeout;
- return r;
+ return r;
}
+ @Override
public Reference
changeTimeout(int newTimeout)
{
@@ -235,9 +257,10 @@ public class RoutableReference extends Reference
}
r._endpoints = newEndpoints;
}
- return r;
+ return r;
}
+ @Override
public Reference
changeConnectionId(String id)
{
@@ -256,21 +279,24 @@ public class RoutableReference extends Reference
}
r._endpoints = newEndpoints;
}
- return r;
+ return r;
}
+ @Override
public boolean
isIndirect()
{
return _endpoints.length == 0;
}
+ @Override
public boolean
isWellKnown()
{
return _endpoints.length == 0 && _adapterId.length() == 0;
}
+ @Override
public void
streamWrite(BasicStream s)
throws Ice.MarshalException
@@ -293,6 +319,7 @@ public class RoutableReference extends Reference
}
}
+ @Override
public String
toString()
{
@@ -320,7 +347,7 @@ public class RoutableReference extends Reference
else if(_adapterId.length() > 0)
{
s.append(" @ ");
-
+
//
// If the encoded adapter id string contains characters which
// the reference parser uses as separators, then we enclose
@@ -341,6 +368,7 @@ public class RoutableReference extends Reference
return s.toString();
}
+ @Override
public java.util.Map<String, String> toProperty(String prefix)
{
java.util.Map<String, String> properties = new java.util.HashMap<String, String>();
@@ -349,7 +377,7 @@ public class RoutableReference extends Reference
properties.put(prefix + ".CollocationOptimized", _collocationOptimized ? "1" : "0");
properties.put(prefix + ".ConnectionCached", _cacheConnection ? "1" : "0");
properties.put(prefix + ".PreferSecure", _preferSecure ? "1" : "0");
- properties.put(prefix + ".EndpointSelection",
+ properties.put(prefix + ".EndpointSelection",
_endpointSelection == Ice.EndpointSelectionType.Random ? "Random" : "Ordered");
{
@@ -386,6 +414,7 @@ public class RoutableReference extends Reference
return properties;
}
+ @Override
public synchronized int
hashCode()
{
@@ -397,6 +426,7 @@ public class RoutableReference extends Reference
return _hashValue;
}
+ @Override
public boolean
equals(java.lang.Object obj)
{
@@ -465,6 +495,7 @@ public class RoutableReference extends Reference
return true;
}
+ @Override
public Ice.ConnectionI
getConnection(Ice.BooleanHolder comp)
{
@@ -514,7 +545,7 @@ public class RoutableReference extends Reference
{
assert(_locatorInfo != null);
_locatorInfo.clearCache(this);
- if(cached.value)
+ if(cached.value)
{
TraceLevels traceLevels = getInstance().traceLevels();
if(traceLevels.retry >= 2)
@@ -530,6 +561,7 @@ public class RoutableReference extends Reference
}
}
+ @Override
public void
getConnection(final GetConnectionCallback callback)
{
@@ -541,6 +573,7 @@ public class RoutableReference extends Reference
//
_routerInfo.getClientEndpoints(new RouterInfo.GetClientEndpointsCallback()
{
+ @Override
public void
setEndpoints(EndpointI[] endpts)
{
@@ -555,6 +588,7 @@ public class RoutableReference extends Reference
}
}
+ @Override
public void
setException(Ice.LocalException ex)
{
@@ -582,6 +616,7 @@ public class RoutableReference extends Reference
{
_locatorInfo.getEndpoints(this, _locatorCacheTimeout, new LocatorInfo.GetEndpointsCallback()
{
+ @Override
public void
setEndpoints(EndpointI[] endpoints, final boolean cached)
{
@@ -590,16 +625,18 @@ public class RoutableReference extends Reference
callback.setException(new Ice.NoEndpointException(self.toString()));
return;
}
-
+
applyOverrides(endpoints);
createConnection(endpoints, new GetConnectionCallback()
{
+ @Override
public void
setConnection(Ice.ConnectionI connection, boolean compress)
{
callback.setConnection(connection, compress);
}
-
+
+ @Override
public void
setException(Ice.LocalException exc)
{
@@ -632,7 +669,8 @@ public class RoutableReference extends Reference
}
});
}
-
+
+ @Override
public void
setException(Ice.LocalException ex)
{
@@ -702,7 +740,7 @@ public class RoutableReference extends Reference
endpts[i] = endpts[i].connectionId(_connectionId);
if(_overrideCompress)
{
- endpts[i] = endpts[i].compress(_compress);
+ endpts[i] = endpts[i].compress(_compress);
}
if(_overrideTimeout)
{
@@ -726,7 +764,7 @@ public class RoutableReference extends Reference
endpoints.add(endpoint);
}
}
-
+
//
// Filter out endpoints according to the mode of the reference.
//
@@ -820,7 +858,7 @@ public class RoutableReference extends Reference
java.util.Collections.sort(endpoints, _preferNonSecureEndpointComparator);
}
- return (EndpointI[])endpoints.toArray(new EndpointI[endpoints.size()]);
+ return endpoints.toArray(new EndpointI[endpoints.size()]);
}
protected Ice.ConnectionI
@@ -831,7 +869,7 @@ public class RoutableReference extends Reference
{
throw new Ice.NoEndpointException(toString());
}
-
+
//
// Finally, create the connection.
//
@@ -854,9 +892,9 @@ public class RoutableReference extends Reference
// create a new connection even if there's an existing
// connection for one of the endpoints.
//
-
+
Ice.LocalException exception = null;
- EndpointI[] endpoint = new EndpointI[1];
+ EndpointI[] endpoint = new EndpointI[1];
for(int i = 0; i < endpoints.length; ++i)
{
try
@@ -881,7 +919,7 @@ public class RoutableReference extends Reference
assert(connection != null);
- //
+ //
// If we have a router, set the object adapter for this router
// (if any) to the new connection, so that callbacks from the
// router can be received over this new connection.
@@ -890,7 +928,7 @@ public class RoutableReference extends Reference
{
connection.setAdapter(_routerInfo.getAdapter());
}
-
+
return connection;
}
@@ -903,7 +941,7 @@ public class RoutableReference extends Reference
callback.setException(new Ice.NoEndpointException(toString()));
return;
}
-
+
//
// Finally, create the connection.
//
@@ -914,13 +952,14 @@ public class RoutableReference extends Reference
// Get an existing connection or create one if there's no
// existing connection to one of the given endpoints.
//
- factory.create(endpoints, false, getEndpointSelection(),
+ factory.create(endpoints, false, getEndpointSelection(),
new OutgoingConnectionFactory.CreateConnectionCallback()
{
- public void
+ @Override
+ public void
setConnection(Ice.ConnectionI connection, boolean compress)
{
- //
+ //
// If we have a router, set the object adapter for this router
// (if any) to the new connection, so that callbacks from the
// router can be received over this new connection.
@@ -931,8 +970,9 @@ public class RoutableReference extends Reference
}
callback.setConnection(connection, compress);
}
-
- public void
+
+ @Override
+ public void
setException(Ice.LocalException ex)
{
callback.setException(ex);
@@ -948,14 +988,15 @@ public class RoutableReference extends Reference
// create a new connection even if there's an existing
// connection for one of the endpoints.
//
-
- factory.create(new EndpointI[]{ endpoints[0] }, true, getEndpointSelection(),
+
+ factory.create(new EndpointI[]{ endpoints[0] }, true, getEndpointSelection(),
new OutgoingConnectionFactory.CreateConnectionCallback()
{
- public void
+ @Override
+ public void
setConnection(Ice.ConnectionI connection, boolean compress)
{
- //
+ //
// If we have a router, set the object adapter for this router
// (if any) to the new connection, so that callbacks from the
// router can be received over this new connection.
@@ -966,21 +1007,22 @@ public class RoutableReference extends Reference
}
callback.setConnection(connection, compress);
}
-
- public void
+
+ @Override
+ public void
setException(final Ice.LocalException ex)
{
if(_exception == null)
{
_exception = ex;
}
-
+
if(++_i == endpoints.length)
{
callback.setException(_exception);
return;
}
-
+
final boolean more = _i != endpoints.length - 1;
final EndpointI[] endpoint = new EndpointI[]{ endpoints[_i] };
factory.create(endpoint, more, getEndpointSelection(), this);
@@ -998,7 +1040,8 @@ public class RoutableReference extends Reference
{
_preferSecure = preferSecure;
}
-
+
+ @Override
public int
compare(EndpointI le, EndpointI re)
{
@@ -1034,7 +1077,7 @@ public class RoutableReference extends Reference
private boolean _preferSecure;
}
-
+
private static EndpointComparator _preferNonSecureEndpointComparator = new EndpointComparator(false);
private static EndpointComparator _preferSecureEndpointComparator = new EndpointComparator(true);
private static EndpointI[] _emptyEndpoints = new EndpointI[0];