Class StreamManagementIOProcessor.OutQueue

java.lang.Object
tigase.server.xmppclient.StreamManagementIOProcessor.Counter
tigase.server.xmppclient.StreamManagementIOProcessor.OutQueue
Enclosing class:
StreamManagementIOProcessor
public static class StreamManagementIOProcessor.OutQueue extends StreamManagementIOProcessor.Counter
OutQueue class implements queue of outgoing packets waiting for ack with implementation of removing acked elements when id of acked packet is passed
Author:
andrzej

  • Constructor Details

    • OutQueue

      public OutQueue()

    • OutQueue

      protected OutQueue(LongSupplier timestampSupplier)

  • Method Details

    • append

      @Deprecated public boolean append(Packet packet, int timeoutInSec)
      Deprecated.
      Append packet to waiting for ack queue

    • append

      @Deprecated public boolean append(Packet packet, int maxQueueSize, int timeoutInSec)
      Deprecated.
      Append packet to waiting for ack queue

    • append

      public boolean append(Packet packet, int maxQueueSize, int timeoutInSec, int burstPeriodInSec, int burstRatio)
      Append packet to waiting for ack queue

    • ack

      public void ack(int value)
      Confirm delivery of packets up to count passed as value

    • sendingRequest

      public void sendingRequest()
      Method notifies class that request for ack is being sent

    • setAckRequestCount

      public void setAckRequestCount(int ackRequestCount)
      Sets ack request count value
      Parameters:
      ackRequestCount -

    • setResumptionEnabled

      @Deprecated public void setResumptionEnabled(boolean enabled)
      Deprecated.

    • waitingForAck

      public int waitingForAck()
      Returns size of queue containing packets waiting for ack

    • getQueue

      protected ArrayDeque<StreamManagementIOProcessor.OutQueue.Entry> getQueue()
      Method returns internal queue with packets waiting for ack - use testing only!

    • getLastConfirmationAt

      protected long getLastConfirmationAt()
      Method returns timestamp of the last received ack.
      Returns:

    • getLastRequestSentAt

      protected long getLastRequestSentAt()
      Method returns timestamp of the last request for ack being sent.
      Returns:

    • gotAckOrSentRequestSince

      protected boolean gotAckOrSentRequestSince(long since)
      Method checks if any ack was received or request for ack was sent since passed timestamp.
      Parameters:
      since -
      Returns:

    • unackedSinceLastRequest

      protected int unackedSinceLastRequest()
      Method returns no. of unacked stanzas since last request for ack was sent.
      Returns: