diff options
author | Marc Laukien <marc@zeroc.com> | 2004-04-19 13:04:27 +0000 |
---|---|---|
committer | Marc Laukien <marc@zeroc.com> | 2004-04-19 13:04:27 +0000 |
commit | e07e3dea777cf84947fa100a0de1d02ffeee78ad (patch) | |
tree | 289d3d975cdc22cacca0b45fada6949fb3a32bfe /java/src/Ice/ObjectPrxHelper.java | |
parent | *** empty log message *** (diff) | |
download | ice-e07e3dea777cf84947fa100a0de1d02ffeee78ad.tar.bz2 ice-e07e3dea777cf84947fa100a0de1d02ffeee78ad.tar.xz ice-e07e3dea777cf84947fa100a0de1d02ffeee78ad.zip |
casts for ObjectPrxHelper
Diffstat (limited to 'java/src/Ice/ObjectPrxHelper.java')
-rw-r--r-- | java/src/Ice/ObjectPrxHelper.java | 663 |
1 files changed, 1 insertions, 662 deletions
diff --git a/java/src/Ice/ObjectPrxHelper.java b/java/src/Ice/ObjectPrxHelper.java index 6b02b63ca75..acc0594f104 100644 --- a/java/src/Ice/ObjectPrxHelper.java +++ b/java/src/Ice/ObjectPrxHelper.java @@ -14,473 +14,8 @@ package Ice; -public class ObjectPrxHelper implements ObjectPrx +public class ObjectPrxHelper extends ObjectPrxHelperBase { - public final int - hashCode() - { - return _reference.hashValue; - } - - public final int - ice_hash() - { - return _reference.hashValue; - } - - public final boolean - ice_isA(String __id) - { - return ice_isA(__id, null); - } - - public final boolean - ice_isA(String __id, java.util.Map __context) - { - int __cnt = 0; - while(true) - { - try - { - __checkTwowayOnly("ice_isA"); - _ObjectDel __del = __getDelegate(); - return __del.ice_isA(__id, __context); - } - catch(IceInternal.NonRepeatable __ex) - { - __cnt = __handleException(__ex.get(), __cnt); - } - catch(LocalException __ex) - { - __cnt = __handleException(__ex, __cnt); - } - } - } - - public final void - ice_ping() - { - ice_ping(null); - } - - public final void - ice_ping(java.util.Map __context) - { - int __cnt = 0; - while(true) - { - try - { - __checkTwowayOnly("ice_ping"); - _ObjectDel __del = __getDelegate(); - __del.ice_ping(__context); - return; - } - catch(IceInternal.NonRepeatable __ex) - { - __cnt = __handleException(__ex.get(), __cnt); - } - catch(LocalException __ex) - { - __cnt = __handleException(__ex, __cnt); - } - } - } - - public String[] - ice_ids() - { - return ice_ids(null); - } - - public String[] - ice_ids(java.util.Map __context) - { - int __cnt = 0; - while(true) - { - try - { - __checkTwowayOnly("ice_ids"); - _ObjectDel __del = __getDelegate(); - return __del.ice_ids(__context); - } - catch(IceInternal.NonRepeatable __ex) - { - __cnt = __handleException(__ex.get(), __cnt); - } - catch(LocalException __ex) - { - __cnt = __handleException(__ex, __cnt); - } - } - } - - public String - ice_id() - { - return ice_id(null); - } - - public String - ice_id(java.util.Map __context) - { - int __cnt = 0; - while(true) - { - try - { - __checkTwowayOnly("ice_id"); - _ObjectDel __del = __getDelegate(); - return __del.ice_id(__context); - } - catch(IceInternal.NonRepeatable __ex) - { - __cnt = __handleException(__ex.get(), __cnt); - } - catch(LocalException __ex) - { - __cnt = __handleException(__ex, __cnt); - } - } - } - - public final boolean - ice_invoke(String operation, OperationMode mode, byte[] inParams, ByteSeqHolder outParams) - { - return ice_invoke(operation, mode, inParams, outParams, null); - } - - public final boolean - ice_invoke(String operation, OperationMode mode, byte[] inParams, ByteSeqHolder outParams, - java.util.Map context) - { - int __cnt = 0; - while(true) - { - try - { - _ObjectDel __del = __getDelegate(); - return __del.ice_invoke(operation, mode, inParams, outParams, context); - } - catch(IceInternal.NonRepeatable __ex) - { - if(mode == OperationMode.Nonmutating || mode == OperationMode.Idempotent) - { - __cnt = __handleException(__ex.get(), __cnt); - } - else - { - __rethrowException(__ex.get()); - } - } - catch(LocalException __ex) - { - __cnt = __handleException(__ex, __cnt); - } - } - } - - public final void - ice_invoke_async(AMI_Object_ice_invoke cb, String operation, OperationMode mode, byte[] inParams) - { - ice_invoke_async(cb, operation, mode, inParams, null); - } - - public final void - ice_invoke_async(AMI_Object_ice_invoke cb, String operation, OperationMode mode, byte[] inParams, - java.util.Map context) - { - __checkTwowayOnly("ice_invoke_async"); - cb.__invoke(__reference(), operation, mode, inParams, context); - } - - public final Identity - ice_getIdentity() - { - return _reference.identity; - } - - public final ObjectPrx - ice_newIdentity(Identity newIdentity) - { - if(newIdentity.equals(_reference.identity)) - { - return this; - } - else - { - ObjectPrxHelper proxy = new ObjectPrxHelper(); - proxy.setup(_reference.changeIdentity(newIdentity)); - return proxy; - } - } - - public final java.util.Map - ice_getContext() - { - return _reference.context; - } - - public final ObjectPrx - ice_newContext(java.util.Map newContext) - { - if(newContext.equals(_reference.context)) - { - return this; - } - else - { - ObjectPrxHelper proxy = new ObjectPrxHelper(); - proxy.setup(_reference.changeContext(newContext)); - return proxy; - } - } - - public final String - ice_getFacet() - { - return _reference.facet; - } - - public final ObjectPrx - ice_newFacet(String newFacet) - { - if(newFacet.equals(_reference.facet)) - { - return this; - } - else - { - ObjectPrxHelper proxy = new ObjectPrxHelper(); - proxy.setup(_reference.changeFacet(newFacet)); - return proxy; - } - } - - public final ObjectPrx - ice_twoway() - { - IceInternal.Reference ref = _reference.changeMode(IceInternal.Reference.ModeTwoway); - if(ref.equals(_reference)) - { - return this; - } - else - { - ObjectPrxHelper proxy = new ObjectPrxHelper(); - proxy.setup(ref); - return proxy; - } - } - - public final boolean - ice_isTwoway() - { - return _reference.mode == IceInternal.Reference.ModeTwoway; - } - - public final ObjectPrx - ice_oneway() - { - IceInternal.Reference ref = _reference.changeMode(IceInternal.Reference.ModeOneway); - if(ref.equals(_reference)) - { - return this; - } - else - { - ObjectPrxHelper proxy = new ObjectPrxHelper(); - proxy.setup(ref); - return proxy; - } - } - - public final boolean - ice_isOneway() - { - return _reference.mode == IceInternal.Reference.ModeOneway; - } - - public final ObjectPrx - ice_batchOneway() - { - IceInternal.Reference ref = _reference.changeMode(IceInternal.Reference.ModeBatchOneway); - if(ref.equals(_reference)) - { - return this; - } - else - { - ObjectPrxHelper proxy = new ObjectPrxHelper(); - proxy.setup(ref); - return proxy; - } - } - - public final boolean - ice_isBatchOneway() - { - return _reference.mode == IceInternal.Reference.ModeBatchOneway; - } - - public final ObjectPrx - ice_datagram() - { - IceInternal.Reference ref = _reference.changeMode(IceInternal.Reference.ModeDatagram); - if(ref.equals(_reference)) - { - return this; - } - else - { - ObjectPrxHelper proxy = new ObjectPrxHelper(); - proxy.setup(ref); - return proxy; - } - } - - public final boolean - ice_isDatagram() - { - return _reference.mode == IceInternal.Reference.ModeDatagram; - } - - public final ObjectPrx - ice_batchDatagram() - { - IceInternal.Reference ref = _reference.changeMode(IceInternal.Reference.ModeBatchDatagram); - if(ref.equals(_reference)) - { - return this; - } - else - { - ObjectPrxHelper proxy = new ObjectPrxHelper(); - proxy.setup(ref); - return proxy; - } - } - - public final boolean - ice_isBatchDatagram() - { - return _reference.mode == IceInternal.Reference.ModeBatchDatagram; - } - - public final ObjectPrx - ice_secure(boolean b) - { - IceInternal.Reference ref = _reference.changeSecure(b); - if(ref.equals(_reference)) - { - return this; - } - else - { - ObjectPrxHelper proxy = new ObjectPrxHelper(); - proxy.setup(ref); - return proxy; - } - } - - public final ObjectPrx - ice_compress(boolean co) - { - IceInternal.Reference ref = _reference.changeCompress(co); - if(ref.equals(_reference)) - { - return this; - } - else - { - ObjectPrxHelper proxy = new ObjectPrxHelper(); - proxy.setup(ref); - return proxy; - } - } - - public final ObjectPrx - ice_timeout(int t) - { - IceInternal.Reference ref = _reference.changeTimeout(t); - if(ref.equals(_reference)) - { - return this; - } - else - { - ObjectPrxHelper proxy = new ObjectPrxHelper(); - proxy.setup(ref); - return proxy; - } - } - - public final ObjectPrx - ice_router(Ice.RouterPrx router) - { - IceInternal.Reference ref = _reference.changeRouter(router); - if(ref.equals(_reference)) - { - return this; - } - else - { - ObjectPrxHelper proxy = new ObjectPrxHelper(); - proxy.setup(ref); - return proxy; - } - } - - public final ObjectPrx - ice_locator(Ice.LocatorPrx locator) - { - IceInternal.Reference ref = _reference.changeLocator(locator); - if(ref.equals(_reference)) - { - return this; - } - else - { - ObjectPrxHelper proxy = new ObjectPrxHelper(); - proxy.setup(ref); - return proxy; - } - } - - public final ObjectPrx - ice_collocationOptimization(boolean b) - { - IceInternal.Reference ref = _reference.changeCollocationOptimization(b); - if(ref.equals(_reference)) - { - return this; - } - else - { - ObjectPrxHelper proxy = new ObjectPrxHelper(); - proxy.setup(ref); - return proxy; - } - } - - public final ObjectPrx - ice_default() - { - IceInternal.Reference ref = _reference.changeDefault(); - if(ref.equals(_reference)) - { - return this; - } - else - { - ObjectPrxHelper proxy = new ObjectPrxHelper(); - proxy.setup(ref); - return proxy; - } - } - - /* public static ObjectPrx checkedCast(Ice.ObjectPrx b) { @@ -528,200 +63,4 @@ public class ObjectPrxHelper implements ObjectPrx } return d; } - */ - - public final boolean - equals(java.lang.Object r) - { - ObjectPrxHelper rhs = (ObjectPrxHelper)r; - return _reference.equals(rhs._reference); - } - - public final IceInternal.Reference - __reference() - { - return _reference; - } - - public final void - __copyFrom(ObjectPrx from) - { - ObjectPrxHelper h = (ObjectPrxHelper)from; - IceInternal.Reference ref = null; - _ObjectDelM delegateM = null; - _ObjectDelD delegateD = null; - - synchronized(from) - { - ref = h._reference; - try - { - delegateM = (_ObjectDelM)h._delegate; - } - catch(ClassCastException ex) - { - } - try - { - delegateD = (_ObjectDelD)h._delegate; - } - catch(ClassCastException ex) - { - } - } - - // - // No need to synchronize "*this", as this operation is only - // called upon initialization. - // - - assert(_reference == null); - assert(_delegate == null); - - _reference = ref; - - if(delegateD != null) - { - _ObjectDelD delegate = __createDelegateD(); - delegate.__copyFrom(delegateD); - _delegate = delegate; - } - else if(delegateM != null) - { - _ObjectDelM delegate = __createDelegateM(); - delegate.__copyFrom(delegateM); - _delegate = delegate; - } - } - - public final int - __handleException(LocalException ex, int cnt) - { - // - // Only _delegate needs to be mutex protected here. - // - synchronized(this) - { - _delegate = null; - } - - if(_reference.locatorInfo != null) - { - _reference.locatorInfo.clearObjectCache(_reference); - } - - IceInternal.ProxyFactory proxyFactory = _reference.instance.proxyFactory(); - if(proxyFactory != null) - { - return proxyFactory.checkRetryAfterException(ex, cnt); - } - else - { - throw ex; // The communicator is already destroyed, so we cannot retry. - } - } - - public final synchronized void - __rethrowException(LocalException ex) - { - _delegate = null; - - if(_reference.locatorInfo != null) - { - _reference.locatorInfo.clearObjectCache(_reference); - } - - throw ex; - } - - public final void - __checkTwowayOnly(String name) - { - // - // No mutex lock necessary, there is nothing mutable in this - // operation. - // - - if(!ice_isTwoway()) - { - TwowayOnlyException ex = new TwowayOnlyException(); - ex.operation = name; - throw ex; - } - } - - public final synchronized _ObjectDel - __getDelegate() - { - if(_delegate == null) - { - if(_reference.collocationOptimization) - { - ObjectAdapter adapter = _reference.instance.objectAdapterFactory().findObjectAdapter(this); - if(adapter != null) - { - _ObjectDelD delegate = __createDelegateD(); - delegate.setup(_reference, adapter); - _delegate = delegate; - } - } - - if(_delegate == null) - { - _ObjectDelM delegate = __createDelegateM(); - delegate.setup(_reference); - _delegate = delegate; - - // - // If this proxy is for a non-local object, and we are - // using a router, then add this proxy to the router info - // object. - // - if(_reference.routerInfo != null) - { - _reference.routerInfo.addProxy(this); - } - } - } - - return _delegate; - } - - protected _ObjectDelM - __createDelegateM() - { - return new _ObjectDelM(); - } - - protected _ObjectDelD - __createDelegateD() - { - return new _ObjectDelD(); - } - - protected java.util.Map - __defaultContext() - { - return _reference.context; - } - - // - // Only for use by IceInternal.ProxyFactory - // - public final void - setup(IceInternal.Reference ref) - { - // - // No need to synchronize, as this operation is only called - // upon initial initialization. - // - - assert(_reference == null); - assert(_delegate == null); - - _reference = ref; - } - - private IceInternal.Reference _reference; - private _ObjectDel _delegate; } |