|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.jboss.remoting.transport.multiplex.MultiplexingManager
Copyright (c) 2005
Nested Class Summary | |
protected class |
MultiplexingManager.PendingActionThread
|
protected class |
MultiplexingManager.ShutdownManager
The motivation behind this class is to prevent the following problem. |
protected class |
MultiplexingManager.ShutdownThread
|
Constructor Summary | |
protected |
MultiplexingManager(java.net.InetSocketAddress address,
int timeout,
javax.net.SocketFactory socketFactory)
|
protected |
MultiplexingManager(java.net.Socket socket)
|
protected |
MultiplexingManager(javax.net.SocketFactory socketFactory)
|
Method Summary | |
protected void |
addToPendingActions(PendingAction pendingAction)
FIXME Comment this |
void |
bind(java.net.InetSocketAddress address)
|
static boolean |
checkForManagerByAddressPair(java.net.InetSocketAddress localAddress,
java.net.InetSocketAddress remoteAddress)
|
static boolean |
checkForManagerByAddressPair(java.net.InetSocketAddress localAddress,
java.net.InetSocketAddress remoteAddress,
javax.net.SocketFactory socketFactory)
|
static boolean |
checkForShareableManager(java.net.InetSocketAddress address)
|
static boolean |
checkForShareableManager(java.net.InetSocketAddress address,
javax.net.SocketFactory socketFactory)
|
static boolean |
checkForShareableManagerByAddressPair(java.net.InetSocketAddress localAddress,
java.net.InetSocketAddress remoteAddress)
|
static boolean |
checkForShareableManagerByAddressPair(java.net.InetSocketAddress localAddress,
java.net.InetSocketAddress remoteAddress,
javax.net.SocketFactory socketFactory)
|
void |
connect(java.net.InetSocketAddress address,
int timeout)
|
void |
decrementReferences()
FIXME Comment this |
java.util.Collection |
getAllOutputStreams()
|
static MultiplexingManager |
getaManager(java.net.Socket socket)
|
static MultiplexingManager |
getaManagerByAddressPair(java.net.InetSocketAddress remoteAddress,
java.net.InetSocketAddress localAddress,
int timeout)
|
static MultiplexingManager |
getaManagerByAddressPair(java.net.InetSocketAddress remoteAddress,
java.net.InetSocketAddress localAddress,
int timeout,
javax.net.SocketFactory socketFactory)
|
static MultiplexingManager |
getaManagerByLocalAddress(java.net.InetSocketAddress address)
|
static MultiplexingManager |
getaManagerByLocalAddress(java.net.InetSocketAddress address,
javax.net.SocketFactory socketFactory)
|
static MultiplexingManager |
getaManagerByRemoteAddress(java.net.InetSocketAddress address,
int timeout)
|
static MultiplexingManager |
getaManagerByRemoteAddress(java.net.InetSocketAddress address,
int timeout,
javax.net.SocketFactory socketFactory)
|
static MultiplexingManager |
getAnExistingShareableManager(java.net.InetSocketAddress address,
javax.net.SocketFactory socketFactory)
|
static MultiplexingManager |
getAnExistingShareableManagerByAddressPair(java.net.InetSocketAddress remoteAddress,
java.net.InetSocketAddress localAddress,
javax.net.SocketFactory socketFactory)
|
MultiplexingInputStream |
getAnInputStream(SocketId socketId,
VirtualSocket socket)
|
static MultiplexingManager |
getaShareableManager(java.net.InetSocketAddress address,
int timeout)
|
static MultiplexingManager |
getaShareableManager(java.net.InetSocketAddress address,
int timeout,
javax.net.SocketFactory socketFactory)
|
static MultiplexingManager |
getaShareableManagerByAddressPair(java.net.InetSocketAddress remoteAddress,
java.net.InetSocketAddress localAddress,
int timeout)
|
static MultiplexingManager |
getaShareableManagerByAddressPair(java.net.InetSocketAddress remoteAddress,
java.net.InetSocketAddress localAddress,
int timeout,
javax.net.SocketFactory socketFactory)
|
OutputMultiplexor |
getOutputMultiplexor()
|
java.io.OutputStream |
getOutputStreamByLocalSocket(SocketId socketId)
|
Protocol |
getProtocol()
|
java.net.ServerSocket |
getServerSocket()
FIXME Comment this |
java.net.Socket |
getSocket()
|
VirtualSocket |
getSocketByLocalPort(SocketId socketId)
|
javax.net.SocketFactory |
getSocketFactory()
|
void |
incrementReferences()
FIXME Comment this |
boolean |
isBound()
FIXME Comment this |
boolean |
isConnected()
FIXME Comment this |
boolean |
isRemoteServerSocketRegistered()
|
boolean |
isServerSocketRegistered()
FIXME Comment this |
boolean |
isShutdown()
|
boolean |
isSocketRegistered(SocketId socketId)
|
protected void |
registerByLocalAddress(java.net.InetSocketAddress address)
FIXME Comment this |
protected void |
registerByRemoteAddress(java.net.InetSocketAddress address)
|
void |
registerRemoteServerSocket()
FIXME Comment this |
MultiplexingDataInputStream |
registerServerSocket(java.net.ServerSocket serverSocket)
|
protected void |
registerShareable(java.net.InetSocketAddress address)
|
MultiplexingInputStream |
registerSocket(VirtualSocket socket)
|
protected void |
removeAnInputStream(SocketId socketId)
FIXME Comment this |
boolean |
respondToShutdownRequest()
FIXME Comment this |
void |
setSocketFactory(javax.net.SocketFactory socketFactory)
|
protected void |
setup()
|
protected void |
shutdown()
|
protected void |
unregisterByLocalAddress()
FIXME Comment this |
protected void |
unregisterByRemoteAddress()
FIXME Comment this |
void |
unRegisterRemoteServerSocket()
FIXME Comment this |
void |
unRegisterServerSocket(java.net.ServerSocket serverSocket)
|
protected void |
unregisterShareable()
FIXME Comment this |
void |
unRegisterSocket(VirtualSocket socket)
|
boolean |
waitForRemoteServerSocketRegistered()
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
protected MultiplexingManager(javax.net.SocketFactory socketFactory) throws java.io.IOException
protected MultiplexingManager(java.net.Socket socket) throws java.io.IOException
socket
-
java.io.IOException
protected MultiplexingManager(java.net.InetSocketAddress address, int timeout, javax.net.SocketFactory socketFactory) throws java.io.IOException
address
- timeout
- TODOsocketFactory
- TODO
java.io.IOException
Method Detail |
protected void setup() throws java.io.IOException
java.io.IOException
public static MultiplexingManager getaManager(java.net.Socket socket) throws java.io.IOException
socket
-
java.io.IOException
- TODO: what if multiplexor already exists?public static MultiplexingManager getaManagerByLocalAddress(java.net.InetSocketAddress address) throws java.io.IOException
address
-
java.io.IOException
public static MultiplexingManager getaManagerByLocalAddress(java.net.InetSocketAddress address, javax.net.SocketFactory socketFactory) throws java.io.IOException
address
- socketFactory
-
java.io.IOException
public static MultiplexingManager getaManagerByRemoteAddress(java.net.InetSocketAddress address, int timeout) throws java.io.IOException
address
- timeout
-
java.io.IOException
public static MultiplexingManager getaManagerByRemoteAddress(java.net.InetSocketAddress address, int timeout, javax.net.SocketFactory socketFactory) throws java.io.IOException
address
- timeout
- socketFactory
-
java.io.IOException
public static MultiplexingManager getaManagerByAddressPair(java.net.InetSocketAddress remoteAddress, java.net.InetSocketAddress localAddress, int timeout) throws java.io.IOException
remoteAddress
- localAddress
- timeout
-
java.io.IOException
public static MultiplexingManager getaManagerByAddressPair(java.net.InetSocketAddress remoteAddress, java.net.InetSocketAddress localAddress, int timeout, javax.net.SocketFactory socketFactory) throws java.io.IOException
remoteAddress
- localAddress
- timeout
- socketFactory
-
java.io.IOException
public static MultiplexingManager getaShareableManager(java.net.InetSocketAddress address, int timeout) throws java.io.IOException
address
- timeout
-
java.io.IOException
public static MultiplexingManager getaShareableManager(java.net.InetSocketAddress address, int timeout, javax.net.SocketFactory socketFactory) throws java.io.IOException
address
- timeout
- socketFactory
-
java.io.IOException
public static MultiplexingManager getAnExistingShareableManager(java.net.InetSocketAddress address, javax.net.SocketFactory socketFactory) throws java.io.IOException
address
- socketFactory
-
java.io.IOException
public static MultiplexingManager getaShareableManagerByAddressPair(java.net.InetSocketAddress remoteAddress, java.net.InetSocketAddress localAddress, int timeout) throws java.io.IOException
remoteAddress
- localAddress
- timeout
-
java.io.IOException
public static MultiplexingManager getaShareableManagerByAddressPair(java.net.InetSocketAddress remoteAddress, java.net.InetSocketAddress localAddress, int timeout, javax.net.SocketFactory socketFactory) throws java.io.IOException
remoteAddress
- localAddress
- timeout
- socketFactory
-
java.io.IOException
public static MultiplexingManager getAnExistingShareableManagerByAddressPair(java.net.InetSocketAddress remoteAddress, java.net.InetSocketAddress localAddress, javax.net.SocketFactory socketFactory) throws java.io.IOException
remoteAddress
- localAddress
- socketFactory
-
java.io.IOException
public static boolean checkForShareableManager(java.net.InetSocketAddress address) throws java.io.IOException
address
-
java.io.IOException
public static boolean checkForShareableManager(java.net.InetSocketAddress address, javax.net.SocketFactory socketFactory) throws java.io.IOException
address
- socketFactory
-
java.io.IOException
public static boolean checkForManagerByAddressPair(java.net.InetSocketAddress localAddress, java.net.InetSocketAddress remoteAddress)
localAddress
- remoteAddress
-
public static boolean checkForManagerByAddressPair(java.net.InetSocketAddress localAddress, java.net.InetSocketAddress remoteAddress, javax.net.SocketFactory socketFactory)
localAddress
- remoteAddress
- socketFactory
-
public static boolean checkForShareableManagerByAddressPair(java.net.InetSocketAddress localAddress, java.net.InetSocketAddress remoteAddress)
localAddress
- remoteAddress
-
public static boolean checkForShareableManagerByAddressPair(java.net.InetSocketAddress localAddress, java.net.InetSocketAddress remoteAddress, javax.net.SocketFactory socketFactory)
localAddress
- remoteAddress
-
public void bind(java.net.InetSocketAddress address) throws java.io.IOException
address
-
java.io.IOException
public void connect(java.net.InetSocketAddress address, int timeout) throws java.io.IOException
address
- timeout
- TODO
java.io.IOException
public MultiplexingDataInputStream registerServerSocket(java.net.ServerSocket serverSocket) throws java.io.IOException
java.io.IOException
public void unRegisterServerSocket(java.net.ServerSocket serverSocket) throws java.io.IOException
serverSocket
-
java.io.IOException
public MultiplexingInputStream registerSocket(VirtualSocket socket) throws java.io.IOException
socket
-
java.io.IOException
public void unRegisterSocket(VirtualSocket socket) throws java.io.IOException
socket
-
java.io.IOException
public void registerRemoteServerSocket() throws java.io.IOException
java.io.IOException
public void unRegisterRemoteServerSocket()
public boolean isRemoteServerSocketRegistered()
public boolean waitForRemoteServerSocketRegistered()
public void incrementReferences() throws java.io.IOException
java.io.IOException
public void decrementReferences() throws java.io.IOException
java.io.IOException
public java.util.Collection getAllOutputStreams()
public MultiplexingInputStream getAnInputStream(SocketId socketId, VirtualSocket socket) throws java.io.IOException
socketId
- socket
- TODO
java.io.IOException
public OutputMultiplexor getOutputMultiplexor()
public java.io.OutputStream getOutputStreamByLocalSocket(SocketId socketId)
socketId
-
public Protocol getProtocol()
public java.net.ServerSocket getServerSocket()
public java.net.Socket getSocket()
public VirtualSocket getSocketByLocalPort(SocketId socketId)
socketId
-
public javax.net.SocketFactory getSocketFactory()
public boolean isBound()
public boolean isConnected()
public boolean isServerSocketRegistered()
public boolean isShutdown()
public boolean isSocketRegistered(SocketId socketId)
socketId
-
public boolean respondToShutdownRequest()
public void setSocketFactory(javax.net.SocketFactory socketFactory)
socketFactory
- protected void registerByLocalAddress(java.net.InetSocketAddress address)
address
- protected void unregisterByLocalAddress()
protected void registerByRemoteAddress(java.net.InetSocketAddress address)
address
- protected void unregisterByRemoteAddress()
protected void registerShareable(java.net.InetSocketAddress address)
address
- protected void unregisterShareable()
protected void removeAnInputStream(SocketId socketId)
socketId
- protected void shutdown()
protected void addToPendingActions(PendingAction pendingAction)
pendingAction
-
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |