unicastremotecall.java

kaffe是一个java虚拟机的源代码。里面包含了一些java例程和标准的java包。

/*
 * Copyright (c) 1996, 1997, 1998, 1999
 *      Transvirtual Technologies, Inc.  All rights reserved.
 *
 * See the file "license-lesser.terms" for information on usage and 
 * redistribution of this file.
 */

package kaffe.rmi.server;

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 kaffe.util.NotImplemented();
}

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 {
}

}

}