org.opendaylight.controller.cluster.datastore

Class ThreePhaseCommitCohortProxy

java.lang.Object

org.opendaylight.controller.cluster.datastore.AbstractThreePhaseCommitCohort<akka.actor.ActorSelection>

org.opendaylight.controller.cluster.datastore.ThreePhaseCommitCohortProxy

All Implemented Interfaces:

DOMStoreThreePhaseCommitCohort

public class ThreePhaseCommitCohortProxy
extends AbstractThreePhaseCommitCohort<akka.actor.ActorSelection>

ThreePhaseCommitCohortProxy represents a set of remote cohort proxies.

Field Summary

Fields inherited from class org.opendaylight.controller.cluster.datastore.AbstractThreePhaseCommitCohort

IMMEDIATE_BOOLEAN_SUCCESS, IMMEDIATE_VOID_SUCCESS

Constructor Summary

Constructors

Constructor and Description
ThreePhaseCommitCohortProxy(ActorContext actorContext, List<org.opendaylight.controller.cluster.datastore.ThreePhaseCommitCohortProxy.CohortInfo> cohorts, TransactionIdentifier transactionId)

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

ThreePhaseCommitCohortProxy

public ThreePhaseCommitCohortProxy(ActorContext actorContext,
                                   List<org.opendaylight.controller.cluster.datastore.ThreePhaseCommitCohortProxy.CohortInfo> cohorts,
                                   TransactionIdentifier transactionId)

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.

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 and only if the participant responded on DOMStoreThreePhaseCommitCohort.canCommit() call with positive response.

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.

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.

Returns:

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