Package fr.dyade.aaa.agent

Class HttpNetwork

java.lang.Object

fr.dyade.aaa.agent.Network

fr.dyade.aaa.agent.StreamNetwork

fr.dyade.aaa.agent.HttpNetwork

All Implemented Interfaces:

HttpNetworkMBean, MessageComparator, MessageConsumer, NetworkMBean

Direct Known Subclasses:

HttpsNetwork

public class HttpNetwork
extends StreamNetwork
implements HttpNetworkMBean

HttpNetwork is a simple implementation of StreamNetwork based on HTTP 1.1 protocol.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) class	HttpNetwork.NetServerIn
(package private) class	HttpNetwork.NetServerOut
(package private) class	HttpNetwork.NetworkInputStream	Class used to read messages through a stream.
(package private) class	HttpNetwork.NetworkOutputStream	Class used to send messages through a stream.

Nested classes/interfaces inherited from class fr.dyade.aaa.agent.Network

Network.NetworkAverageLoadTask

Field Summary

Fields

Modifier and Type	Field	Description
protected long	activationPeriod	Period of time between two activation of NetServerOut, it matches to the time between two requests from the client to the server when there is no message to transmit from client to server.
(package private) Daemon[]	dmon	Daemon component
(package private) int	NbDaemon	Number of listening daemon, this value is only valid for the server part of the HttpNetwork.
private InetAddress	proxy	Network address of proxy server.
(package private) String	proxyhost	Hostname (or IP dotted address) of proxy host, if not defined there is a direct connection between the client and the server.
(package private) int	proxyport	Port number of proxy if any.
(package private) ServerDesc	server	Descriptor of the listen server, it is used only on the client side (NetServerOut component).

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, DEBUG, DELIVER, domain, idxLS, logger, name, nbMessageIn, nbMessageOut, port, qout, servers, serversFN, sid, WDActivationPeriod, WDNbRetryLevel1, WDNbRetryLevel2, WDRetryPeriod1, WDRetryPeriod2, WDRetryPeriod3

Constructor Summary

Constructors

Constructor	Description
HttpNetwork()	Creates a new network component.

Method Summary

Modifier and Type	Method	Description
long	getActivationPeriod()	Gets the activationPeriod value.
long	getNbDaemon()	Gets the NbDaemon value.
String	getProxyhost()	Gets the proxyhost value.
long	getProxyport()	Gets the proxyport value.
protected void	getReply(InputStream is, HttpNetwork.NetworkInputStream nis, byte[] buf)
protected short	getRequest(InputStream is, HttpNetwork.NetworkInputStream nis, byte[] buf)
protected int	handle(Message msgout, HttpNetwork.NetworkInputStream nis)
void	init(String name, int port, short[] servers)	Initializes a new network component.
boolean	isRunning()	Tests if the network component is alive.
(package private) String	readLine(InputStream is, byte[] buf)
protected void	sendReply(Message msg, OutputStream os, HttpNetwork.NetworkOutputStream nos, int ack, long currentTimeMillis)
protected void	sendRequest(Message msg, OutputStream os, HttpNetwork.NetworkOutputStream nos, int ack, long currentTimeMillis)
void	setActivationPeriod(long activationPeriod)	Sets the activationPeriod value.
void	start()	Causes this network component to begin execution.
void	stop()	Forces the network component to stop executing.
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, channelPostAndValidate, checkActive, delete, deleteMessage, deliver, delServer, getAverageLoad1, getAverageLoad15, getAverageLoad5, getBootTS, getDomainName, getMessageDest, getMessageSource, getName, getNbMessageReceived, getNbMessageSent, getNbWaitingMessages, getPort, getQueue, getStamp, getWDActivationPeriod, getWDNbRetryLevel1, getWDNbRetryLevel2, getWDRetryPeriod1, getWDRetryPeriod2, getWDRetryPeriod3, index, insert, isPrior, post, postAndValidate, postMessage, prepareMessage, prepareMessageWithoutStamp, resetServer, restore, save, saveChannel, setMessageSource, setPort, setStamp, setWDActivationPeriod, setWDNbRetryLevel1, setWDNbRetryLevel2, setWDRetryPeriod1, setWDRetryPeriod2, setWDRetryPeriod3, testBootTS, testRecvUpdate, validate, validateChannel

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.NetworkMBean

getAverageLoad1, getAverageLoad15, getAverageLoad5, getName, getNbMessageReceived, getNbMessageSent, getNbWaitingMessages, getWDActivationPeriod, getWDNbRetryLevel1, getWDNbRetryLevel2, getWDRetryPeriod1, getWDRetryPeriod2, getWDRetryPeriod3, setWDActivationPeriod, setWDNbRetryLevel1, setWDNbRetryLevel2, setWDRetryPeriod1, setWDRetryPeriod2, setWDRetryPeriod3

Field Detail

proxy

private InetAddress proxy

Network address of proxy server.

See Also:

proxyhost, proxyport

proxyhost

String proxyhost

