summaryrefslogtreecommitdiff
path: root/java/src/Ice/ObjectPrxHelperBase.java
diff options
context:
space:
mode:
authorMatthew Newhook <matthew@zeroc.com>2014-10-20 11:40:05 -0230
committerMatthew Newhook <matthew@zeroc.com>2014-10-20 11:40:05 -0230
commitb51469b41167fb86ae2059a15cf0475c53fdda7b (patch)
treefc85d6ca2efd89c67e1e4e7438f437c3e08313f4 /java/src/Ice/ObjectPrxHelperBase.java
parentFixed (ICE-5695) - IceSSL: misleading exception (diff)
downloadice-b51469b41167fb86ae2059a15cf0475c53fdda7b.tar.bz2
ice-b51469b41167fb86ae2059a15cf0475c53fdda7b.tar.xz
ice-b51469b41167fb86ae2059a15cf0475c53fdda7b.zip
Down with ant. From the gradle to the grave.
Diffstat (limited to 'java/src/Ice/ObjectPrxHelperBase.java')
-rw-r--r--java/src/Ice/ObjectPrxHelperBase.java3068
1 files changed, 0 insertions, 3068 deletions
diff --git a/java/src/Ice/ObjectPrxHelperBase.java b/java/src/Ice/ObjectPrxHelperBase.java
deleted file mode 100644
index 2c763f56cc2..00000000000
--- a/java/src/Ice/ObjectPrxHelperBase.java
+++ /dev/null
@@ -1,3068 +0,0 @@
-// **********************************************************************
-//
-// Copyright (c) 2003-2014 ZeroC, Inc. All rights reserved.
-//
-// This copy of Ice is licensed to you under the terms described in the
-// ICE_LICENSE file included in this distribution.
-//
-// **********************************************************************
-
-package Ice;
-
-import java.util.LinkedList;
-import java.util.List;
-
-import Ice.Instrumentation.InvocationObserver;
-import IceInternal.QueueRequestHandler;
-import IceInternal.RetryException;
-
-/**
- * Base class for all proxies.
- **/
-public class ObjectPrxHelperBase implements ObjectPrx, java.io.Serializable
-{
- /**
- * Returns a hash code for this proxy.
- *
- * @return The hash code.
- **/
- @Override
- public final int
- hashCode()
- {
- return _reference.hashCode();
- }
-
- /**
- * Returns the communicator that created this proxy.
- *
- * @return The communicator that created this proxy.
- **/
- @Override
- public final Communicator
- ice_getCommunicator()
- {
- return _reference.getCommunicator();
- }
-
- /**
- * Returns the stringified form of this proxy.
- *
- * @return The stringified proxy.
- **/
- @Override
- public final String
- toString()
- {
- return _reference.toString();
- }
-
- /**
- * Tests whether this proxy supports a given interface.
- *
- * @param __id The Slice type ID of an interface.
- * @return <code>true</code> if this proxy supports the specified interface; <code>false</code>, otherwise.
- **/
- @Override
- public final boolean
- ice_isA(String __id)
- {
- return ice_isA(__id, null, false);
- }
-
- /**
- * Tests whether this proxy supports a given interface.
- *
- * @param __id The Slice type ID of an interface.
- * @param __context The <code>Context</code> map for the invocation.
- * @return <code>true</code> if this proxy supports the specified interface; <code>false</code>, otherwise.
- **/
- @Override
- public final boolean
- ice_isA(String __id, java.util.Map<String, String> __context)
- {
- return ice_isA(__id, __context, true);
- }
-
- private static final String __ice_isA_name = "ice_isA";
-
- private boolean
- ice_isA(String __id, java.util.Map<String, String> __context, boolean __explicitCtx)
- {
- __checkTwowayOnly(__ice_isA_name);
- return end_ice_isA(begin_ice_isA(__id, __context, __explicitCtx, true, null));
- }
-
- /**
- * Tests whether this proxy supports a given interface.
- *
- * @param __id The Slice type ID of an interface.
- * @return The asynchronous result object.
- **/
- @Override
- public final AsyncResult
- begin_ice_isA(String __id)
- {
- return begin_ice_isA(__id, null, false, false, null);
- }
-
- /**
- * Tests whether this proxy supports a given interface.
- *
- * @param __id The Slice type ID of an interface.
- * @param __context The <code>Context</code> map for the invocation.
- * @return The asynchronous result object.
- **/
- @Override
- public final AsyncResult
- begin_ice_isA(String __id, java.util.Map<String, String> __context)
- {
- return begin_ice_isA(__id, __context, true, false, null);
- }
-
- /**
- * Tests whether this proxy supports a given interface.
- *
- * @param __id The Slice type ID of an interface.
- * @param __cb The asynchronous callback object.
- * @return The asynchronous result object.
- **/
- @Override
- public final AsyncResult
- begin_ice_isA(String __id, Callback __cb)
- {
- return begin_ice_isA(__id, null, false, false, __cb);
- }
-
- /**
- * Tests whether this proxy supports a given interface.
- *
- * @param __id The Slice type ID of an interface.
- * @param __context The <code>Context</code> map for the invocation.
- * @param __cb The asynchronous callback object.
- * @return The asynchronous result object.
- **/
- @Override
- public final AsyncResult
- begin_ice_isA(String __id, java.util.Map<String, String> __context, Callback __cb)
- {
- return begin_ice_isA(__id, __context, true, false, __cb);
- }
-
- /**
- * Tests whether this proxy supports a given interface.
- *
- * @param __id The Slice type ID of an interface.
- * @param __cb The asynchronous callback object.
- * @return The asynchronous result object.
- **/
- @Override
- public final AsyncResult
- begin_ice_isA(String __id, Callback_Object_ice_isA __cb)
- {
- return begin_ice_isA(__id, null, false, false, __cb);
- }
-
- /**
- * Tests whether this proxy supports a given interface.
- *
- * @param __id The Slice type ID of an interface.
- * @param __context The <code>Context</code> map for the invocation.
- * @param __cb The asynchronous callback object.
- * @return The asynchronous result object.
- **/
- @Override
- public final AsyncResult
- begin_ice_isA(String __id, java.util.Map<String, String> __context, Callback_Object_ice_isA __cb)
- {
- return begin_ice_isA(__id, __context, true, false, __cb);
- }
-
- /**
- * Tests whether this proxy supports a given interface.
- *
- * @param __id The Slice type ID of an interface.
- * @param __responseCb The asynchronous response callback object.
- * @param __exceptionCb The asynchronous exception callback object.
- * @return The asynchronous result object.
- **/
- @Override
- public final AsyncResult
- begin_ice_isA(String __id,
- IceInternal.Functional_BoolCallback __responseCb,
- IceInternal.Functional_GenericCallback1<Ice.Exception> __exceptionCb)
- {
- return begin_ice_isA(__id, null, false, false, __responseCb, __exceptionCb, null);
- }
-
- /**
- * Tests whether this proxy supports a given interface.
- *
- * @param __id The Slice type ID of an interface.
- * @param __responseCb The asynchronous response callback object.
- * @param __exceptionCb The asynchronous exception callback object.
- * @param __sentCb The asynchronous sent callback object.
- * @return The asynchronous result object.
- **/
- @Override
- public final AsyncResult
- begin_ice_isA(String __id,
- IceInternal.Functional_BoolCallback __responseCb,
- IceInternal.Functional_GenericCallback1<Ice.Exception> __exceptionCb,
- IceInternal.Functional_BoolCallback __sentCb)
- {
- return begin_ice_isA(__id, null, false, false, __responseCb, __exceptionCb, __sentCb);
- }
-
- /**
- * Tests whether this proxy supports a given interface.
- *
- * @param __id The Slice type ID of an interface.
- * @param __context The <code>Context</code> map for the invocation.
- * @param __responseCb The asynchronous response callback object.
- * @param __exceptionCb The asynchronous exception callback object.
- * @return The asynchronous result object.
- **/
- @Override
- public final AsyncResult
- begin_ice_isA(String __id,
- java.util.Map<String, String> __context,
- IceInternal.Functional_BoolCallback __responseCb,
- IceInternal.Functional_GenericCallback1<Ice.Exception> __exceptionCb)
- {
- return begin_ice_isA(__id, __context, true, false, __responseCb, __exceptionCb, null);
- }
-
- /**
- * Tests whether this proxy supports a given interface.
- *
- * @param __id The Slice type ID of an interface.
- * @param __context The <code>Context</code> map for the invocation.
- * @param __responseCb The asynchronous response callback object.
- * @param __exceptionCb The asynchronous exception callback object.
- * @param __sentCb The asynchronous sent callback object.
- * @return The asynchronous result object.
- **/
- @Override
- public final AsyncResult
- begin_ice_isA(String __id,
- java.util.Map<String, String> __context,
- IceInternal.Functional_BoolCallback __responseCb,
- IceInternal.Functional_GenericCallback1<Ice.Exception> __exceptionCb,
- IceInternal.Functional_BoolCallback __sentCb)
- {
- return begin_ice_isA(__id, __context, true, false, __responseCb, __exceptionCb, __sentCb);
- }
-
- private final AsyncResult
- begin_ice_isA(String __id,
- java.util.Map<String, String> __context,
- boolean __explicitCtx,
- boolean __synchronous,
- IceInternal.Functional_BoolCallback __responseCb,
- IceInternal.Functional_GenericCallback1<Ice.Exception> __exceptionCb,
- IceInternal.Functional_BoolCallback __sentCb)
- {
- return begin_ice_isA(__id, __context, __explicitCtx, __synchronous,
- new IceInternal.Functional_TwowayCallbackBool(__responseCb, __exceptionCb, __sentCb)
- {
- @Override
- public final void __completed(AsyncResult __result)
- {
- ObjectPrxHelperBase.__ice_isA_completed(this, __result);
- }
- });
- }
-
- private AsyncResult
- begin_ice_isA(String __id, java.util.Map<String, String> __context, boolean __explicitCtx,
- boolean __synchronous, IceInternal.CallbackBase __cb)
- {
- __checkAsyncTwowayOnly(__ice_isA_name);
- IceInternal.OutgoingAsync __result = getOutgoingAsync(__ice_isA_name, __cb);
- try
- {
- __result.prepare(__ice_isA_name, OperationMode.Nonmutating, __context, __explicitCtx, __synchronous);
- IceInternal.BasicStream __os = __result.startWriteParams(Ice.FormatType.DefaultFormat);
- __os.writeString(__id);
- __result.endWriteParams();
- __result.invoke();
- }
- catch(Exception __ex)
- {
- __result.abort(__ex);
- }
- return __result;
- }
-
- /**
- * Completes the asynchronous ice_isA request.
- *
- * @param __result The asynchronous result.
- * @return <code>true</code> if this proxy supports the specified interface; <code>false</code>, otherwise.
- **/
- @Override
- public final boolean
- end_ice_isA(AsyncResult __iresult)
- {
- IceInternal.OutgoingAsync __result = IceInternal.OutgoingAsync.check(__iresult, this, __ice_isA_name);
- try
- {
- if(!__result.__wait())
- {
- try
- {
- __result.throwUserException();
- }
- catch(UserException __ex)
- {
- throw new UnknownUserException(__ex.ice_name(), __ex);
- }
- }
- boolean __ret;
- IceInternal.BasicStream __is = __result.startReadParams();
- __ret = __is.readBool();
- __result.endReadParams();
- return __ret;
- }
- finally
- {
- if(__result != null)
- {
- __result.cacheMessageBuffers();
- }
- }
- }
-
- static public final void __ice_isA_completed(TwowayCallbackBool __cb, Ice.AsyncResult __result)
- {
- boolean __ret = false;
- try
- {
- __ret = __result.getProxy().end_ice_isA(__result);
- }
- catch(LocalException __ex)
- {
- __cb.exception(__ex);
- return;
- }
- catch(SystemException __ex)
- {
- __cb.exception(__ex);
- return;
- }
- __cb.response(__ret);
- }
-
- /**
- * Tests whether the target object of this proxy can be reached.
- **/
- @Override
- public final void
- ice_ping()
- {
- ice_ping(null, false);
- }
-
- /**
- * Tests whether the target object of this proxy can be reached.
- *
- * @param __context The <code>Context</code> map for the invocation.
- **/
- @Override
- public final void
- ice_ping(java.util.Map<String, String> __context)
- {
- ice_ping(__context, true);
- }
-
- private static final String __ice_ping_name = "ice_ping";
-
- private void
- ice_ping(java.util.Map<String, String> __context, boolean __explicitCtx)
- {
- end_ice_ping(begin_ice_ping(__context, __explicitCtx, true, null));
- }
-
- /**
- * Tests whether the target object of this proxy can be reached.
- *
- * @return The asynchronous result object.
- **/
- @Override
- public final AsyncResult
- begin_ice_ping()
- {
- return begin_ice_ping(null, false, false, null);
- }
-
- /**
- * Tests whether the target object of this proxy can be reached.
- *
- * @param __context The context map for the invocation.
- * @return The asynchronous result object.
- **/
- @Override
- public final AsyncResult
- begin_ice_ping(java.util.Map<String, String> __context)
- {
- return begin_ice_ping(__context, true, false, null);
- }
-
- /**
- * Tests whether the target object of this proxy can be reached.
- *
- * @param __cb The asynchronous callback object.
- * @return The asynchronous result object.
- **/
- @Override
- public final AsyncResult
- begin_ice_ping(Callback __cb)
- {
- return begin_ice_ping(null, false, false, __cb);
- }
-
- /**
- * Tests whether the target object of this proxy can be reached.
- *
- * @param __context The context map for the invocation.
- * @param __cb The asynchronous callback object.
- * @return The asynchronous result object.
- **/
- @Override
- public final AsyncResult
- begin_ice_ping(java.util.Map<String, String> __context, Callback __cb)
- {
- return begin_ice_ping(__context, true, false, __cb);
- }
-
- /**
- * Tests whether the target object of this proxy can be reached.
- *
- * @param __cb The asynchronous callback object.
- * @return The asynchronous result object.
- **/
- @Override
- public final AsyncResult
- begin_ice_ping(Callback_Object_ice_ping __cb)
- {
- return begin_ice_ping(null, false, false, __cb);
- }
-
- /**
- * Tests whether the target object of this proxy can be reached.
- *
- * @param __context The context map for the invocation.
- * @param __cb The asynchronous callback object.
- * @return The asynchronous result object.
- **/
- @Override
- public final AsyncResult
- begin_ice_ping(java.util.Map<String, String> __context, Callback_Object_ice_ping __cb)
- {
- return begin_ice_ping(__context, true, false, __cb);
- }
-
- /**
- * Tests whether the target object of this proxy can be reached.
- *
- * @param __responseCb The asynchronous response callback object.
- * @param __exceptionCb The asynchronous exception callback object.
- * @return The asynchronous result object.
- **/
- @Override
- public final AsyncResult
- begin_ice_ping(IceInternal.Functional_VoidCallback __responseCb,
- IceInternal.Functional_GenericCallback1<Ice.Exception> __exceptionCb)
- {
- return begin_ice_ping(null, false, false,
- new IceInternal.Functional_OnewayCallback(__responseCb, __exceptionCb, null));
- }
-
- /**
- * Tests whether the target object of this proxy can be reached.
- *
- * @param __responseCb The asynchronous response callback object.
- * @param __exceptionCb The asynchronous exception callback object.
- * @param __sentCb The asynchronous sent callback object.
- * @return The asynchronous result object.
- **/
- @Override
- public final AsyncResult
- begin_ice_ping(IceInternal.Functional_VoidCallback __responseCb,
- IceInternal.Functional_GenericCallback1<Ice.Exception> __exceptionCb,
- IceInternal.Functional_BoolCallback __sentCb)
- {
- return begin_ice_ping(null, false, false, new IceInternal.Functional_OnewayCallback(__responseCb,
- __exceptionCb, __sentCb));
- }
-
- /**
- * Tests whether the target object of this proxy can be reached.
- *
- * @param __context The context map for the invocation.
- * @param __responseCb The asynchronous response callback object.
- * @param __exceptionCb The asynchronous exception callback object.
- * @return The asynchronous result object.
- **/
- @Override
- public final AsyncResult
- begin_ice_ping(java.util.Map<String, String> __context,
- IceInternal.Functional_VoidCallback __responseCb,
- IceInternal.Functional_GenericCallback1<Ice.Exception> __exceptionCb)
- {
- return begin_ice_ping(__context, true, false, new IceInternal.Functional_OnewayCallback(__responseCb,
- __exceptionCb, null));
- }
-
- /**
- * Tests whether the target object of this proxy can be reached.
- *
- * @param __context The context map for the invocation.
- * @param __responseCb The asynchronous response callback object.
- * @param __exceptionCb The asynchronous exception callback object.
- * @param __sentCb The asynchronous sent callback object.
- * @return The asynchronous result object.
- **/
- @Override
- public final AsyncResult
- begin_ice_ping(java.util.Map<String, String> __context,
- IceInternal.Functional_VoidCallback __responseCb,
- IceInternal.Functional_GenericCallback1<Ice.Exception> __exceptionCb,
- IceInternal.Functional_BoolCallback __sentCb)
- {
- return begin_ice_ping(__context, true, false,
- new IceInternal.Functional_OnewayCallback(__responseCb, __exceptionCb, __sentCb));
- }
-
- private AsyncResult begin_ice_ping(java.util.Map<String, String> __context, boolean __explicitCtx,
- boolean __synchronous, IceInternal.CallbackBase __cb)
- {
- IceInternal.OutgoingAsync __result = getOutgoingAsync(__ice_ping_name, __cb);
- try
- {
- __result.prepare(__ice_ping_name, OperationMode.Nonmutating, __context, __explicitCtx, __synchronous);
- __result.writeEmptyParams();
- __result.invoke();
- }
- catch(Exception __ex)
- {
- __result.abort(__ex);
- }
- return __result;
- }
-
- /**
- * Completes the asynchronous ping request.
- *
- * @param __result The asynchronous result.
- **/
- @Override
- public final void
- end_ice_ping(AsyncResult __result)
- {
- __end(__result, __ice_ping_name);
- }
-
- /**
- * Returns the Slice type IDs of the interfaces supported by the target object of this proxy.
- *
- * @return The Slice type IDs of the interfaces supported by the target object, in base-to-derived
- * order. The first element of the returned array is always <code>::Ice::Object</code>.
- **/
- @Override
- public final String[]
- ice_ids()
- {
- return ice_ids(null, false);
- }
-
- /**
- * Returns the Slice type IDs of the interfaces supported by the target object of this proxy.
- *
- * @param __context The <code>Context</code> map for the invocation.
- * @return The Slice type IDs of the interfaces supported by the target object, in base-to-derived
- * order. The first element of the returned array is always <code>::Ice::Object</code>.
- **/
- @Override
- public final String[]
- ice_ids(java.util.Map<String, String> __context)
- {
- return ice_ids(__context, true);
- }
-
- private static final String __ice_ids_name = "ice_ids";
-
- private String[]
- ice_ids(java.util.Map<String, String> __context, boolean __explicitCtx)
- {
- __checkTwowayOnly(__ice_id_name);
- return end_ice_ids(begin_ice_ids(__context, __explicitCtx, true, null));
- }
-
- /**
- * Returns the Slice type IDs of the interfaces supported by the target object of this proxy.
- *
- * @return The asynchronous result object.
- **/
- @Override
- public final AsyncResult
- begin_ice_ids()
- {
- return begin_ice_ids(null, false, false, null);
- }
-
- /**
- * Returns the Slice type IDs of the interfaces supported by the target object of this proxy.
- *
- * @param __context The context map for the invocation.
- * @return The asynchronous result object.
- **/
- @Override
- public final AsyncResult
- begin_ice_ids(java.util.Map<String, String> __context)
- {
- return begin_ice_ids(__context, true, false, null);
- }
-
- /**
- * Returns the Slice type IDs of the interfaces supported by the target object of this proxy.
- *
- * @param __cb The asynchronous callback object.
- * @return The asynchronous result object.
- **/
- @Override
- public final AsyncResult
- begin_ice_ids(Callback __cb)
- {
- return begin_ice_ids(null, false, false,__cb);
- }
-
- /**
- * Returns the Slice type IDs of the interfaces supported by the target object of this proxy.
- *
- * @param __context The context map for the invocation.
- * @param __cb The asynchronous callback object.
- * @return The asynchronous result object.
- **/
- @Override
- public final AsyncResult
- begin_ice_ids(java.util.Map<String, String> __context, Callback __cb)
- {
- return begin_ice_ids(__context, true, false,__cb);
- }
-
- /**
- * Returns the Slice type IDs of the interfaces supported by the target object of this proxy.
- *
- * @param __cb The asynchronous callback object.
- * @return The asynchronous result object.
- **/
- @Override
- public final AsyncResult
- begin_ice_ids(Callback_Object_ice_ids __cb)
- {
- return begin_ice_ids(null, false, false,__cb);
- }
-
- /**
- * Returns the Slice type IDs of the interfaces supported by the target object of this proxy.
- *
- * @param __context The context map for the invocation.
- * @param __cb The asynchronous callback object.
- * @return The asynchronous result object.
- **/
- @Override
- public final AsyncResult
- begin_ice_ids(java.util.Map<String, String> __context, Callback_Object_ice_ids __cb)
- {
- return begin_ice_ids(__context, true, false,__cb);
- }
-
- private class FunctionalCallback_Object_ice_ids extends IceInternal.Functional_TwowayCallbackArg1<String[]>
- {
- FunctionalCallback_Object_ice_ids(IceInternal.Functional_GenericCallback1<String[]> __responseCb,
- IceInternal.Functional_GenericCallback1<Ice.Exception> __exceptionCb,
- IceInternal.Functional_BoolCallback __sentCb)
- {
- super(__responseCb, __exceptionCb, __sentCb);
- }
-
- @Override
- public final void __completed(AsyncResult __result)
- {
- ObjectPrxHelperBase.__ice_ids_completed(this, __result);
- }
- }
-
- /**
- * Returns the Slice type IDs of the interfaces supported by the target object of this proxy.
- *
- * @param __responseCb The asynchronous response callback object.
- * @param __exceptionCb The asynchronous exception callback object.
- * @return The asynchronous result object.
- **/
- @Override
- public final AsyncResult
- begin_ice_ids(IceInternal.Functional_GenericCallback1<String[]> __responseCb,
- IceInternal.Functional_GenericCallback1<Ice.Exception> __exceptionCb)
- {
- return begin_ice_ids(null, false, false, new FunctionalCallback_Object_ice_ids(__responseCb, __exceptionCb,
- null));
- }
-
- /**
- * Returns the Slice type IDs of the interfaces supported by the target object of this proxy.
- *
- * @param __responseCb The asynchronous response callback object.
- * @param __exceptionCb The asynchronous exception callback object.
- * @param __sentCb The asynchronous sent callback object.
- * @return The asynchronous result object.
- **/
- @Override
- public final AsyncResult
- begin_ice_ids(IceInternal.Functional_GenericCallback1<String[]> __responseCb,
- IceInternal.Functional_GenericCallback1<Ice.Exception> __exceptionCb,
- IceInternal.Functional_BoolCallback __sentCb)
- {
- return begin_ice_ids(null, false, false, new FunctionalCallback_Object_ice_ids(__responseCb, __exceptionCb,
- __sentCb));
- }
-
- /**
- * Returns the Slice type IDs of the interfaces supported by the target object of this proxy.
- *
- * @param __context The context map for the invocation.
- * @param __responseCb The asynchronous response callback object.
- * @param __exceptionCb The asynchronous exception callback object.
- * @return The asynchronous result object.
- **/
- @Override
- public final AsyncResult
- begin_ice_ids(java.util.Map<String, String> __context,
- IceInternal.Functional_GenericCallback1<String[]> __responseCb,
- IceInternal.Functional_GenericCallback1<Ice.Exception> __exceptionCb)
- {
- return begin_ice_ids(__context, true, false, new FunctionalCallback_Object_ice_ids(__responseCb, __exceptionCb,
- null));
- }
-
- /**
- * Returns the Slice type IDs of the interfaces supported by the target object of this proxy.
- *
- * @param __context The context map for the invocation.
- * @param __responseCb The asynchronous response callback object.
- * @param __exceptionCb The asynchronous exception callback object.
- * @param __sentCb The asynchronous sent callback object.
- * @return The asynchronous result object.
- **/
- @Override
- public final AsyncResult
- begin_ice_ids(java.util.Map<String, String> __context,
- IceInternal.Functional_GenericCallback1<String[]> __responseCb,
- IceInternal.Functional_GenericCallback1<Ice.Exception> __exceptionCb,
- IceInternal.Functional_BoolCallback __sentCb)
- {
- return begin_ice_ids(__context, true, false,
- new FunctionalCallback_Object_ice_ids(__responseCb, __exceptionCb, __sentCb));
- }
-
- private AsyncResult begin_ice_ids(java.util.Map<String, String> __context, boolean __explicitCtx,
- boolean __synchronous, IceInternal.CallbackBase __cb)
- {
- __checkAsyncTwowayOnly(__ice_ids_name);
- IceInternal.OutgoingAsync __result = getOutgoingAsync(__ice_ids_name, __cb);
- try
- {
- __result.prepare(__ice_ids_name, OperationMode.Nonmutating, __context, __explicitCtx, __synchronous);
- __result.writeEmptyParams();
- __result.invoke();
- }
- catch(Exception __ex)
- {
- __result.abort(__ex);
- }
- return __result;
- }
-
- /**
- * Completes the asynchronous ice_ids request.
- *
- * @param __result The asynchronous result.
- * @return The Slice type IDs of the interfaces supported by the target object, in base-to-derived
- * order. The first element of the returned array is always <code>::Ice::Object</code>.
- **/
- @Override
- public final String[]
- end_ice_ids(AsyncResult __iresult)
- {
- IceInternal.OutgoingAsync __result = IceInternal.OutgoingAsync.check(__iresult, this, __ice_ids_name);
- try
- {
- if(!__result.__wait())
- {
- try
- {
- __result.throwUserException();
- }
- catch(UserException __ex)
- {
- throw new UnknownUserException(__ex.ice_name(), __ex);
- }
- }
- String[] __ret = null;
- IceInternal.BasicStream __is = __result.startReadParams();
- __ret = StringSeqHelper.read(__is);
- __result.endReadParams();
- return __ret;
- }
- finally
- {
- if(__result != null)
- {
- __result.cacheMessageBuffers();
- }
- }
- }
-
- static public final void __ice_ids_completed(TwowayCallbackArg1<String[]> __cb, AsyncResult __result)
- {
- String[] __ret = null;
- try
- {
- __ret = __result.getProxy().end_ice_ids(__result);
- }
- catch(LocalException __ex)
- {
- __cb.exception(__ex);
- return;
- }
- catch(SystemException __ex)
- {
- __cb.exception(__ex);
- return;
- }
- __cb.response(__ret);
- }
-
- /**
- * Returns the Slice type ID of the most-derived interface supported by the target object of this proxy.
- *
- * @return The Slice type ID of the most-derived interface.
- **/
- @Override
- public final String
- ice_id()
- {
- return ice_id(null, false);
- }
-
- /**
- * Returns the Slice type ID of the most-derived interface supported by the target object of this proxy.
- *
- * @param __context The <code>Context</code> map for the invocation.
- * @return The Slice type ID of the most-derived interface.
- **/
- @Override
- public final String
- ice_id(java.util.Map<String, String> __context)
- {
- return ice_id(__context, true);
- }
-
- private static final String __ice_id_name = "ice_id";
-
- private String
- ice_id(java.util.Map<String, String> __context, boolean __explicitCtx)
- {
- __checkTwowayOnly(__ice_id_name);
- return end_ice_id(begin_ice_id(__context, __explicitCtx, true, null));
- }
-
- /**
- * Returns the Slice type ID of the most-derived interface supported by the target object of this proxy.
- *
- * @return The asynchronous result object.
- **/
- @Override
- public final AsyncResult
- begin_ice_id()
- {
- return begin_ice_id(null, false, false, null);
- }
-
- /**
- * Returns the Slice type ID of the most-derived interface supported by the target object of this proxy.
- *
- * @param __context The context map for the invocation.
- * @return The asynchronous result object.
- **/
- @Override
- public final AsyncResult
- begin_ice_id(java.util.Map<String, String> __context)
- {
- return begin_ice_id(__context, true, false, null);
- }
-
- /**
- * Returns the Slice type ID of the most-derived interface supported by the target object of this proxy.
- *
- * @param __cb The asynchronous callback object.
- * @return The asynchronous result object.
- **/
- @Override
- public final AsyncResult
- begin_ice_id(Callback __cb)
- {
- return begin_ice_id(null, false, false, __cb);
- }
-
- /**
- * Returns the Slice type ID of the most-derived interface supported by the target object of this proxy.
- *
- * @param __context The context map for the invocation.
- * @param __cb The asynchronous callback object.
- * @return The asynchronous result object.
- **/
- @Override
- public final AsyncResult
- begin_ice_id(java.util.Map<String, String> __context, Callback __cb)
- {
- return begin_ice_id(__context, true, false, __cb);
- }
-
- /**
- * Returns the Slice type ID of the most-derived interface supported by the target object of this proxy.
- *
- * @param __cb The asynchronous callback object.
- * @return The asynchronous result object.
- **/
- @Override
- public final AsyncResult
- begin_ice_id(Callback_Object_ice_id __cb)
- {
- return begin_ice_id(null, false, false, __cb);
- }
-
- /**
- * Returns the Slice type ID of the most-derived interface supported by the target object of this proxy.
- *
- * @param __context The context map for the invocation.
- * @param __cb The asynchronous callback object.
- * @return The asynchronous result object.
- **/
- @Override
- public final AsyncResult
- begin_ice_id(java.util.Map<String, String> __context, Callback_Object_ice_id __cb)
- {
- return begin_ice_id(__context, true, false, __cb);
- }
-
- private class FunctionalCallback_Object_ice_id extends IceInternal.Functional_TwowayCallbackArg1<String>
- {
- FunctionalCallback_Object_ice_id(IceInternal.Functional_GenericCallback1<String> responseCb,
- IceInternal.Functional_GenericCallback1<Ice.Exception> exceptionCb,
- IceInternal.Functional_BoolCallback sentCb)
- {
- super(responseCb, exceptionCb, sentCb);
- }
-
- @Override
- public final void __completed(AsyncResult __result)
- {
- ObjectPrxHelperBase.__ice_id_completed(this, __result);
- }
- }
-
- /**
- * Returns the Slice type ID of the most-derived interface supported by the target object of this proxy.
- *
- * @param __responseCb The asynchronous response callback object.
- * @param __exceptionCb The asynchronous exception callback object.
- * @return The asynchronous result object.
- **/
- @Override
- public final AsyncResult
- begin_ice_id(IceInternal.Functional_GenericCallback1<String> __responseCb,
- IceInternal.Functional_GenericCallback1<Ice.Exception> __exceptionCb)
- {
- return begin_ice_id(null, false, false, new FunctionalCallback_Object_ice_id(__responseCb, __exceptionCb, null));
- }
-
- /**
- * Returns the Slice type ID of the most-derived interface supported by the target object of this proxy.
- *
- * @param __responseCb The asynchronous response callback object.
- * @param __exceptionCb The asynchronous exception callback object.
- * @param __sentCb The asynchronous sent callback object.
- * @return The asynchronous result object.
- **/
- @Override
- public final AsyncResult
- begin_ice_id(IceInternal.Functional_GenericCallback1<String> __responseCb,
- IceInternal.Functional_GenericCallback1<Ice.Exception> __exceptionCb,
- IceInternal.Functional_BoolCallback __sentCb)
- {
- return begin_ice_id(null, false, false, new FunctionalCallback_Object_ice_id(__responseCb, __exceptionCb, __sentCb));
- }
-
- /**
- * Returns the Slice type ID of the most-derived interface supported by the target object of this proxy.
- *
- * @param __context The context map for the invocation.
- * @param __responseCb The asynchronous response callback object.
- * @param __exceptionCb The asynchronous exception callback object.
- * @return The asynchronous result object.
- **/
- @Override
- public final AsyncResult
- begin_ice_id(java.util.Map<String, String> __context,
- IceInternal.Functional_GenericCallback1<String> __responseCb,
- IceInternal.Functional_GenericCallback1<Ice.Exception> __exceptionCb)
- {
- return begin_ice_id(__context, true, false, new FunctionalCallback_Object_ice_id(__responseCb, __exceptionCb, null));
- }
-
- /**
- * Returns the Slice type ID of the most-derived interface supported by the target object of this proxy.
- *
- * @param __context The context map for the invocation.
- * @param __responseCb The asynchronous response callback object.
- * @param __exceptionCb The asynchronous exception callback object.
- * @param __sentCb The asynchronous sent callback object.
- * @return The asynchronous result object.
- **/
- @Override
- public final AsyncResult
- begin_ice_id(java.util.Map<String, String> __context,
- IceInternal.Functional_GenericCallback1<String> __responseCb,
- IceInternal.Functional_GenericCallback1<Ice.Exception> __exceptionCb,
- IceInternal.Functional_BoolCallback __sentCb)
- {
- return begin_ice_id(__context, true, false,
- new FunctionalCallback_Object_ice_id(__responseCb, __exceptionCb, __sentCb));
- }
-
- private AsyncResult begin_ice_id(java.util.Map<String, String> __context, boolean __explicitCtx,
- boolean __synchronous, IceInternal.CallbackBase __cb)
- {
- __checkAsyncTwowayOnly(__ice_id_name);
- IceInternal.OutgoingAsync __result = getOutgoingAsync(__ice_id_name, __cb);
- try
- {
- __result.prepare(__ice_id_name, OperationMode.Nonmutating, __context, __explicitCtx, __synchronous);
- __result.writeEmptyParams();
- __result.invoke();
- }
- catch(Exception __ex)
- {
- __result.abort(__ex);
- }
- return __result;
- }
-
- /**
- * Completes the asynchronous ice_id request.
- *
- * @param __result The asynchronous result.
- * @return The Slice type ID of the most-derived interface.
- **/
- @Override
- public final String
- end_ice_id(AsyncResult __iresult)
- {
- IceInternal.OutgoingAsync __result = IceInternal.OutgoingAsync.check(__iresult, this, __ice_id_name);
- try
- {
- if(!__result.__wait())
- {
- try
- {
- __result.throwUserException();
- }
- catch(UserException __ex)
- {
- throw new UnknownUserException(__ex.ice_name(), __ex);
- }
- }
- String __ret = null;
- IceInternal.BasicStream __is = __result.startReadParams();
- __ret = __is.readString();
- __result.endReadParams();
- return __ret;
- }
- finally
- {
- if(__result != null)
- {
- __result.cacheMessageBuffers();
- }
- }
- }
-
- static public final void __ice_id_completed(TwowayCallbackArg1<String> __cb, AsyncResult __result)
- {
- String __ret = null;
- try
- {
- __ret = __result.getProxy().end_ice_id(__result);
- }
- catch(LocalException __ex)
- {
- __cb.exception(__ex);
- return;
- }
- catch(SystemException __ex)
- {
- __cb.exception(__ex);
- return;
- }
- __cb.response(__ret);
- }
-
- /**
- * Invoke an operation dynamically.
- *
- * @param operation The name of the operation to invoke.
- * @param mode The operation mode (normal or idempotent).
- * @param inParams The encoded in-parameters for the operation.
- * @param outParams The encoded out-paramaters and return value
- * for the operation. The return value follows any out-parameters.
- * @return If the operation completed successfully, the return value
- * is <code>true</code>. If the operation raises a user exception,
- * the return value is <code>false</code>; in this case, <code>outParams</code>
- * contains the encoded user exception. If the operation raised an
- * it throws it directly.
- *
- * @see Blobject
- * @see OperationMode
- **/
- @Override
- public final boolean
- ice_invoke(String operation, OperationMode mode, byte[] inParams, ByteSeqHolder outParams)
- {
- return ice_invoke(operation, mode, inParams, outParams, null, false);
- }
-
- /**
- * Invoke an operation dynamically.
- *
- * @param operation The name of the operation to invoke.
- * @param mode The operation mode (normal or idempotent).
- * @param inParams The encoded in-parameters for the operation.
- * @param outParams The encoded out-paramaters and return value
- * for the operation. The return value follows any out-parameters.
- * @param __context The context map for the invocation.
- * @return If the operation was invoked synchronously (because there
- * was no need to queue the request), the return value is <code>true</code>;
- * otherwise, if the invocation was queued, the return value is <code>false</code>.
- *
- * @see Blobject
- * @see OperationMode
- **/
- @Override
- public final boolean
- ice_invoke(String operation, OperationMode mode, byte[] inParams, ByteSeqHolder outParams,
- java.util.Map<String, String> context)
- {
- return ice_invoke(operation, mode, inParams, outParams, context, true);
- }
-
- private boolean
- ice_invoke(String operation, OperationMode mode, byte[] inParams, ByteSeqHolder outParams,
- java.util.Map<String, String> context, boolean explicitCtx)
- {
- return end_ice_invoke(outParams, begin_ice_invoke(operation, mode, inParams, context, explicitCtx, true, null));
- }
-
- private static final String __ice_invoke_name = "ice_invoke";
-
- /**
- * Invokes an operation dynamically and asynchronously.
- *
- * @param operation The name of the operation to invoke.
- * @param mode The operation mode (normal or idempotent).
- * @param inParams The encoded in-parameters for the operation.
- * @return The asynchronous result object.
- *
- * @see Blobject
- * @see OperationMode
- **/
- @Override
- public final AsyncResult
- begin_ice_invoke(String operation, OperationMode mode, byte[] inParams)
- {
- return begin_ice_invoke(operation, mode, inParams, null, false, false, null);
- }
-
- /**
- * Invokes an operation dynamically and asynchronously.
- *
- * @param operation The name of the operation to invoke.
- * @param mode The operation mode (normal or idempotent).
- * @param inParams The encoded in-parameters for the operation.
- * for the operation. The return value follows any out-parameters.
- * @param __context The context map for the invocation.
- * @return The asynchronous result object.
- *
- * @see Blobject
- * @see OperationMode
- **/
- @Override
- public final AsyncResult
- begin_ice_invoke(String operation, OperationMode mode, byte[] inParams,
- java.util.Map<String, String> __context)
- {
- return begin_ice_invoke(operation, mode, inParams, __context, true, false, null);
- }
-
- /**
- * Invokes an operation dynamically and asynchronously.
- *
- * @param operation The name of the operation to invoke.
- * @param mode The operation mode (normal or idempotent).
- * @param inParams The encoded in-parameters for the operation.
- * for the operation. The return value follows any out-parameters.
- * @param __cb The asynchronous callback object.
- * @return The asynchronous result object.
- *
- * @see Blobject
- * @see OperationMode
- **/
- @Override
- public final AsyncResult
- begin_ice_invoke(String operation, OperationMode mode, byte[] inParams, Callback __cb)
- {
- return begin_ice_invoke(operation, mode, inParams, null, false, false, __cb);
- }
-
- /**
- * Invokes an operation dynamically and asynchronously.
- *
- * @param operation The name of the operation to invoke.
- * @param mode The operation mode (normal or idempotent).
- * @param inParams The encoded in-parameters for the operation.
- * for the operation. The return value follows any out-parameters.
- * @param __context The context map for the invocation.
- * @param __cb The asynchronous callback object.
- * @return The asynchronous result object.
- *
- * @see Blobject
- * @see OperationMode
- **/
- @Override
- public final AsyncResult
- begin_ice_invoke(String operation, OperationMode mode, byte[] inParams, java.util.Map<String, String> __context,
- Callback __cb)
- {
- return begin_ice_invoke(operation, mode, inParams, __context, true, false, __cb);
- }
-
- /**
- * Invokes an operation dynamically and asynchronously.
- *
- * @param operation The name of the operation to invoke.
- * @param mode The operation mode (normal or idempotent).
- * @param inParams The encoded in-parameters for the operation.
- * for the operation. The return value follows any out-parameters.
- * @param __cb The asynchronous callback object.
- * @return The asynchronous result object.
- *
- * @see Blobject
- * @see OperationMode
- **/
- @Override
- public final AsyncResult
- begin_ice_invoke(String operation, OperationMode mode, byte[] inParams, Callback_Object_ice_invoke __cb)
- {
- return begin_ice_invoke(operation, mode, inParams, null, false, false, __cb);
- }
-
- /**
- * Invokes an operation dynamically and asynchronously.
- *
- * @param operation The name of the operation to invoke.
- * @param mode The operation mode (normal or idempotent).
- * @param inParams The encoded in-parameters for the operation.
- * for the operation. The return value follows any out-parameters.
- * @param __context The context map for the invocation.
- * @param __cb The asynchronous callback object.
- * @return The asynchronous result object.
- *
- * @see Blobject
- * @see OperationMode
- **/
- @Override
- public final AsyncResult
- begin_ice_invoke(String operation, OperationMode mode, byte[] inParams, java.util.Map<String, String> __context,
- Callback_Object_ice_invoke __cb)
- {
- return begin_ice_invoke(operation, mode, inParams, __context, true, false, __cb);
- }
-
- /**
- * Invokes an operation dynamically and asynchronously.
- *
- * @param operation The name of the operation to invoke.
- * @param mode The operation mode (normal or idempotent).
- * @param inParams The encoded in-parameters for the operation.
- * for the operation. The return value follows any out-parameters.
- * @param __responseCb The asynchronous response callback object.
- * @param __exceptionCb The asynchronous exception callback object.
- * @param __sentCb The asynchronous sent callback object.
- * @return The asynchronous result object.
- *
- * @see Blobject
- * @see OperationMode
- **/
- @Override
- public final AsyncResult begin_ice_invoke(String operation, OperationMode mode, byte[] inParams,
- FunctionalCallback_Object_ice_invoke_Response responseCb,
- IceInternal.Functional_GenericCallback1<Ice.Exception> exceptionCb,
- IceInternal.Functional_BoolCallback sentCb)
- {
- return begin_ice_invoke(operation, mode, inParams, null, false, false, responseCb, exceptionCb, sentCb);
- }
-
- /**
- * Invokes an operation dynamically and asynchronously.
- *
- * @param operation The name of the operation to invoke.
- * @param mode The operation mode (normal or idempotent).
- * @param inParams The encoded in-parameters for the operation.
- * for the operation. The return value follows any out-parameters.
- * @param __responseCb The asynchronous response callback object.
- * @param __exceptionCb The asynchronous exception callback object.
- * @return The asynchronous result object.
- *
- * @see Blobject
- * @see OperationMode
- **/
- @Override
- public final AsyncResult begin_ice_invoke(String operation, OperationMode mode, byte[] inParams,
- FunctionalCallback_Object_ice_invoke_Response responseCb,
- IceInternal.Functional_GenericCallback1<Ice.Exception> exceptionCb)
- {
- return begin_ice_invoke(operation, mode, inParams, null, false, false, responseCb, exceptionCb, null);
- }
-
- /**
- * Invokes an operation dynamically and asynchronously.
- *
- * @param operation The name of the operation to invoke.
- * @param mode The operation mode (normal or idempotent).
- * @param inParams The encoded in-parameters for the operation.
- * @param __context The context map for the invocation.
- * for the operation. The return value follows any out-parameters.
- * @param __responseCb The asynchronous response callback object.
- * @param __exceptionCb The asynchronous exception callback object.
- * @param __sentCb The asynchronous sent callback object.
- * @return The asynchronous result object.
- *
- * @see Blobject
- * @see OperationMode
- **/
- @Override
- public final AsyncResult begin_ice_invoke(String operation, OperationMode mode, byte[] inParams,
- java.util.Map<String, String> context,
- FunctionalCallback_Object_ice_invoke_Response responseCb,
- IceInternal.Functional_GenericCallback1<Ice.Exception> exceptionCb,
- IceInternal.Functional_BoolCallback sentCb)
- {
- return begin_ice_invoke(operation, mode, inParams, context, true, false, responseCb, exceptionCb, sentCb);
- }
-
- /**
- * Invokes an operation dynamically and asynchronously.
- *
- * @param operation The name of the operation to invoke.
- * @param mode The operation mode (normal or idempotent).
- * @param inParams The encoded in-parameters for the operation.
- * @param __context The context map for the invocation.
- * for the operation. The return value follows any out-parameters.
- * @param __responseCb The asynchronous response callback object.
- * @param __exceptionCb The asynchronous exception callback object.
- * @return The asynchronous result object.
- *
- * @see Blobject
- * @see OperationMode
- **/
- @Override
- public final AsyncResult begin_ice_invoke(String operation, OperationMode mode, byte[] inParams,
- java.util.Map<String, String> context,
- FunctionalCallback_Object_ice_invoke_Response responseCb,
- IceInternal.Functional_GenericCallback1<Ice.Exception> exceptionCb)
- {
- return begin_ice_invoke(operation, mode, inParams, context, true, false, responseCb, exceptionCb, null);
- }
-
- private final AsyncResult begin_ice_invoke(String operation, OperationMode mode, byte[] inParams,
- java.util.Map<String, String> __context,
- boolean __explicitCtx,
- boolean __synchronous,
- FunctionalCallback_Object_ice_invoke_Response __responseCb,
- IceInternal.Functional_GenericCallback1<Ice.Exception> __exceptionCb,
- IceInternal.Functional_BoolCallback __sentCb)
- {
- class CB extends IceInternal.Functional_TwowayCallback implements _Callback_Object_ice_invoke
- {
- CB(FunctionalCallback_Object_ice_invoke_Response responseCb,
- IceInternal.Functional_GenericCallback1<Ice.Exception> exceptionCb,
- IceInternal.Functional_BoolCallback sentCb)
- {
- super(responseCb != null, exceptionCb, sentCb);
- __responseCb = responseCb;
- }
-
- @Override
- public void response(boolean __ret, byte[] outParams)
- {
- __responseCb.apply(__ret, outParams);
- }
-
- @Override
- public final void __completed(AsyncResult __result)
- {
- ObjectPrxHelperBase.__ice_invoke_completed(this, __result);
- }
-
- FunctionalCallback_Object_ice_invoke_Response __responseCb;
- }
- return begin_ice_invoke(operation, mode, inParams, __context, __explicitCtx, __synchronous,
- new CB(__responseCb, __exceptionCb, __sentCb));
- }
-
- private AsyncResult
- begin_ice_invoke(String operation, OperationMode mode, byte[] inParams, java.util.Map<String, String> __context,
- boolean __explicitCtx, boolean __synchronous, IceInternal.CallbackBase __cb)
- {
- IceInternal.OutgoingAsync __result = getOutgoingAsync(__ice_invoke_name, __cb);
- try
- {
- __result.prepare(operation, mode, __context, __explicitCtx, __synchronous);
- __result.writeParamEncaps(inParams);
- __result.invoke();
- }
- catch(Exception __ex)
- {
- __result.abort(__ex);
- }
- return __result;
- }
-
- /**
- * Completes the asynchronous ice_invoke request.
- *
- * @param outParams The encoded out-paramaters and return value.
- * @param __result The asynchronous result.
- * @return If the operation completed successfully, the return value
- * is <code>true</code>. If the operation raises a user exception,
- * the return value is <code>false</code>; in this case, <code>outParams</code>
- * contains the encoded user exception. If the operation raises a run-time exception,
- * it throws it directly.
- **/
- @Override
- public final boolean
- end_ice_invoke(ByteSeqHolder outParams, AsyncResult __iresult)
- {
- IceInternal.OutgoingAsync __result = IceInternal.OutgoingAsync.check(__iresult, this, __ice_invoke_name);
- try
- {
- boolean ok = __result.__wait();
- if(_reference.getMode() == IceInternal.Reference.ModeTwoway)
- {
- if(outParams != null)
- {
- outParams.value = __result.readParamEncaps();
- }
- }
- return ok;
- }
- finally
- {
- if(__result != null)
- {
- __result.cacheMessageBuffers();
- }
- }
- }
-
- public static void __ice_invoke_completed(_Callback_Object_ice_invoke __cb, AsyncResult __result)
- {
- ByteSeqHolder outParams = new ByteSeqHolder();
- boolean __ret = false;
- try
- {
- __ret = __result.getProxy().end_ice_invoke(outParams, __result);
- }
- catch(LocalException __ex)
- {
- __cb.exception(__ex);
- return;
- }
- catch(SystemException __ex)
- {
- __cb.exception(__ex);
- return;
- }
- __cb.response(__ret, outParams.value);
- }
-
- /**
- * Returns the identity embedded in this proxy.
- *
- * @return The identity of the target object.
- **/
- @Override
- public final Identity
- ice_getIdentity()
- {
- return (Identity)_reference.getIdentity().clone();
- }
-
- /**
- * Creates a new proxy that is identical to this proxy, except for the identity.
- *
- * @param newIdentity The identity for the new proxy.
- * @return The proxy with the new identity.
- **/
- @Override
- public final ObjectPrx
- ice_identity(Identity newIdentity)
- {
- if(newIdentity.name.equals(""))
- {
- throw new IllegalIdentityException();
- }
- if(newIdentity.equals(_reference.getIdentity()))
- {
- return this;
- }
- else
- {
- ObjectPrxHelperBase proxy = new ObjectPrxHelperBase();
- proxy.__setup(_reference.changeIdentity(newIdentity));
- return proxy;
- }
- }
-
- /**
- * Returns the per-proxy context for this proxy.
- *
- * @return The per-proxy context. If the proxy does not have a per-proxy (implicit) context, the return value
- * is <code>null</code>.
- **/
- @Override
- public final java.util.Map<String, String>
- ice_getContext()
- {
- return new java.util.HashMap<String, String>(_reference.getContext());
- }
-
- /**
- * Creates a new proxy that is identical to this proxy, except for the per-proxy context.
- *
- * @param newContext The context for the new proxy.
- * @return The proxy with the new per-proxy context.
- **/
- @Override
- public final ObjectPrx
- ice_context(java.util.Map<String, String> newContext)
- {
- return newInstance(_reference.changeContext(newContext));
- }
-
- /**
- * Returns the facet for this proxy.
- *
- * @return The facet for this proxy. If the proxy uses the default facet, the return value is the empty string.
- **/
- @Override
- public final String
- ice_getFacet()
- {
- return _reference.getFacet();
- }
-
- /**
- * Creates a new proxy that is identical to this proxy, except for the facet.
- *
- * @param newFacet The facet for the new proxy.
- * @return The proxy with the new facet.
- **/
- @Override
- public final ObjectPrx
- ice_facet(String newFacet)
- {
- if(newFacet == null)
- {
- newFacet = "";
- }
-
- if(newFacet.equals(_reference.getFacet()))
- {
- return this;
- }
- else
- {
- ObjectPrxHelperBase proxy = new ObjectPrxHelperBase();
- proxy.__setup(_reference.changeFacet(newFacet));
- return proxy;
- }
- }
-
- /**
- * Returns the adapter ID for this proxy.
- *
- * @return The adapter ID. If the proxy does not have an adapter ID, the return value is the empty string.
- **/
- @Override
- public final String
- ice_getAdapterId()
- {
- return _reference.getAdapterId();
- }
-
- /**
- * Creates a new proxy that is identical to this proxy, except for the adapter ID.
- *
- * @param newAdapterId The adapter ID for the new proxy.
- * @return The proxy with the new adapter ID.
- **/
- @Override
- public final ObjectPrx
- ice_adapterId(String newAdapterId)
- {
- if(newAdapterId == null)
- {
- newAdapterId = "";
- }
-
- if(newAdapterId.equals(_reference.getAdapterId()))
- {
- return this;
- }
- else
- {
- return newInstance(_reference.changeAdapterId(newAdapterId));
- }
- }
-
- /**
- * Returns the endpoints used by this proxy.
- *
- * @return The endpoints used by this proxy.
- *
- * @see Endpoint
- **/
- @Override
- public final Endpoint[]
- ice_getEndpoints()
- {
- return _reference.getEndpoints().clone();
- }
-
- /**
- * Creates a new proxy that is identical to this proxy, except for the endpoints.
- *
- * @param newEndpoints The endpoints for the new proxy.
- * @return The proxy with the new endpoints.
- **/
- @Override
- public final ObjectPrx
- ice_endpoints(Endpoint[] newEndpoints)
- {
- if(java.util.Arrays.equals(newEndpoints, _reference.getEndpoints()))
- {
- return this;
- }
- else
- {
- IceInternal.EndpointI[] edpts = new IceInternal.EndpointI[newEndpoints.length];
- edpts = java.util.Arrays.asList(newEndpoints).toArray(edpts);
- return newInstance(_reference.changeEndpoints(edpts));
- }
- }
-
- /**
- * Returns the locator cache timeout of this proxy.
- *
- * @return The locator cache timeout value (in seconds).
- *
- * @see Locator
- **/
- @Override
- public final int
- ice_getLocatorCacheTimeout()
- {
- return _reference.getLocatorCacheTimeout();
- }
-
- /**
- * Returns the invocation timeout of this proxy.
- *
- * @return The invocation timeout value (in seconds).
- **/
- @Override
- public final int
- ice_getInvocationTimeout()
- {
- return _reference.getInvocationTimeout();
- }
-
- /**
- * Returns the connection id of this proxy.
- *
- * @return The connection id.
- *
- **/
- @Override
- public final String
- ice_getConnectionId()
- {
- return _reference.getConnectionId();
- }
-
- /**
- * Creates a new proxy that is identical to this proxy, except for the locator cache timeout.
- *
- * @param newTimeout The new locator cache timeout (in seconds).
- *
- * @see Locator
- **/
- @Override
- public final ObjectPrx
- ice_locatorCacheTimeout(int newTimeout)
- {
- if(newTimeout < -1)
- {
- throw new IllegalArgumentException("invalid value passed to ice_locatorCacheTimeout: " + newTimeout);
- }
- if(newTimeout == _reference.getLocatorCacheTimeout())
- {
- return this;
- }
- else
- {
- return newInstance(_reference.changeLocatorCacheTimeout(newTimeout));
- }
- }
-
- /**
- * Creates a new proxy that is identical to this proxy, except for the invocation timeout.
- *
- * @param newTimeout The new invocation timeout (in seconds).
- **/
- @Override
- public final ObjectPrx
- ice_invocationTimeout(int newTimeout)
- {
- if(newTimeout < 1 && newTimeout != -1 && newTimeout != -2)
- {
- throw new IllegalArgumentException("invalid value passed to ice_invocationTimeout: " + newTimeout);
- }
- if(newTimeout == _reference.getInvocationTimeout())
- {
- return this;
- }
- else
- {
- return newInstance(_reference.changeInvocationTimeout(newTimeout));
- }
- }
-
- /**
- * Returns whether this proxy caches connections.
- *
- * @return <code>true</code> if this proxy caches connections; <code>false</code>, otherwise.
- **/
- @Override
- public final boolean
- ice_isConnectionCached()
- {
- return _reference.getCacheConnection();
- }
-
- /**
- * Creates a new proxy that is identical to this proxy, except for connection caching.
- *
- * @param newCache <code>true</code> if the new proxy should cache connections; <code>false</code>, otherwise.
- * @return The new proxy with the specified caching policy.
- **/
- @Override
- public final ObjectPrx
- ice_connectionCached(boolean newCache)
- {
- if(newCache == _reference.getCacheConnection())
- {
- return this;
- }
- else
- {
- return newInstance(_reference.changeCacheConnection(newCache));
- }
- }
-
- /**
- * Returns how this proxy selects endpoints (randomly or ordered).
- *
- * @return The endpoint selection policy.
- *
- * @see EndpointSelectionType
- **/
- @Override
- public final Ice.EndpointSelectionType
- ice_getEndpointSelection()
- {
- return _reference.getEndpointSelection();
- }
-
- /**
- * Creates a new proxy that is identical to this proxy, except for the endpoint selection policy.
- *
- * @param newType The new endpoint selection policy.
- * @return The new proxy with the specified endpoint selection policy.
- *
- * @see EndpointSelectionType
- **/
- @Override
- public final ObjectPrx
- ice_endpointSelection(Ice.EndpointSelectionType newType)
- {
- if(newType == _reference.getEndpointSelection())
- {
- return this;
- }
- else
- {
- return newInstance(_reference.changeEndpointSelection(newType));
- }
- }
-
- /**
- * Returns whether this proxy uses only secure endpoints.
- *
- * @return <code>true</code> if all endpoints for this proxy are secure; <code>false</code>, otherwise.
- **/
- @Override
- public final boolean
- ice_isSecure()
- {
- return _reference.getSecure();
- }
-
- /**
- * Creates a new proxy that is identical to this proxy, except for its endpoints.
- *
- * @param If <code>b</code> is <code>true</code>, only endpoints that use a secure transport are
- * retained for the new proxy. If <code>b</code> is false, the returned proxy is identical to this proxy.
- * @return The new proxy with possible different endpoints.k
- **/
- @Override
- public final ObjectPrx
- ice_secure(boolean b)
- {
- if(b == _reference.getSecure())
- {
- return this;
- }
- else
- {
- return newInstance(_reference.changeSecure(b));
- }
- }
-
- /**
- * Creates a new proxy that is identical to this proxy, except for the encoding used to marshal
- * parameters.
- *
- * @param e The encoding version to use to marshal requests parameters.
- * @return The new proxy with the specified encoding version.
- **/
- @Override
- public final ObjectPrx
- ice_encodingVersion(Ice.EncodingVersion e)
- {
- if(e.equals(_reference.getEncoding()))
- {
- return this;
- }
- else
- {
- return newInstance(_reference.changeEncoding(e));
- }
- }
-
- /**
- * Returns the encoding version used to marshal requests parameters.
- *
- * @return The encoding version.
- **/
- @Override
- public final Ice.EncodingVersion
- ice_getEncodingVersion()
- {
- return (Ice.EncodingVersion)_reference.getEncoding().clone();
- }
-
- /**
- * Returns whether this proxy prefers secure endpoints.
- *
- * @return <code>true</code> if the proxy always attempts to invoke via secure endpoints before it
- * attempts to use insecure endpoints; <code>false</code>, otherwise;
- **/
- @Override
- public final boolean
- ice_isPreferSecure()
- {
- return _reference.getPreferSecure();
- }
-
- /**
- * Creates a new proxy that is identical to this proxy, except for its endpoint selection policy.
- *
- * @param b If <code>b</code> is <code>true</code>, the new proxy will use secure endpoints for invocations
- * and only use insecure endpoints if an invocation cannot be made via secure endpoints. If <code>b</code> is
- * <code>false</code>, the proxy prefers insecure endpoints to secure ones.
- * @return The new proxy with the new endpoint selection policy.
- **/
- @Override
- public final ObjectPrx
- ice_preferSecure(boolean b)
- {
- if(b == _reference.getPreferSecure())
- {
- return this;
- }
- else
- {
- return newInstance(_reference.changePreferSecure(b));
- }
- }
-
- /**
- * Returns the router for this proxy.
- *
- * @return The router for the proxy. If no router is configured for the proxy, the return value
- * is <code>null</code>.
- **/
- @Override
- public final Ice.RouterPrx
- ice_getRouter()
- {
- IceInternal.RouterInfo ri = _reference.getRouterInfo();
- return ri != null ? ri.getRouter() : null;
- }
-
- /**
- * Creates a new proxy that is identical to this proxy, except for the router.
- *
- * @param router The router for the new proxy.
- * @return The new proxy with the specified router.
- **/
- @Override
- public final ObjectPrx
- ice_router(Ice.RouterPrx router)
- {
- IceInternal.Reference ref = _reference.changeRouter(router);
- if(ref.equals(_reference))
- {
- return this;
- }
- else
- {
- return newInstance(ref);
- }
- }
-
- /**
- * Returns the locator for this proxy.
- *
- * @return The locator for this proxy. If no locator is configured, the return value is <code>null</code>.
- **/
- @Override
- public final Ice.LocatorPrx
- ice_getLocator()
- {
- IceInternal.LocatorInfo ri = _reference.getLocatorInfo();
- return ri != null ? ri.getLocator() : null;
- }
-
- /**
- * Creates a new proxy that is identical to this proxy, except for the locator.
- *
- * @param The locator for the new proxy.
- * @return The new proxy with the specified locator.
- **/
- @Override
- public final ObjectPrx
- ice_locator(Ice.LocatorPrx locator)
- {
- IceInternal.Reference ref = _reference.changeLocator(locator);
- if(ref.equals(_reference))
- {
- return this;
- }
- else
- {
- return newInstance(ref);
- }
- }
-
- /**
- * Returns whether this proxy uses collocation optimization.
- *
- * @return <code>true</code> if the proxy uses collocation optimization; <code>false</code>, otherwise.
- **/
- @Override
- public final boolean
- ice_isCollocationOptimized()
- {
- return _reference.getCollocationOptimized();
- }
-
- /**
- * Creates a new proxy that is identical to this proxy, except for collocation optimization.
- *
- * @param b <code>true</code> if the new proxy enables collocation optimization; <code>false</code>, otherwise.
- * @return The new proxy the specified collocation optimization.
- **/
- @Override
- public final ObjectPrx
- ice_collocationOptimized(boolean b)
- {
- if(b == _reference.getCollocationOptimized())
- {
- return this;
- }
- else
- {
- return newInstance(_reference.changeCollocationOptimized(b));
- }
- }
-
- /**
- * Creates a new proxy that is identical to this proxy, but uses twoway invocations.
- *
- * @return A new proxy that uses twoway invocations.
- **/
- @Override
- public final ObjectPrx
- ice_twoway()
- {
- if(_reference.getMode() == IceInternal.Reference.ModeTwoway)
- {
- return this;
- }
- else
- {
- return newInstance(_reference.changeMode(IceInternal.Reference.ModeTwoway));
- }
- }
-
- /**
- * Returns whether this proxy uses twoway invocations.
- * @return <code>true</code> if this proxy uses twoway invocations; <code>false</code>, otherwise.
- **/
- @Override
- public final boolean
- ice_isTwoway()
- {
- return _reference.getMode() == IceInternal.Reference.ModeTwoway;
- }
-
- /**
- * Creates a new proxy that is identical to this proxy, but uses oneway invocations.
- *
- * @return A new proxy that uses oneway invocations.
- **/
- @Override
- public final ObjectPrx
- ice_oneway()
- {
- if(_reference.getMode() == IceInternal.Reference.ModeOneway)
- {
- return this;
- }
- else
- {
- return newInstance(_reference.changeMode(IceInternal.Reference.ModeOneway));
- }
- }
-
- /**
- * Returns whether this proxy uses oneway invocations.
- * @return <code>true</code> if this proxy uses oneway invocations; <code>false</code>, otherwise.
- **/
- @Override
- public final boolean
- ice_isOneway()
- {
- return _reference.getMode() == IceInternal.Reference.ModeOneway;
- }
-
- /**
- * Creates a new proxy that is identical to this proxy, but uses batch oneway invocations.
- *
- * @return A new proxy that uses batch oneway invocations.
- **/
- @Override
- public final ObjectPrx
- ice_batchOneway()
- {
- if(_reference.getMode() == IceInternal.Reference.ModeBatchOneway)
- {
- return this;
- }
- else
- {
- return newInstance(_reference.changeMode(IceInternal.Reference.ModeBatchOneway));
- }
- }
-
- /**
- * Returns whether this proxy uses batch oneway invocations.
- * @return <code>true</code> if this proxy uses batch oneway invocations; <code>false</code>, otherwise.
- **/
- @Override
- public final boolean
- ice_isBatchOneway()
- {
- return _reference.getMode() == IceInternal.Reference.ModeBatchOneway;
- }
-
- /**
- * Creates a new proxy that is identical to this proxy, but uses datagram invocations.
- *
- * @return A new proxy that uses datagram invocations.
- **/
- @Override
- public final ObjectPrx
- ice_datagram()
- {
- if(_reference.getMode() == IceInternal.Reference.ModeDatagram)
- {
- return this;
- }
- else
- {
- return newInstance(_reference.changeMode(IceInternal.Reference.ModeDatagram));
- }
- }
-
- /**
- * Returns whether this proxy uses datagram invocations.
- * @return <code>true</code> if this proxy uses datagram invocations; <code>false</code>, otherwise.
- **/
- @Override
- public final boolean
- ice_isDatagram()
- {
- return _reference.getMode() == IceInternal.Reference.ModeDatagram;
- }
-
- /**
- * Creates a new proxy that is identical to this proxy, but uses batch datagram invocations.
- *
- * @return A new proxy that uses batch datagram invocations.
- **/
- @Override
- public final ObjectPrx
- ice_batchDatagram()
- {
- if(_reference.getMode() == IceInternal.Reference.ModeBatchDatagram)
- {
- return this;
- }
- else
- {
- return newInstance(_reference.changeMode(IceInternal.Reference.ModeBatchDatagram));
- }
- }
-
- /**
- * Returns whether this proxy uses batch datagram invocations.
- * @return <code>true</code> if this proxy uses batch datagram invocations; <code>false</code>, otherwise.
- **/
- @Override
- public final boolean
- ice_isBatchDatagram()
- {
- return _reference.getMode() == IceInternal.Reference.ModeBatchDatagram;
- }
-
- /**
- * Creates a new proxy that is identical to this proxy, except for compression.
- *
- * @param co <code>true</code> enables compression for the new proxy; <code>false</code>disables compression.
- * @return A new proxy with the specified compression setting.
- **/
- @Override
- public final ObjectPrx
- ice_compress(boolean co)
- {
- IceInternal.Reference ref = _reference.changeCompress(co);
- if(ref.equals(_reference))
- {
- return this;
- }
- else
- {
- return newInstance(ref);
- }
- }
-
- /**
- * Creates a new proxy that is identical to this proxy, except for its timeout setting.
- *
- * @param t The timeout for the new proxy in milliseconds.
- * @return A new proxy with the specified timeout.
- **/
- @Override
- public final ObjectPrx
- ice_timeout(int t)
- {
- if(t < 1 && t != -1)
- {
- throw new IllegalArgumentException("invalid value passed to ice_timeout: " + t);
- }
- IceInternal.Reference ref = _reference.changeTimeout(t);
- if(ref.equals(_reference))
- {
- return this;
- }
- else
- {
- return newInstance(ref);
- }
- }
-
- /**
- * Creates a new proxy that is identical to this proxy, except for its connection ID.
- *
- * @param connectionId The connection ID for the new proxy. An empty string removes the
- * connection ID.
- *
- * @return A new proxy with the specified connection ID.
- **/
- @Override
- public final ObjectPrx
- ice_connectionId(String id)
- {
- IceInternal.Reference ref = _reference.changeConnectionId(id);
- if(ref.equals(_reference))
- {
- return this;
- }
- else
- {
- return newInstance(ref);
- }
- }
-
- /**
- * Returns the {@link Connection} for this proxy. If the proxy does not yet have an established connection,
- * it first attempts to create a connection.
- *
- * @return The {@link Connection} for this proxy.
- * @throws CollocationOptimizationException If the proxy uses collocation optimization and denotes a
- * collocated object.
- *
- * @see Connection
- **/
- @Override
- public final Connection
- ice_getConnection()
- {
- final InvocationObserver observer = IceInternal.ObserverHelper.get(this, "ice_getConnection");
- int cnt = 0;
- if(Thread.interrupted())
- {
- throw new Ice.OperationInterruptedException();
- }
- try
- {
- while(true)
- {
- IceInternal.RequestHandler handler = null;
- try
- {
- handler = __getRequestHandler();
- try
- {
- // Wait for the connection to be established.
- return handler.waitForConnection();
- }
- catch(InterruptedException e)
- {
- throw new Ice.OperationInterruptedException();
- }
- }
- catch(RetryException e)
- {
- // Clear request handler and retry.
- __setRequestHandler(handler, null);
- }
- catch(Ice.Exception ex)
- {
- try
- {
- Ice.Holder<Integer> interval = new Ice.Holder<Integer>();
- cnt = __handleException(ex, handler, OperationMode.Idempotent, false, interval, cnt);
- if(observer != null)
- {
- observer.retried();
- }
- if(interval.value > 0)
- {
- try
- {
- Thread.sleep(interval.value);
- }
- catch(InterruptedException ex1)
- {
- throw new Ice.OperationInterruptedException();
- }
- }
- }
- catch(Ice.Exception exc)
- {
- if(observer != null)
- {
- observer.failed(exc.ice_name());
- }
- throw exc;
- }
- }
- }
- }
- finally
- {
- if(observer != null)
- {
- observer.detach();
- }
- }
- }
-
- /**
- * Asynchronously gets the connection for this proxy. The call does not block.
- *
- * @return The asynchronous result object.
- **/
- @Override
- public AsyncResult
- begin_ice_getConnection()
- {
- AsyncResult result = begin_ice_getConnectionInternal(null);
- return result;
- }
-
- /**
- * Asynchronously gets the connection for this proxy. The call does not block.
- *
- * @param __cb The callback object to notify the application when the flush is complete.
- * @return The asynchronous result object.
- **/
- @Override
- public AsyncResult
- begin_ice_getConnection(Callback __cb)
- {
- AsyncResult result = begin_ice_getConnectionInternal(__cb);
- return result;
- }
-
- /**
- * Asynchronously gets the connection for this proxy. The call does not block.
- *
- * @param __cb The callback object to notify the application when the flush is complete.
- * @return The asynchronous result object.
- **/
- @Override
- public AsyncResult
- begin_ice_getConnection(Callback_Object_ice_getConnection __cb)
- {
- AsyncResult result = begin_ice_getConnectionInternal(__cb);
- return result;
- }
-
- private class FunctionalCallback_Object_ice_getConnection
- extends IceInternal.Functional_TwowayCallbackArg1<Ice.Connection>
- {
- FunctionalCallback_Object_ice_getConnection(
- IceInternal.Functional_GenericCallback1<Ice.Connection> __responseCb,
- IceInternal.Functional_GenericCallback1<Ice.Exception> __exceptionCb)
- {
- super(__responseCb, __exceptionCb, null);
- }
-
- @Override
- public final void __completed(AsyncResult __result)
- {
- ObjectPrxHelperBase.__ice_getConnection_completed(this, __result);
- }
- }
-
- /**
- * Asynchronously gets the connection for this proxy. The call does not block.
- *
- * @param __responseCb The callback object to notify the application when the there is a response available.
- * @param __exceptionCb The callback object to notify the application when the there is an exception getting
- * connection.
- * @return The asynchronous result object.
- **/
- @Override
- public AsyncResult
- begin_ice_getConnection(IceInternal.Functional_GenericCallback1<Ice.Connection> __responseCb,
- IceInternal.Functional_GenericCallback1<Ice.Exception> __exceptionCb)
- {
- return begin_ice_getConnectionInternal(
- new FunctionalCallback_Object_ice_getConnection(__responseCb, __exceptionCb));
- }
-
- private static final String __ice_getConnection_name = "ice_getConnection";
-
- private AsyncResult
- begin_ice_getConnectionInternal(IceInternal.CallbackBase cb)
- {
- IceInternal.ProxyGetConnection result = new IceInternal.ProxyGetConnection(this, __ice_getConnection_name, cb);
- try
- {
- result.invoke();
- }
- catch(Exception ex)
- {
- result.abort(ex);
- }
- return result;
- }
-
- @Override
- public Ice.Connection
- end_ice_getConnection(AsyncResult r)
- {
- IceInternal.ProxyGetConnection result = IceInternal.ProxyGetConnection.check(r, this, __ice_getConnection_name);
- result.__wait();
- return ice_getCachedConnection();
- }
-
- static public final void __ice_getConnection_completed(TwowayCallbackArg1<Ice.Connection> cb, AsyncResult result)
- {
- Ice.Connection ret = null;
- try
- {
- ret = result.getProxy().end_ice_getConnection(result);
- }
- catch(LocalException ex)
- {
- cb.exception(ex);
- return;
- }
- catch(SystemException ex)
- {
- cb.exception(ex);
- return;
- }
- cb.response(ret);
- }
-
- /**
- * Returns the cached {@link Connection} for this proxy. If the proxy does not yet have an established
- * connection, it does not attempt to create a connection.
- *
- * @return The cached {@link Connection} for this proxy (<code>null</code> if the proxy does not have
- * an established connection).
- * @throws CollocationOptimizationException If the proxy uses collocation optimization and denotes a
- * collocated object.
- *
- * @see Connection
- **/
- @Override
- public final Connection
- ice_getCachedConnection()
- {
- IceInternal.RequestHandler handler = null;
- synchronized(this)
- {
- handler = _requestHandler;
- }
-
- if(handler != null)
- {
- try
- {
- return handler.getConnection();
- }
- catch(LocalException ex)
- {
- }
- }
- return null;
- }
-
- /**
- * Flushes any pending batched requests for this communicator. The call blocks until the flush is complete.
- **/
- @Override
- public void
- ice_flushBatchRequests()
- {
- end_ice_flushBatchRequests(begin_ice_flushBatchRequests());
- }
-
- /**
- * Asynchronously flushes any pending batched requests for this communicator. The call does not block.
- *
- * @return The asynchronous result object.
- **/
- @Override
- public AsyncResult
- begin_ice_flushBatchRequests()
- {
- AsyncResult result = begin_ice_flushBatchRequestsInternal(null);
- return result;
- }
-
- /**
- * Asynchronously flushes any pending batched requests for this communicator. The call does not block.
- *
- * @param __cb The callback object to notify the application when the flush is complete.
- * @return The asynchronous result object.
- **/
- @Override
- public AsyncResult
- begin_ice_flushBatchRequests(Callback __cb)
- {
- AsyncResult result = begin_ice_flushBatchRequestsInternal(__cb);
- return result;
- }
-
- /**
- * Asynchronously flushes any pending batched requests for this communicator. The call does not block.
- *
- * @param __cb The callback object to notify the application when the flush is complete.
- * @return The asynchronous result object.
- **/
- @Override
- public AsyncResult
- begin_ice_flushBatchRequests(Callback_Object_ice_flushBatchRequests __cb)
- {
- AsyncResult result = begin_ice_flushBatchRequestsInternal(__cb);
- return result;
- }
-
- /**
- * Asynchronously flushes any pending batched requests for this communicator. The call does not block.
- *
- * @param __exceptionCb The callback object to notify the application when the there is an exception flushing
- * the requests.
- * @param __sentCb The callback object to notify the application when the flush is complete.
- * @return The asynchronous result object.
- **/
- @Override
- public AsyncResult
- begin_ice_flushBatchRequests(IceInternal.Functional_VoidCallback __responseCb,
- IceInternal.Functional_GenericCallback1<Ice.Exception> __exceptionCb,
- IceInternal.Functional_BoolCallback __sentCb)
- {
- return begin_ice_flushBatchRequestsInternal(
- new IceInternal.Functional_OnewayCallback(__responseCb, __exceptionCb, __sentCb));
- }
-
- private static final String __ice_flushBatchRequests_name = "ice_flushBatchRequests";
-
- private AsyncResult
- begin_ice_flushBatchRequestsInternal(IceInternal.CallbackBase cb)
- {
- IceInternal.ProxyFlushBatch result = new IceInternal.ProxyFlushBatch(this, __ice_flushBatchRequests_name, cb);
- try
- {
- result.invoke();
- }
- catch(Exception ex)
- {
- result.abort(ex);
- }
- return result;
- }
-
- @Override
- public void
- end_ice_flushBatchRequests(AsyncResult r)
- {
- IceInternal.ProxyFlushBatch result = IceInternal.ProxyFlushBatch.check(r, this, __ice_flushBatchRequests_name);
- result.__wait();
- }
-
- /**
- * Returns whether this proxy equals the passed object. Two proxies are equal if they are equal in all respects,
- * that is, if their object identity, endpoints timeout settings, and so on are all equal.
- *
- * @param r The object to compare this proxy with.
- * @return <code>true</code> if this proxy is equal to <code>r</code>; <code>false</code>, otherwise.
- **/
- @Override
- public final boolean
- equals(java.lang.Object r)
- {
- if(this == r)
- {
- return true;
- }
-
- if(r instanceof ObjectPrxHelperBase)
- {
- return _reference.equals(((ObjectPrxHelperBase)r)._reference);
- }
-
- return false;
- }
-
- public final IceInternal.Reference
- __reference()
- {
- return _reference;
- }
-
- public final void
- __copyFrom(ObjectPrx from)
- {
- synchronized(from)
- {
- ObjectPrxHelperBase h = (ObjectPrxHelperBase)from;
- _reference = h._reference;
- _requestHandler = h._requestHandler;
- }
- }
-
- public final int
- __handleException(Exception ex, IceInternal.RequestHandler handler, OperationMode mode, boolean sent,
- Holder<Integer> interval, int cnt)
- {
- __setRequestHandler(handler, null); // Clear the request handler
-
- //
- // We only retry local exception, system exceptions aren't retried.
- //
- // A CloseConnectionException indicates graceful server shutdown, and is therefore
- // always repeatable without violating "at-most-once". That's because by sending a
- // close connection message, the server guarantees that all outstanding requests
- // can safely be repeated.
- //
- // An ObjectNotExistException can always be retried as well without violating
- // "at-most-once" (see the implementation of the checkRetryAfterException method
- // of the ProxyFactory class for the reasons why it can be useful).
- //
- // If the request didn't get sent or if it's non-mutating or idempotent it can
- // also always be retried if the retry count isn't reached.
- //
- if(ex instanceof LocalException && (!sent ||
- mode == OperationMode.Nonmutating || mode == OperationMode.Idempotent ||
- ex instanceof CloseConnectionException ||
- ex instanceof ObjectNotExistException))
- {
- try
- {
- return _reference.getInstance().proxyFactory().checkRetryAfterException((LocalException)ex,
- _reference,
- interval,
- cnt);
- }
- catch(CommunicatorDestroyedException exc)
- {
- //
- // The communicator is already destroyed, so we cannot retry.
- //
- throw ex;
- }
- }
- else
- {
- throw ex; // Retry could break at-most-once semantics, don't retry.
- }
- }
-
- 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 void
- __checkAsyncTwowayOnly(String name)
- {
- //
- // No mutex lock necessary, there is nothing mutable in this
- // operation.
- //
-
- if(!ice_isTwoway())
- {
- throw new java.lang.IllegalArgumentException("`" + name + "' can only be called with a twoway proxy");
- }
- }
-
- public final void
- __end(AsyncResult r, String operation)
- {
- IceInternal.ProxyOutgoingAsyncBase result = IceInternal.ProxyOutgoingAsyncBase.check(r, this, operation);
- try
- {
- boolean ok = result.__wait();
- if(_reference.getMode() == IceInternal.Reference.ModeTwoway)
- {
- IceInternal.OutgoingAsync outAsync = (IceInternal.OutgoingAsync)result;
- if(!ok)
- {
- try
- {
- outAsync.throwUserException();
- }
- catch(UserException ex)
- {
- throw new UnknownUserException(ex.ice_name(), ex);
- }
- }
- outAsync.readEmptyParams();
- }
- }
- finally
- {
- if(result != null)
- {
- result.cacheMessageBuffers();
- }
- }
- }
-
- public final IceInternal.RequestHandler
- __getRequestHandler()
- {
- IceInternal.RequestHandler handler;
- if(_reference.getCacheConnection())
- {
- synchronized(this)
- {
- if(_requestHandler != null)
- {
- return _requestHandler;
- }
- _requestHandler = createRequestHandler();
- handler = _requestHandler;
- }
- }
- else
- {
- handler = createRequestHandler();
- }
- return handler.connect();
- }
-
- public void
- __setRequestHandler(IceInternal.RequestHandler previous, IceInternal.RequestHandler handler)
- {
- if(_reference.getCacheConnection() && previous != null)
- {
- synchronized(this)
- {
- if(_requestHandler != null && _requestHandler != handler)
- {
- //
- // Update the request handler only if "previous" is the same
- // as the current request handler. This is called after
- // connection binding by the connect request handler. We only
- // replace the request handler if the current handler is the
- // connect request handler.
- //
- _requestHandler = _requestHandler.update(previous, handler);
- }
- }
- }
- }
-
- public void
- cacheMessageBuffers(IceInternal.BasicStream is, IceInternal.BasicStream os)
- {
- synchronized(this)
- {
- if(_streamCache == null)
- {
- _streamCache = new LinkedList<StreamCacheEntry>();
- }
- _streamCache.add(new StreamCacheEntry(is, os));
- }
- }
-
- private IceInternal.RequestHandler
- createRequestHandler()
- {
- if(_reference.getCollocationOptimized())
- {
- ObjectAdapter adapter = _reference.getInstance().objectAdapterFactory().findObjectAdapter(this);
- if(adapter != null)
- {
- return new IceInternal.CollocatedRequestHandler(_reference, adapter);
- }
- }
-
- IceInternal.RequestHandler handler = new IceInternal.ConnectRequestHandler(_reference, this);
- if(_reference.getInstance().queueRequests())
- {
- handler = new QueueRequestHandler(_reference.getInstance(), handler);
- }
- return handler;
- }
-
- //
- // 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(_requestHandler == null);
-
- _reference = ref;
- }
-
- protected static <T> T checkedCastImpl(Ice.ObjectPrx obj, String id, Class<T> proxyCls, Class<?> helperCls)
- {
- return checkedCastImpl(obj, null, false, null, false, id, proxyCls, helperCls);
- }
-
- protected static <T> T checkedCastImpl(Ice.ObjectPrx obj, java.util.Map<String, String> ctx, String id,
- Class<T> proxyCls, Class<?> helperCls)
- {
- return checkedCastImpl(obj, ctx, true, null, false, id, proxyCls, helperCls);
- }
-
- protected static <T> T checkedCastImpl(Ice.ObjectPrx obj, String facet, String id, Class<T> proxyCls,
- Class<?> helperCls)
- {
- return checkedCastImpl(obj, null, false, facet, true, id, proxyCls, helperCls);
- }
-
- protected static <T> T checkedCastImpl(Ice.ObjectPrx obj, String facet, java.util.Map<String, String> ctx,
- String id, Class<T> proxyCls, Class<?> helperCls)
- {
- return checkedCastImpl(obj, ctx, true, facet, true, id, proxyCls, helperCls);
- }
-
- protected static <T> T checkedCastImpl(Ice.ObjectPrx obj, java.util.Map<String, String> ctx, boolean explicitCtx,
- String facet, boolean explicitFacet, String id, Class<T> proxyCls,
- Class<?> helperCls)
- {
- T d = null;
- if(obj != null)
- {
- if(explicitFacet)
- {
- obj = obj.ice_facet(facet);
- }
- if(proxyCls.isInstance(obj))
- {
- d = proxyCls.cast(obj);
- }
- else
- {
- try
- {
- final boolean b = explicitCtx ? obj.ice_isA(id, ctx) : obj.ice_isA(id);
- if(b)
- {
- ObjectPrxHelperBase h = null;
- try
- {
- h = ObjectPrxHelperBase.class.cast(helperCls.newInstance());
- }
- catch(InstantiationException ex)
- {
- throw new SyscallException(ex);
- }
- catch(IllegalAccessException ex)
- {
- throw new SyscallException(ex);
- }
- h.__copyFrom(obj);
- d = proxyCls.cast(h);
- }
- }
- catch(FacetNotExistException ex)
- {
- }
- }
- }
- return d;
- }
-
- protected static <T> T uncheckedCastImpl(Ice.ObjectPrx obj, Class<T> proxyCls, Class<?> helperCls)
- {
- return uncheckedCastImpl(obj, null, false, proxyCls, helperCls);
- }
-
- protected static <T> T uncheckedCastImpl(Ice.ObjectPrx obj, String facet, Class<T> proxyCls, Class<?> helperCls)
- {
- return uncheckedCastImpl(obj, facet, true, proxyCls, helperCls);
- }
-
- protected static <T> T uncheckedCastImpl(Ice.ObjectPrx obj, String facet, boolean explicitFacet, Class<T> proxyCls,
- Class<?> helperCls)
- {
- T d = null;
- if(obj != null)
- {
- try
- {
- if(explicitFacet)
- {
- ObjectPrxHelperBase h = ObjectPrxHelperBase.class.cast(helperCls.newInstance());
- h.__copyFrom(obj.ice_facet(facet));
- d = proxyCls.cast(h);
- }
- else
- {
- if(proxyCls.isInstance(obj))
- {
- d = proxyCls.cast(obj);
- }
- else
- {
- ObjectPrxHelperBase h = ObjectPrxHelperBase.class.cast(helperCls.newInstance());
- h.__copyFrom(obj);
- d = proxyCls.cast(h);
- }
- }
- }
- catch(InstantiationException ex)
- {
- throw new SyscallException(ex);
- }
- catch(IllegalAccessException ex)
- {
- throw new SyscallException(ex);
- }
- }
- return d;
- }
-
- protected IceInternal.OutgoingAsync
- getOutgoingAsync(String operation, IceInternal.CallbackBase cb)
- {
- StreamCacheEntry cacheEntry = null;
- if(_reference.getInstance().cacheMessageBuffers() > 0)
- {
- synchronized(this)
- {
- if(_streamCache != null && !_streamCache.isEmpty())
- {
- cacheEntry = _streamCache.remove(0);
- }
- }
- }
- if(cacheEntry == null)
- {
- return new IceInternal.OutgoingAsync(this, operation, cb);
- }
- else
- {
- return new IceInternal.OutgoingAsync(this, operation, cb, cacheEntry.is, cacheEntry.os);
- }
- }
-
- private final ObjectPrxHelperBase
- newInstance(IceInternal.Reference ref)
- {
- try
- {
- ObjectPrxHelperBase proxy = getClass().newInstance();
- proxy.__setup(ref);
- return proxy;
- }
- catch(InstantiationException e)
- {
- //
- // Impossible
- //
- assert false;
- return null;
- }
- catch(IllegalAccessException e)
- {
- //
- // Impossible
- //
- assert false;
- return null;
- }
- }
-
- private void
- writeObject(java.io.ObjectOutputStream out)
- throws java.io.IOException
- {
- out.writeUTF(toString());
- }
-
- private void
- readObject(java.io.ObjectInputStream in)
- throws java.io.IOException, ClassNotFoundException
- {
- String s = in.readUTF();
- try
- {
- Communicator communicator = ((Ice.ObjectInputStream)in).getCommunicator();
- if(communicator == null)
- {
- throw new java.io.IOException("Cannot deserialize proxy: no communicator provided");
- }
- ObjectPrxHelperBase proxy = (ObjectPrxHelperBase)communicator.stringToProxy(s);
- _reference = proxy._reference;
- assert(proxy._requestHandler == null);
- }
- catch(ClassCastException ex)
- {
- java.io.IOException e =
- new java.io.IOException("Cannot deserialize proxy: Ice.ObjectInputStream not found");
- e.initCause(ex);
- throw e;
- }
- catch(LocalException ex)
- {
- java.io.IOException e = new java.io.IOException("Failure occurred while deserializing proxy");
- e.initCause(ex);
- throw e;
- }
- }
-
- private static class StreamCacheEntry
- {
- StreamCacheEntry(IceInternal.BasicStream is, IceInternal.BasicStream os)
- {
- this.is = is;
- this.os = os;
- }
-
- IceInternal.BasicStream is;
- IceInternal.BasicStream os;
- }
-
- private transient IceInternal.Reference _reference;
- private transient IceInternal.RequestHandler _requestHandler;
- private transient List<StreamCacheEntry> _streamCache;
- public static final long serialVersionUID = 0L;
-}