net.sf.appia.protocols.nakfifo
Class NakFifoSession

java.lang.Object
  net.sf.appia.core.Session
      net.sf.appia.protocols.nakfifo.NakFifoSession

All Implemented Interfaces:

InitializableSession

public class NakFifoSession
extends Session
implements InitializableSession

Session of protocols that provides reliable point-to-point communication.
It offers AppiaMulticast support by sending a different message to each destination.

Author:

Alexandre Pinto

Field Summary

static boolean	debugFull Full debug information.
static int	debugListLimit
static long	DEFAULT_MAX_APPL_TIME Default maximum time without receiving an Application message.
static long	DEFAULT_MAX_RECV_TIME Default maximum time, in milliseconds, to recieve a message from a peer.
static long	DEFAULT_MAX_SENT_TIME Default maximum time to send a message to a peer.
static long	DEFAULT_RESEND_TIME Default time, in milliseconds, to resend a NAK.
static long	DEFAULT_TIMER_PERIOD The default duration of a round in milliseconds.

Fields inherited from class net.sf.appia.core.Session

layer

Constructor Summary

NakFifoSession(Layer layer)
Creates a new instance of NakFifoSession

Method Summary

void	handle(Event event) Main Event handler.
void	init(SessionProperties params) Initializes the session using the parameters given in the XML configuration.

Methods inherited from class net.sf.appia.core.Session

boundSessions, getId, getLayer, setId

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

DEFAULT_TIMER_PERIOD

public static final long DEFAULT_TIMER_PERIOD

The default duration of a round in milliseconds.

See Also:

Constant Field Values

DEFAULT_RESEND_TIME

public static final long DEFAULT_RESEND_TIME

Default time, in milliseconds, to resend a NAK.
Must be a multiple of the round duration (DEFAULT_TIMER_PERIOD).

See Also:

Constant Field Values

DEFAULT_MAX_APPL_TIME

public static final long DEFAULT_MAX_APPL_TIME

Default maximum time without receiving an Application message. When this time is reached the peer is discarded.
Must be a multiple of the round duration (DEFAULT_TIMER_PERIOD).

See Also:

Constant Field Values

DEFAULT_MAX_RECV_TIME

public static final long DEFAULT_MAX_RECV_TIME

Default maximum time, in milliseconds, to recieve a message from a peer. If this time is reached the peer is considered failed.
Must be a multiple of the round duration (DEFAULT_TIMER_PERIOD).

See Also:

Constant Field Values

DEFAULT_MAX_SENT_TIME

public static final long DEFAULT_MAX_SENT_TIME

Default maximum time to send a message to a peer. If this time is reached a Ping message is sent.
Must be a multiple of the round duration (DEFAULT_TIMER_PERIOD).

See Also:

Constant Field Values

debugFull

public static final boolean debugFull

Full debug information.

See Also:

Constant Field Values

debugListLimit

public static final int debugListLimit

See Also:

Constant Field Values

Constructor Detail

NakFifoSession

public NakFifoSession(Layer layer)

Creates a new instance of NakFifoSession

Method Detail

init

public void init(SessionProperties params)

Initializes the session using the parameters given in the XML configuration. Possible parameters:

• timer_period the period of the internal timer. (in milliseconds)
• resend_nack_time the time to resend a negative ack. (in milliseconds)
• max_appl_time maximum time without receiving an Application message, and discarding the peer. (in milliseconds)
• max_recv_time maximum time for message reception, before suspecting the peer. (in milliseconds)
• max_sent_time maximum time between sent messages. (in milliseconds)

Specified by:

init in interface InitializableSession

Parameters:

params - The parameters given in the XML configuration.

See Also:

SessionProperties

handle

public void handle(Event event)

Main Event handler.

Overrides:

handle in class Session