X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?p=controller.git;a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-distributed-datastore%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Fdatabroker%2Factors%2Fdds%2FProxyHistory.java;h=2a21b8e858c9548ccf5ef82206042b83f38cb4e5;hp=827c19e526fcbd5f6b3cc1c33dfdc40698af11e9;hb=3ee40198347cfb53bd0ce12ffd625cff8ed2383b;hpb=2c747874d93b29fab12f4d8fe4fa2af32134b794 diff --git a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/databroker/actors/dds/ProxyHistory.java b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/databroker/actors/dds/ProxyHistory.java index 827c19e526..2a21b8e858 100644 --- a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/databroker/actors/dds/ProxyHistory.java +++ b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/databroker/actors/dds/ProxyHistory.java @@ -259,6 +259,8 @@ abstract class ProxyHistory implements Identifiable { @Override void forwardRequest(final Request request, final Consumer> callback, final BiConsumer, Consumer>> forwardTo) throws RequestException { + // FIXME: do not use sendRequest() once we have throttling in place, as we have already waited the + // period required to get into the queue. if (request instanceof TransactionRequest) { forwardTransactionRequest((TransactionRequest) request, callback); } else if (request instanceof LocalHistoryRequest) {