Promote ForeignShardThreePhaseCommitCohort to dom.spi

[mdsal.git] / dom / mdsal-dom-spi / src / main / java / org / opendaylight / mdsal / dom / spi / shard / ForeignShardThreePhaseCommitCohort.java

diff --git a/dom/mdsal-dom-inmemory-datastore/src/main/java/org/opendaylight/mdsal/dom/store/inmemory/ForeignShardThreePhaseCommitCohort.java b/dom/mdsal-dom-spi/src/main/java/org/opendaylight/mdsal/dom/spi/shard/ForeignShardThreePhaseCommitCohort.java
similarity index 73%
rename from dom/mdsal-dom-inmemory-datastore/src/main/java/org/opendaylight/mdsal/dom/store/inmemory/ForeignShardThreePhaseCommitCohort.java
rename to dom/mdsal-dom-spi/src/main/java/org/opendaylight/mdsal/dom/spi/shard/ForeignShardThreePhaseCommitCohort.java
index 7847924f0a555c5c24807e5dc14b2d7449b1d487..5981525d38e6fe01eee2125488415590f65517c9 100644 (file)
--- a/dom/mdsal-dom-inmemory-datastore/src/main/java/org/opendaylight/mdsal/dom/store/inmemory/ForeignShardThreePhaseCommitCohort.java
+++ b/dom/mdsal-dom-spi/src/main/java/org/opendaylight/mdsal/dom/spi/shard/ForeignShardThreePhaseCommitCohort.java
@@ -5,26 +5,22 @@
  * terms of the Eclipse Public License v1.0 which accompanies this distribution,
  * and is available at http://www.eclipse.org/legal/epl-v10.html
  */
-
-package org.opendaylight.mdsal.dom.store.inmemory;
+package org.opendaylight.mdsal.dom.spi.shard;
 
 import static java.util.Objects.requireNonNull;
 
-import com.google.common.util.concurrent.Futures;
+import com.google.common.annotations.Beta;
 import com.google.common.util.concurrent.ListenableFuture;
 import org.opendaylight.mdsal.dom.api.DOMDataTreeIdentifier;
-import org.opendaylight.mdsal.dom.spi.shard.ForeignShardModificationContext;
 import org.opendaylight.mdsal.dom.spi.store.DOMStoreThreePhaseCommitCohort;
+import org.opendaylight.yangtools.util.concurrent.FluentFutures;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
+@Beta
 public class ForeignShardThreePhaseCommitCohort implements DOMStoreThreePhaseCommitCohort {
-
     private static final Logger LOG = LoggerFactory.getLogger(ForeignShardThreePhaseCommitCohort.class);
 
-    private static final ListenableFuture<Boolean> SUCCESS_VALIDATE = Futures.immediateFuture(Boolean.TRUE);
-    private static final ListenableFuture<Void> SUCCESS_FUTURE = Futures.immediateFuture(null);
-
     private final DOMDataTreeIdentifier prefix;
     private final ForeignShardModificationContext shard;
 
@@ -37,25 +33,25 @@ public class ForeignShardThreePhaseCommitCohort implements DOMStoreThreePhaseCom
     @Override
     public ListenableFuture<Boolean> canCommit() {
         LOG.debug("Validating transaction on foreign shard {}", prefix);
-        return shard.isModified() ? shard.validate() : SUCCESS_VALIDATE;
+        return shard.isModified() ? shard.validate() : FluentFutures.immediateTrueFluentFuture();
     }
 
     @Override
     public ListenableFuture<Void> preCommit() {
         LOG.debug("Preparing transaction on foreign shard {}", prefix);
-        return shard.isModified() ? shard.prepare() : SUCCESS_FUTURE;
+        return shard.isModified() ? shard.prepare() : FluentFutures.immediateNullFluentFuture();
     }
 
     @Override
     public ListenableFuture<Void> abort() {
         LOG.debug("Aborting transaction of foreign shard {}", prefix);
         shard.closeForeignTransaction();
-        return SUCCESS_FUTURE;
+        return FluentFutures.immediateNullFluentFuture();
     }
 
     @Override
     public ListenableFuture<Void> commit() {
         LOG.debug("Submitting transaction on foreign shard {}", prefix);
-        return shard.isModified() ? shard.submit() : SUCCESS_FUTURE;
+        return shard.isModified() ? shard.submit() : FluentFutures.immediateNullFluentFuture();
     }
 }
\ No newline at end of file