org.opendaylight.mdsal.dom.store.inmemory

Class ForeignShardThreePhaseCommitCohort

java.lang.Object

org.opendaylight.mdsal.dom.store.inmemory.ForeignShardThreePhaseCommitCohort

All Implemented Interfaces:

DOMStoreThreePhaseCommitCohort

public class ForeignShardThreePhaseCommitCohort
extends Object
implements DOMStoreThreePhaseCommitCohort

Constructor Summary

Constructors

Constructor and Description
ForeignShardThreePhaseCommitCohort(DOMDataTreeIdentifier prefix, ForeignShardModificationContext shard)

Method Summary

Modifier and Type	Method and Description
com.google.common.util.concurrent.ListenableFuture<Void>	abort() Initiates a abort phase of associated transaction on data store.
com.google.common.util.concurrent.ListenableFuture<Boolean>	canCommit() Sends transaction associated with this three phase commit instance to the participant, participant votes on the transaction, if the transaction should be committed or aborted.
com.google.common.util.concurrent.ListenableFuture<Void>	commit() Initiates a commit phase on of associated transaction on data store.
com.google.common.util.concurrent.ListenableFuture<Void>	preCommit() Initiates a pre-commit phase of associated transaction on datastore.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ForeignShardThreePhaseCommitCohort

public ForeignShardThreePhaseCommitCohort(DOMDataTreeIdentifier prefix,
                                          ForeignShardModificationContext shard)

Method Detail

canCommit

public com.google.common.util.concurrent.ListenableFuture<Boolean> canCommit()

Description copied from interface: DOMStoreThreePhaseCommitCohort

Sends transaction associated with this three phase commit instance to the participant, participant votes on the transaction, if the transaction should be committed or aborted.

Specified by:

canCommit in interface DOMStoreThreePhaseCommitCohort

Returns:

ListenableFuture with vote of the participant. Vote Future.get() is following:

• true if transaction is approved by data store.
• false if the transaction is not approved by data store and should be aborted.

preCommit

public com.google.common.util.concurrent.ListenableFuture<Void> preCommit()

Description copied from interface: DOMStoreThreePhaseCommitCohort

Initiates a pre-commit phase of associated transaction on datastore.

This message is valid only and only if the participant responded on DOMStoreThreePhaseCommitCohort.canCommit() call with positive response.

Specified by:

preCommit in interface DOMStoreThreePhaseCommitCohort

Returns:

ListenableFuture representing acknowledgment for participant that pre-commit message was received and processed.

abort

public com.google.common.util.concurrent.ListenableFuture<Void> abort()

Description copied from interface: DOMStoreThreePhaseCommitCohort

Initiates a abort phase of associated transaction on data store.

Specified by:

abort in interface DOMStoreThreePhaseCommitCohort

Returns:

ListenableFuture representing acknowledgment for participant that abort message was received.

commit

public com.google.common.util.concurrent.ListenableFuture<Void> commit()

Description copied from interface: DOMStoreThreePhaseCommitCohort

Initiates a commit phase on of associated transaction on data store.

Specified by:

commit in interface DOMStoreThreePhaseCommitCohort

Returns:

ListenableFuture representing acknowledgment for participant that commit message was received and commit of transaction was processed.