|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object seda.sandStorm.lib.aSocket.ATcpClientSocket
public class ATcpClientSocket
An ATcpClientSocket implements an asynchronous outgoing socket connection. Applications create an ATcpClientSocket and associate a SinkIF with it. When the connection is established an ATcpConnection object will be pushed to the given SinkIF. The ATcpConnection is then used for actual communication.
A Sandstorm stage would use this as follows:
SinkIF mySink = config.getSink(); // 'config' passed to stage init() ATcpClientSocket sock = new ATcpClientSocket(addr, port, mySink);
ATcpConnection
Field Summary | |
---|---|
private java.net.InetAddress |
address
|
private int |
port
|
Constructor Summary | |
---|---|
protected |
ATcpClientSocket()
|
|
ATcpClientSocket(java.net.InetAddress addr,
int port,
SinkIF compQ)
Create a socket connecting to the given address and port. |
|
ATcpClientSocket(java.net.InetAddress addr,
int port,
SinkIF compQ,
int writeClogThreshold,
int connectClogTries)
Create a socket connecting to the given address and port with the given writeClogThreshold value. |
|
ATcpClientSocket(java.lang.String host,
int port,
SinkIF compQ)
Create a socket connecting to the given host and port. |
|
ATcpClientSocket(java.lang.String host,
int port,
SinkIF compQ,
int writeClogThreshold,
int connectClogTries)
Create a socket connecting to the given host and port with the given writeClogThreshold value. |
Method Summary | |
---|---|
java.net.InetAddress |
getAddress()
Return the InetAddress which this socket is connected to. |
int |
getPort()
Return the port which this socket is connected to. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
private java.net.InetAddress address
private int port
Constructor Detail |
---|
public ATcpClientSocket(java.net.InetAddress addr, int port, SinkIF compQ)
public ATcpClientSocket(java.lang.String host, int port, SinkIF compQ) throws java.net.UnknownHostException
java.net.UnknownHostException
public ATcpClientSocket(java.net.InetAddress addr, int port, SinkIF compQ, int writeClogThreshold, int connectClogTries)
writeClogThreshold
- The maximum number of outstanding writes
on this socket before a SinkCloggedEvent is pushed to the
connection's completion queue. This is effectively the maximum depth
threshold for this connection's SinkIF. The default value is -1, which
indicates that no SinkCloggedEvents will be generated.connectClogTries
- The number of times the aSocket layer will
attempt to push a new entry onto the given SinkIF while the
SinkIF is full. The queue entry will be dropped after this many
tries. The default value is -1, which indicates that the aSocket
layer will attempt to push the queue entry indefinitely.public ATcpClientSocket(java.lang.String host, int port, SinkIF compQ, int writeClogThreshold, int connectClogTries) throws java.net.UnknownHostException
writeClogThreshold
- The maximum number of outstanding writes
on this socket before a SinkCloggedEvent is pushed to the
connection's completion queue. This is effectively the maximum depth
threshold for this connection's SinkIF. The default value is -1, which
indicates that no SinkCloggedEvents will be generated.connectClogTries
- The number of times the aSocket layer will
attempt to push a new entry onto the given SinkIF while the
SinkIF is full. The queue entry will be dropped after this many
tries. The default value is -1, which indicates that the aSocket
layer will attempt to push the queue entry indefinitely.
java.net.UnknownHostException
protected ATcpClientSocket()
Method Detail |
---|
public java.net.InetAddress getAddress()
public int getPort()
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |