Package org.jgroups.protocols
Class ReliableMulticast.Entry
- java.lang.Object
-
- org.jgroups.protocols.ReliableMulticast.Entry
-
- Enclosing class:
- ReliableMulticast
protected static class ReliableMulticast.Entry extends java.lang.Object
-
-
Field Summary
Fields Modifier and Type Field Description protected Buffer<Message>
buf
protected java.util.concurrent.atomic.AtomicInteger
num_acks_sent
protected java.util.concurrent.atomic.AtomicBoolean
send_ack
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected Buffer<Message>
buf()
protected boolean
needToSendAck()
protected ReliableMulticast.Entry
sendAck()
java.lang.String
toString()
boolean
update(int num_acks, java.util.function.IntBinaryOperator op)
Returns true if a real ACK should be sent.
-
-
-
Method Detail
-
sendAck
protected ReliableMulticast.Entry sendAck()
-
needToSendAck
protected boolean needToSendAck()
-
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
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
-