diff options
Diffstat (limited to 'javae/src/IceInternal/DirectReference.java')
| -rw-r--r-- | javae/src/IceInternal/DirectReference.java | 200 |
1 files changed, 0 insertions, 200 deletions
diff --git a/javae/src/IceInternal/DirectReference.java b/javae/src/IceInternal/DirectReference.java deleted file mode 100644 index 68aad8e3bf8..00000000000 --- a/javae/src/IceInternal/DirectReference.java +++ /dev/null @@ -1,200 +0,0 @@ -// ********************************************************************** -// -// Copyright (c) 2003-2007 ZeroC, Inc. All rights reserved. -// -// This copy of Ice-E is licensed to you under the terms described in the -// ICEE_LICENSE file included in this distribution. -// -// ********************************************************************** - -package IceInternal; - -public class DirectReference extends RoutableReference -{ - public - DirectReference(Instance inst, - Ice.Communicator com, - Ice.Identity ident, - java.util.Hashtable context, - String fs, - int md, - boolean sec, - Endpoint[] endpts, - RouterInfo rtrInfo) - { - super(inst, com, ident, context, fs, md, sec, rtrInfo); - _endpoints = endpts; - } - - public Endpoint[] - getEndpoints() - { - return _endpoints; - } - - public String - getAdapterId() - { - return ""; - } - - 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(), newAdapterId, getRouterInfo(), - locatorInfo); - } - - public Reference - changeLocator(Ice.LocatorPrx newLocator) - { - return this; - } - - 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. - { - Endpoint[] newEndpoints = new Endpoint[_endpoints.length]; - for(int i = 0; i < _endpoints.length; i++) - { - newEndpoints[i] = _endpoints[i].timeout(newTimeout); - } - r._endpoints = newEndpoints; - } - return r; - } - - public void - streamWrite(BasicStream s) - 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. - } - } - - 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(); - } - - public Ice.Connection - getConnection() - { - Endpoint[] endpts = super.getRoutedEndpoints(); - applyOverrides(endpts); - - if(endpts.length == 0) - { - endpts = _endpoints; // Endpoint overrides are already applied on these endpoints. - } - Endpoint[] filteredEndpoints = filterEndpoints(endpts); - if(filteredEndpoints.length == 0) - { - Ice.NoEndpointException ex = new Ice.NoEndpointException(); - ex.proxy = toString(); - throw ex; - } - - OutgoingConnectionFactory factory = getInstance().outgoingConnectionFactory(); - Ice.Connection connection = factory.create(filteredEndpoints); - - // - // 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()); - } - - if(IceUtil.Debug.ASSERT) - { - IceUtil.Debug.Assert(connection != null); - } - return connection; - } - - public boolean - equals(java.lang.Object obj) - { - if(this == obj) - { - return true; - } - if(!(obj instanceof DirectReference)) - { - return false; - } - DirectReference rhs = (DirectReference)obj; - if(!super.equals(rhs)) - { - return false; - } - return compare(_endpoints, rhs._endpoints); - } - - protected - DirectReference() - { - } - - protected void - shallowCopy(DirectReference ref) - { - super.shallowCopy(ref); - ref._endpoints = _endpoints; - } - - public java.lang.Object - ice_clone() - { - DirectReference result = new DirectReference(); - shallowCopy(result); - return result; - } - - private Endpoint[] _endpoints; -} |