BUG-8422: Propagate enqueue time

[controller.git] / opendaylight / md-sal / cds-access-client / src / main / java / org / opendaylight / controller / cluster / access / client / TransmitQueue.java

diff --git a/opendaylight/md-sal/cds-access-client/src/main/java/org/opendaylight/controller/cluster/access/client/TransmitQueue.java b/opendaylight/md-sal/cds-access-client/src/main/java/org/opendaylight/controller/cluster/access/client/TransmitQueue.java
index d384ba47369ce5dc034028d12cad11bb54f8e3ae..9ab80d0d0085df1ef612e48606079b4eae413ea0 100644 (file)
--- a/opendaylight/md-sal/cds-access-client/src/main/java/org/opendaylight/controller/cluster/access/client/TransmitQueue.java
+++ b/opendaylight/md-sal/cds-access-client/src/main/java/org/opendaylight/controller/cluster/access/client/TransmitQueue.java
@@ -159,6 +159,9 @@ abstract class TransmitQueue {
             return 0;
         }
 
+        // XXX: we should place a guard against incorrect entry sequences:
+        // entry.getEnqueueTicks() should have non-negative difference from the last entry present in the queues
+
         // Reserve an entry before we do anything that can fail
         final long delay = tracker.openTask(now);
         if (canTransmitCount(inflight.size()) <= 0) {