From: tpantelis Date: Wed, 12 Nov 2014 16:21:40 +0000 (-0500) Subject: Bug 2347: DOMConcurrentDataCommitCoordinator uses wrong phase name X-Git-Tag: release/beryllium~149^2~161^2 X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=commitdiff_plain;h=598fd32bb7da0612d630106e9d993215da203053;p=mdsal.git Bug 2347: DOMConcurrentDataCommitCoordinator uses wrong phase name Change-Id: I8b9083a428553525861137fc8630635f6508c2dc Signed-off-by: tpantelis --- diff --git a/opendaylight/md-sal/sal-dom-broker/src/main/java/org/opendaylight/controller/md/sal/dom/broker/impl/DOMConcurrentDataCommitCoordinator.java b/opendaylight/md-sal/sal-dom-broker/src/main/java/org/opendaylight/controller/md/sal/dom/broker/impl/DOMConcurrentDataCommitCoordinator.java index 605d71d81e..25bf228905 100644 --- a/opendaylight/md-sal/sal-dom-broker/src/main/java/org/opendaylight/controller/md/sal/dom/broker/impl/DOMConcurrentDataCommitCoordinator.java +++ b/opendaylight/md-sal/sal-dom-broker/src/main/java/org/opendaylight/controller/md/sal/dom/broker/impl/DOMConcurrentDataCommitCoordinator.java @@ -7,6 +7,14 @@ */ package org.opendaylight.controller.md.sal.dom.broker.impl; +import com.google.common.base.Preconditions; +import com.google.common.collect.Iterables; +import com.google.common.util.concurrent.AbstractFuture; +import com.google.common.util.concurrent.AbstractListeningExecutorService; +import com.google.common.util.concurrent.CheckedFuture; +import com.google.common.util.concurrent.FutureCallback; +import com.google.common.util.concurrent.Futures; +import com.google.common.util.concurrent.ListenableFuture; import java.util.List; import java.util.concurrent.Executor; import java.util.concurrent.ExecutorService; @@ -19,14 +27,6 @@ import org.opendaylight.yangtools.util.DurationStatisticsTracker; import org.opendaylight.yangtools.util.concurrent.MappingCheckedFuture; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -import com.google.common.base.Preconditions; -import com.google.common.collect.Iterables; -import com.google.common.util.concurrent.AbstractFuture; -import com.google.common.util.concurrent.AbstractListeningExecutorService; -import com.google.common.util.concurrent.CheckedFuture; -import com.google.common.util.concurrent.FutureCallback; -import com.google.common.util.concurrent.Futures; -import com.google.common.util.concurrent.ListenableFuture; /** * Implementation of DOMDataCommitExecutor that coordinates transaction commits concurrently. The 3 @@ -134,7 +134,7 @@ public class DOMConcurrentDataCommitCoordinator implements DOMDataCommitExecutor @Override public void onFailure(Throwable t) { - handleException(clientSubmitFuture, transaction, cohorts, cohortSize, CAN_COMMIT, t); + handleException(clientSubmitFuture, transaction, cohorts, cohortSize, PRE_COMMIT, t); } }; @@ -163,7 +163,7 @@ public class DOMConcurrentDataCommitCoordinator implements DOMDataCommitExecutor @Override public void onFailure(Throwable t) { - handleException(clientSubmitFuture, transaction, cohorts, cohortSize, CAN_COMMIT, t); + handleException(clientSubmitFuture, transaction, cohorts, cohortSize, COMMIT, t); } };