* java/rmi/activation/Activatable.java,

	java/rmi/activation/ActivateFailedException.java,
	java/rmi/activation/ActivationDesc.java,
	java/rmi/activation/ActivationException.java,
	java/rmi/activation/ActivationGroup.java,
	java/rmi/activation/ActivationGroupDesc.java,
	java/rmi/activation/ActivationGroupID.java,
	java/rmi/activation/ActivationID.java,
	java/rmi/activation/ActivationInstantiator.java,
	java/rmi/activation/ActivationMonitor.java,
	java/rmi/activation/ActivationSystem.java,
	java/rmi/activation/Activator.java,
	java/rmi/activation/UnknownGroupException.java,
	java/rmi/activation/UnknownObjectException.java,
	java/rmi/AccessException.java,
	java/rmi/AlreadyBoundException.java,
	java/rmi/ConnectException.java, java/rmi/ConnectIOException.java,
	java/rmi/MarshalException.java, java/rmi/MarshalledObject.java,
	java/rmi/Naming.java, java/rmi/NoSuchObjectException.java,
	java/rmi/NotBoundException.java,
	java/rmi/RMISecurityException.java,
	java/rmi/RMISecurityManager.java, java/rmi/Remote.java,
	java/rmi/RemoteException.java, java/rmi/ServerError.java,
	java/rmi/ServerException.java,
	java/rmi/ServerRuntimeException.java,
	java/rmi/StubNotFoundException.java,
	java/rmi/UnexpectedException.java,
	java/rmi/UnknownHostException.java,
	java/rmi/UnmarshalException.java, java/rmi/dgc/DGC.java,
	java/rmi/dgc/Lease.java, java/rmi/dgc/VMID.java,
	java/rmi/registry/LocateRegistry.java,
	java/rmi/registry/Registry.java,
	java/rmi/registry/RegistryHandler.java,
	java/rmi/server/ExportException.java,
	java/rmi/server/LoaderHandler.java,
	java/rmi/server/LogStream.java, java/rmi/server/ObjID.java,
	java/rmi/server/Operation.java,
	java/rmi/server/RMIClassLoader.java,
	java/rmi/server/RMIClientSocketFactory.java,
	java/rmi/server/RMIFailureHandler.java,
	java/rmi/server/RMIServerSocketFactory.java,
	java/rmi/server/RMISocketFactory.java,
	java/rmi/server/RemoteCall.java,
	java/rmi/server/RemoteObject.java, java/rmi/server/RemoteRef.java,
	java/rmi/server/RemoteServer.java,
	java/rmi/server/RemoteStub.java,
	java/rmi/server/ServerCloneException.java,
	java/rmi/server/ServerNotActiveException.java,
	java/rmi/server/ServerRef.java, java/rmi/server/Skeleton.java,
	java/rmi/server/SkeletonMismatchException.java,
	java/rmi/server/SkeletonNotFoundException.java,
	java/rmi/server/SocketSecurityException.java,
	java/rmi/server/UID.java,
	java/rmi/server/UnicastRemoteObject.java,
	java/rmi/server/Unreferenced.java, gnu/java/rmi/dgc/DGCImpl.java,
	gnu/java/rmi/dgc/DGCImpl_Skel.java,
	gnu/java/rmi/dgc/DGCImpl_Stub.java,
	gnu/java/rmi/registry/RegistryImpl.java,
	gnu/java/rmi/registry/RegistryImpl_Skel.java,
	gnu/java/rmi/registry/RegistryImpl_Stub.java,
	gnu/java/rmi/rmic/RMIC.java, gnu/java/rmi/rmic/TabbedWriter.java,
	gnu/java/rmi/server/ProtocolConstants.java,
	gnu/java/rmi/server/RMIDefaultSocketFactory.java,
	gnu/java/rmi/server/RMIHashes.java,
	gnu/java/rmi/server/RMIObjectInputStream.java,
	gnu/java/rmi/server/RMIObjectOutputStream.java,
	gnu/java/rmi/server/UnicastConnection.java,
	gnu/java/rmi/server/UnicastConnectionManager.java,
	gnu/java/rmi/server/UnicastRef.java,
	gnu/java/rmi/server/UnicastRemoteCall.java,
	gnu/java/rmi/server/UnicastRemoteStub.java,
	gnu/java/rmi/server/UnicastServer.java,
	gnu/java/rmi/server/UnicastServerRef.java: RMI implementation from
	Kaffe.  Relabelled classes to fit into Classpath tree.
	* Makefile.in: Rebuilt.
	* Makefile.am (rmi_java_source_files): New macro.
	(ordinary_java_source_files): Reference it.
	(bin_PROGRAMS): Added rmic and rmiregistry.
	(rmic_SOURCES): New macro.
	(EXTRA_rmic_SOURCES): Likewise.
	(rmic_LDFLAGS): Likewise.
	(rmic_LINK): Likewise.
	(rmic_LDADD): Likewise.
	(rmic_DEPENDENCIES): Likewise.
	(rmiregistry_SOURCES): New macro.
	(EXTRA_rmiregistry_SOURCES): Likewise.
	(rmiregistry_LDFLAGS): Likewise.
	(rmiregistry_LINK): Likewise.
	(rmiregistry_LDADD): Likewise.
	(rmiregistry_DEPENDENCIES): Likewise.


