| java.lang.Object java.io.InputStream java.io.ObjectInputStream sun.rmi.server.MarshalInputStream sun.rmi.transport.ConnectionInputStream
ConnectionInputStream | class ConnectionInputStream extends MarshalInputStream (Code) | | Special stream to keep track of refs being unmarshaled so that
refs can be ref-counted locally.
author: Ann Wollrath |
Method Summary | |
void | done(Connection c) Done with input stream for remote call. | void | readID() | void | registerRefs() Add references to DGC table (and possibly send dirty call). | void | saveRef(LiveRef ref) Save reference in order to send "dirty" call after all args/returns
have been unmarshaled. | void | setAckNeeded() Indicate that an ack is required to the distributed
collector. |
ConnectionInputStream | ConnectionInputStream(InputStream in) throws IOException(Code) | | Constructs a marshal input stream using the underlying
stream "in".
|
done | void done(Connection c)(Code) | | Done with input stream for remote call. Send DGC ack if necessary.
Allow sending of ack to fail without flagging an error.
|
registerRefs | void registerRefs() throws IOException(Code) | | Add references to DGC table (and possibly send dirty call).
RegisterRefs now calls DGCClient.referenced on all
refs with the same endpoint at once to achieve batching of
calls to the DGC
|
saveRef | void saveRef(LiveRef ref)(Code) | | Save reference in order to send "dirty" call after all args/returns
have been unmarshaled. Save in hashtable incomingRefTable. This
table is keyed on endpoints, and holds objects of type
IncomingRefTableEntry.
|
setAckNeeded | void setAckNeeded()(Code) | | Indicate that an ack is required to the distributed
collector.
|
Fields inherited from sun.rmi.server.MarshalInputStream | protected static Map permittedSunClasses(Code)(Java Doc)
|
Methods inherited from java.io.ObjectInputStream | public int available() throws IOException(Code)(Java Doc) public void close() throws IOException(Code)(Java Doc) public void defaultReadObject() throws IOException, ClassNotFoundException(Code)(Java Doc) protected boolean enableResolveObject(boolean enable) throws SecurityException(Code)(Java Doc) public int read() throws IOException(Code)(Java Doc) public int read(byte[] buf, int off, int len) throws IOException(Code)(Java Doc) public boolean readBoolean() throws IOException(Code)(Java Doc) public byte readByte() throws IOException(Code)(Java Doc) public char readChar() throws IOException(Code)(Java Doc) protected ObjectStreamClass readClassDescriptor() throws IOException, ClassNotFoundException(Code)(Java Doc) public double readDouble() throws IOException(Code)(Java Doc) public ObjectInputStream.GetField readFields() throws IOException, ClassNotFoundException(Code)(Java Doc) public float readFloat() throws IOException(Code)(Java Doc) public void readFully(byte[] buf) throws IOException(Code)(Java Doc) public void readFully(byte[] buf, int off, int len) throws IOException(Code)(Java Doc) public int readInt() throws IOException(Code)(Java Doc) public String readLine() throws IOException(Code)(Java Doc) public long readLong() throws IOException(Code)(Java Doc) final public Object readObject() throws IOException, ClassNotFoundException(Code)(Java Doc) protected Object readObjectOverride() throws IOException, ClassNotFoundException(Code)(Java Doc) public short readShort() throws IOException(Code)(Java Doc) protected void readStreamHeader() throws IOException, StreamCorruptedException(Code)(Java Doc) public String readUTF() throws IOException(Code)(Java Doc) public Object readUnshared() throws IOException, ClassNotFoundException(Code)(Java Doc) public int readUnsignedByte() throws IOException(Code)(Java Doc) public int readUnsignedShort() throws IOException(Code)(Java Doc) public void registerValidation(ObjectInputValidation obj, int prio) throws NotActiveException, InvalidObjectException(Code)(Java Doc) protected Class> resolveClass(ObjectStreamClass desc) throws IOException, ClassNotFoundException(Code)(Java Doc) protected Object resolveObject(Object obj) throws IOException(Code)(Java Doc) protected Class> resolveProxyClass(String[] interfaces) throws IOException, ClassNotFoundException(Code)(Java Doc) public int skipBytes(int len) throws IOException(Code)(Java Doc)
|
|
|