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>bufprotected java.util.concurrent.atomic.AtomicIntegernum_acks_sentprotected java.util.concurrent.atomic.AtomicBooleansend_ack
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected Buffer<Message>buf()protected booleanneedToSendAck()protected ReliableMulticast.EntrysendAck()java.lang.StringtoString()booleanupdate(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:
toStringin classjava.lang.Object
-
-