X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fcds-access-client%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Faccess%2Fclient%2FTransmitQueue.java;h=d384ba47369ce5dc034028d12cad11bb54f8e3ae;hb=4ec6c11c03ae92e11a7cea29795e4b7f5547f64e;hp=4a1b3a2f293a499a64e805250a5a3776222caa67;hpb=a36d5af3e383cbddc31527a6d05bc23de3f3571d;p=controller.git 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 4a1b3a2f29..d384ba4736 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 @@ -112,6 +112,10 @@ abstract class TransmitQueue { return tracker.ticksStalling(now); } + final boolean hasSuccessor() { + return successor != null; + } + // If a matching request was found, this will track a task was closed. final Optional complete(final ResponseEnvelope envelope, final long now) { Optional maybeEntry = findMatchingEntry(inflight, envelope);