Class UNICAST3.SenderEntry

    • Field Detail

      • sent_msgs_seqno

        final java.util.concurrent.atomic.AtomicLong sent_msgs_seqno
      • watermark

        final long[] watermark
      • last_timestamp

        int last_timestamp
    • Constructor Detail

      • SenderEntry

        public SenderEntry​(short send_conn_id)
    • Method Detail

      • watermark

        long[] watermark()
      • updateLastTimestamp

        private boolean updateLastTimestamp​(int ts)
        Updates last_timestamp. Returns true of the update was in order (ts > last_timestamp)
      • toString

        public java.lang.String toString()
        Overrides:
        toString in class java.lang.Object