com.viaoa.comm.multiplexer.io

Class MultiplexerOutputStreamController

java.lang.Object

com.viaoa.comm.multiplexer.io.MultiplexerOutputStreamController

public class MultiplexerOutputStreamController
extends Object

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

Author:

vvia

Method Summary

Modifier and Type	Method and Description
protected int	getMaxWriteLength(VirtualSocket vs, int requestSize) Used to determine the max size that can be written to real socket per request.
int	getThrottleLimit()
long	getWriteCount()
long	getWriteSize()
protected void	onSocketException(Exception e)
protected void	sendCommand(int cmd, int param) Send a command to receiver.
protected void	sendCommand(int cmd, int param, String serverSocketName) Send a command to receiver.
void	sendPingCommand()
void	setThrottleLimit(int mbPerSecond) Throttle to limit the number of MB per second, calculated 10 times per second.

Methods inherited from class java.lang.Object

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

Method Detail

setThrottleLimit

public void setThrottleLimit(int mbPerSecond)

Throttle to limit the number of MB per second, calculated 10 times per second. if 0 then no limit. Each write will check to see if the max has been written for the current time slice (10th sec), and sleep for the remainder if the limit has been exceeded.

getThrottleLimit

public int getThrottleLimit()

getWriteCount

public long getWriteCount()

Returns:

number of writes made.

getWriteSize

public long getWriteSize()

getMaxWriteLength

protected int getMaxWriteLength(VirtualSocket vs,
                                int requestSize)

Used to determine the max size that can be written to real socket per request. This is a recommendation, and is not enforced when writing to the real outputstream.

sendPingCommand

public void sendPingCommand()
                     throws IOException

Throws:

IOException

onSocketException

protected void onSocketException(Exception e)

sendCommand

protected void sendCommand(int cmd,
                           int param)
                    throws IOException

Send a command to receiver. The command is then read by MultiplexerInputStreamController.readRealSocket() can processed by MultiplexerInputStreamController and/or MultiplexerSocketController.

Throws:

IOException

sendCommand

protected void sendCommand(int cmd,
                           int param,
                           String serverSocketName)
                    throws IOException

Send a command to receiver. The command is then read by MultiplexerInputStreamController.readRealSocket() can processed by MultiplexerInputStreamController and/or MultiplexerSocketController.

Parameters:

cmd - see MultiplexerSocketController for list of commands

Throws:

IOException