com.viaoa.comm.multiplexer.io

Class MultiplexerInputStreamController

java.lang.Object

com.viaoa.comm.multiplexer.io.MultiplexerInputStreamController

public abstract class MultiplexerInputStreamController
extends Object

Internally created by MultiplexerSocketController to manage the InputStream for the "real" socket.

Method Summary

Modifier and Type	Method and Description
protected void	close() Flag the inputstream as closed and notify all vsockets that are waiting to read from it.
protected abstract void	closeRealSocket() Called by processCommand to close the "real" socket.
protected abstract void	closeSocket(int id, boolean bSendCommand) Called by processCommand to close an existing vsocket.
protected abstract void	createNewSocket(int connectionId, int id, String serverSocketName) Called by processCommand to create a new vsocket.
long	getLastReadTime()
protected abstract int	getMaxSocketId() this is needed to verify the max ID used for virtual sockets
long	getReadCount()
long	getReadSize()
protected abstract VirtualSocket	getSocket(int id) Used by readRealSocket when reading the header for the next vsocket data to read.
protected void	processCommand(int cmd, int param) Process "real" socket commands.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

close

protected void close()
              throws IOException

Flag the inputstream as closed and notify all vsockets that are waiting to read from it.

Throws:

IOException

getLastReadTime

public long getLastReadTime()

getReadCount

public long getReadCount()

Returns:

number of reads made.

getReadSize

public long getReadSize()

processCommand

protected void processCommand(int cmd,
                              int param)
                       throws Exception

Process "real" socket commands.

Throws:

Exception

See Also:

MultiplexerOutputStreamController.sendCommand(int, int)

createNewSocket

protected abstract void createNewSocket(int connectionId,
                                        int id,
                                        String serverSocketName)

Called by processCommand to create a new vsocket.

closeSocket

protected abstract void closeSocket(int id,
                                    boolean bSendCommand)

Called by processCommand to close an existing vsocket.

closeRealSocket

protected abstract void closeRealSocket()

Called by processCommand to close the "real" socket.

getSocket

protected abstract VirtualSocket getSocket(int id)

Used by readRealSocket when reading the header for the next vsocket data to read.

getMaxSocketId

protected abstract int getMaxSocketId()

this is needed to verify the max ID used for virtual sockets