Hostname (or IP dotted address) of proxy host, if not defined there is a direct connection between the client and the server. This value can be adjusted for all HttpNetwork components by setting proxyhost global property or for a particular network by setting <DomainName>.proxyhost specific property.

Theses properties can be fixed either from java launching command, or in a3servers.xml configuration file.

proxyport

int proxyport

Port number of proxy if any. This value can be adjusted for all HttpNetwork components by setting proxyport global property or for a particular network by setting <DomainName>.proxyport specific property.

Theses properties can be fixed either from java launching command, or in a3servers.xml configuration file.

activationPeriod

protected long activationPeriod

Period of time between two activation of NetServerOut, it matches to the time between two requests from the client to the server when there is no message to transmit from client to server. This value can be adjusted for all HttpNetwork components by setting ActivationPeriod global property or for a particular network by setting <DomainName>.ActivationPeriod specific property.

Theses properties can be fixed either from java launching command, or in a3servers.xml configuration file. By default, its value is 10000 (10s).

NbDaemon

int NbDaemon

Number of listening daemon, this value is only valid for the server part of the HttpNetwork. This value can be adjusted for all HttpNetwork components by setting NbDaemon global property or for a particular network by setting <DomainName>.NbDaemon specific property.

Theses properties can be fixed either from java launching command, or in a3servers.xml configuration file.

server

ServerDesc server

Descriptor of the listen server, it is used only on the client side (NetServerOut component).

dmon

Daemon[] dmon

Daemon component

Constructor Detail

HttpNetwork

public HttpNetwork()

Creates a new network component.

Method Detail

getProxyhost

public String getProxyhost()

Gets the proxyhost value.

Specified by:

getProxyhost in interface HttpNetworkMBean

Returns:

the proxyhost value

getProxyport

public long getProxyport()

Gets the proxyport value.

Specified by:

getProxyport in interface HttpNetworkMBean

Returns:

the proxyport value

getActivationPeriod

public long getActivationPeriod()

Gets the activationPeriod value.

Specified by:

getActivationPeriod in interface HttpNetworkMBean

Returns:

the activationPeriod value

setActivationPeriod

public void setActivationPeriod(long activationPeriod)

Sets the activationPeriod value.

Specified by:

setActivationPeriod in interface HttpNetworkMBean

Parameters:

activationPeriod - the activationPeriod value

getNbDaemon

public long getNbDaemon()

Gets the NbDaemon value.

Specified by:

getNbDaemon in interface HttpNetworkMBean

Returns:

the NbDaemon value

init

public void init(String name,
                 int port,
                 short[] servers)
          throws Exception

Initializes a new network component. This method is used in order to easily creates and configure a Network component from a class name. So we can use the Class.newInstance() method for create (whitout any parameter) the component, then we can initialize it with this method.
This method initializes the logical clock for the domain.

Overrides:

init in class StreamNetwork

Parameters:

name - The domain name.

port - The listen port.

servers - The list of servers directly accessible from this network interface.

Throws:

Exception - an error occurs.

See Also:

Network

start

public void start()
           throws Exception

Causes this network component to begin execution.

Specified by:

start in interface MessageConsumer

Specified by:

start in interface NetworkMBean

Throws:

Exception - an error occurs.

See Also:

MessageConsumer.stop()

wakeup

public void wakeup()

Wakes up the watch-dog thread.

stop

public void stop()

Forces the network component to stop executing.

Specified by:

stop in interface MessageConsumer

Specified by:

stop in interface NetworkMBean

See Also:

MessageConsumer.start()

isRunning

public boolean isRunning()

Tests if the network component is alive.

Specified by:

isRunning in interface MessageConsumer

Specified by:

isRunning in interface NetworkMBean

Returns:

true if this MessageConsumer is alive; false otherwise.

toString

public String toString()

Returns a string representation of this consumer, including the daemon's name and status.

Specified by:

toString in interface NetworkMBean

Overrides:

toString in class Network

Returns:

A string representation of this consumer.

readLine

String readLine(InputStream is,
                byte[] buf)
         throws IOException

Throws:

IOException

sendRequest

protected void sendRequest(Message msg,
                           OutputStream os,
                           HttpNetwork.NetworkOutputStream nos,
                           int ack,
                           long currentTimeMillis)
                    throws Exception

Throws:

Exception

getRequest

protected final short getRequest(InputStream is,
                                 HttpNetwork.NetworkInputStream nis,
                                 byte[] buf)
                          throws Exception

Throws:

Exception

sendReply

protected final void sendReply(Message msg,
                               OutputStream os,
                               HttpNetwork.NetworkOutputStream nos,
                               int ack,
                               long currentTimeMillis)
                        throws Exception

Throws:

Exception

getReply

protected void getReply(InputStream is,
                        HttpNetwork.NetworkInputStream nis,
                        byte[] buf)
                 throws Exception

Throws:

Exception

handle

protected int handle(Message msgout,
                     HttpNetwork.NetworkInputStream nis)
              throws Exception

Throws:

Exception