Class 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  
    • Constructor Summary

      Constructors 
      Modifier Constructor Description
      protected Entry​(Buffer<Message> buf)  
    • Field Detail

      • num_acks_sent

        protected final java.util.concurrent.atomic.AtomicInteger num_acks_sent
      • send_ack

        protected final java.util.concurrent.atomic.AtomicBoolean send_ack
    • Method Detail

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