|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectfr.dyade.aaa.agent.Network
fr.dyade.aaa.agent.StreamNetwork
public abstract class StreamNetwork
StreamNetwork
is a base implementation of Network
class for TCP sockets.
Nested Class Summary |
---|
Nested classes/interfaces inherited from class fr.dyade.aaa.agent.Network |
---|
Network.NetworkAverageLoadTask |
Field Summary | |
---|---|
(package private) int |
backlog
The maximum queue length for incoming connection indications, default value is 5. |
(package private) int |
CnxRetry
Numbers of attempt to bind the server's socket before aborting, default value is 3. |
(package private) int |
ConnectTimeout
Defines in milliseconds the timeout used during socket connection. |
(package private) java.net.InetAddress |
inLocalAddr
The local address the listen ServerSocket is bound to. |
(package private) java.net.InetAddress |
outLocalAddr
The local address the sockets are bound to. |
(package private) int |
outLocalPort
The local port the sockets are bound to. |
(package private) ServerSocketFactory |
serverSocketFactory
Allows to define a specific factory for ServerSocket in order to by-pass compatibility problem between JDK version. |
(package private) SocketFactory |
socketFactory
Allows to define a specific factory for Socket in order to by-pass compatibility problem between JDK version. |
(package private) int |
SoLinger
Enable SO_LINGER with the specified linger time in seconds, if the value is less than 0 then it disables SO_LINGER. |
(package private) int |
SoTimeout
Enable/disable SO_TIMEOUT with the specified timeout in milliseconds. |
(package private) boolean |
TcpNoDelay
Enable/disable TCP_NODELAY (disable/enable Nagle's algorithm), default value is false. |
Fields inherited from class fr.dyade.aaa.agent.Network |
---|
ALREADY_DELIVERED, averageLoadTask, bootTSFN, DELIVER, domain, idxLS, logmon, name, nbMessageIn, nbMessageOut, port, qout, servers, serversFN, sid, WDActivationPeriod, WDNbRetryLevel1, WDNbRetryLevel2, WDRetryPeriod1, WDRetryPeriod2, WDRetryPeriod3 |
Constructor Summary | |
---|---|
StreamNetwork()
Creates a new Network component |
Method Summary | |
---|---|
(package private) java.net.ServerSocket |
createServerSocket()
This method creates and returns a server socket which uses all network interfaces on the host, and is bound to the specified port. |
(package private) java.net.ServerSocket |
createServerSocket(int port)
This method creates and returns a server socket which uses all network interfaces on the host, and is bound to the specified port. |
(package private) java.net.Socket |
createSocket(java.net.InetAddress addr,
int port)
This method creates and returns a socket connected to a ServerSocket at the specified network address and port. |
(package private) java.net.Socket |
createSocket(ServerDesc server)
This method creates and returns a socket connected to a specified server. |
(package private) java.net.Socket |
createSocket(SocketAddress addr)
This method creates and returns a socket connected to a ServerSocket at the specified socket address. |
void |
init(java.lang.String name,
int port,
short[] servers)
Initializes a new StreamNetwork component. |
void |
setProperties()
Set the properties of the network. |
(package private) void |
setSocketOption(java.net.Socket sock)
Configures this socket using the socket options established for this factory. |
Methods inherited from class fr.dyade.aaa.agent.Network |
---|
addServer, delete, deliver, delServer, getAverageLoad1, getAverageLoad15, getAverageLoad5, getBootTS, getDomainName, getName, getNbMessageReceived, getNbMessageSent, getNbWaitingMessages, getPort, getQueue, getStamp, getWDActivationPeriod, getWDNbRetryLevel1, getWDNbRetryLevel2, getWDRetryPeriod1, getWDRetryPeriod2, getWDRetryPeriod3, index, insert, post, resetServer, restore, save, setPort, setStamp, setWDActivationPeriod, setWDNbRetryLevel1, setWDNbRetryLevel2, setWDRetryPeriod1, setWDRetryPeriod2, setWDRetryPeriod3, testBootTS, toString, validate |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Methods inherited from interface fr.dyade.aaa.agent.MessageConsumer |
---|
isRunning, start, stop |
Methods inherited from interface fr.dyade.aaa.agent.NetworkMBean |
---|
isRunning, start, stop |
Field Detail |
---|
int CnxRetry
CnxRetry
global property or for a particular network
by setting \.CnxRetry
specific property.
Theses properties can be fixed either from java
launching
command, or in a3servers.xml
configuration file.
int backlog
backlog
global property or for a particular network
by setting \.backlog
specific property.
Theses properties can be fixed either from java
launching
command, or in a3servers.xml
configuration file.
boolean TcpNoDelay
TcpNoDelay
global property or for a particular network
by setting \.TcpNoDelay
specific property.
Theses properties can be fixed either from java
launching
command, or in a3servers.xml
configuration file.
int SoLinger
SoLinger
global property or for a particular network
by setting \.SoLinger
specific property.
Theses properties can be fixed either from java
launching
command, or in a3servers.xml
configuration file.
int SoTimeout
SoTimeout
global property or for a particular network
by setting \.SoTimeout
specific property.
Theses properties can be fixed either from java
launching
command, or in a3servers.xml
configuration file.
int ConnectTimeout
ConnectTimeout
global property or for a particular network
by setting \.ConnectTimeout
specific property.
Theses properties can be fixed either from java
launching
command, or in a3servers.xml
configuration file.
java.net.InetAddress inLocalAddr
InLocalAddress
global property or for a particular network
by setting \.InLocalAddress
specific property.
Theses properties can be fixed either from java
launching
command, or in a3servers.xml
configuration file.
int outLocalPort
OutLocalPort
global property or for a particular network
by setting \.OutLocalPort
specific property.
Theses properties can be fixed either from java
launching
command, or in a3servers.xml
configuration file.
java.net.InetAddress outLocalAddr
OutLocalAddress
global property or for a particular network
by setting \.OutLocalAddress
specific property.
Theses properties can be fixed either from java
launching
command, or in a3servers.xml
configuration file.
ServerSocketFactory serverSocketFactory
ServerSocketFactory13
for JDK prior
to 1.4.
This value can be adjusted for all network components by setting
ServerSocketFactory
global property or for a particular
network by setting \.ServerSocketFactory
specific property.
Theses properties can be fixed either from java
launching
command, or in a3servers.xml
configuration file.
SocketFactory socketFactory
SocketFactory13
for JDK prior to 1.4.
This value can be adjusted for all network components by setting
SocketFactory
global property or for a particular network
by setting \.SocketFactory
specific property.
Theses properties can be fixed either from java
launching
command, or in a3servers.xml
configuration file.
Constructor Detail |
---|
public StreamNetwork()
Method Detail |
---|
public void init(java.lang.String name, int port, short[] servers) throws java.lang.Exception
init
in class Network
name
- The domain name.port
- The listen port.servers
- The list of servers directly accessible from this
network interface.
java.lang.Exception
Network
public void setProperties() throws java.lang.Exception
setProperties
in class Network
java.lang.Exception
final java.net.Socket createSocket(ServerDesc server) throws java.io.IOException
server
- the server descriptor.
java.io.IOException
- if the connection can't be establishedfinal java.net.Socket createSocket(SocketAddress addr) throws java.io.IOException
addr
- the socket address.
java.io.IOException
- if the connection can't be establishedjava.net.Socket createSocket(java.net.InetAddress addr, int port) throws java.io.IOException
Due to polymorphism of both factories and sockets, different kinds of sockets can be used by the same application code. The sockets returned to the application can be subclasses of Socket, so that they can directly expose new APIs for features such as compression, security, or firewall tunneling.
addr
- the server address.port
- the server port.
java.io.IOException
- if the connection can't be establishedfinal java.net.ServerSocket createServerSocket() throws java.io.IOException
java.io.IOException
- for networking errorsjava.net.ServerSocket createServerSocket(int port) throws java.io.IOException
port
- the port to listen to.
java.io.IOException
- for networking errorsvoid setSocketOption(java.net.Socket sock) throws java.net.SocketException
Socket
- the socket.
java.io.IOException
- for networking errors
java.net.SocketException
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |