X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?p=controller.git;a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fcds-access-client%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Faccess%2Fclient%2FTransmitQueue.java;h=9ab80d0d0085df1ef612e48606079b4eae413ea0;hp=d384ba47369ce5dc034028d12cad11bb54f8e3ae;hb=17e4759c7561e09786a22210e43b5b32db45149e;hpb=7da03519bcdb9a9ff3b0c73064eb48dd9393f013 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 d384ba4736..9ab80d0d00 100644 --- 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) {