|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectcom.sun.jini.jeri.internal.mux.Mux
com.sun.jini.jeri.internal.mux.MuxClient
public class MuxClient
A MuxClient controls the client side of multiplexed connection.
Field Summary | |
---|---|
private static int |
clientInitialInboundRation
initial inbound ration as client, default is 32768 |
Fields inherited from class com.sun.jini.jeri.internal.mux.Mux |
---|
Abort, Abort_partial, Acknowledgment, busySessions, CLIENT, ClientConnectionHeader_negotiate, Close, Data, Data_ackRequired, Data_close, Data_eof, Data_open, Error, IncrementRation, IncrementRation_shift, initialInboundRation, initialOutboundRation, MAX_REQUESTS, MAX_SESSION_ID, maxFragmentSize, muxDown, muxDownCause, muxDownMessage, muxLock, NoOperation, Ping, PingAck, role, SERVER, serverConnectionReady, sessions, Shutdown |
Constructor Summary | |
---|---|
MuxClient(OutputStream out,
InputStream in)
Initiates the client side of the multiplexed connection over the given input/output stream pair. |
|
MuxClient(SocketChannel channel)
|
Method Summary | |
---|---|
OutboundRequest |
newRequest()
Starts a new request over this connection, returning the corresponding OutboundRequest object. |
protected void |
populateContext(Collection context)
Populates the context collection with information representing this connection. |
int |
requestsInProgress()
Returns the current number of requests in progress over this connection. |
void |
shutdown(String message)
Shuts down this multiplexed connection. |
Methods inherited from class com.sun.jini.jeri.internal.mux.Mux |
---|
addSession, asyncSendAbort, asyncSendAcknowledgment, asyncSendClientConnectionHeader, asyncSendClose, asyncSendData, asyncSendError, asyncSendIncrementRation, asyncSendNoOperation, asyncSendPing, asyncSendPingAck, asyncSendServerConnectionHeader, asyncSendShutdown, directBuffersUseful, futureSendData, futureSendError, handleDown, handleOpen, processIncomingData, removeSession, setDown, setStartTimeout, start |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
private static final int clientInitialInboundRation
Constructor Detail |
---|
public MuxClient(OutputStream out, InputStream in) throws IOException
out
- the output stream of the underlying connectionin
- the input stream of the underlying connection
IOException
public MuxClient(SocketChannel channel) throws IOException
IOException
Method Detail |
---|
public OutboundRequest newRequest() throws IOException
IOException
public int requestsInProgress() throws IOException
IOException
- if the multiplexed connection is no longer
activepublic void shutdown(String message)
message
- reason for shutdown to be included in
IOExceptions thrown from future I/O operationsprotected void populateContext(Collection context)
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |