Class ReliableUnicast.Entry

java.lang.Object

org.jgroups.protocols.ReliableUnicast.Entry

Direct Known Subclasses:

ReliableUnicast.ReceiverEntry, ReliableUnicast.SenderEntry

Enclosing class:

ReliableUnicast

protected abstract class ReliableUnicast.Entry
extends Object

Since:

5.4

Author:

Bela Ban

Field Summary

Fields

Modifier and Type	Field	Description
protected final AtomicInteger	acks_sent
protected final Buffer<Message>	buf
protected final short	conn_id
protected final AtomicBoolean	send_ack
protected ReliableUnicast.State	state
protected final AtomicLong	timestamp

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	Entry(short conn_id, Buffer<Message> buf)

Method Summary

Modifier and Type	Method	Description
protected long	age()
Buffer<Message>	buf()
short	connId()
protected boolean	needToSendAck()
protected ReliableUnicast.Entry	sendAck()
protected ReliableUnicast.State	state()
protected ReliableUnicast.Entry	state(ReliableUnicast.State s)
protected void	update()
boolean	update(int num_acks, IntBinaryOperator op)	Returns true if a real ACK should be sent.

Methods inherited from class Object

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

Field Details

buf

protected final Buffer<Message> buf

conn_id

protected final short conn_id

timestamp

protected final AtomicLong timestamp

state

protected volatile ReliableUnicast.State state

send_ack

protected final AtomicBoolean send_ack

acks_sent

protected final AtomicInteger acks_sent

Constructor Details

Entry

protected Entry(short conn_id,
 Buffer<Message> buf)

Method Details

buf

public Buffer<Message> buf()

connId

public short connId()

update

protected void update()

age

protected long age()

needToSendAck

protected boolean needToSendAck()

sendAck

protected ReliableUnicast.Entry sendAck()

state

protected ReliableUnicast.State state()

state

protected ReliableUnicast.Entry state(ReliableUnicast.State s)

update

public boolean update(int num_acks,
 IntBinaryOperator op)

Returns true if a real ACK should be sent. This is when num_acks_sent is greater than ack_threshold