Class

Tree

PREV CLASS NEXT CLASS

FRAMES NO FRAMES

SUMMARY: INNER | FIELD | CONSTR | METHOD

DETAIL: FIELD | CONSTR | METHOD

com.newstep.solid.comm.rtt

Class HeartBeatAckElement

com.newstep.solid.comm.AbstractChannel

|

+--com.newstep.solid.comm.ProtocolElement

|

+--com.newstep.solid.comm.rtt.HeartBeatAckElement

All Implemented Interfaces:
Channel, ChannelListener, ChannelStatusListener, TimerListener

public class HeartBeatAckElement

This ProtocolElement deals with sending/receiving the heartbeat. It keeps a
copy of all sent messages and if the heartbeat does not come in time, asks
the redundant protocol element to retransmit it on the other channel.

Implements:

ChannelStatusListener
TimerListener

Links:

Kernel Association Association Link

to Enumeration Type

Associates type:

association

Client cardinality:

1

Client navigability:

NOT NAVIGABLE

Client visibility:

private

Supplier cardinality:

1

Supplier navigability:

NAVIGABLE

Supplier visibility:

private

Kernel Association Association Link

to Class RttTimer

Associates type:

aggregationByValue

Client cardinality:

1

Client navigability:

NOT NAVIGABLE

Client visibility:

private

Supplier cardinality:

1

Supplier navigability:

NAVIGABLE

Supplier visibility:

private

Custom properties

link:

aggregationByValue

Implementation Implementation Link

to Interface ChannelStatusListener

This ProtocolElement deals with sending/receiving the heartbeat. It keeps a
copy of all sent messages and if the heartbeat does not come in time, asks
the redundant protocol element to retransmit it on the other channel.

Generalization Generalization Link

to Class ProtocolElement

This ProtocolElement deals with sending/receiving the heartbeat. It keeps a
copy of all sent messages and if the heartbeat does not come in time, asks
the redundant protocol element to retransmit it on the other channel.

Implementation Implementation Link

to Interface TimerListener

This ProtocolElement deals with sending/receiving the heartbeat. It keeps a
copy of all sent messages and if the heartbeat does not come in time, asks
the redundant protocol element to retransmit it on the other channel.

Field Summary
Type	role
private int	channelId
private static String	className
private final static long	DELAY
private final static long	HEARTBEAT
private int	nextAck
private int	nextExpectedSeq
private int	nextSendSeq
private long	pulse
private Type	role
private RttTimer	timer

Constructor Summary
public void	HeartBeatAckElement(Channel subChannel)

Method Summary
public void	close()
public long	getChannelId()
private int	getNextAck()
private int	getNextExpectedSeq()
private int	getNextSendSeq()
public Type	getRole()
private void	incrementNextExpectedSeq()
private void	incrementNextSendSeq()
public void	onMessage(Message message)
public void	open()
private void	setNextAck(Integer nr)
public void	setRole(Type role)
public void	statusChanged(Channel channel, ChannelState state)
public void	timerExpired()
public String	toString()
public synchronized void	write(Message message)

Field Detail

channelId

private int channelId

Multiplicity:

1

className

private static String className

Multiplicity:

1

Static.

DELAY

private final static long DELAY

Final.

Multiplicity:

1

Static.

HEARTBEAT

private final static long HEARTBEAT

Final.

Multiplicity:

1

Static.

nextAck

private int nextAck

Multiplicity:

1

nextExpectedSeq

private int nextExpectedSeq

Multiplicity:

1

nextSendSeq

private int nextSendSeq

Multiplicity:

1

Custom properties

associates:

com.newstep.solid.comm.rtt.RttMessage

__supplierQualifier_1:

0..*

pulse

private long pulse

Multiplicity:

1

role

Type role

role

private Type role

Multiplicity:

1

timer

private RttTimer timer

Multiplicity:

1

Constructor Detail

HeartBeatAckElement

public void HeartBeatAckElement (Channel subChannel)

Stereotype:

create

Method Detail

close

public void close ()

Channel Interface. Propagates the close downstream

Throws:

ChannelException

getChannelId

public long getChannelId ()

getNextAck

private int getNextAck ()

getNextExpectedSeq

private int getNextExpectedSeq ()

getNextSendSeq

private int getNextSendSeq ()

getRole

public Type getRole ()

Returns the role of this element

Return:

Type

incrementNextExpectedSeq

private void incrementNextExpectedSeq ()

incrementNextSendSeq

private void incrementNextSendSeq ()

onMessage

public void onMessage (Message message)

Channel Interface. Receives a message from the channel bellow it process
it and it propagates it upstream.

open

public void open ()

Channle Interface. Propagates the OPEN downstream

Throws:

ChannelException

setNextAck

private void setNextAck (Integer nr)

setRole

public void setRole (Type role)

Assigns the role of this element

statusChanged

public void statusChanged (Channel channel, ChannelState state)

ChannelListener interface. Status change notifications

timerExpired

public void timerExpired ()

TimerListener interface; looks after the heartbeat

toString

public String toString ()

write

public synchronized void write (Message message)

Channel Interface. Writes a message to the channel

Synchronized.

Throws:

ChannelException

Class

Tree

PREV CLASS NEXT CLASS

FRAMES NO FRAMES

SUMMARY: INNER | FIELD | CONSTR | METHOD

DETAIL: FIELD | CONSTR | METHOD