|
|||||||||
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
fr.dyade.aaa.agent.NGNetwork
public class NGNetwork
NGNetwork
is a new implementation of Network
class using nio package.
Nested Class Summary | |
---|---|
(package private) class |
NGNetwork.CnxHandler
|
(package private) class |
NGNetwork.Dispatcher
|
(package private) class |
NGNetwork.MessageVector
|
(package private) class |
NGNetwork.NetServer
|
Nested classes/interfaces inherited from class fr.dyade.aaa.agent.Network |
---|
Network.NetworkAverageLoadTask |
Field Summary | |
---|---|
(package private) NGNetwork.Dispatcher |
dispatcher
|
(package private) NGNetwork.NetServer[] |
dmon
|
(package private) NGNetwork.CnxHandler[] |
handlers
|
(package private) static int |
Kb
|
(package private) java.nio.channels.ServerSocketChannel |
listen
|
(package private) static int |
Mb
|
(package private) static int |
NbNetServer
|
(package private) java.nio.channels.Selector |
selector
|
(package private) static int |
SO_BUFSIZE
|
Fields inherited from class fr.dyade.aaa.agent.StreamNetwork |
---|
backlog, CnxRetry, ConnectTimeout, inLocalAddr, outLocalAddr, outLocalPort, serverSocketFactory, socketFactory, SoLinger, SoTimeout, TcpNoDelay |
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 | |
---|---|
NGNetwork()
Creates a new network component. |
Method Summary | |
---|---|
(package private) void |
close()
|
(package private) void |
cnxStart(java.nio.channels.SocketChannel channel)
|
(package private) NGNetwork.CnxHandler |
getHandler(short sid)
|
void |
init(java.lang.String name,
int port,
short[] servers)
Initializes a new network component. |
boolean |
isRunning()
Tests if the network component is alive. |
(package private) void |
open()
|
void |
start()
Causes this network component to begin execution. |
void |
stop()
Forces the network component to stop executing. |
java.lang.String |
toString()
Returns a string representation of this consumer, including the daemon's name and status. |
void |
wakeup()
Wakes up the watch-dog thread. |
Methods inherited from class fr.dyade.aaa.agent.StreamNetwork |
---|
createServerSocket, createServerSocket, createSocket, createSocket, createSocket, setProperties, setSocketOption |
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, validate |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Field Detail |
---|
static final int Kb
static final int Mb
static final int SO_BUFSIZE
java.nio.channels.Selector selector
NGNetwork.Dispatcher dispatcher
NGNetwork.NetServer[] dmon
static final int NbNetServer
NGNetwork.CnxHandler[] handlers
java.nio.channels.ServerSocketChannel listen
Constructor Detail |
---|
public NGNetwork()
Method Detail |
---|
public void init(java.lang.String name, int port, short[] servers) throws java.lang.Exception
Class.newInstance()
method for create
(whitout any parameter) the component, then we can initialize it with
this method.
init
in class StreamNetwork
name
- The domain name.port
- The listen port.servers
- The list of servers directly accessible from this
network interface.
java.lang.Exception
Network
void open() throws java.io.IOException
java.io.IOException
void close()
public void start() throws java.lang.Exception
java.lang.Exception
stop
final NGNetwork.CnxHandler getHandler(short sid)
public void wakeup()
public void stop()
start
public boolean isRunning()
MessageConsumer
is alive; false
otherwise.public java.lang.String toString()
toString
in interface NetworkMBean
toString
in class Network
void cnxStart(java.nio.channels.SocketChannel channel) throws java.io.IOException
java.io.IOException
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |