X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fstatistics-manager%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fmd%2Fstatistics%2Fmanager%2FNodeStatisticsHandler.java;h=d62b680e1466c89d88180b51b0d89a97b2120602;hb=refs%2Fchanges%2F42%2F5342%2F1;hp=691b9c0b15f58a9d6a01d05e7146c8a69251e332;hpb=def3f90c150a98aa910ce5ba3e4692c461dd3250;p=controller.git diff --git a/opendaylight/md-sal/statistics-manager/src/main/java/org/opendaylight/controller/md/statistics/manager/NodeStatisticsHandler.java b/opendaylight/md-sal/statistics-manager/src/main/java/org/opendaylight/controller/md/statistics/manager/NodeStatisticsHandler.java index 691b9c0b15..d62b680e14 100644 --- a/opendaylight/md-sal/statistics-manager/src/main/java/org/opendaylight/controller/md/statistics/manager/NodeStatisticsHandler.java +++ b/opendaylight/md-sal/statistics-manager/src/main/java/org/opendaylight/controller/md/statistics/manager/NodeStatisticsHandler.java @@ -11,7 +11,6 @@ import java.util.Collection; import java.util.List; import java.util.concurrent.TimeUnit; -import org.opendaylight.controller.md.statistics.manager.MultipartMessageManager.StatsRequestType; import org.opendaylight.controller.sal.binding.api.data.DataModificationTransaction; import org.opendaylight.controller.sal.binding.api.data.DataProviderService; import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.FlowCapableNode; @@ -299,11 +298,11 @@ public final class NodeStatisticsHandler implements AutoCloseable, FlowCapableCo } @Override - public void registerTransaction(final ListenableFuture future, final StatsRequestType type) { + public void registerTransaction(final ListenableFuture future) { Futures.addCallback(future, new FutureCallback() { @Override public void onSuccess(TransactionId result) { - msgManager.recordExpectedTransaction(result, type); + msgManager.recordExpectedTransaction(result); logger.debug("Transaction {} for node {} sent successfully", result, targetNodeKey); } @@ -319,7 +318,7 @@ public final class NodeStatisticsHandler implements AutoCloseable, FlowCapableCo Futures.addCallback(future, new FutureCallback() { @Override public void onSuccess(TransactionId result) { - msgManager.recordExpectedTableTransaction(result, StatsRequestType.AGGR_FLOW, id); + msgManager.recordExpectedTableTransaction(result, id); logger.debug("Transaction {} for node {} table {} sent successfully", result, targetNodeKey, id); }