summaryrefslogtreecommitdiff
path: root/java/src
diff options
context:
space:
mode:
authorBernard Normier <bernard@zeroc.com>2016-11-17 13:37:27 -0500
committerBernard Normier <bernard@zeroc.com>2016-11-17 13:37:27 -0500
commit9fe9ffb11554bcbb6f4a32bcae70d9ffbb3b40ab (patch)
treed766a020835106766c07cf12f11a309764969c20 /java/src
parentICE-7417 - Rename data directory (diff)
downloadice-9fe9ffb11554bcbb6f4a32bcae70d9ffbb3b40ab.tar.bz2
ice-9fe9ffb11554bcbb6f4a32bcae70d9ffbb3b40ab.tar.xz
ice-9fe9ffb11554bcbb6f4a32bcae70d9ffbb3b40ab.zip
Replaced double-underscores in java and java-compat
Diffstat (limited to 'java/src')
-rw-r--r--java/src/Ice/src/main/java/com/zeroc/Ice/Blobject.java2
-rw-r--r--java/src/Ice/src/main/java/com/zeroc/Ice/BlobjectAsync.java2
-rw-r--r--java/src/Ice/src/main/java/com/zeroc/Ice/CommunicatorI.java16
-rw-r--r--java/src/Ice/src/main/java/com/zeroc/Ice/ConnectionI.java28
-rw-r--r--java/src/Ice/src/main/java/com/zeroc/Ice/DispatchInterceptor.java2
-rw-r--r--java/src/Ice/src/main/java/com/zeroc/Ice/InputStream.java14
-rw-r--r--java/src/Ice/src/main/java/com/zeroc/Ice/InterfaceByValue.java12
-rw-r--r--java/src/Ice/src/main/java/com/zeroc/Ice/Object.java110
-rw-r--r--java/src/Ice/src/main/java/com/zeroc/Ice/ObjectAdapterI.java4
-rw-r--r--java/src/Ice/src/main/java/com/zeroc/Ice/ObjectPrx.java326
-rw-r--r--java/src/Ice/src/main/java/com/zeroc/Ice/OutputStream.java20
-rw-r--r--java/src/Ice/src/main/java/com/zeroc/Ice/UnknownSlicedValue.java12
-rw-r--r--java/src/Ice/src/main/java/com/zeroc/Ice/UserException.java14
-rw-r--r--java/src/Ice/src/main/java/com/zeroc/Ice/Value.java29
-rw-r--r--java/src/Ice/src/main/java/com/zeroc/Ice/ValueReader.java4
-rw-r--r--java/src/Ice/src/main/java/com/zeroc/Ice/ValueWriter.java4
-rw-r--r--java/src/Ice/src/main/java/com/zeroc/Ice/_ObjectPrxI.java194
-rw-r--r--java/src/Ice/src/main/java/com/zeroc/IceInternal/CommunicatorFlushBatch.java12
-rw-r--r--java/src/Ice/src/main/java/com/zeroc/IceInternal/ConnectRequestHandler.java2
-rw-r--r--java/src/Ice/src/main/java/com/zeroc/IceInternal/ConnectionFlushBatch.java8
-rw-r--r--java/src/Ice/src/main/java/com/zeroc/IceInternal/FixedReference.java2
-rw-r--r--java/src/Ice/src/main/java/com/zeroc/IceInternal/Incoming.java6
-rw-r--r--java/src/Ice/src/main/java/com/zeroc/IceInternal/InvocationFutureI.java18
-rw-r--r--java/src/Ice/src/main/java/com/zeroc/IceInternal/LocatorInfo.java12
-rw-r--r--java/src/Ice/src/main/java/com/zeroc/IceInternal/LocatorManager.java2
-rw-r--r--java/src/Ice/src/main/java/com/zeroc/IceInternal/ObserverHelper.java2
-rw-r--r--java/src/Ice/src/main/java/com/zeroc/IceInternal/OutgoingAsync.java26
-rw-r--r--java/src/Ice/src/main/java/com/zeroc/IceInternal/ProxyFactory.java6
-rw-r--r--java/src/Ice/src/main/java/com/zeroc/IceInternal/ProxyFlushBatch.java16
-rw-r--r--java/src/Ice/src/main/java/com/zeroc/IceInternal/ProxyGetConnection.java8
-rw-r--r--java/src/Ice/src/main/java/com/zeroc/IceInternal/ProxyIceInvoke.java18
-rw-r--r--java/src/Ice/src/main/java/com/zeroc/IceInternal/ProxyOutgoingAsyncBaseI.java30
-rw-r--r--java/src/Ice/src/main/java/com/zeroc/IceInternal/Reference.java4
-rw-r--r--java/src/Ice/src/main/java/com/zeroc/IceInternal/ReferenceFactory.java4
-rw-r--r--java/src/Ice/src/main/java/com/zeroc/IceInternal/RequestHandlerFactory.java4
-rw-r--r--java/src/Ice/src/main/java/com/zeroc/IceInternal/RoutableReference.java4
-rw-r--r--java/src/Ice/src/main/java/com/zeroc/IceInternal/RouterInfo.java6
-rw-r--r--java/src/Ice/src/main/java/com/zeroc/IceInternal/UdpEndpointI.java4
-rw-r--r--java/src/Ice/src/main/java/com/zeroc/IceInternal/ValueWriter.java2
39 files changed, 495 insertions, 494 deletions
diff --git a/java/src/Ice/src/main/java/com/zeroc/Ice/Blobject.java b/java/src/Ice/src/main/java/com/zeroc/Ice/Blobject.java
index 6855c538e92..ad14827ff88 100644
--- a/java/src/Ice/src/main/java/com/zeroc/Ice/Blobject.java
+++ b/java/src/Ice/src/main/java/com/zeroc/Ice/Blobject.java
@@ -38,7 +38,7 @@ public interface Blobject extends com.zeroc.Ice.Object
throws UserException;
@Override
- default CompletionStage<OutputStream> __dispatch(com.zeroc.IceInternal.Incoming in, Current current)
+ default CompletionStage<OutputStream> _iceDispatch(com.zeroc.IceInternal.Incoming in, Current current)
throws UserException
{
byte[] inEncaps = in.readParamEncaps();
diff --git a/java/src/Ice/src/main/java/com/zeroc/Ice/BlobjectAsync.java b/java/src/Ice/src/main/java/com/zeroc/Ice/BlobjectAsync.java
index 3498fcfaa2c..2e3acf67f54 100644
--- a/java/src/Ice/src/main/java/com/zeroc/Ice/BlobjectAsync.java
+++ b/java/src/Ice/src/main/java/com/zeroc/Ice/BlobjectAsync.java
@@ -44,7 +44,7 @@ public interface BlobjectAsync extends com.zeroc.Ice.Object
throws UserException;
@Override
- default CompletionStage<OutputStream> __dispatch(com.zeroc.IceInternal.Incoming in, Current current)
+ default CompletionStage<OutputStream> _iceDispatch(com.zeroc.IceInternal.Incoming in, Current current)
throws UserException
{
byte[] inEncaps = in.readParamEncaps();
diff --git a/java/src/Ice/src/main/java/com/zeroc/Ice/CommunicatorI.java b/java/src/Ice/src/main/java/com/zeroc/Ice/CommunicatorI.java
index 035c6b39f15..3ee8b9f7054 100644
--- a/java/src/Ice/src/main/java/com/zeroc/Ice/CommunicatorI.java
+++ b/java/src/Ice/src/main/java/com/zeroc/Ice/CommunicatorI.java
@@ -206,16 +206,16 @@ public final class CommunicatorI implements Communicator
@Override
public void flushBatchRequests()
{
- __flushBatchRequestsAsync().__wait();
+ _iceI_flushBatchRequestsAsync().waitForResponse();
}
@Override
public java.util.concurrent.CompletableFuture<Void> flushBatchRequestsAsync()
{
- return __flushBatchRequestsAsync();
+ return _iceI_flushBatchRequestsAsync();
}
- public com.zeroc.IceInternal.CommunicatorFlushBatch __flushBatchRequestsAsync()
+ public com.zeroc.IceInternal.CommunicatorFlushBatch _iceI_flushBatchRequestsAsync()
{
com.zeroc.IceInternal.OutgoingConnectionFactory connectionFactory = _instance.outgoingConnectionFactory();
com.zeroc.IceInternal.ObjectAdapterFactory adapterFactory = _instance.objectAdapterFactory();
@@ -224,19 +224,19 @@ public final class CommunicatorI implements Communicator
// This callback object receives the results of all invocations
// of Connection.begin_flushBatchRequests.
//
- com.zeroc.IceInternal.CommunicatorFlushBatch __f =
+ com.zeroc.IceInternal.CommunicatorFlushBatch f =
new com.zeroc.IceInternal.CommunicatorFlushBatch(this, _instance);
- connectionFactory.flushAsyncBatchRequests(__f);
- adapterFactory.flushAsyncBatchRequests(__f);
+ connectionFactory.flushAsyncBatchRequests(f);
+ adapterFactory.flushAsyncBatchRequests(f);
//
// Inform the callback that we have finished initiating all of the
// flush requests.
//
- __f.ready();
+ f.ready();
- return __f;
+ return f;
}
@Override
diff --git a/java/src/Ice/src/main/java/com/zeroc/Ice/ConnectionI.java b/java/src/Ice/src/main/java/com/zeroc/Ice/ConnectionI.java
index 24ce63ef54d..3b73897443b 100644
--- a/java/src/Ice/src/main/java/com/zeroc/Ice/ConnectionI.java
+++ b/java/src/Ice/src/main/java/com/zeroc/Ice/ConnectionI.java
@@ -431,16 +431,16 @@ public final class ConnectionI extends com.zeroc.IceInternal.EventHandler
@Override
public void flushBatchRequests()
{
- ObjectPrx.__waitForCompletion(flushBatchRequestsAsync());
+ ObjectPrx.waitForResponseForCompletion(flushBatchRequestsAsync());
}
@Override
public java.util.concurrent.CompletableFuture<Void> flushBatchRequestsAsync()
{
- com.zeroc.IceInternal.ConnectionFlushBatch __f =
+ com.zeroc.IceInternal.ConnectionFlushBatch f =
new com.zeroc.IceInternal.ConnectionFlushBatch(this, _communicator, _instance);
- __f.invoke();
- return __f;
+ f.invoke();
+ return f;
}
@Override
@@ -850,10 +850,10 @@ public final class ConnectionI extends com.zeroc.IceInternal.EventHandler
throw ex;
}
- _readProtocol.ice_read(_readStream);
+ _readProtocol.read(_readStream);
Protocol.checkSupportedProtocol(_readProtocol);
- _readProtocolEncoding.ice_read(_readStream);
+ _readProtocolEncoding.read(_readStream);
Protocol.checkSupportedProtocolEncoding(_readProtocolEncoding);
_readStream.readByte(); // messageType
@@ -1849,8 +1849,8 @@ public final class ConnectionI extends com.zeroc.IceInternal.EventHandler
//
OutputStream os = new OutputStream(_instance, Protocol.currentProtocolEncoding);
os.writeBlob(Protocol.magic);
- Protocol.currentProtocol.ice_write(os);
- Protocol.currentProtocolEncoding.ice_write(os);
+ Protocol.currentProtocol.write(os);
+ Protocol.currentProtocolEncoding.write(os);
os.writeByte(Protocol.closeConnectionMsg);
os.writeByte((byte) 0); // compression status: always report 0 for
// CloseConnection in Java.
@@ -1882,8 +1882,8 @@ public final class ConnectionI extends com.zeroc.IceInternal.EventHandler
{
OutputStream os = new OutputStream(_instance, Protocol.currentProtocolEncoding);
os.writeBlob(Protocol.magic);
- Protocol.currentProtocol.ice_write(os);
- Protocol.currentProtocolEncoding.ice_write(os);
+ Protocol.currentProtocol.write(os);
+ Protocol.currentProtocolEncoding.write(os);
os.writeByte(Protocol.validateConnectionMsg);
os.writeByte((byte) 0);
os.writeInt(Protocol.headerSize); // Message size.
@@ -1933,8 +1933,8 @@ public final class ConnectionI extends com.zeroc.IceInternal.EventHandler
if(_writeStream.isEmpty())
{
_writeStream.writeBlob(Protocol.magic);
- Protocol.currentProtocol.ice_write(_writeStream);
- Protocol.currentProtocolEncoding.ice_write(_writeStream);
+ Protocol.currentProtocol.write(_writeStream);
+ Protocol.currentProtocolEncoding.write(_writeStream);
_writeStream.writeByte(Protocol.validateConnectionMsg);
_writeStream.writeByte((byte) 0); // Compression status
// (always zero for
@@ -2006,10 +2006,10 @@ public final class ConnectionI extends com.zeroc.IceInternal.EventHandler
throw ex;
}
- _readProtocol.ice_read(_readStream);
+ _readProtocol.read(_readStream);
Protocol.checkSupportedProtocol(_readProtocol);
- _readProtocolEncoding.ice_read(_readStream);
+ _readProtocolEncoding.read(_readStream);
Protocol.checkSupportedProtocolEncoding(_readProtocolEncoding);
byte messageType = _readStream.readByte();
diff --git a/java/src/Ice/src/main/java/com/zeroc/Ice/DispatchInterceptor.java b/java/src/Ice/src/main/java/com/zeroc/Ice/DispatchInterceptor.java
index d4cb560b808..58f7478dc00 100644
--- a/java/src/Ice/src/main/java/com/zeroc/Ice/DispatchInterceptor.java
+++ b/java/src/Ice/src/main/java/com/zeroc/Ice/DispatchInterceptor.java
@@ -37,7 +37,7 @@ public abstract class DispatchInterceptor implements com.zeroc.Ice.Object
throws UserException;
@Override
- public CompletionStage<OutputStream> __dispatch(com.zeroc.IceInternal.Incoming in, Current current)
+ public CompletionStage<OutputStream> _iceDispatch(com.zeroc.IceInternal.Incoming in, Current current)
throws UserException
{
return dispatch(in);
diff --git a/java/src/Ice/src/main/java/com/zeroc/Ice/InputStream.java b/java/src/Ice/src/main/java/com/zeroc/Ice/InputStream.java
index 1e9803ff774..0da5e67d431 100644
--- a/java/src/Ice/src/main/java/com/zeroc/Ice/InputStream.java
+++ b/java/src/Ice/src/main/java/com/zeroc/Ice/InputStream.java
@@ -695,7 +695,7 @@ public class InputStream
if(encoding != null)
{
- encoding.ice_read(this);
+ encoding.read(this);
_buf.b.position(_buf.b.position() - 6);
}
else
@@ -2326,7 +2326,7 @@ public class InputStream
//
// Read the instance.
//
- v.__read(_stream);
+ v._iceRead(_stream);
if(_patchMap != null)
{
@@ -2501,7 +2501,7 @@ public class InputStream
//
if(userEx != null)
{
- userEx.__read(_stream);
+ userEx._read(_stream);
if(usesClasses)
{
readPendingValues();
@@ -2662,7 +2662,7 @@ public class InputStream
// For the 1.0 encoding, the type ID for the base Object class
// marks the last slice.
//
- if(_typeId.equals(Value.ice_staticId))
+ if(_typeId.equals(Value.ice_staticId()))
{
throw new NoValueFactoryException("", mostDerivedId);
}
@@ -2806,7 +2806,7 @@ public class InputStream
//
if(userEx != null)
{
- userEx.__read(_stream);
+ userEx._read(_stream);
throw userEx;
// Never reached.
@@ -3225,7 +3225,7 @@ public class InputStream
// We pass the "::Ice::Object" ID to indicate that this is the
// last chance to preserve the instance.
//
- v = newInstance(Value.ice_staticId);
+ v = newInstance(Value.ice_staticId());
if(v == null)
{
v = new UnknownSlicedValue(mostDerivedId);
@@ -3285,7 +3285,7 @@ public class InputStream
for(int j = 0; j < info.instances.length; ++j)
{
addPatchEntry(table[j],
- new SequencePatcher<Value>(info.instances, Value.class, Value.ice_staticId, j));
+ new SequencePatcher<Value>(info.instances, Value.class, Value.ice_staticId(), j));
}
}
diff --git a/java/src/Ice/src/main/java/com/zeroc/Ice/InterfaceByValue.java b/java/src/Ice/src/main/java/com/zeroc/Ice/InterfaceByValue.java
index f3757a8817e..7a2cb5cc095 100644
--- a/java/src/Ice/src/main/java/com/zeroc/Ice/InterfaceByValue.java
+++ b/java/src/Ice/src/main/java/com/zeroc/Ice/InterfaceByValue.java
@@ -35,17 +35,17 @@ public class InterfaceByValue extends Value
}
@Override
- protected void __writeImpl(OutputStream __os)
+ protected void _iceWriteImpl(OutputStream ostr)
{
- __os.startSlice(ice_id(), -1, true);
- __os.endSlice();
+ ostr.startSlice(ice_id(), -1, true);
+ ostr.endSlice();
}
@Override
- protected void __readImpl(InputStream __is)
+ protected void _iceReadImpl(InputStream istr)
{
- __is.startSlice();
- __is.endSlice();
+ istr.startSlice();
+ istr.endSlice();
}
public static final long serialVersionUID = 0L;
diff --git a/java/src/Ice/src/main/java/com/zeroc/Ice/Object.java b/java/src/Ice/src/main/java/com/zeroc/Ice/Object.java
index 6c230280d72..3e8efe94934 100644
--- a/java/src/Ice/src/main/java/com/zeroc/Ice/Object.java
+++ b/java/src/Ice/src/main/java/com/zeroc/Ice/Object.java
@@ -18,11 +18,9 @@ import com.zeroc.IceInternal.Incoming;
**/
public interface Object
{
- public static final String ice_staticId = "::Ice::Object";
-
- public final static String[] __ids =
+ final static String[] _iceIds =
{
- ice_staticId
+ "::Ice::Object"
};
/**
@@ -99,7 +97,7 @@ public interface Object
**/
default String[] ice_ids(Current current)
{
- return __ids;
+ return _iceIds;
}
/**
@@ -110,7 +108,7 @@ public interface Object
**/
default String ice_id(Current current)
{
- return __ids[0];
+ return ice_staticId();
}
/**
@@ -120,7 +118,7 @@ public interface Object
**/
public static String ice_staticId()
{
- return ice_staticId;
+ return _iceIds[0];
}
/**
@@ -153,7 +151,7 @@ public interface Object
return 0;
}
- final static String[] __ops =
+ final static String[] _iceOps =
{
"ice_id",
"ice_ids",
@@ -176,13 +174,13 @@ public interface Object
{
Incoming in = (Incoming)request;
in.startOver();
- return __dispatch(in, in.getCurrent());
+ return _iceDispatch(in, in.getCurrent());
}
- default CompletionStage<OutputStream> __dispatch(Incoming in, Current current)
+ default CompletionStage<OutputStream> _iceDispatch(Incoming in, Current current)
throws UserException
{
- int pos = java.util.Arrays.binarySearch(__ops, current.operation);
+ int pos = java.util.Arrays.binarySearch(_iceOps, current.operation);
if(pos < 0)
{
throw new OperationNotExistException(current.id, current.facet, current.operation);
@@ -192,19 +190,19 @@ public interface Object
{
case 0:
{
- return ___ice_id(this, in, current);
+ return _iceD_ice_id(this, in, current);
}
case 1:
{
- return ___ice_ids(this, in, current);
+ return _iceD_ice_ids(this, in, current);
}
case 2:
{
- return ___ice_isA(this, in, current);
+ return _iceD_ice_isA(this, in, current);
}
case 3:
{
- return ___ice_ping(this, in, current);
+ return _iceD_ice_ping(this, in, current);
}
}
@@ -212,68 +210,68 @@ public interface Object
throw new OperationNotExistException(current.id, current.facet, current.operation);
}
- default void __write(OutputStream __os)
+ default void _iceWrite(OutputStream ostr)
{
- __os.startValue(null);
- __writeImpl(__os);
- __os.endValue();
+ ostr.startValue(null);
+ _iceWriteImpl(ostr);
+ ostr.endValue();
}
- default void __writeImpl(OutputStream __os)
+ default void _iceWriteImpl(OutputStream ostr)
{
}
- default void __read(InputStream __is)
+ default void _iceRead(InputStream istr)
{
- __is.startValue();
- __readImpl(__is);
- __is.endValue(false);
+ istr.startValue();
+ _iceReadImpl(istr);
+ istr.endValue(false);
}
- default void __readImpl(InputStream __is)
+ default void _iceReadImpl(InputStream istr)
{
}
- static CompletionStage<OutputStream> ___ice_isA(Object __obj, Incoming __inS, Current __current)
+ static CompletionStage<OutputStream> _iceD_ice_isA(Object obj, Incoming inS, Current current)
{
- InputStream __is = __inS.startReadParams();
- String __id = __is.readString();
- __inS.endReadParams();
- boolean __ret = __obj.ice_isA(__id, __current);
- OutputStream __os = __inS.startWriteParams();
- __os.writeBool(__ret);
- __inS.endWriteParams(__os);
- return __inS.setResult(__os);
+ InputStream istr = inS.startReadParams();
+ String id = istr.readString();
+ inS.endReadParams();
+ boolean ret = obj.ice_isA(id, current);
+ OutputStream ostr = inS.startWriteParams();
+ ostr.writeBool(ret);
+ inS.endWriteParams(ostr);
+ return inS.setResult(ostr);
}
- static CompletionStage<OutputStream> ___ice_ping(Object __obj, Incoming __inS, Current __current)
+ static CompletionStage<OutputStream> _iceD_ice_ping(Object obj, Incoming inS, Current current)
{
- __inS.readEmptyParams();
- __obj.ice_ping(__current);
- return __inS.setResult(__inS.writeEmptyParams());
+ inS.readEmptyParams();
+ obj.ice_ping(current);
+ return inS.setResult(inS.writeEmptyParams());
}
- static CompletionStage<OutputStream> ___ice_ids(Object __obj, Incoming __inS, Current __current)
+ static CompletionStage<OutputStream> _iceD_ice_ids(Object obj, Incoming inS, Current current)
{
- __inS.readEmptyParams();
- String[] __ret = __obj.ice_ids(__current);
- OutputStream __os = __inS.startWriteParams();
- __os.writeStringSeq(__ret);
- __inS.endWriteParams(__os);
- return __inS.setResult(__os);
+ inS.readEmptyParams();
+ String[] ret = obj.ice_ids(current);
+ OutputStream ostr = inS.startWriteParams();
+ ostr.writeStringSeq(ret);
+ inS.endWriteParams(ostr);
+ return inS.setResult(ostr);
}
- static CompletionStage<OutputStream> ___ice_id(Object __obj, Incoming __inS, Current __current)
+ static CompletionStage<OutputStream> _iceD_ice_id(Object obj, Incoming inS, Current current)
{
- __inS.readEmptyParams();
- String __ret = __obj.ice_id(__current);
- OutputStream __os = __inS.startWriteParams();
- __os.writeString(__ret);
- __inS.endWriteParams(__os);
- return __inS.setResult(__os);
+ inS.readEmptyParams();
+ String ret = obj.ice_id(current);
+ OutputStream ostr = inS.startWriteParams();
+ ostr.writeString(ret);
+ inS.endWriteParams(ostr);
+ return inS.setResult(ostr);
}
- static String __operationModeToString(OperationMode mode)
+ static String _iceOperationModeToString(OperationMode mode)
{
if(mode == OperationMode.Normal)
{
@@ -292,7 +290,7 @@ public interface Object
return "???";
}
- static void __checkMode(OperationMode expected, OperationMode received)
+ static void _iceCheckMode(OperationMode expected, OperationMode received)
{
if(expected == null)
{
@@ -312,8 +310,8 @@ public interface Object
{
MarshalException ex = new MarshalException();
ex.reason = "unexpected operation mode. expected = "
- + __operationModeToString(expected) + " received = "
- + __operationModeToString(received);
+ + _iceOperationModeToString(expected) + " received = "
+ + _iceOperationModeToString(received);
throw ex;
}
}
diff --git a/java/src/Ice/src/main/java/com/zeroc/Ice/ObjectAdapterI.java b/java/src/Ice/src/main/java/com/zeroc/Ice/ObjectAdapterI.java
index 2ae50796171..1bbe0aa90e6 100644
--- a/java/src/Ice/src/main/java/com/zeroc/Ice/ObjectAdapterI.java
+++ b/java/src/Ice/src/main/java/com/zeroc/Ice/ObjectAdapterI.java
@@ -517,7 +517,7 @@ public final class ObjectAdapterI implements ObjectAdapter
{
checkForDeactivation();
- com.zeroc.IceInternal.Reference ref = ((_ObjectPrxI)proxy).__reference();
+ com.zeroc.IceInternal.Reference ref = ((_ObjectPrxI)proxy)._getReference();
return findFacet(ref.getIdentity(), ref.getFacet());
}
@@ -673,7 +673,7 @@ public final class ObjectAdapterI implements ObjectAdapter
// it can be called for AMI invocations if the proxy has no delegate set yet.
//
- com.zeroc.IceInternal.Reference ref = ((_ObjectPrxI)proxy).__reference();
+ com.zeroc.IceInternal.Reference ref = ((_ObjectPrxI)proxy)._getReference();
if(ref.isWellKnown())
{
//
diff --git a/java/src/Ice/src/main/java/com/zeroc/Ice/ObjectPrx.java b/java/src/Ice/src/main/java/com/zeroc/Ice/ObjectPrx.java
index 22576393a9f..e28558dedf6 100644
--- a/java/src/Ice/src/main/java/com/zeroc/Ice/ObjectPrx.java
+++ b/java/src/Ice/src/main/java/com/zeroc/Ice/ObjectPrx.java
@@ -35,12 +35,12 @@ public interface ObjectPrx
* Tests whether this object supports a specific Slice interface.
*
* @param id The type ID of the Slice interface to test against.
- * @param __context The context map for the invocation.
+ * @param context The context map for the invocation.
* @return <code>true</code> if the target object has the interface
* specified by <code>id</code> or derives from the interface
* specified by <code>id</code>.
**/
- boolean ice_isA(String id, java.util.Map<String, String> __context);
+ boolean ice_isA(String id, java.util.Map<String, String> context);
/**
* Tests whether this object supports a specific Slice interface.
@@ -54,10 +54,10 @@ public interface ObjectPrx
* Tests whether this object supports a specific Slice interface.
*
* @param id The type ID of the Slice interface to test against.
- * @param __context The context map for the invocation.
+ * @param context The context map for the invocation.
* @return A future for the completion of the request.
**/
- java.util.concurrent.CompletableFuture<Boolean> ice_isAAsync(String id, java.util.Map<String, String> __context);
+ java.util.concurrent.CompletableFuture<Boolean> ice_isAAsync(String id, java.util.Map<String, String> context);
/**
* Tests whether the target object of this proxy can be reached.
@@ -67,9 +67,9 @@ public interface ObjectPrx
/**
* Tests whether the target object of this proxy can be reached.
*
- * @param __context The context map for the invocation.
+ * @param context The context map for the invocation.
**/
- void ice_ping(java.util.Map<String, String> __context);
+ void ice_ping(java.util.Map<String, String> context);
/**
* Tests whether the target object of this proxy can be reached.
@@ -81,10 +81,10 @@ public interface ObjectPrx
/**
* Tests whether the target object of this proxy can be reached.
*
- * @param __context The context map for the invocation.
+ * @param context The context map for the invocation.
* @return A future for the completion of the request.
**/
- java.util.concurrent.CompletableFuture<Void> ice_pingAsync(java.util.Map<String, String> __context);
+ java.util.concurrent.CompletableFuture<Void> ice_pingAsync(java.util.Map<String, String> context);
/**
* Returns the Slice type IDs of the interfaces supported by the target object of this proxy.
@@ -97,11 +97,11 @@ public interface ObjectPrx
/**
* 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 context The context 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>.
**/
- String[] ice_ids(java.util.Map<String, String> __context);
+ String[] ice_ids(java.util.Map<String, String> context);
/**
* Returns the Slice type IDs of the interfaces supported by the target object of this proxy.
@@ -113,10 +113,10 @@ public interface ObjectPrx
/**
* 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 context The context map for the invocation.
* @return A future for the completion of the request.
**/
- java.util.concurrent.CompletableFuture<String[]> ice_idsAsync(java.util.Map<String, String> __context);
+ java.util.concurrent.CompletableFuture<String[]> ice_idsAsync(java.util.Map<String, String> context);
/**
* Returns the Slice type ID of the most-derived interface supported by the target object of this proxy.
@@ -128,10 +128,10 @@ public interface ObjectPrx
/**
* 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 context The context map for the invocation.
* @return The Slice type ID of the most-derived interface.
**/
- String ice_id(java.util.Map<String, String> __context);
+ String ice_id(java.util.Map<String, String> context);
/**
* Returns the Slice type ID of the most-derived interface supported by the target object of this proxy.
@@ -143,10 +143,10 @@ public interface ObjectPrx
/**
* 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 context The context map for the invocation.
* @return A future for the completion of the request.
**/
- java.util.concurrent.CompletableFuture<String> ice_idAsync(java.util.Map<String, String> __context);
+ java.util.concurrent.CompletableFuture<String> ice_idAsync(java.util.Map<String, String> context);
/**
* Invokes an operation dynamically.
@@ -167,14 +167,14 @@ public interface ObjectPrx
* @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.
+ * @param context The context map for the invocation.
* @return The results of the invocation.
*
* @see Blobject
* @see OperationMode
**/
com.zeroc.Ice.Object.Ice_invokeResult ice_invoke(String operation, OperationMode mode, byte[] inParams,
- java.util.Map<String, String> __context);
+ java.util.Map<String, String> context);
/**
* Invokes an operation dynamically and asynchronously.
@@ -199,7 +199,7 @@ public interface ObjectPrx
* @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 context The context map for the invocation.
* @return A future for the completion of the request.
*
* @see Blobject
@@ -209,7 +209,7 @@ public interface ObjectPrx
String operation,
OperationMode mode,
byte[] inParams,
- java.util.Map<String, String> __context);
+ java.util.Map<String, String> context);
/**
* Returns the identity embedded in this proxy.
@@ -242,7 +242,7 @@ public interface ObjectPrx
**/
default ObjectPrx ice_context(java.util.Map<String, String> newContext)
{
- return __ice_context(newContext);
+ return _ice_context(newContext);
}
/**
@@ -275,7 +275,7 @@ public interface ObjectPrx
**/
default ObjectPrx ice_adapterId(String newAdapterId)
{
- return __ice_adapterId(newAdapterId);
+ return _ice_adapterId(newAdapterId);
}
/**
@@ -295,7 +295,7 @@ public interface ObjectPrx
**/
default ObjectPrx ice_endpoints(Endpoint[] newEndpoints)
{
- return __ice_endpoints(newEndpoints);
+ return _ice_endpoints(newEndpoints);
}
/**
@@ -332,7 +332,7 @@ public interface ObjectPrx
**/
default ObjectPrx ice_locatorCacheTimeout(int newTimeout)
{
- return __ice_locatorCacheTimeout(newTimeout);
+ return _ice_locatorCacheTimeout(newTimeout);
}
/**
@@ -344,7 +344,7 @@ public interface ObjectPrx
**/
default ObjectPrx ice_invocationTimeout(int newTimeout)
{
- return __ice_invocationTimeout(newTimeout);
+ return _ice_invocationTimeout(newTimeout);
}
/**
@@ -362,7 +362,7 @@ public interface ObjectPrx
**/
default ObjectPrx ice_connectionCached(boolean newCache)
{
- return __ice_connectionCached(newCache);
+ return _ice_connectionCached(newCache);
}
/**
@@ -384,7 +384,7 @@ public interface ObjectPrx
**/
default ObjectPrx ice_endpointSelection(EndpointSelectionType newType)
{
- return __ice_endpointSelection(newType);
+ return _ice_endpointSelection(newType);
}
/**
@@ -404,7 +404,7 @@ public interface ObjectPrx
**/
default ObjectPrx ice_secure(boolean b)
{
- return __ice_secure(b);
+ return _ice_secure(b);
}
/**
@@ -416,7 +416,7 @@ public interface ObjectPrx
**/
default ObjectPrx ice_encodingVersion(EncodingVersion e)
{
- return __ice_encodingVersion(e);
+ return _ice_encodingVersion(e);
}
/**
@@ -444,7 +444,7 @@ public interface ObjectPrx
**/
default ObjectPrx ice_preferSecure(boolean b)
{
- return __ice_preferSecure(b);
+ return _ice_preferSecure(b);
}
/**
@@ -463,7 +463,7 @@ public interface ObjectPrx
**/
default ObjectPrx ice_router(RouterPrx router)
{
- return __ice_router(router);
+ return _ice_router(router);
}
/**
@@ -481,7 +481,7 @@ public interface ObjectPrx
**/
default ObjectPrx ice_locator(LocatorPrx locator)
{
- return __ice_locator(locator);
+ return _ice_locator(locator);
}
/**
@@ -499,7 +499,7 @@ public interface ObjectPrx
**/
default ObjectPrx ice_collocationOptimized(boolean b)
{
- return __ice_collocationOptimized(b);
+ return _ice_collocationOptimized(b);
}
/**
@@ -509,7 +509,7 @@ public interface ObjectPrx
**/
default ObjectPrx ice_twoway()
{
- return __ice_twoway();
+ return _ice_twoway();
}
/**
@@ -525,7 +525,7 @@ public interface ObjectPrx
**/
default ObjectPrx ice_oneway()
{
- return __ice_oneway();
+ return _ice_oneway();
}
/**
@@ -541,7 +541,7 @@ public interface ObjectPrx
**/
default ObjectPrx ice_batchOneway()
{
- return __ice_batchOneway();
+ return _ice_batchOneway();
}
/**
@@ -557,7 +557,7 @@ public interface ObjectPrx
**/
default ObjectPrx ice_datagram()
{
- return __ice_datagram();
+ return _ice_datagram();
}
/**
@@ -573,7 +573,7 @@ public interface ObjectPrx
**/
default ObjectPrx ice_batchDatagram()
{
- return __ice_batchDatagram();
+ return _ice_batchDatagram();
}
/**
@@ -590,7 +590,7 @@ public interface ObjectPrx
**/
default ObjectPrx ice_compress(boolean co)
{
- return __ice_compress(co);
+ return _ice_compress(co);
}
/**
@@ -601,7 +601,7 @@ public interface ObjectPrx
**/
default ObjectPrx ice_timeout(int t)
{
- return __ice_timeout(t);
+ return _ice_timeout(t);
}
/**
@@ -614,7 +614,7 @@ public interface ObjectPrx
**/
default ObjectPrx ice_connectionId(String connectionId)
{
- return __ice_connectionId(connectionId);
+ return _ice_connectionId(connectionId);
}
/**
@@ -687,12 +687,12 @@ public interface ObjectPrx
* the server and will throw an Ice run-time exception if the target
* object does not exist or the server cannot be reached.
*
- * @param __obj The proxy to cast to @{link ObjectPrx}.
- * @return <code>__obj</code>.
+ * @param obj The proxy to cast to @{link ObjectPrx}.
+ * @return <code>obj</code>.
**/
- static ObjectPrx checkedCast(ObjectPrx __obj)
+ static ObjectPrx checkedCast(ObjectPrx obj)
{
- return __obj;
+ return obj;
}
/**
@@ -700,13 +700,13 @@ public interface ObjectPrx
* the server and throws an Ice run-time exception if the target
* object does not exist or the server cannot be reached.
*
- * @param __obj The proxy to cast to {@link ObjectPrx}.
- * @param __ctx The <code>Context</code> map for the invocation.
- * @return <code>__obj</code>.
+ * @param obj The proxy to cast to {@link ObjectPrx}.
+ * @param context The <code>Context</code> map for the invocation.
+ * @return <code>obj</code>.
**/
- static ObjectPrx checkedCast(ObjectPrx __obj, java.util.Map<String, String> __ctx)
+ static ObjectPrx checkedCast(ObjectPrx obj, java.util.Map<String, String> context)
{
- return __obj;
+ return obj;
}
/**
@@ -715,13 +715,13 @@ public interface ObjectPrx
* the server and throws an Ice run-time exception if the target
* object does not exist, the specified facet does not exist, or the server cannot be reached.
*
- * @param __obj The proxy to cast to {@link ObjectPrx}.
- * @param __facet The facet for the new proxy.
+ * @param obj The proxy to cast to {@link ObjectPrx}.
+ * @param facet The facet for the new proxy.
* @return The new proxy with the specified facet.
**/
- static ObjectPrx checkedCast(ObjectPrx __obj, String __facet)
+ static ObjectPrx checkedCast(ObjectPrx obj, String facet)
{
- return checkedCast(__obj, __facet, noExplicitContext);
+ return checkedCast(obj, facet, noExplicitContext);
}
/**
@@ -730,23 +730,23 @@ public interface ObjectPrx
* the server and throws an Ice run-time exception if the target
* object does not exist, the specified facet does not exist, or the server cannot be reached.
*
- * @param __obj The proxy to cast to {@link ObjectPrx}.
- * @param __facet The facet for the new proxy.
- * @param __ctx The <code>Context</code> map for the invocation.
+ * @param obj The proxy to cast to {@link ObjectPrx}.
+ * @param facet The facet for the new proxy.
+ * @param context The <code>Context</code> map for the invocation.
* @return The new proxy with the specified facet.
**/
- static ObjectPrx checkedCast(ObjectPrx __obj, String __facet, java.util.Map<String, String> __ctx)
+ static ObjectPrx checkedCast(ObjectPrx obj, String facet, java.util.Map<String, String> context)
{
ObjectPrx r = null;
- if(__obj != null)
+ if(obj != null)
{
- ObjectPrx p = __obj.ice_facet(__facet);
+ ObjectPrx p = obj.ice_facet(facet);
try
{
- boolean ok = p.ice_isA(ice_staticId, __ctx);
+ boolean ok = p.ice_isA(ice_staticId, context);
assert(ok);
r = new _ObjectPrxI();
- r.__copyFrom(p);
+ r._copyFrom(p);
}
catch(FacetNotExistException ex)
{
@@ -759,30 +759,30 @@ public interface ObjectPrx
* Casts a proxy to {@link ObjectPrx}. This call does
* not contact the server and always succeeds.
*
- * @param __obj The proxy to cast to {@link ObjectPrx}.
- * @return <code>__obj</code>.
+ * @param obj The proxy to cast to {@link ObjectPrx}.
+ * @return <code>obj</code>.
**/
- static ObjectPrx uncheckedCast(ObjectPrx __obj)
+ static ObjectPrx uncheckedCast(ObjectPrx obj)
{
- return __obj;
+ return obj;
}
/**
* Creates a new proxy that is identical to the passed proxy, except
* for its facet. This call does not contact the server and always succeeds.
*
- * @param __obj The proxy to cast to {@link ObjectPrx}.
- * @param __facet The facet for the new proxy.
+ * @param obj The proxy to cast to {@link ObjectPrx}.
+ * @param facet The facet for the new proxy.
* @return The new proxy with the specified facet.
**/
- static ObjectPrx uncheckedCast(ObjectPrx __obj, String __facet)
+ static ObjectPrx uncheckedCast(ObjectPrx obj, String facet)
{
ObjectPrx r = null;
- if(__obj != null)
+ if(obj != null)
{
- ObjectPrx p = __obj.ice_facet(__facet);
+ ObjectPrx p = obj.ice_facet(facet);
r = new _ObjectPrxI();
- r.__copyFrom(p);
+ r._copyFrom(p);
}
return r;
}
@@ -809,29 +809,29 @@ public interface ObjectPrx
return istr.readProxy();
}
- static <T> T __checkedCast(ObjectPrx obj, String id, Class<T> proxy, Class<?> impl)
+ static <T> T _checkedCast(ObjectPrx obj, String id, Class<T> proxy, Class<?> impl)
{
- return __checkedCast(obj, false, null, noExplicitContext, id, proxy, impl);
+ return _checkedCast(obj, false, null, noExplicitContext, id, proxy, impl);
}
- static <T> T __checkedCast(ObjectPrx obj, java.util.Map<String, String> ctx, String id, Class<T> proxy,
+ static <T> T _checkedCast(ObjectPrx obj, java.util.Map<String, String> ctx, String id, Class<T> proxy,
Class<?> impl)
{
- return __checkedCast(obj, false, null, ctx, id, proxy, impl);
+ return _checkedCast(obj, false, null, ctx, id, proxy, impl);
}
- static <T> T __checkedCast(ObjectPrx obj, String facet, String id, Class<T> proxy, Class<?> impl)
+ static <T> T _checkedCast(ObjectPrx obj, String facet, String id, Class<T> proxy, Class<?> impl)
{
- return __checkedCast(obj, true, facet, noExplicitContext, id, proxy, impl);
+ return _checkedCast(obj, true, facet, noExplicitContext, id, proxy, impl);
}
- static <T> T __checkedCast(ObjectPrx obj, String facet, java.util.Map<String, String> ctx, String id,
+ static <T> T _checkedCast(ObjectPrx obj, String facet, java.util.Map<String, String> ctx, String id,
Class<T> proxy, Class<?> impl)
{
- return __checkedCast(obj, true, facet, ctx, id, proxy, impl);
+ return _checkedCast(obj, true, facet, ctx, id, proxy, impl);
}
- static <T> T __checkedCast(ObjectPrx obj, boolean explicitFacet, String facet, java.util.Map<String, String> ctx,
+ static <T> T _checkedCast(ObjectPrx obj, boolean explicitFacet, String facet, java.util.Map<String, String> ctx,
String id, Class<T> proxy, Class<?> impl)
{
T r = null;
@@ -865,7 +865,7 @@ public interface ObjectPrx
{
throw new SyscallException(ex);
}
- h.__copyFrom(obj);
+ h._copyFrom(obj);
r = proxy.cast(h);
}
}
@@ -877,17 +877,17 @@ public interface ObjectPrx
return r;
}
- static <T> T __uncheckedCast(ObjectPrx obj, Class<T> proxy, Class<?> impl)
+ static <T> T _uncheckedCast(ObjectPrx obj, Class<T> proxy, Class<?> impl)
{
- return __uncheckedCast(obj, false, null, proxy, impl);
+ return _uncheckedCast(obj, false, null, proxy, impl);
}
- static <T> T __uncheckedCast(ObjectPrx obj, String facet, Class<T> proxy, Class<?> impl)
+ static <T> T _uncheckedCast(ObjectPrx obj, String facet, Class<T> proxy, Class<?> impl)
{
- return __uncheckedCast(obj, true, facet, proxy, impl);
+ return _uncheckedCast(obj, true, facet, proxy, impl);
}
- static <T> T __uncheckedCast(ObjectPrx obj, boolean explicitFacet, String facet, Class<T> proxy, Class<?> impl)
+ static <T> T _uncheckedCast(ObjectPrx obj, boolean explicitFacet, String facet, Class<T> proxy, Class<?> impl)
{
T r = null;
if(obj != null)
@@ -897,7 +897,7 @@ public interface ObjectPrx
if(explicitFacet)
{
ObjectPrx h = _ObjectPrxI.class.cast(impl.newInstance());
- h.__copyFrom(obj.ice_facet(facet));
+ h._copyFrom(obj.ice_facet(facet));
r = proxy.cast(h);
}
else
@@ -909,7 +909,7 @@ public interface ObjectPrx
else
{
ObjectPrx h = _ObjectPrxI.class.cast(impl.newInstance());
- h.__copyFrom(obj);
+ h._copyFrom(obj);
r = proxy.cast(h);
}
}
@@ -926,11 +926,11 @@ public interface ObjectPrx
return r;
}
- static <T> T __waitForCompletion(java.util.concurrent.CompletableFuture<T> f)
+ static <T> T waitForResponseForCompletion(java.util.concurrent.CompletableFuture<T> f)
{
try
{
- return __waitForCompletionUserEx(f);
+ return waitForResponseForCompletionUserEx(f);
}
catch(UserException ex)
{
@@ -938,7 +938,7 @@ public interface ObjectPrx
}
}
- static <T> T __waitForCompletionUserEx(java.util.concurrent.CompletableFuture<T> f)
+ static <T> T waitForResponseForCompletionUserEx(java.util.concurrent.CompletableFuture<T> f)
throws UserException
{
if(Thread.interrupted())
@@ -975,36 +975,36 @@ public interface ObjectPrx
}
}
- void __write(OutputStream os);
- void __copyFrom(ObjectPrx p);
- com.zeroc.IceInternal.Reference __reference();
- ObjectPrx __newInstance(com.zeroc.IceInternal.Reference r);
+ void _write(OutputStream os);
+ void _copyFrom(ObjectPrx p);
+ com.zeroc.IceInternal.Reference _getReference();
+ ObjectPrx _newInstance(com.zeroc.IceInternal.Reference r);
- default ObjectPrx __ice_context(java.util.Map<String, String> newContext)
+ default ObjectPrx _ice_context(java.util.Map<String, String> newContext)
{
- return __newInstance(__reference().changeContext(newContext));
+ return _newInstance(_getReference().changeContext(newContext));
}
- default ObjectPrx __ice_adapterId(String newAdapterId)
+ default ObjectPrx _ice_adapterId(String newAdapterId)
{
if(newAdapterId == null)
{
newAdapterId = "";
}
- if(newAdapterId.equals(__reference().getAdapterId()))
+ if(newAdapterId.equals(_getReference().getAdapterId()))
{
return this;
}
else
{
- return __newInstance(__reference().changeAdapterId(newAdapterId));
+ return _newInstance(_getReference().changeAdapterId(newAdapterId));
}
}
- default ObjectPrx __ice_endpoints(Endpoint[] newEndpoints)
+ default ObjectPrx _ice_endpoints(Endpoint[] newEndpoints)
{
- if(java.util.Arrays.equals(newEndpoints, __reference().getEndpoints()))
+ if(java.util.Arrays.equals(newEndpoints, _getReference().getEndpoints()))
{
return this;
}
@@ -1012,240 +1012,240 @@ public interface ObjectPrx
{
com.zeroc.IceInternal.EndpointI[] edpts = new com.zeroc.IceInternal.EndpointI[newEndpoints.length];
edpts = java.util.Arrays.asList(newEndpoints).toArray(edpts);
- return __newInstance(__reference().changeEndpoints(edpts));
+ return _newInstance(_getReference().changeEndpoints(edpts));
}
}
- default ObjectPrx __ice_locatorCacheTimeout(int newTimeout)
+ default ObjectPrx _ice_locatorCacheTimeout(int newTimeout)
{
if(newTimeout < -1)
{
throw new IllegalArgumentException("invalid value passed to ice_locatorCacheTimeout: " + newTimeout);
}
- if(newTimeout == __reference().getLocatorCacheTimeout())
+ if(newTimeout == _getReference().getLocatorCacheTimeout())
{
return this;
}
else
{
- return __newInstance(__reference().changeLocatorCacheTimeout(newTimeout));
+ return _newInstance(_getReference().changeLocatorCacheTimeout(newTimeout));
}
}
- default ObjectPrx __ice_invocationTimeout(int newTimeout)
+ default 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())
+ if(newTimeout == _getReference().getInvocationTimeout())
{
return this;
}
else
{
- return __newInstance(__reference().changeInvocationTimeout(newTimeout));
+ return _newInstance(_getReference().changeInvocationTimeout(newTimeout));
}
}
- default ObjectPrx __ice_connectionCached(boolean newCache)
+ default ObjectPrx _ice_connectionCached(boolean newCache)
{
- if(newCache == __reference().getCacheConnection())
+ if(newCache == _getReference().getCacheConnection())
{
return this;
}
else
{
- return __newInstance(__reference().changeCacheConnection(newCache));
+ return _newInstance(_getReference().changeCacheConnection(newCache));
}
}
- default ObjectPrx __ice_endpointSelection(EndpointSelectionType newType)
+ default ObjectPrx _ice_endpointSelection(EndpointSelectionType newType)
{
- if(newType == __reference().getEndpointSelection())
+ if(newType == _getReference().getEndpointSelection())
{
return this;
}
else
{
- return __newInstance(__reference().changeEndpointSelection(newType));
+ return _newInstance(_getReference().changeEndpointSelection(newType));
}
}
- default ObjectPrx __ice_secure(boolean b)
+ default ObjectPrx _ice_secure(boolean b)
{
- if(b == __reference().getSecure())
+ if(b == _getReference().getSecure())
{
return this;
}
else
{
- return __newInstance(__reference().changeSecure(b));
+ return _newInstance(_getReference().changeSecure(b));
}
}
- default ObjectPrx __ice_encodingVersion(EncodingVersion e)
+ default ObjectPrx _ice_encodingVersion(EncodingVersion e)
{
- if(e.equals(__reference().getEncoding()))
+ if(e.equals(_getReference().getEncoding()))
{
return this;
}
else
{
- return __newInstance(__reference().changeEncoding(e));
+ return _newInstance(_getReference().changeEncoding(e));
}
}
- default ObjectPrx __ice_preferSecure(boolean b)
+ default ObjectPrx _ice_preferSecure(boolean b)
{
- if(b == __reference().getPreferSecure())
+ if(b == _getReference().getPreferSecure())
{
return this;
}
else
{
- return __newInstance(__reference().changePreferSecure(b));
+ return _newInstance(_getReference().changePreferSecure(b));
}
}
- default ObjectPrx __ice_router(RouterPrx router)
+ default ObjectPrx _ice_router(RouterPrx router)
{
- com.zeroc.IceInternal.Reference ref = __reference().changeRouter(router);
- if(ref.equals(__reference()))
+ com.zeroc.IceInternal.Reference ref = _getReference().changeRouter(router);
+ if(ref.equals(_getReference()))
{
return this;
}
else
{
- return __newInstance(ref);
+ return _newInstance(ref);
}
}
- default ObjectPrx __ice_locator(LocatorPrx locator)
+ default ObjectPrx _ice_locator(LocatorPrx locator)
{
- com.zeroc.IceInternal.Reference ref = __reference().changeLocator(locator);
- if(ref.equals(__reference()))
+ com.zeroc.IceInternal.Reference ref = _getReference().changeLocator(locator);
+ if(ref.equals(_getReference()))
{
return this;
}
else
{
- return __newInstance(ref);
+ return _newInstance(ref);
}
}
- default ObjectPrx __ice_collocationOptimized(boolean b)
+ default ObjectPrx _ice_collocationOptimized(boolean b)
{
- if(b == __reference().getCollocationOptimized())
+ if(b == _getReference().getCollocationOptimized())
{
return this;
}
else
{
- return __newInstance(__reference().changeCollocationOptimized(b));
+ return _newInstance(_getReference().changeCollocationOptimized(b));
}
}
- default ObjectPrx __ice_twoway()
+ default ObjectPrx _ice_twoway()
{
- if(__reference().getMode() == com.zeroc.IceInternal.Reference.ModeTwoway)
+ if(_getReference().getMode() == com.zeroc.IceInternal.Reference.ModeTwoway)
{
return this;
}
else
{
- return __newInstance(__reference().changeMode(com.zeroc.IceInternal.Reference.ModeTwoway));
+ return _newInstance(_getReference().changeMode(com.zeroc.IceInternal.Reference.ModeTwoway));
}
}
- default ObjectPrx __ice_oneway()
+ default ObjectPrx _ice_oneway()
{
- if(__reference().getMode() == com.zeroc.IceInternal.Reference.ModeOneway)
+ if(_getReference().getMode() == com.zeroc.IceInternal.Reference.ModeOneway)
{
return this;
}
else
{
- return __newInstance(__reference().changeMode(com.zeroc.IceInternal.Reference.ModeOneway));
+ return _newInstance(_getReference().changeMode(com.zeroc.IceInternal.Reference.ModeOneway));
}
}
- default ObjectPrx __ice_batchOneway()
+ default ObjectPrx _ice_batchOneway()
{
- if(__reference().getMode() == com.zeroc.IceInternal.Reference.ModeBatchOneway)
+ if(_getReference().getMode() == com.zeroc.IceInternal.Reference.ModeBatchOneway)
{
return this;
}
else
{
- return __newInstance(__reference().changeMode(com.zeroc.IceInternal.Reference.ModeBatchOneway));
+ return _newInstance(_getReference().changeMode(com.zeroc.IceInternal.Reference.ModeBatchOneway));
}
}
- default ObjectPrx __ice_datagram()
+ default ObjectPrx _ice_datagram()
{
- if(__reference().getMode() == com.zeroc.IceInternal.Reference.ModeDatagram)
+ if(_getReference().getMode() == com.zeroc.IceInternal.Reference.ModeDatagram)
{
return this;
}
else
{
- return __newInstance(__reference().changeMode(com.zeroc.IceInternal.Reference.ModeDatagram));
+ return _newInstance(_getReference().changeMode(com.zeroc.IceInternal.Reference.ModeDatagram));
}
}
- default ObjectPrx __ice_batchDatagram()
+ default ObjectPrx _ice_batchDatagram()
{
- if(__reference().getMode() == com.zeroc.IceInternal.Reference.ModeBatchDatagram)
+ if(_getReference().getMode() == com.zeroc.IceInternal.Reference.ModeBatchDatagram)
{
return this;
}
else
{
- return __newInstance(__reference().changeMode(com.zeroc.IceInternal.Reference.ModeBatchDatagram));
+ return _newInstance(_getReference().changeMode(com.zeroc.IceInternal.Reference.ModeBatchDatagram));
}
}
- default ObjectPrx __ice_compress(boolean co)
+ default ObjectPrx _ice_compress(boolean co)
{
- com.zeroc.IceInternal.Reference ref = __reference().changeCompress(co);
- if(ref.equals(__reference()))
+ com.zeroc.IceInternal.Reference ref = _getReference().changeCompress(co);
+ if(ref.equals(_getReference()))
{
return this;
}
else
{
- return __newInstance(ref);
+ return _newInstance(ref);
}
}
- default ObjectPrx __ice_timeout(int t)
+ default ObjectPrx _ice_timeout(int t)
{
if(t < 1 && t != -1)
{
throw new IllegalArgumentException("invalid value passed to ice_timeout: " + t);
}
- com.zeroc.IceInternal.Reference ref = __reference().changeTimeout(t);
- if(ref.equals(__reference()))
+ com.zeroc.IceInternal.Reference ref = _getReference().changeTimeout(t);
+ if(ref.equals(_getReference()))
{
return this;
}
else
{
- return __newInstance(ref);
+ return _newInstance(ref);
}
}
- default ObjectPrx __ice_connectionId(String connectionId)
+ default ObjectPrx _ice_connectionId(String connectionId)
{
- com.zeroc.IceInternal.Reference ref = __reference().changeConnectionId(connectionId);
- if(ref.equals(__reference()))
+ com.zeroc.IceInternal.Reference ref = _getReference().changeConnectionId(connectionId);
+ if(ref.equals(_getReference()))
{
return this;
}
else
{
- return __newInstance(ref);
+ return _newInstance(ref);
}
}
diff --git a/java/src/Ice/src/main/java/com/zeroc/Ice/OutputStream.java b/java/src/Ice/src/main/java/com/zeroc/Ice/OutputStream.java
index 5d3f5adfb01..4df391c80ce 100644
--- a/java/src/Ice/src/main/java/com/zeroc/Ice/OutputStream.java
+++ b/java/src/Ice/src/main/java/com/zeroc/Ice/OutputStream.java
@@ -387,7 +387,7 @@ public class OutputStream
_encapsStack.start = _buf.size();
writeInt(0); // Placeholder for the encapsulation length.
- _encapsStack.encoding.ice_write(this);
+ _encapsStack.encoding.write(this);
}
/**
@@ -418,7 +418,7 @@ public class OutputStream
{
com.zeroc.IceInternal.Protocol.checkSupportedEncoding(encoding);
writeInt(6); // Size
- encoding.ice_write(this);
+ encoding.write(this);
}
/**
@@ -1574,12 +1574,12 @@ public class OutputStream
{
if(v != null)
{
- v.__write(this);
+ v._write(this);
}
else
{
Identity ident = new Identity();
- ident.ice_write(this);
+ ident.write(this);
}
}
@@ -1867,9 +1867,9 @@ public class OutputStream
// This allows reading the pending instances even if some part of
// the exception was sliced.
//
- boolean usesClasses = v.__usesClasses();
+ boolean usesClasses = v._usesClasses();
_stream.writeBool(usesClasses);
- v.__write(_stream);
+ v._write(_stream);
if(usesClasses)
{
writePendingValues();
@@ -1890,7 +1890,7 @@ public class OutputStream
//
// Write the Object slice.
//
- startSlice(Value.ice_staticId, -1, true);
+ startSlice(Value.ice_staticId(), -1, true);
_stream.writeSize(0); // For compatibility with the old AFM.
endSlice();
}
@@ -1974,7 +1974,7 @@ public class OutputStream
_stream.instance().initializationData().logger.warning(s);
}
- p.getKey().__write(_stream);
+ p.getKey()._iceWrite(_stream);
}
}
_stream.writeSize(0); // Zero marker indicates end of sequence of sequences of instances.
@@ -2074,7 +2074,7 @@ public class OutputStream
@Override
void writeException(UserException v)
{
- v.__write(_stream);
+ v._write(_stream);
}
@Override
@@ -2321,7 +2321,7 @@ public class OutputStream
}
_stream.writeSize(1); // Class instance marker.
- v.__write(_stream);
+ v._iceWrite(_stream);
}
private static final class InstanceData
diff --git a/java/src/Ice/src/main/java/com/zeroc/Ice/UnknownSlicedValue.java b/java/src/Ice/src/main/java/com/zeroc/Ice/UnknownSlicedValue.java
index 39e606cc2ee..18734abb867 100644
--- a/java/src/Ice/src/main/java/com/zeroc/Ice/UnknownSlicedValue.java
+++ b/java/src/Ice/src/main/java/com/zeroc/Ice/UnknownSlicedValue.java
@@ -35,17 +35,17 @@ public final class UnknownSlicedValue extends Value
}
@Override
- public void __write(OutputStream __os)
+ public void _iceWrite(OutputStream ostr)
{
- __os.startValue(_slicedData);
- __os.endValue();
+ ostr.startValue(_slicedData);
+ ostr.endValue();
}
@Override
- public void __read(InputStream __is)
+ public void _iceRead(InputStream istr)
{
- __is.startValue();
- _slicedData = __is.endValue(true);
+ istr.startValue();
+ _slicedData = istr.endValue(true);
}
private final String _unknownTypeId;
diff --git a/java/src/Ice/src/main/java/com/zeroc/Ice/UserException.java b/java/src/Ice/src/main/java/com/zeroc/Ice/UserException.java
index 388cd92111a..88479216740 100644
--- a/java/src/Ice/src/main/java/com/zeroc/Ice/UserException.java
+++ b/java/src/Ice/src/main/java/com/zeroc/Ice/UserException.java
@@ -83,28 +83,28 @@ public abstract class UserException extends java.lang.Exception implements Clone
return sw.toString();
}
- public void __write(OutputStream os)
+ public void _write(OutputStream os)
{
os.startException(null);
- __writeImpl(os);
+ _writeImpl(os);
os.endException();
}
- public void __read(InputStream is)
+ public void _read(InputStream is)
{
is.startException();
- __readImpl(is);
+ _readImpl(is);
is.endException(false);
}
- public boolean __usesClasses()
+ public boolean _usesClasses()
{
return false;
}
- protected abstract void __writeImpl(OutputStream os);
+ protected abstract void _writeImpl(OutputStream os);
- protected abstract void __readImpl(InputStream is);
+ protected abstract void _readImpl(InputStream is);
public static final long serialVersionUID = 0L;
}
diff --git a/java/src/Ice/src/main/java/com/zeroc/Ice/Value.java b/java/src/Ice/src/main/java/com/zeroc/Ice/Value.java
index 7b1c64781f8..362ff7d9414 100644
--- a/java/src/Ice/src/main/java/com/zeroc/Ice/Value.java
+++ b/java/src/Ice/src/main/java/com/zeroc/Ice/Value.java
@@ -52,8 +52,6 @@ public abstract class Value implements java.lang.Cloneable, java.io.Serializable
{
}
- public static final String ice_staticId = "::Ice::Object";
-
/**
* Returns the Slice type ID of the most-derived interface supported by this object.
*
@@ -61,28 +59,33 @@ public abstract class Value implements java.lang.Cloneable, java.io.Serializable
**/
public String ice_id()
{
- return ice_staticId;
+ return ice_staticId();
+ }
+
+ public static String ice_staticId()
+ {
+ return "::Ice::Object";
}
- public void __write(OutputStream __os)
+ public void _iceWrite(OutputStream ostr)
{
- __os.startValue(null);
- __writeImpl(__os);
- __os.endValue();
+ ostr.startValue(null);
+ _iceWriteImpl(ostr);
+ ostr.endValue();
}
- public void __read(InputStream __is)
+ public void _iceRead(InputStream istr)
{
- __is.startValue();
- __readImpl(__is);
- __is.endValue(false);
+ istr.startValue();
+ _iceReadImpl(istr);
+ istr.endValue(false);
}
- protected void __writeImpl(OutputStream __os)
+ protected void _iceWriteImpl(OutputStream ostr)
{
}
- protected void __readImpl(InputStream __is)
+ protected void _iceReadImpl(InputStream istr)
{
}
diff --git a/java/src/Ice/src/main/java/com/zeroc/Ice/ValueReader.java b/java/src/Ice/src/main/java/com/zeroc/Ice/ValueReader.java
index 90dbdd46cb6..d56a2a634fb 100644
--- a/java/src/Ice/src/main/java/com/zeroc/Ice/ValueReader.java
+++ b/java/src/Ice/src/main/java/com/zeroc/Ice/ValueReader.java
@@ -22,13 +22,13 @@ public abstract class ValueReader extends Value
public abstract void read(InputStream in);
@Override
- public void __write(OutputStream os)
+ public void _iceWrite(OutputStream os)
{
assert(false);
}
@Override
- public void __read(InputStream is)
+ public void _iceRead(InputStream is)
{
read(is);
}
diff --git a/java/src/Ice/src/main/java/com/zeroc/Ice/ValueWriter.java b/java/src/Ice/src/main/java/com/zeroc/Ice/ValueWriter.java
index 89860e8bedf..f232a1dcb28 100644
--- a/java/src/Ice/src/main/java/com/zeroc/Ice/ValueWriter.java
+++ b/java/src/Ice/src/main/java/com/zeroc/Ice/ValueWriter.java
@@ -22,13 +22,13 @@ public abstract class ValueWriter extends Value
public abstract void write(OutputStream out);
@Override
- public void __write(OutputStream os)
+ public void _iceWrite(OutputStream os)
{
write(os);
}
@Override
- public void __read(InputStream is)
+ public void _iceRead(InputStream is)
{
assert(false);
}
diff --git a/java/src/Ice/src/main/java/com/zeroc/Ice/_ObjectPrxI.java b/java/src/Ice/src/main/java/com/zeroc/Ice/_ObjectPrxI.java
index 10af97bb35a..322257dbd1d 100644
--- a/java/src/Ice/src/main/java/com/zeroc/Ice/_ObjectPrxI.java
+++ b/java/src/Ice/src/main/java/com/zeroc/Ice/_ObjectPrxI.java
@@ -29,38 +29,38 @@ public class _ObjectPrxI implements ObjectPrx, java.io.Serializable
return ice_isA(id, ObjectPrx.noExplicitContext);
}
- public boolean ice_isA(String id, java.util.Map<String, String> __ctx)
+ public boolean ice_isA(String id, java.util.Map<String, String> context)
{
- return __ice_isAAsync(id, __ctx, true).__wait();
+ return _iceI_ice_isAAsync(id, context, true).waitForResponse();
}
public java.util.concurrent.CompletableFuture<java.lang.Boolean> ice_isAAsync(String id)
{
- return __ice_isAAsync(id, ObjectPrx.noExplicitContext, false);
+ return _iceI_ice_isAAsync(id, ObjectPrx.noExplicitContext, false);
}
public java.util.concurrent.CompletableFuture<java.lang.Boolean> ice_isAAsync(
String id,
- java.util.Map<String, String> __ctx)
+ java.util.Map<String, String> context)
{
- return __ice_isAAsync(id, __ctx, false);
+ return _iceI_ice_isAAsync(id, context, false);
}
- private OutgoingAsync<java.lang.Boolean> __ice_isAAsync(
+ private OutgoingAsync<java.lang.Boolean> _iceI_ice_isAAsync(
String id,
- java.util.Map<String, String> __ctx,
- boolean __sync)
- {
- OutgoingAsync<java.lang.Boolean> __f =
- new OutgoingAsync<>(this, "ice_isA", OperationMode.Nonmutating, __sync, null);
- __f.invoke(true, __ctx, null, __os -> {
- __os.writeString(id);
- }, __is -> {
- boolean __ret;
- __ret = __is.readBool();
- return __ret;
+ java.util.Map<String, String> context,
+ boolean sync)
+ {
+ OutgoingAsync<java.lang.Boolean> f =
+ new OutgoingAsync<>(this, "ice_isA", OperationMode.Nonmutating, sync, null);
+ f.invoke(true, context, null, ostr -> {
+ ostr.writeString(id);
+ }, istr -> {
+ boolean ret;
+ ret = istr.readBool();
+ return ret;
});
- return __f;
+ return f;
}
public void ice_ping()
@@ -68,28 +68,28 @@ public class _ObjectPrxI implements ObjectPrx, java.io.Serializable
ice_ping(ObjectPrx.noExplicitContext);
}
- public void ice_ping(java.util.Map<String, String> __ctx)
+ public void ice_ping(java.util.Map<String, String> context)
{
- __ice_pingAsync(__ctx, true).__wait();
+ _iceI_ice_pingAsync(context, true).waitForResponse();
}
public java.util.concurrent.CompletableFuture<Void> ice_pingAsync()
{
- return __ice_pingAsync(ObjectPrx.noExplicitContext, false);
+ return _iceI_ice_pingAsync(ObjectPrx.noExplicitContext, false);
}
- public java.util.concurrent.CompletableFuture<Void> ice_pingAsync(java.util.Map<String, String> __ctx)
+ public java.util.concurrent.CompletableFuture<Void> ice_pingAsync(java.util.Map<String, String> context)
{
- return __ice_pingAsync(__ctx, false);
+ return _iceI_ice_pingAsync(context, false);
}
- private OutgoingAsync<Void> __ice_pingAsync(
- java.util.Map<String, String> __ctx,
- boolean __sync)
+ private OutgoingAsync<Void> _iceI_ice_pingAsync(
+ java.util.Map<String, String> context,
+ boolean sync)
{
- OutgoingAsync<Void> __f = new OutgoingAsync<>(this, "ice_ping", OperationMode.Nonmutating, __sync, null);
- __f.invoke(false, __ctx, null, null, null);
- return __f;
+ OutgoingAsync<Void> f = new OutgoingAsync<>(this, "ice_ping", OperationMode.Nonmutating, sync, null);
+ f.invoke(false, context, null, null, null);
+ return f;
}
public String[] ice_ids()
@@ -97,33 +97,33 @@ public class _ObjectPrxI implements ObjectPrx, java.io.Serializable
return ice_ids(ObjectPrx.noExplicitContext);
}
- public String[] ice_ids(java.util.Map<String, String> __ctx)
+ public String[] ice_ids(java.util.Map<String, String> context)
{
- return __ice_idsAsync(__ctx, true).__wait();
+ return _iceI_ice_idsAsync(context, true).waitForResponse();
}
public java.util.concurrent.CompletableFuture<String[]> ice_idsAsync()
{
- return __ice_idsAsync(ObjectPrx.noExplicitContext, false);
+ return _iceI_ice_idsAsync(ObjectPrx.noExplicitContext, false);
}
- public java.util.concurrent.CompletableFuture<String[]> ice_idsAsync(java.util.Map<String, String> __ctx)
+ public java.util.concurrent.CompletableFuture<String[]> ice_idsAsync(java.util.Map<String, String> context)
{
- return __ice_idsAsync(__ctx, false);
+ return _iceI_ice_idsAsync(context, false);
}
- private OutgoingAsync<String[]> __ice_idsAsync(
- java.util.Map<String, String> __ctx,
- boolean __sync)
+ private OutgoingAsync<String[]> _iceI_ice_idsAsync(
+ java.util.Map<String, String> context,
+ boolean sync)
{
- OutgoingAsync<String[]> __f =
- new OutgoingAsync<>(this, "ice_ids", OperationMode.Nonmutating, __sync, null);
- __f.invoke(true, __ctx, null, null, __is -> {
- String[] __ret;
- __ret = StringSeqHelper.read(__is);
- return __ret;
+ OutgoingAsync<String[]> f =
+ new OutgoingAsync<>(this, "ice_ids", OperationMode.Nonmutating, sync, null);
+ f.invoke(true, context, null, null, istr -> {
+ String[] ret;
+ ret = StringSeqHelper.read(istr);
+ return ret;
});
- return __f;
+ return f;
}
public String ice_id()
@@ -131,33 +131,33 @@ public class _ObjectPrxI implements ObjectPrx, java.io.Serializable
return ice_id(ObjectPrx.noExplicitContext);
}
- public String ice_id(java.util.Map<String, String> __ctx)
+ public String ice_id(java.util.Map<String, String> context)
{
- return __ice_idAsync(__ctx, true).__wait();
+ return _iceI_ice_idAsync(context, true).waitForResponse();
}
public java.util.concurrent.CompletableFuture<java.lang.String> ice_idAsync()
{
- return __ice_idAsync(ObjectPrx.noExplicitContext, false);
+ return _iceI_ice_idAsync(ObjectPrx.noExplicitContext, false);
}
- public java.util.concurrent.CompletableFuture<java.lang.String> ice_idAsync(java.util.Map<String, String> __ctx)
+ public java.util.concurrent.CompletableFuture<java.lang.String> ice_idAsync(java.util.Map<String, String> context)
{
- return __ice_idAsync(__ctx, false);
+ return _iceI_ice_idAsync(context, false);
}
- private OutgoingAsync<java.lang.String> __ice_idAsync(
- java.util.Map<String, String> __ctx,
- boolean __sync)
+ private OutgoingAsync<java.lang.String> _iceI_ice_idAsync(
+ java.util.Map<String, String> context,
+ boolean sync)
{
- OutgoingAsync<java.lang.String> __f =
- new OutgoingAsync<>(this, "ice_id", OperationMode.Nonmutating, __sync, null);
- __f.invoke(true, __ctx, null, null, __is -> {
- String __ret;
- __ret = __is.readString();
- return __ret;
+ OutgoingAsync<java.lang.String> f =
+ new OutgoingAsync<>(this, "ice_id", OperationMode.Nonmutating, sync, null);
+ f.invoke(true, context, null, null, istr -> {
+ String ret;
+ ret = istr.readString();
+ return ret;
});
- return __f;
+ return f;
}
public com.zeroc.Ice.Object.Ice_invokeResult ice_invoke(String operation, OperationMode mode, byte[] inParams)
@@ -166,9 +166,9 @@ public class _ObjectPrxI implements ObjectPrx, java.io.Serializable
}
public com.zeroc.Ice.Object.Ice_invokeResult ice_invoke(String operation, OperationMode mode, byte[] inParams,
- java.util.Map<String, String> __context)
+ java.util.Map<String, String> context)
{
- return __ice_invokeAsync(operation, mode, inParams, __context, true).__wait();
+ return _iceI_ice_invokeAsync(operation, mode, inParams, context, true).waitForResponse();
}
public java.util.concurrent.CompletableFuture<com.zeroc.Ice.Object.Ice_invokeResult> ice_invokeAsync(
@@ -183,22 +183,22 @@ public class _ObjectPrxI implements ObjectPrx, java.io.Serializable
String operation,
OperationMode mode,
byte[] inParams,
- java.util.Map<String, String> __context)
+ java.util.Map<String, String> context)
{
- return __ice_invokeAsync(operation, mode, inParams, __context, false);
+ return _iceI_ice_invokeAsync(operation, mode, inParams, context, false);
}
- private com.zeroc.IceInternal.ProxyIceInvoke __ice_invokeAsync(
+ private com.zeroc.IceInternal.ProxyIceInvoke _iceI_ice_invokeAsync(
String operation,
OperationMode mode,
byte[] inParams,
- java.util.Map<String, String> __context,
- boolean __sync)
+ java.util.Map<String, String> context,
+ boolean sync)
{
- com.zeroc.IceInternal.ProxyIceInvoke __f =
- new com.zeroc.IceInternal.ProxyIceInvoke(this, operation, mode, __sync);
- __f.invoke(inParams, __context);
- return __f;
+ com.zeroc.IceInternal.ProxyIceInvoke f =
+ new com.zeroc.IceInternal.ProxyIceInvoke(this, operation, mode, sync);
+ f.invoke(inParams, context);
+ return f;
}
public Identity ice_getIdentity()
@@ -219,7 +219,7 @@ public class _ObjectPrxI implements ObjectPrx, java.io.Serializable
else
{
_ObjectPrxI proxy = new _ObjectPrxI();
- proxy.__setup(_reference.changeIdentity(newIdentity));
+ proxy._setup(_reference.changeIdentity(newIdentity));
return proxy;
}
}
@@ -248,7 +248,7 @@ public class _ObjectPrxI implements ObjectPrx, java.io.Serializable
else
{
_ObjectPrxI proxy = new _ObjectPrxI();
- proxy.__setup(_reference.changeFacet(newFacet));
+ proxy._setup(_reference.changeFacet(newFacet));
return proxy;
}
}
@@ -347,15 +347,15 @@ public class _ObjectPrxI implements ObjectPrx, java.io.Serializable
public Connection ice_getConnection()
{
- return __ice_getConnectionAsync().__wait();
+ return _iceI_ice_getConnectionAsync().waitForResponse();
}
public java.util.concurrent.CompletableFuture<Connection> ice_getConnectionAsync()
{
- return __ice_getConnectionAsync();
+ return _iceI_ice_getConnectionAsync();
}
- private com.zeroc.IceInternal.ProxyGetConnection __ice_getConnectionAsync()
+ private com.zeroc.IceInternal.ProxyGetConnection _iceI_ice_getConnectionAsync()
{
com.zeroc.IceInternal.ProxyGetConnection r = new com.zeroc.IceInternal.ProxyGetConnection(this);
r.invoke();
@@ -385,26 +385,26 @@ public class _ObjectPrxI implements ObjectPrx, java.io.Serializable
public void ice_flushBatchRequests()
{
- __ice_flushBatchRequestsAsync().__wait();
+ _iceI_ice_flushBatchRequestsAsync().waitForResponse();
}
public java.util.concurrent.CompletableFuture<Void> ice_flushBatchRequestsAsync()
{
- return __ice_flushBatchRequestsAsync();
+ return _iceI_ice_flushBatchRequestsAsync();
}
- private com.zeroc.IceInternal.ProxyFlushBatch __ice_flushBatchRequestsAsync()
+ private com.zeroc.IceInternal.ProxyFlushBatch _iceI_ice_flushBatchRequestsAsync()
{
- com.zeroc.IceInternal.ProxyFlushBatch __f = new com.zeroc.IceInternal.ProxyFlushBatch(this);
+ com.zeroc.IceInternal.ProxyFlushBatch f = new com.zeroc.IceInternal.ProxyFlushBatch(this);
try
{
- __f.invoke();
+ f.invoke();
}
catch(Exception ex)
{
- __f.abort(ex);
+ f.abort(ex);
}
- return __f;
+ return f;
}
@Override
@@ -436,14 +436,14 @@ public class _ObjectPrxI implements ObjectPrx, java.io.Serializable
}
@Override
- public void __write(OutputStream os)
+ public void _write(OutputStream os)
{
- _reference.getIdentity().ice_write(os);
+ _reference.getIdentity().write(os);
_reference.streamWrite(os);
}
@Override
- public void __copyFrom(ObjectPrx p)
+ public void _copyFrom(ObjectPrx p)
{
synchronized(p)
{
@@ -454,18 +454,18 @@ public class _ObjectPrxI implements ObjectPrx, java.io.Serializable
}
@Override
- public com.zeroc.IceInternal.Reference __reference()
+ public com.zeroc.IceInternal.Reference _getReference()
{
return _reference;
}
@Override
- public ObjectPrx __newInstance(com.zeroc.IceInternal.Reference ref)
+ public ObjectPrx _newInstance(com.zeroc.IceInternal.Reference ref)
{
try
{
_ObjectPrxI proxy = getClass().newInstance();
- proxy.__setup(ref);
+ proxy._setup(ref);
return proxy;
}
catch(InstantiationException e)
@@ -486,7 +486,7 @@ public class _ObjectPrxI implements ObjectPrx, java.io.Serializable
}
}
- public StreamPair __getCachedMessageBuffers()
+ public StreamPair _getCachedMessageBuffers()
{
synchronized(this)
{
@@ -498,7 +498,7 @@ public class _ObjectPrxI implements ObjectPrx, java.io.Serializable
return null;
}
- public void __cacheMessageBuffers(InputStream is, OutputStream os)
+ public void _cacheMessageBuffers(InputStream is, OutputStream os)
{
synchronized(this)
{
@@ -510,10 +510,10 @@ public class _ObjectPrxI implements ObjectPrx, java.io.Serializable
}
}
- public int __handleException(Exception ex, com.zeroc.IceInternal.RequestHandler handler, OperationMode mode,
+ public int _handleException(Exception ex, com.zeroc.IceInternal.RequestHandler handler, OperationMode mode,
boolean sent, com.zeroc.IceInternal.Holder<Integer> interval, int cnt)
{
- __updateRequestHandler(handler, null); // Clear the request handler
+ _updateRequestHandler(handler, null); // Clear the request handler
//
// We only retry local exception, system exceptions aren't retried.
@@ -556,7 +556,7 @@ public class _ObjectPrxI implements ObjectPrx, java.io.Serializable
}
}
- public com.zeroc.IceInternal.RequestHandler __getRequestHandler()
+ public com.zeroc.IceInternal.RequestHandler _getRequestHandler()
{
if(_reference.getCacheConnection())
{
@@ -571,7 +571,7 @@ public class _ObjectPrxI implements ObjectPrx, java.io.Serializable
return _reference.getRequestHandler(this);
}
- synchronized public com.zeroc.IceInternal.BatchRequestQueue __getBatchRequestQueue()
+ synchronized public com.zeroc.IceInternal.BatchRequestQueue _getBatchRequestQueue()
{
if(_batchRequestQueue == null)
{
@@ -580,7 +580,7 @@ public class _ObjectPrxI implements ObjectPrx, java.io.Serializable
return _batchRequestQueue;
}
- public com.zeroc.IceInternal.RequestHandler __setRequestHandler(com.zeroc.IceInternal.RequestHandler handler)
+ public com.zeroc.IceInternal.RequestHandler _setRequestHandler(com.zeroc.IceInternal.RequestHandler handler)
{
if(_reference.getCacheConnection())
{
@@ -596,7 +596,7 @@ public class _ObjectPrxI implements ObjectPrx, java.io.Serializable
return handler;
}
- public void __updateRequestHandler(com.zeroc.IceInternal.RequestHandler previous,
+ public void _updateRequestHandler(com.zeroc.IceInternal.RequestHandler previous,
com.zeroc.IceInternal.RequestHandler handler)
{
if(_reference.getCacheConnection() && previous != null)
@@ -621,7 +621,7 @@ public class _ObjectPrxI implements ObjectPrx, java.io.Serializable
//
// Only for use by ProxyFactory
//
- public void __setup(com.zeroc.IceInternal.Reference ref)
+ public void _setup(com.zeroc.IceInternal.Reference ref)
{
//
// No need to synchronize, as this operation is only called
diff --git a/java/src/Ice/src/main/java/com/zeroc/IceInternal/CommunicatorFlushBatch.java b/java/src/Ice/src/main/java/com/zeroc/IceInternal/CommunicatorFlushBatch.java
index 13bc6a5b5a0..a7c4dc65b38 100644
--- a/java/src/Ice/src/main/java/com/zeroc/IceInternal/CommunicatorFlushBatch.java
+++ b/java/src/Ice/src/main/java/com/zeroc/IceInternal/CommunicatorFlushBatch.java
@@ -28,9 +28,9 @@ public class CommunicatorFlushBatch extends InvocationFutureI<Void>
}
@Override
- protected void __sent()
+ protected void markSent()
{
- super.__sent();
+ super.markSent();
assert((_state & StateOK) != 0);
complete(null);
@@ -48,19 +48,19 @@ public class CommunicatorFlushBatch extends InvocationFutureI<Void>
}
@Override
- protected void __sent()
+ protected void markSent()
{
assert(false);
}
@Override
- protected boolean __needCallback()
+ protected boolean needCallback()
{
return false;
}
@Override
- protected void __completed()
+ protected void markCompleted()
{
assert(false);
}
@@ -145,7 +145,7 @@ public class CommunicatorFlushBatch extends InvocationFutureI<Void>
doCheck(true);
}
- public void __wait()
+ public void waitForResponse()
{
if(Thread.interrupted())
{
diff --git a/java/src/Ice/src/main/java/com/zeroc/IceInternal/ConnectRequestHandler.java b/java/src/Ice/src/main/java/com/zeroc/IceInternal/ConnectRequestHandler.java
index 12e6d3616a1..ffc5c51be46 100644
--- a/java/src/Ice/src/main/java/com/zeroc/IceInternal/ConnectRequestHandler.java
+++ b/java/src/Ice/src/main/java/com/zeroc/IceInternal/ConnectRequestHandler.java
@@ -343,7 +343,7 @@ public class ConnectRequestHandler
}
for(com.zeroc.Ice._ObjectPrxI proxy : _proxies)
{
- proxy.__updateRequestHandler(previous, _requestHandler);
+ proxy._updateRequestHandler(previous, _requestHandler);
}
}
diff --git a/java/src/Ice/src/main/java/com/zeroc/IceInternal/ConnectionFlushBatch.java b/java/src/Ice/src/main/java/com/zeroc/IceInternal/ConnectionFlushBatch.java
index d576323caed..2d4a35a0f82 100644
--- a/java/src/Ice/src/main/java/com/zeroc/IceInternal/ConnectionFlushBatch.java
+++ b/java/src/Ice/src/main/java/com/zeroc/IceInternal/ConnectionFlushBatch.java
@@ -27,22 +27,22 @@ public class ConnectionFlushBatch extends OutgoingAsyncBaseI<Void>
}
@Override
- protected void __sent()
+ protected void markSent()
{
- super.__sent();
+ super.markSent();
assert((_state & StateOK) != 0);
complete(null);
}
@Override
- protected void __completed()
+ protected void markCompleted()
{
if(_exception != null)
{
completeExceptionally(_exception);
}
- super.__completed();
+ super.markCompleted();
}
public void invoke()
diff --git a/java/src/Ice/src/main/java/com/zeroc/IceInternal/FixedReference.java b/java/src/Ice/src/main/java/com/zeroc/IceInternal/FixedReference.java
index a861857bf4d..d7d7ce1ba09 100644
--- a/java/src/Ice/src/main/java/com/zeroc/IceInternal/FixedReference.java
+++ b/java/src/Ice/src/main/java/com/zeroc/IceInternal/FixedReference.java
@@ -278,7 +278,7 @@ public class FixedReference extends Reference
{
handler = new QueueRequestHandler(getInstance(), handler);
}
- return proxy.__setRequestHandler(handler);
+ return proxy._setRequestHandler(handler);
}
@Override
diff --git a/java/src/Ice/src/main/java/com/zeroc/IceInternal/Incoming.java b/java/src/Ice/src/main/java/com/zeroc/IceInternal/Incoming.java
index 67941f3b1e5..687bc03d412 100644
--- a/java/src/Ice/src/main/java/com/zeroc/IceInternal/Incoming.java
+++ b/java/src/Ice/src/main/java/com/zeroc/IceInternal/Incoming.java
@@ -114,7 +114,7 @@ final public class Incoming implements com.zeroc.Ice.Request
//
// Read the current.
//
- _current.id.ice_read(_is);
+ _current.id.read(_is);
//
// For compatibility with the old FacetPath.
@@ -223,7 +223,7 @@ final public class Incoming implements com.zeroc.Ice.Request
try
{
- CompletionStage<OutputStream> f = _servant.__dispatch(this, _current);
+ CompletionStage<OutputStream> f = _servant._iceDispatch(this, _current);
if(f == null)
{
completed(null, false);
@@ -617,7 +617,7 @@ final public class Incoming implements com.zeroc.Ice.Request
{
assert(false);
}
- ex.id.ice_write(_os);
+ ex.id.write(_os);
//
// For compatibility with the old FacetPath.
diff --git a/java/src/Ice/src/main/java/com/zeroc/IceInternal/InvocationFutureI.java b/java/src/Ice/src/main/java/com/zeroc/IceInternal/InvocationFutureI.java
index 38821b2d98e..a99f3788e85 100644
--- a/java/src/Ice/src/main/java/com/zeroc/IceInternal/InvocationFutureI.java
+++ b/java/src/Ice/src/main/java/com/zeroc/IceInternal/InvocationFutureI.java
@@ -211,7 +211,7 @@ public abstract class InvocationFutureI<T> extends com.zeroc.Ice.InvocationFutur
return r;
}
- protected synchronized void __sent()
+ protected synchronized void markSent()
{
if(_sentFuture != null && !_sentFuture.isDone())
{
@@ -230,7 +230,7 @@ public abstract class InvocationFutureI<T> extends com.zeroc.Ice.InvocationFutur
try
{
- __sent();
+ markSent();
}
catch(java.lang.RuntimeException ex)
{
@@ -265,12 +265,12 @@ public abstract class InvocationFutureI<T> extends com.zeroc.Ice.InvocationFutur
}
}
- protected boolean __needCallback()
+ protected boolean needCallback()
{
return true;
}
- protected void __completed()
+ protected void markCompleted()
{
if(_exception != null && _sentFuture != null)
{
@@ -289,7 +289,7 @@ public abstract class InvocationFutureI<T> extends com.zeroc.Ice.InvocationFutur
try
{
- __completed();
+ markCompleted();
}
catch(RuntimeException ex)
{
@@ -403,7 +403,7 @@ public abstract class InvocationFutureI<T> extends com.zeroc.Ice.InvocationFutur
_state |= StateOK;
}
_cancellationHandler = null;
- if(!__needCallback())
+ if(!needCallback())
{
if(_observer != null)
{
@@ -412,7 +412,7 @@ public abstract class InvocationFutureI<T> extends com.zeroc.Ice.InvocationFutur
}
}
this.notifyAll();
- return __needCallback();
+ return needCallback();
}
}
@@ -427,7 +427,7 @@ public abstract class InvocationFutureI<T> extends com.zeroc.Ice.InvocationFutur
{
_observer.failed(ex.ice_id());
}
- if(!__needCallback())
+ if(!needCallback())
{
if(_observer != null)
{
@@ -436,7 +436,7 @@ public abstract class InvocationFutureI<T> extends com.zeroc.Ice.InvocationFutur
}
}
this.notifyAll();
- return __needCallback();
+ return needCallback();
}
}
diff --git a/java/src/Ice/src/main/java/com/zeroc/IceInternal/LocatorInfo.java b/java/src/Ice/src/main/java/com/zeroc/IceInternal/LocatorInfo.java
index 8e5cc8974ce..bc7406c876d 100644
--- a/java/src/Ice/src/main/java/com/zeroc/IceInternal/LocatorInfo.java
+++ b/java/src/Ice/src/main/java/com/zeroc/IceInternal/LocatorInfo.java
@@ -25,7 +25,7 @@ public final class LocatorInfo
EndpointI[] endpoints = null;
if(proxy != null)
{
- Reference r = ((com.zeroc.Ice._ObjectPrxI)proxy).__reference();
+ Reference r = ((com.zeroc.Ice._ObjectPrxI)proxy)._getReference();
if(_ref.isWellKnown() && !Protocol.isSupported(_ref.getEncoding(), r.getEncoding()))
{
//
@@ -644,7 +644,7 @@ public final class LocatorInfo
finishRequest(Reference ref, java.util.List<Reference> wellKnownRefs, com.zeroc.Ice.ObjectPrx proxy,
boolean notRegistered)
{
- if(proxy == null || ((com.zeroc.Ice._ObjectPrxI)proxy).__reference().isIndirect())
+ if(proxy == null || ((com.zeroc.Ice._ObjectPrxI)proxy)._getReference().isIndirect())
{
//
// Remove the cached references of well-known objects for which we tried
@@ -658,11 +658,11 @@ public final class LocatorInfo
if(!ref.isWellKnown())
{
- if(proxy != null && !((com.zeroc.Ice._ObjectPrxI)proxy).__reference().isIndirect())
+ if(proxy != null && !((com.zeroc.Ice._ObjectPrxI)proxy)._getReference().isIndirect())
{
// Cache the adapter endpoints.
_table.addAdapterEndpoints(ref.getAdapterId(),
- ((com.zeroc.Ice._ObjectPrxI)proxy).__reference().getEndpoints());
+ ((com.zeroc.Ice._ObjectPrxI)proxy)._getReference().getEndpoints());
}
else if(notRegistered) // If the adapter isn't registered anymore, remove it from the cache.
{
@@ -677,10 +677,10 @@ public final class LocatorInfo
}
else
{
- if(proxy != null && !((com.zeroc.Ice._ObjectPrxI)proxy).__reference().isWellKnown())
+ if(proxy != null && !((com.zeroc.Ice._ObjectPrxI)proxy)._getReference().isWellKnown())
{
// Cache the well-known object reference.
- _table.addObjectReference(ref.getIdentity(), ((com.zeroc.Ice._ObjectPrxI)proxy).__reference());
+ _table.addObjectReference(ref.getIdentity(), ((com.zeroc.Ice._ObjectPrxI)proxy)._getReference());
}
else if(notRegistered) // If the well-known object isn't registered anymore, remove it from the cache.
{
diff --git a/java/src/Ice/src/main/java/com/zeroc/IceInternal/LocatorManager.java b/java/src/Ice/src/main/java/com/zeroc/IceInternal/LocatorManager.java
index ae1aaca8019..a32a221e3f9 100644
--- a/java/src/Ice/src/main/java/com/zeroc/IceInternal/LocatorManager.java
+++ b/java/src/Ice/src/main/java/com/zeroc/IceInternal/LocatorManager.java
@@ -58,7 +58,7 @@ public final class LocatorManager
LocatorKey set(com.zeroc.Ice.LocatorPrx locator)
{
- Reference r = ((com.zeroc.Ice._ObjectPrxI)locator).__reference();
+ Reference r = ((com.zeroc.Ice._ObjectPrxI)locator)._getReference();
_id = r.getIdentity();
_encoding = r.getEncoding();
return this;
diff --git a/java/src/Ice/src/main/java/com/zeroc/IceInternal/ObserverHelper.java b/java/src/Ice/src/main/java/com/zeroc/IceInternal/ObserverHelper.java
index 6075fcbd2b7..3be5ddc1f13 100644
--- a/java/src/Ice/src/main/java/com/zeroc/IceInternal/ObserverHelper.java
+++ b/java/src/Ice/src/main/java/com/zeroc/IceInternal/ObserverHelper.java
@@ -40,7 +40,7 @@ public final class ObserverHelper
get(com.zeroc.Ice.ObjectPrx proxy, String op, java.util.Map<String, String> context)
{
CommunicatorObserver obsv =
- ((com.zeroc.Ice._ObjectPrxI)proxy).__reference().getInstance().initializationData().observer;
+ ((com.zeroc.Ice._ObjectPrxI)proxy)._getReference().getInstance().initializationData().observer;
if(obsv != null)
{
InvocationObserver observer;
diff --git a/java/src/Ice/src/main/java/com/zeroc/IceInternal/OutgoingAsync.java b/java/src/Ice/src/main/java/com/zeroc/IceInternal/OutgoingAsync.java
index bff6a72055d..e3965ad6650 100644
--- a/java/src/Ice/src/main/java/com/zeroc/IceInternal/OutgoingAsync.java
+++ b/java/src/Ice/src/main/java/com/zeroc/IceInternal/OutgoingAsync.java
@@ -34,11 +34,11 @@ public class OutgoingAsync<T> extends ProxyOutgoingAsyncBaseI<T>
_mode = mode == null ? OperationMode.Normal : mode;
_synchronous = synchronous;
_userExceptions = userExceptions;
- _encoding = Protocol.getCompatibleEncoding(_proxy.__reference().getEncoding());
+ _encoding = Protocol.getCompatibleEncoding(_proxy._getReference().getEncoding());
if(_instance.cacheMessageBuffers() > 0)
{
- _ObjectPrxI.StreamPair p = _proxy.__getCachedMessageBuffers();
+ _ObjectPrxI.StreamPair p = _proxy._getCachedMessageBuffers();
if(p != null)
{
_is = p.is;
@@ -87,7 +87,7 @@ public class OutgoingAsync<T> extends ProxyOutgoingAsyncBaseI<T>
// NOTE: we don't call sent/completed callbacks for batch AMI requests
//
_sentSynchronously = true;
- _proxy.__getBatchRequestQueue().finishBatchRequest(_os, _proxy, _operation);
+ _proxy._getBatchRequestQueue().finishBatchRequest(_os, _proxy, _operation);
finished(true);
}
else
@@ -106,7 +106,7 @@ public class OutgoingAsync<T> extends ProxyOutgoingAsyncBaseI<T>
}
}
- public T __wait()
+ public T waitForResponse()
{
if(isBatch())
{
@@ -115,7 +115,7 @@ public class OutgoingAsync<T> extends ProxyOutgoingAsyncBaseI<T>
try
{
- return __waitUserEx();
+ return waitForResponseOrUserEx();
}
catch(UserException ex)
{
@@ -123,7 +123,7 @@ public class OutgoingAsync<T> extends ProxyOutgoingAsyncBaseI<T>
}
}
- public T __waitUserEx()
+ public T waitForResponseOrUserEx()
throws UserException
{
if(Thread.interrupted())
@@ -161,9 +161,9 @@ public class OutgoingAsync<T> extends ProxyOutgoingAsyncBaseI<T>
}
@Override
- protected void __sent()
+ protected void markSent()
{
- super.__sent();
+ super.markSent();
if(!_proxy.ice_isTwoway())
{
@@ -192,7 +192,7 @@ public class OutgoingAsync<T> extends ProxyOutgoingAsyncBaseI<T>
public int invokeCollocated(CollocatedRequestHandler handler)
{
// The stream cannot be cached if the proxy is not a twoway or there is an invocation timeout set.
- if(!_proxy.ice_isTwoway() || _proxy.__reference().getInvocationTimeout() > 0)
+ if(!_proxy.ice_isTwoway() || _proxy._getReference().getInvocationTimeout() > 0)
{
// Disable caching by marking the streams as cached!
_state |= StateCachedBuffers;
@@ -210,16 +210,16 @@ public class OutgoingAsync<T> extends ProxyOutgoingAsyncBaseI<T>
// must notify the connection about that we give up ownership
// of the batch stream.
//
- _proxy.__getBatchRequestQueue().abortBatchRequest(_os);
+ _proxy._getBatchRequestQueue().abortBatchRequest(_os);
}
super.abort(ex);
}
@Override
- protected void __completed()
+ protected void markCompleted()
{
- super.__completed();
+ super.markCompleted();
try
{
@@ -374,7 +374,7 @@ public class OutgoingAsync<T> extends ProxyOutgoingAsyncBaseI<T>
}
_os.reset();
- _proxy.__cacheMessageBuffers(_is, _os);
+ _proxy._cacheMessageBuffers(_is, _os);
_is = null;
_os = null;
diff --git a/java/src/Ice/src/main/java/com/zeroc/IceInternal/ProxyFactory.java b/java/src/Ice/src/main/java/com/zeroc/IceInternal/ProxyFactory.java
index 941dbab051a..0150fb73f78 100644
--- a/java/src/Ice/src/main/java/com/zeroc/IceInternal/ProxyFactory.java
+++ b/java/src/Ice/src/main/java/com/zeroc/IceInternal/ProxyFactory.java
@@ -26,7 +26,7 @@ public final class ProxyFactory
if(proxy != null)
{
com.zeroc.Ice._ObjectPrxI h = (com.zeroc.Ice._ObjectPrxI)proxy;
- return h.__reference().toString();
+ return h._getReference().toString();
}
else
{
@@ -48,7 +48,7 @@ public final class ProxyFactory
if(proxy != null)
{
com.zeroc.Ice._ObjectPrxI h = (com.zeroc.Ice._ObjectPrxI)proxy;
- return h.__reference().toProperty(prefix);
+ return h._getReference().toProperty(prefix);
}
else
{
@@ -71,7 +71,7 @@ public final class ProxyFactory
if(ref != null)
{
com.zeroc.Ice._ObjectPrxI proxy = new com.zeroc.Ice._ObjectPrxI();
- proxy.__setup(ref);
+ proxy._setup(ref);
return proxy;
}
else
diff --git a/java/src/Ice/src/main/java/com/zeroc/IceInternal/ProxyFlushBatch.java b/java/src/Ice/src/main/java/com/zeroc/IceInternal/ProxyFlushBatch.java
index 5bdd570cd82..527a26658bd 100644
--- a/java/src/Ice/src/main/java/com/zeroc/IceInternal/ProxyFlushBatch.java
+++ b/java/src/Ice/src/main/java/com/zeroc/IceInternal/ProxyFlushBatch.java
@@ -15,7 +15,7 @@ public class ProxyFlushBatch extends ProxyOutgoingAsyncBaseI<Void>
{
super(prx, "ice_flushBatchRequests");
_observer = ObserverHelper.get(prx, "ice_flushBatchRequests");
- _batchRequestNum = prx.__getBatchRequestQueue().swap(_os);
+ _batchRequestNum = prx._getBatchRequestQueue().swap(_os);
}
@Override
@@ -26,24 +26,24 @@ public class ProxyFlushBatch extends ProxyOutgoingAsyncBaseI<Void>
}
@Override
- protected synchronized void __sent()
+ protected synchronized void markSent()
{
- super.__sent();
+ super.markSent();
assert((_state & StateOK) != 0);
complete(null);
}
@Override
- protected boolean __needCallback()
+ protected boolean needCallback()
{
return true;
}
@Override
- protected void __completed()
+ protected void markCompleted()
{
- super.__completed();
+ super.markCompleted();
if(_exception != null)
{
completeExceptionally(_exception);
@@ -74,11 +74,11 @@ public class ProxyFlushBatch extends ProxyOutgoingAsyncBaseI<Void>
public void invoke()
{
- Protocol.checkSupportedProtocol(Protocol.getCompatibleProtocol(_proxy.__reference().getProtocol()));
+ Protocol.checkSupportedProtocol(Protocol.getCompatibleProtocol(_proxy._getReference().getProtocol()));
invokeImpl(true); // userThread = true
}
- public void __wait()
+ public void waitForResponse()
{
if(Thread.interrupted())
{
diff --git a/java/src/Ice/src/main/java/com/zeroc/IceInternal/ProxyGetConnection.java b/java/src/Ice/src/main/java/com/zeroc/IceInternal/ProxyGetConnection.java
index 0363b63aba2..84effe3a4e7 100644
--- a/java/src/Ice/src/main/java/com/zeroc/IceInternal/ProxyGetConnection.java
+++ b/java/src/Ice/src/main/java/com/zeroc/IceInternal/ProxyGetConnection.java
@@ -18,15 +18,15 @@ public class ProxyGetConnection extends ProxyOutgoingAsyncBaseI<com.zeroc.Ice.Co
}
@Override
- protected boolean __needCallback()
+ protected boolean needCallback()
{
return true;
}
@Override
- protected void __completed()
+ protected void markCompleted()
{
- super.__completed();
+ super.markCompleted();
if(_exception != null)
{
@@ -72,7 +72,7 @@ public class ProxyGetConnection extends ProxyOutgoingAsyncBaseI<com.zeroc.Ice.Co
invokeImpl(true); // userThread = true
}
- public com.zeroc.Ice.Connection __wait()
+ public com.zeroc.Ice.Connection waitForResponse()
{
if(Thread.interrupted())
{
diff --git a/java/src/Ice/src/main/java/com/zeroc/IceInternal/ProxyIceInvoke.java b/java/src/Ice/src/main/java/com/zeroc/IceInternal/ProxyIceInvoke.java
index e5fcdbe89b8..94f2dd82a64 100644
--- a/java/src/Ice/src/main/java/com/zeroc/IceInternal/ProxyIceInvoke.java
+++ b/java/src/Ice/src/main/java/com/zeroc/IceInternal/ProxyIceInvoke.java
@@ -25,7 +25,7 @@ public class ProxyIceInvoke extends ProxyOutgoingAsyncBaseI<com.zeroc.Ice.Object
super((com.zeroc.Ice._ObjectPrxI)prx, operation);
_mode = mode == null ? com.zeroc.Ice.OperationMode.Normal : mode;
_synchronous = synchronous;
- _encoding = Protocol.getCompatibleEncoding(_proxy.__reference().getEncoding());
+ _encoding = Protocol.getCompatibleEncoding(_proxy._getReference().getEncoding());
_is = null;
}
@@ -42,7 +42,7 @@ public class ProxyIceInvoke extends ProxyOutgoingAsyncBaseI<com.zeroc.Ice.Object
// NOTE: we don't call sent/completed callbacks for batch AMI requests
//
_sentSynchronously = true;
- _proxy.__getBatchRequestQueue().finishBatchRequest(_os, _proxy, _operation);
+ _proxy._getBatchRequestQueue().finishBatchRequest(_os, _proxy, _operation);
finished(true);
}
else
@@ -61,7 +61,7 @@ public class ProxyIceInvoke extends ProxyOutgoingAsyncBaseI<com.zeroc.Ice.Object
}
}
- public com.zeroc.Ice.Object.Ice_invokeResult __wait()
+ public com.zeroc.Ice.Object.Ice_invokeResult waitForResponse()
{
if(isBatch())
{
@@ -102,9 +102,9 @@ public class ProxyIceInvoke extends ProxyOutgoingAsyncBaseI<com.zeroc.Ice.Object
}
@Override
- protected void __sent()
+ protected void markSent()
{
- super.__sent();
+ super.markSent();
if(!_proxy.ice_isTwoway())
{
@@ -133,7 +133,7 @@ public class ProxyIceInvoke extends ProxyOutgoingAsyncBaseI<com.zeroc.Ice.Object
public int invokeCollocated(CollocatedRequestHandler handler)
{
// The stream cannot be cached if the proxy is not a twoway or there is an invocation timeout set.
- if(!_proxy.ice_isTwoway() || _proxy.__reference().getInvocationTimeout() > 0)
+ if(!_proxy.ice_isTwoway() || _proxy._getReference().getInvocationTimeout() > 0)
{
// Disable caching by marking the streams as cached!
_state |= StateCachedBuffers;
@@ -151,16 +151,16 @@ public class ProxyIceInvoke extends ProxyOutgoingAsyncBaseI<com.zeroc.Ice.Object
// must notify the connection about that we give up ownership
// of the batch stream.
//
- _proxy.__getBatchRequestQueue().abortBatchRequest(_os);
+ _proxy._getBatchRequestQueue().abortBatchRequest(_os);
}
super.abort(ex);
}
@Override
- protected void __completed()
+ protected void markCompleted()
{
- super.__completed();
+ super.markCompleted();
if(_exception != null)
{
diff --git a/java/src/Ice/src/main/java/com/zeroc/IceInternal/ProxyOutgoingAsyncBaseI.java b/java/src/Ice/src/main/java/com/zeroc/IceInternal/ProxyOutgoingAsyncBaseI.java
index cb29f052104..7cb2a1ee367 100644
--- a/java/src/Ice/src/main/java/com/zeroc/IceInternal/ProxyOutgoingAsyncBaseI.java
+++ b/java/src/Ice/src/main/java/com/zeroc/IceInternal/ProxyOutgoingAsyncBaseI.java
@@ -220,7 +220,7 @@ public abstract class ProxyOutgoingAsyncBaseI<T> extends OutgoingAsyncBaseI<T> i
// require could end up waiting for the flush of the
// connection to be done.
//
- _proxy.__updateRequestHandler(_handler, null); // Clear request handler and always retry.
+ _proxy._updateRequestHandler(_handler, null); // Clear request handler and always retry.
_instance.retryQueue().add(this, 0);
}
catch(com.zeroc.Ice.Exception exc)
@@ -240,7 +240,7 @@ public abstract class ProxyOutgoingAsyncBaseI<T> extends OutgoingAsyncBaseI<T> i
public void cancelable(final CancellationHandler handler)
{
- if(_proxy.__reference().getInvocationTimeout() == -2 && _cachedConnection != null)
+ if(_proxy._getReference().getInvocationTimeout() == -2 && _cachedConnection != null)
{
final int timeout = _cachedConnection.timeout();
if(timeout > 0)
@@ -280,26 +280,26 @@ public abstract class ProxyOutgoingAsyncBaseI<T> extends OutgoingAsyncBaseI<T> i
protected ProxyOutgoingAsyncBaseI(com.zeroc.Ice._ObjectPrxI prx, String op)
{
- super(prx.ice_getCommunicator(), prx.__reference().getInstance(), op);
+ super(prx.ice_getCommunicator(), prx._getReference().getInstance(), op);
_proxy = prx;
_mode = com.zeroc.Ice.OperationMode.Normal;
_cnt = 0;
_sent = false;
- _proxyMode = _proxy.__reference().getMode();
+ _proxyMode = _proxy._getReference().getMode();
}
protected ProxyOutgoingAsyncBaseI(com.zeroc.Ice._ObjectPrxI prx, String op, com.zeroc.Ice.OutputStream os)
{
- super(prx.ice_getCommunicator(), prx.__reference().getInstance(), op, os);
+ super(prx.ice_getCommunicator(), prx._getReference().getInstance(), op, os);
_proxy = prx;
_mode = com.zeroc.Ice.OperationMode.Normal;
_cnt = 0;
_sent = false;
- _proxyMode = _proxy.__reference().getMode();
+ _proxyMode = _proxy._getReference().getMode();
}
@Override
- protected boolean __needCallback()
+ protected boolean needCallback()
{
return !isBatch();
}
@@ -310,7 +310,7 @@ public abstract class ProxyOutgoingAsyncBaseI<T> extends OutgoingAsyncBaseI<T> i
{
if(userThread)
{
- int invocationTimeout = _proxy.__reference().getInvocationTimeout();
+ int invocationTimeout = _proxy._getReference().getInvocationTimeout();
if(invocationTimeout > 0)
{
_timerFuture = _instance.timer().schedule(
@@ -338,7 +338,7 @@ public abstract class ProxyOutgoingAsyncBaseI<T> extends OutgoingAsyncBaseI<T> i
{
_sent = false;
_handler = null;
- _handler = _proxy.__getRequestHandler();
+ _handler = _proxy._getRequestHandler();
int status = _handler.sendAsyncRequest(this);
if((status & AsyncStatus.Sent) > 0)
{
@@ -362,7 +362,7 @@ public abstract class ProxyOutgoingAsyncBaseI<T> extends OutgoingAsyncBaseI<T> i
}
catch(RetryException ex)
{
- _proxy.__updateRequestHandler(_handler, null); // Clear request handler and always retry.
+ _proxy._updateRequestHandler(_handler, null); // Clear request handler and always retry.
}
catch(com.zeroc.Ice.Exception ex)
{
@@ -442,13 +442,13 @@ public abstract class ProxyOutgoingAsyncBaseI<T> extends OutgoingAsyncBaseI<T> i
protected int handleException(com.zeroc.Ice.Exception exc)
{
Holder<Integer> interval = new Holder<>();
- _cnt = _proxy.__handleException(exc, _handler, _mode, _sent, interval, _cnt);
+ _cnt = _proxy._handleException(exc, _handler, _mode, _sent, interval, _cnt);
return interval.value;
}
protected void prepare(java.util.Map<String, String> ctx)
{
- Protocol.checkSupportedProtocol(Protocol.getCompatibleProtocol(_proxy.__reference().getProtocol()));
+ Protocol.checkSupportedProtocol(Protocol.getCompatibleProtocol(_proxy._getReference().getProtocol()));
_observer = ObserverHelper.get(_proxy, _operation, ctx == null ? _emptyContext : ctx);
@@ -465,14 +465,14 @@ public abstract class ProxyOutgoingAsyncBaseI<T> extends OutgoingAsyncBaseI<T> i
case Reference.ModeBatchOneway:
case Reference.ModeBatchDatagram:
{
- _proxy.__getBatchRequestQueue().prepareBatchRequest(_os);
+ _proxy._getBatchRequestQueue().prepareBatchRequest(_os);
break;
}
}
- Reference ref = _proxy.__reference();
+ Reference ref = _proxy._getReference();
- ref.getIdentity().ice_write(_os);
+ ref.getIdentity().write(_os);
//
// For compatibility with the old FacetPath.
diff --git a/java/src/Ice/src/main/java/com/zeroc/IceInternal/Reference.java b/java/src/Ice/src/main/java/com/zeroc/IceInternal/Reference.java
index 2b2d2fc12e0..0b246868519 100644
--- a/java/src/Ice/src/main/java/com/zeroc/IceInternal/Reference.java
+++ b/java/src/Ice/src/main/java/com/zeroc/IceInternal/Reference.java
@@ -283,8 +283,8 @@ public abstract class Reference implements Cloneable
if(!s.getEncoding().equals(com.zeroc.Ice.Util.Encoding_1_0))
{
- _protocol.ice_write(s);
- _encoding.ice_write(s);
+ _protocol.write(s);
+ _encoding.write(s);
}
// Derived class writes the remainder of the reference.
diff --git a/java/src/Ice/src/main/java/com/zeroc/IceInternal/ReferenceFactory.java b/java/src/Ice/src/main/java/com/zeroc/IceInternal/ReferenceFactory.java
index b9313f1d136..47d6622bafa 100644
--- a/java/src/Ice/src/main/java/com/zeroc/IceInternal/ReferenceFactory.java
+++ b/java/src/Ice/src/main/java/com/zeroc/IceInternal/ReferenceFactory.java
@@ -744,7 +744,7 @@ public final class ReferenceFactory
LocatorInfo locatorInfo = null;
if(_defaultLocator != null)
{
- if(!((com.zeroc.Ice._ObjectPrxI)_defaultLocator).__reference().getEncoding().equals(encoding))
+ if(!((com.zeroc.Ice._ObjectPrxI)_defaultLocator)._getReference().getEncoding().equals(encoding))
{
locatorInfo = _instance.locatorManager().get(_defaultLocator.ice_encodingVersion(encoding));
}
@@ -784,7 +784,7 @@ public final class ReferenceFactory
com.zeroc.Ice.LocatorPrx.uncheckedCast(_communicator.propertyToProxy(property));
if(locator != null)
{
- if(!((com.zeroc.Ice._ObjectPrxI)locator).__reference().getEncoding().equals(encoding))
+ if(!((com.zeroc.Ice._ObjectPrxI)locator)._getReference().getEncoding().equals(encoding))
{
locatorInfo = _instance.locatorManager().get(locator.ice_encodingVersion(encoding));
}
diff --git a/java/src/Ice/src/main/java/com/zeroc/IceInternal/RequestHandlerFactory.java b/java/src/Ice/src/main/java/com/zeroc/IceInternal/RequestHandlerFactory.java
index 19b2a85ad9b..491449fe503 100644
--- a/java/src/Ice/src/main/java/com/zeroc/IceInternal/RequestHandlerFactory.java
+++ b/java/src/Ice/src/main/java/com/zeroc/IceInternal/RequestHandlerFactory.java
@@ -28,7 +28,7 @@ public final class RequestHandlerFactory
com.zeroc.Ice.ObjectAdapter adapter = _instance.objectAdapterFactory().findObjectAdapter(proxy);
if(adapter != null)
{
- return proxy.__setRequestHandler(new CollocatedRequestHandler(ref, adapter));
+ return proxy._setRequestHandler(new CollocatedRequestHandler(ref, adapter));
}
}
@@ -73,7 +73,7 @@ public final class RequestHandlerFactory
ref.getConnection(handler);
}
}
- return proxy.__setRequestHandler(handler.connect(proxy));
+ return proxy._setRequestHandler(handler.connect(proxy));
}
void
diff --git a/java/src/Ice/src/main/java/com/zeroc/IceInternal/RoutableReference.java b/java/src/Ice/src/main/java/com/zeroc/IceInternal/RoutableReference.java
index 4600da1e9d3..846708989bf 100644
--- a/java/src/Ice/src/main/java/com/zeroc/IceInternal/RoutableReference.java
+++ b/java/src/Ice/src/main/java/com/zeroc/IceInternal/RoutableReference.java
@@ -395,7 +395,7 @@ public class RoutableReference extends Reference
if(_routerInfo != null)
{
com.zeroc.Ice._ObjectPrxI h = (com.zeroc.Ice._ObjectPrxI)_routerInfo.getRouter();
- java.util.Map<String, String> routerProperties = h.__reference().toProperty(prefix + ".Router");
+ java.util.Map<String, String> routerProperties = h._getReference().toProperty(prefix + ".Router");
for(java.util.Map.Entry<String, String> p : routerProperties.entrySet())
{
properties.put(p.getKey(), p.getValue());
@@ -405,7 +405,7 @@ public class RoutableReference extends Reference
if(_locatorInfo != null)
{
com.zeroc.Ice._ObjectPrxI h = (com.zeroc.Ice._ObjectPrxI)_locatorInfo.getLocator();
- java.util.Map<String, String> locatorProperties = h.__reference().toProperty(prefix + ".Locator");
+ java.util.Map<String, String> locatorProperties = h._getReference().toProperty(prefix + ".Locator");
for(java.util.Map.Entry<String, String> p : locatorProperties.entrySet())
{
properties.put(p.getKey(), p.getValue());
diff --git a/java/src/Ice/src/main/java/com/zeroc/IceInternal/RouterInfo.java b/java/src/Ice/src/main/java/com/zeroc/IceInternal/RouterInfo.java
index e103ead153a..109965fe194 100644
--- a/java/src/Ice/src/main/java/com/zeroc/IceInternal/RouterInfo.java
+++ b/java/src/Ice/src/main/java/com/zeroc/IceInternal/RouterInfo.java
@@ -201,7 +201,7 @@ public final class RouterInfo
//
// If getClientProxy() return nil, use router endpoints.
//
- _clientEndpoints = ((com.zeroc.Ice._ObjectPrxI)_router).__reference().getEndpoints();
+ _clientEndpoints = ((com.zeroc.Ice._ObjectPrxI)_router)._getReference().getEndpoints();
}
else
{
@@ -217,7 +217,7 @@ public final class RouterInfo
clientProxy = clientProxy.ice_timeout(_router.ice_getConnection().timeout());
}
- _clientEndpoints = ((com.zeroc.Ice._ObjectPrxI)clientProxy).__reference().getEndpoints();
+ _clientEndpoints = ((com.zeroc.Ice._ObjectPrxI)clientProxy)._getReference().getEndpoints();
}
}
return _clientEndpoints;
@@ -232,7 +232,7 @@ public final class RouterInfo
}
serverProxy = serverProxy.ice_router(null); // The server proxy cannot be routed.
- _serverEndpoints = ((com.zeroc.Ice._ObjectPrxI)serverProxy).__reference().getEndpoints();
+ _serverEndpoints = ((com.zeroc.Ice._ObjectPrxI)serverProxy)._getReference().getEndpoints();
return _serverEndpoints;
}
diff --git a/java/src/Ice/src/main/java/com/zeroc/IceInternal/UdpEndpointI.java b/java/src/Ice/src/main/java/com/zeroc/IceInternal/UdpEndpointI.java
index d11b031271f..67057b67191 100644
--- a/java/src/Ice/src/main/java/com/zeroc/IceInternal/UdpEndpointI.java
+++ b/java/src/Ice/src/main/java/com/zeroc/IceInternal/UdpEndpointI.java
@@ -258,8 +258,8 @@ final class UdpEndpointI extends IPEndpointI
super.streamWriteImpl(s);
if(s.getEncoding().equals(com.zeroc.Ice.Util.Encoding_1_0))
{
- com.zeroc.Ice.Util.Protocol_1_0.ice_write(s);
- com.zeroc.Ice.Util.Encoding_1_0.ice_write(s);
+ com.zeroc.Ice.Util.Protocol_1_0.write(s);
+ com.zeroc.Ice.Util.Encoding_1_0.write(s);
}
// Not transmitted.
//s.writeBool(_connect);
diff --git a/java/src/Ice/src/main/java/com/zeroc/IceInternal/ValueWriter.java b/java/src/Ice/src/main/java/com/zeroc/IceInternal/ValueWriter.java
index 45f4c8e8a94..2ac38d8bb26 100644
--- a/java/src/Ice/src/main/java/com/zeroc/IceInternal/ValueWriter.java
+++ b/java/src/Ice/src/main/java/com/zeroc/IceInternal/ValueWriter.java
@@ -84,7 +84,7 @@ public final class ValueWriter
{
writeName(name, out);
com.zeroc.Ice._ObjectPrxI proxy = (com.zeroc.Ice._ObjectPrxI)value;
- out.print(proxy.__reference().toString());
+ out.print(proxy._getReference().toString());
}
else if(value instanceof com.zeroc.Ice.Value)
{