git-svn-id: svn+ssh://gcc.gnu.org/svn/gcc/trunk@45218 138bc75d-0d04-0410-961f-82ee72b054a4

1 files changed, 301 insertions, 0 deletions

diff --git a/libjava/gnu/java/rmi/server/UnicastRemoteCall.java b/libjava/gnu/java/rmi/server/UnicastRemoteCall.java
new file mode 100644
index 00000000000..42759e70a67
--- /dev/null
+++ b/libjava/gnu/java/rmi/server/UnicastRemoteCall.java
@@ -0,0 +1,301 @@
+/*
+  Copyright (c) 1996, 1997, 1998, 1999 Free Software Foundation, Inc.
+
+This file is part of GNU Classpath.
+
+GNU Classpath is free software; you can redistribute it and/or modify
+it under the terms of the GNU General Public License as published by
+the Free Software Foundation; either version 2, or (at your option)
+any later version.
+ 
+GNU Classpath is distributed in the hope that it will be useful, but
+WITHOUT ANY WARRANTY; without even the implied warranty of
+MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
+General Public License for more details.
+
+You should have received a copy of the GNU General Public License
+along with GNU Classpath; see the file COPYING.  If not, write to the
+Free Software Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA
+02111-1307 USA.
+
+As a special exception, if you link this library with other files to
+produce an executable, this library does not by itself cause the
+resulting executable to be covered by the GNU General Public License.
+This exception does not however invalidate any other reasons why the
+executable file might be covered by the GNU General Public License.
+ */
+
+package gnu.java.rmi.server;
+
+import java.lang.Exception;
+import java.io.IOException;
+import java.io.ObjectOutput;
+import java.io.ObjectInput;
+import java.io.StreamCorruptedException;
+import java.rmi.server.RemoteCall;
+import java.util.Vector;
+
+public class UnicastRemoteCall
+	implements RemoteCall {
+
+private UnicastConnection conn;
+private Object result;
+private Object object;
+private int opnum;
+private long hash;
+private Vector vec;
+private int ptr;
+
+/**
+ * Incoming call.
+ */
+UnicastRemoteCall(UnicastConnection conn) {
+	this.conn = conn;
+}
+
+/**
+ * Outgoing call.
+ */
+UnicastRemoteCall(Object obj, int opnum, long hash) {
+	this.object = obj;
+	this.opnum = opnum;
+	this.hash = hash;
+}
+
+public ObjectOutput getOutputStream() throws IOException {
+	vec = new Vector();
+	return (new DummyObjectOutputStream());
+}
+
+public void releaseOutputStream() throws IOException {
+	// Does nothing.
+}
+
+public ObjectInput getInputStream() throws IOException {
+	if (conn != null) {
+		return (conn.getObjectInputStream());
+	}
+	else {
+		ptr = 0;
+		return (new DummyObjectInputStream());
+	}
+}
+
+public void releaseInputStream() throws IOException {
+	// Does nothing.
+}
+
+public ObjectOutput getResultStream(boolean success) throws IOException, StreamCorruptedException {
+	vec = new Vector();
+	return (new DummyObjectOutputStream());
+}
+
+public void executeCall() throws Exception {
+	throw new Error("Not implemented");
+}
+
+public void done() throws IOException {
+	/* Does nothing */
+}
+
+Object returnValue() {
+	return (vec.elementAt(0));
+}
+
+Object[] getArguments() {
+	return (vec.toArray());
+}
+
+Object getObject() {
+	return (object);
+}
+
+int getOpnum() {
+	return (opnum);
+}
+
+long getHash() {
+	return (hash);
+}
+
+void setReturnValue(Object obj) {
+	vec.removeAllElements();
+	vec.addElement(obj);
+}
+
+/**
+ * Dummy object output class.
+ */
+private class DummyObjectOutputStream implements ObjectOutput {
+
+public void writeBoolean(boolean v) throws IOException {
+	vec.addElement(new Boolean(v));
+}
+
+public void writeByte(int v) throws IOException {
+	vec.addElement(new Byte((byte)v));
+}
+
+public void writeChar(int v) throws IOException {
+	vec.addElement(new Character((char)v));
+}
+
+public void writeDouble(double v) throws IOException {
+	vec.addElement(new Double(v));
+}
+
+public void writeFloat(float v) throws IOException {
+	vec.addElement(new Float(v));
+}
+
+public void writeInt(int v) throws IOException {
+	vec.addElement(new Integer(v));
+}
+
+public void writeLong(long v) throws IOException {
+	vec.addElement(new Long(v));
+}
+
+public void writeShort(int v) throws IOException {
+	vec.addElement(new Short((short)v));
+}
+
+public void writeObject(Object obj) throws IOException {
+	vec.addElement(obj);
+}
+
+public void write(byte b[]) throws IOException {
+	throw new IOException("not required");
+}
+
+public void write(byte b[], int off, int len) throws IOException {
+	throw new IOException("not required");
+}
+
+public void write(int b) throws IOException {
+	throw new IOException("not required");
+}
+
+public void writeBytes(String s) throws IOException {
+	throw new IOException("not required");
+}
+
+public void writeChars(String s) throws IOException {
+	throw new IOException("not required");
+}
+
+public void writeUTF(String str) throws IOException {
+	throw new IOException("not required");
+}
+
+public void flush() throws IOException {
+}
+
+public void close() throws IOException {
+}
+
+}
+
+/**
+ * Dummy object input class.
+ */
+private class DummyObjectInputStream implements ObjectInput {
+
+public boolean readBoolean() throws IOException {
+	Object obj = vec.elementAt(ptr++);
+	return (((Boolean)obj).booleanValue());
+}
+
+public byte readByte() throws IOException {
+	Object obj = vec.elementAt(ptr++);
+	return (((Byte)obj).byteValue());
+}
+
+public char readChar() throws IOException {
+	Object obj = vec.elementAt(ptr++);
+	return (((Character)obj).charValue());
+}
+
+public double readDouble() throws IOException {
+	Object obj = vec.elementAt(ptr++);
+	return (((Double)obj).doubleValue());
+}
+
+public float readFloat() throws IOException {
+	Object obj = vec.elementAt(ptr++);
+	return (((Float)obj).floatValue());
+}
+
+public int readInt() throws IOException {
+	Object obj = vec.elementAt(ptr++);
+	return (((Integer)obj).intValue());
+}
+
+public long readLong() throws IOException {
+	Object obj = vec.elementAt(ptr++);
+	return (((Long)obj).longValue());
+}
+
+public short readShort() throws IOException {
+	Object obj = vec.elementAt(ptr++);
+	return (((Short)obj).shortValue());
+}
+
+public Object readObject() throws IOException {
+	return (vec.elementAt(ptr++));
+}
+
+public int read(byte b[]) throws IOException {
+	throw new IOException("not required");
+}
+
+public int read(byte b[], int off, int len) throws IOException {
+	throw new IOException("not required");
+}
+
+public int read() throws IOException {
+	throw new IOException("not required");
+}
+
+public long skip(long n) throws IOException {
+	throw new IOException("not required");
+}
+
+public int available() throws IOException {
+	throw new IOException("not required");
+}
+
+public void readFully(byte b[]) throws IOException {
+	throw new IOException("not required");
+}
+
+public void readFully(byte b[], int off, int len) throws IOException {
+	throw new IOException("not required");
+}
+
+public String readLine() throws IOException {
+	throw new IOException("not required");
+}
+
+public String readUTF() throws IOException {
+	throw new IOException("not required");
+}
+
+public int readUnsignedByte() throws IOException {
+	throw new IOException("not required");
+}
+
+public int readUnsignedShort() throws IOException {
+	throw new IOException("not required");
+}
+
+public int skipBytes(int n) throws IOException {
+	throw new IOException("not required");
+}
+
+public void close() throws IOException {
+}
+
+}
+
+}