Package org.jgroups.protocols

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 java.lang.Object

Field Summary

Fields

Modifier and Type	Field	Description
protected java.util.concurrent.atomic.AtomicInteger	acks_sent
protected Buffer<Message>	buf
protected short	conn_id
protected java.util.concurrent.atomic.AtomicBoolean	send_ack
protected ReliableUnicast.State	state
protected java.util.concurrent.atomic.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, java.util.function.IntBinaryOperator op)	Returns true if a real ACK should be sent.

Methods inherited from class java.lang.Object

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

Field Detail

buf

protected final Buffer<Message> buf

conn_id

protected final short conn_id

timestamp

protected final java.util.concurrent.atomic.AtomicLong timestamp

state

protected volatile ReliableUnicast.State state

send_ack

protected final java.util.concurrent.atomic.AtomicBoolean send_ack

acks_sent

protected final java.util.concurrent.atomic.AtomicInteger acks_sent

Constructor Detail

Entry

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

Method Detail

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,
                      java.util.function.IntBinaryOperator op)

Returns true if a real ACK should be sent. This is based on num_acks_sent being > ack_threshold