summaryrefslogtreecommitdiff
path: root/java/src/IceInternal/DirectReference.java
diff options
context:
space:
mode:
Diffstat (limited to 'java/src/IceInternal/DirectReference.java')
-rw-r--r--java/src/IceInternal/DirectReference.java244
1 files changed, 122 insertions, 122 deletions
diff --git a/java/src/IceInternal/DirectReference.java b/java/src/IceInternal/DirectReference.java
index ba7a73058b9..56224453de5 100644
--- a/java/src/IceInternal/DirectReference.java
+++ b/java/src/IceInternal/DirectReference.java
@@ -13,21 +13,21 @@ public class DirectReference extends RoutableReference
{
public
DirectReference(Instance inst,
- Ice.Communicator com,
- Ice.Identity ident,
- java.util.Map ctx,
- String fs,
- int md,
- boolean sec,
- boolean prefSec,
- EndpointI[] endpts,
- RouterInfo rtrInfo,
- boolean collocationOpt,
+ Ice.Communicator com,
+ Ice.Identity ident,
+ java.util.Map ctx,
+ String fs,
+ int md,
+ boolean sec,
+ boolean prefSec,
+ EndpointI[] endpts,
+ RouterInfo rtrInfo,
+ boolean collocationOpt,
boolean cacheConnection,
Ice.EndpointSelectionType endpointSelection,
boolean threadPerConnection)
{
- super(inst, com, ident, ctx, fs, md, sec, prefSec, rtrInfo, collocationOpt, cacheConnection, endpointSelection,
+ super(inst, com, ident, ctx, fs, md, sec, prefSec, rtrInfo, collocationOpt, cacheConnection, endpointSelection,
threadPerConnection);
_endpoints = endpts;
}
@@ -35,7 +35,7 @@ public class DirectReference extends RoutableReference
public String
getAdapterId()
{
- return "";
+ return "";
}
public EndpointI[]
@@ -47,75 +47,75 @@ public class DirectReference extends RoutableReference
public int
getLocatorCacheTimeout()
{
- return 0;
+ return 0;
}
public Reference
changeLocator(Ice.LocatorPrx newLocator)
{
- return this;
+ return this;
}
public Reference
changeCompress(boolean newCompress)
{
DirectReference r = (DirectReference)super.changeCompress(newCompress);
- if(r != this) // Also override the compress flag on the endpoints if it was updated.
- {
- EndpointI[] newEndpoints = new EndpointI[_endpoints.length];
- for(int i = 0; i < _endpoints.length; i++)
- {
- newEndpoints[i] = _endpoints[i].compress(newCompress);
- }
- r._endpoints = newEndpoints;
- }
- return r;
+ if(r != this) // Also override the compress flag on the endpoints if it was updated.
+ {
+ EndpointI[] newEndpoints = new EndpointI[_endpoints.length];
+ for(int i = 0; i < _endpoints.length; i++)
+ {
+ newEndpoints[i] = _endpoints[i].compress(newCompress);
+ }
+ r._endpoints = newEndpoints;
+ }
+ return r;
}
public Reference
changeTimeout(int newTimeout)
{
DirectReference r = (DirectReference)super.changeTimeout(newTimeout);
- if(r != this) // Also override the timeout on the endpoints if it was updated.
- {
- EndpointI[] newEndpoints = new EndpointI[_endpoints.length];
- for(int i = 0; i < _endpoints.length; i++)
- {
- newEndpoints[i] = _endpoints[i].timeout(newTimeout);
- }
- r._endpoints = newEndpoints;
- }
- return r;
+ if(r != this) // Also override the timeout on the endpoints if it was updated.
+ {
+ EndpointI[] newEndpoints = new EndpointI[_endpoints.length];
+ for(int i = 0; i < _endpoints.length; i++)
+ {
+ newEndpoints[i] = _endpoints[i].timeout(newTimeout);
+ }
+ r._endpoints = newEndpoints;
+ }
+ return r;
}
public Reference
changeConnectionId(String connectionId)
{
DirectReference r = (DirectReference)super.changeConnectionId(connectionId);
- if(r != this) // Also override the connection id on the endpoints if it was updated.
- {
- EndpointI[] newEndpoints = new EndpointI[_endpoints.length];
- for(int i = 0; i < _endpoints.length; i++)
- {
- newEndpoints[i] = _endpoints[i].connectionId(connectionId);
- }
- r._endpoints = newEndpoints;
- }
- return r;
+ if(r != this) // Also override the connection id on the endpoints if it was updated.
+ {
+ EndpointI[] newEndpoints = new EndpointI[_endpoints.length];
+ for(int i = 0; i < _endpoints.length; i++)
+ {
+ newEndpoints[i] = _endpoints[i].connectionId(connectionId);
+ }
+ r._endpoints = newEndpoints;
+ }
+ return r;
}
public Reference
changeAdapterId(String newAdapterId)
{
- if(newAdapterId == null || newAdapterId.length() == 0)
- {
- return this;
- }
- LocatorInfo locatorInfo =
- getInstance().locatorManager().get(getInstance().referenceFactory().getDefaultLocator());
- return getInstance().referenceFactory().create(getIdentity(), getContext(), getFacet(), getMode(),
- getSecure(), getPreferSecure(), newAdapterId, getRouterInfo(),
- locatorInfo, getCollocationOptimization(), getCacheConnection(),
+ if(newAdapterId == null || newAdapterId.length() == 0)
+ {
+ return this;
+ }
+ LocatorInfo locatorInfo =
+ getInstance().locatorManager().get(getInstance().referenceFactory().getDefaultLocator());
+ return getInstance().referenceFactory().create(getIdentity(), getContext(), getFacet(), getMode(),
+ getSecure(), getPreferSecure(), newAdapterId, getRouterInfo(),
+ locatorInfo, getCollocationOptimization(), getCacheConnection(),
getEndpointSelection(), getThreadPerConnection(),
getLocatorCacheTimeout());
}
@@ -123,15 +123,15 @@ public class DirectReference extends RoutableReference
public Reference
changeEndpoints(EndpointI[] newEndpoints)
{
- if(java.util.Arrays.equals(newEndpoints, _endpoints))
- {
- return this;
- }
+ if(java.util.Arrays.equals(newEndpoints, _endpoints))
+ {
+ return this;
+ }
DirectReference r = (DirectReference)getInstance().referenceFactory().copy(this);
- r._endpoints = newEndpoints;
- r.applyOverrides(r._endpoints);
- return r;
+ r._endpoints = newEndpoints;
+ r.applyOverrides(r._endpoints);
+ return r;
}
public Reference
@@ -142,93 +142,93 @@ public class DirectReference extends RoutableReference
public void
streamWrite(BasicStream s)
- throws Ice.MarshalException
+ throws Ice.MarshalException
{
super.streamWrite(s);
- s.writeSize(_endpoints.length);
- if(_endpoints.length > 0)
- {
- for(int i = 0; i < _endpoints.length; i++)
- {
- _endpoints[i].streamWrite(s);
- }
- }
- else
- {
- s.writeString(""); // Adapter id.
- }
+ s.writeSize(_endpoints.length);
+ if(_endpoints.length > 0)
+ {
+ for(int i = 0; i < _endpoints.length; i++)
+ {
+ _endpoints[i].streamWrite(s);
+ }
+ }
+ else
+ {
+ s.writeString(""); // Adapter id.
+ }
}
public String
toString()
{
- //
- // WARNING: Certain features, such as proxy validation in Glacier2,
- // depend on the format of proxy strings. Changes to toString() and
- // methods called to generate parts of the reference string could break
- // these features. Please review for all features that depend on the
- // format of proxyToString() before changing this and related code.
- //
- StringBuffer s = new StringBuffer();
- s.append(super.toString());
-
- for(int i = 0; i < _endpoints.length; i++)
- {
- String endp = _endpoints[i].toString();
- if(endp != null && endp.length() > 0)
- {
- s.append(':');
- s.append(endp);
- }
- }
- return s.toString();
+ //
+ // WARNING: Certain features, such as proxy validation in Glacier2,
+ // depend on the format of proxy strings. Changes to toString() and
+ // methods called to generate parts of the reference string could break
+ // these features. Please review for all features that depend on the
+ // format of proxyToString() before changing this and related code.
+ //
+ StringBuffer s = new StringBuffer();
+ s.append(super.toString());
+
+ for(int i = 0; i < _endpoints.length; i++)
+ {
+ String endp = _endpoints[i].toString();
+ if(endp != null && endp.length() > 0)
+ {
+ s.append(':');
+ s.append(endp);
+ }
+ }
+ return s.toString();
}
public Ice.ConnectionI
getConnection(Ice.BooleanHolder comp)
{
EndpointI[] endpts = super.getRoutedEndpoints();
- applyOverrides(endpts);
-
- if(endpts.length == 0)
- {
- endpts = _endpoints; // Endpoint overrides are already applied on these endpoints.
- }
-
- Ice.ConnectionI connection = createConnection(endpts, comp);
-
- //
- // 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.
- //
- if(getRouterInfo() != null)
- {
- connection.setAdapter(getRouterInfo().getAdapter());
- }
-
- assert(connection != null);
- return connection;
+ applyOverrides(endpts);
+
+ if(endpts.length == 0)
+ {
+ endpts = _endpoints; // Endpoint overrides are already applied on these endpoints.
+ }
+
+ Ice.ConnectionI connection = createConnection(endpts, comp);
+
+ //
+ // 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.
+ //
+ if(getRouterInfo() != null)
+ {
+ connection.setAdapter(getRouterInfo().getAdapter());
+ }
+
+ assert(connection != null);
+ return connection;
}
public boolean
equals(java.lang.Object obj)
{
if(this == obj)
- {
- return true;
- }
- if(!(obj instanceof DirectReference))
- {
- return false;
- }
+ {
+ return true;
+ }
+ if(!(obj instanceof DirectReference))
+ {
+ return false;
+ }
DirectReference rhs = (DirectReference)obj;
if(!super.equals(rhs))
{
return false;
}
- return java.util.Arrays.equals(_endpoints, rhs._endpoints);
+ return java.util.Arrays.equals(_endpoints, rhs._endpoints);
}
private EndpointI[] _endpoints;
generated by cgit v1.2.3 (git 2.46.0) at 2025-08-03 12:48:04 +0000