Package pt.unl.fct.di.novasys.channel.accrual

Class AccrualChannel<T>

java.lang.Object

pt.unl.fct.di.novasys.channel.base.SingleThreadedChannel<T,Y>

pt.unl.fct.di.novasys.channel.base.SingleThreadedBiChannel<T,AccrualMessage<T>>

pt.unl.fct.di.novasys.channel.accrual.AccrualChannel<T>

All Implemented Interfaces:

IChannel<T>, AttributeValidator, InConnListener<AccrualMessage<T>>, MessageListener<AccrualMessage<T>>, OutConnListener<AccrualMessage<T>>

public class AccrualChannel<T>
extends SingleThreadedBiChannel<T,AccrualMessage<T>>
implements AttributeValidator

Based on the akka implementation of the Phi Accrual Failure Detector: https://github.com/akka/akka/blob/main/akka-remote/src/main/scala/akka/remote/PhiAccrualFailureDetector.scala

Field Summary

Fields

Modifier and Type	Field	Description
static final String	ACCEPTABLE_HB_PAUSE_KEY
static final String	ADDRESS_KEY
static final String	CONNECT_TIMEOUT_KEY
static final int	CONNECTION_IN
static final int	CONNECTION_OUT
static final String	DEFAULT_ACCEPTABLE_HB_PAUSE
static final String	DEFAULT_CONNECT_TIMEOUT
static final String	DEFAULT_HB_INTERVAL
static final String	DEFAULT_MIN_STD_DEVIATION
static final String	DEFAULT_PORT
static final String	DEFAULT_PREDICT_INTERVAL
static final String	DEFAULT_THRESHOLD
static final String	DEFAULT_WINDOW_SIZE
static final String	HB_INTERVAL_ATTRIBUTE
static final String	HB_INTERVAL_KEY
static final String	LISTEN_ADDRESS_ATTRIBUTE
static final String	MIN_STD_DEVIATION_KEY
static final String	NAME
static final String	PORT_KEY
static final String	PREDICT_INTERVAL_KEY
static final String	THRESHOLD_KEY
static final String	TRIGGER_SENT_KEY
static final String	WINDOW_SIZE_KEY
static final String	WORKER_GROUP_KEY

Fields inherited from interface pt.unl.fct.di.novasys.network.AttributeValidator

ALWAYS_VALID, CHANNEL_MAGIC_ATTRIBUTE

Constructor Summary

Constructors

Constructor	Description
AccrualChannel(ISerializer<T> serializer, ChannelListener<T> list, Properties properties)

Method Summary

Modifier and Type	Method	Description
void	onDeliverMessage(AccrualMessage<T> msg, Connection<AccrualMessage<T>> conn)
void	onServerSocketBind(boolean success, Throwable cause)
void	onServerSocketClose(boolean success, Throwable cause)
boolean	validateAttributes(Attributes attr)

Methods inherited from class pt.unl.fct.di.novasys.channel.base.SingleThreadedBiChannel

inboundConnectionDown, inboundConnectionUp, outboundConnectionDown, outboundConnectionFailed, outboundConnectionUp, serverSocketBind, serverSocketClose

Methods inherited from class pt.unl.fct.di.novasys.channel.base.SingleThreadedChannel

closeConnection, deliverMessage, openConnection, sendMessage

Methods inherited from class java.lang.Object

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

Field Details

NAME

public static final String NAME

See Also:

• Constant Field Values

ADDRESS_KEY

public static final String ADDRESS_KEY

See Also:

• Constant Field Values

PORT_KEY

public static final String PORT_KEY

See Also:

• Constant Field Values

WORKER_GROUP_KEY

public static final String WORKER_GROUP_KEY

See Also:

• Constant Field Values

TRIGGER_SENT_KEY

public static final String TRIGGER_SENT_KEY

See Also:

• Constant Field Values

CONNECT_TIMEOUT_KEY

public static final String CONNECT_TIMEOUT_KEY

See Also:

• Constant Field Values

LISTEN_ADDRESS_ATTRIBUTE

public static final String LISTEN_ADDRESS_ATTRIBUTE

See Also:

• Constant Field Values

DEFAULT_PORT

public static final String DEFAULT_PORT

See Also:

• Constant Field Values

DEFAULT_CONNECT_TIMEOUT

public static final String DEFAULT_CONNECT_TIMEOUT

See Also:

• Constant Field Values

CONNECTION_OUT

public static final int CONNECTION_OUT

See Also:

• Constant Field Values

CONNECTION_IN

public static final int CONNECTION_IN

See Also:

• Constant Field Values

WINDOW_SIZE_KEY

public static final String WINDOW_SIZE_KEY

See Also:

• Constant Field Values

HB_INTERVAL_KEY

public static final String HB_INTERVAL_KEY

See Also:

• Constant Field Values

HB_INTERVAL_ATTRIBUTE

public static final String HB_INTERVAL_ATTRIBUTE

See Also:

• Constant Field Values

MIN_STD_DEVIATION_KEY

public static final String MIN_STD_DEVIATION_KEY

See Also:

• Constant Field Values

ACCEPTABLE_HB_PAUSE_KEY

public static final String ACCEPTABLE_HB_PAUSE_KEY

See Also:

• Constant Field Values

THRESHOLD_KEY

public static final String THRESHOLD_KEY

See Also:

• Constant Field Values

PREDICT_INTERVAL_KEY

public static final String PREDICT_INTERVAL_KEY

See Also:

• Constant Field Values

DEFAULT_WINDOW_SIZE

public static final String DEFAULT_WINDOW_SIZE

See Also:

• Constant Field Values

DEFAULT_HB_INTERVAL

public static final String DEFAULT_HB_INTERVAL

See Also:

• Constant Field Values

DEFAULT_MIN_STD_DEVIATION

public static final String DEFAULT_MIN_STD_DEVIATION

See Also:

• Constant Field Values

DEFAULT_ACCEPTABLE_HB_PAUSE

public static final String DEFAULT_ACCEPTABLE_HB_PAUSE

See Also:

• Constant Field Values

DEFAULT_THRESHOLD

public static final String DEFAULT_THRESHOLD

See Also:

• Constant Field Values

DEFAULT_PREDICT_INTERVAL

public static final String DEFAULT_PREDICT_INTERVAL

See Also:

• Constant Field Values

Constructor Details

AccrualChannel

public AccrualChannel(ISerializer<T> serializer,
 ChannelListener<T> list,
 Properties properties)
               throws IOException

Throws:

IOException

Method Details

onServerSocketBind

public void onServerSocketBind(boolean success,
 Throwable cause)

onServerSocketClose

public void onServerSocketClose(boolean success,
 Throwable cause)

onDeliverMessage

public void onDeliverMessage(AccrualMessage<T> msg,
 Connection<AccrualMessage<T>> conn)

validateAttributes

public boolean validateAttributes(Attributes attr)

Specified by:

validateAttributes in interface AttributeValidator