org.opendaylight.controller.cluster.datastore

Class Shard

java.lang.Object

akka.actor.UntypedActor

akka.persistence.UntypedPersistentActor

org.opendaylight.controller.cluster.common.actor.AbstractUntypedPersistentActor

org.opendaylight.controller.cluster.raft.RaftActor

org.opendaylight.controller.cluster.datastore.Shard

All Implemented Interfaces:

akka.actor.Actor, akka.actor.Stash, akka.actor.StashFactory, akka.actor.StashSupport, akka.actor.UnrestrictedStash, akka.dispatch.RequiresMessageQueue<akka.dispatch.DequeBasedMessageQueueSemantics>, akka.persistence.Eventsourced, akka.persistence.PersistenceIdentity, akka.persistence.PersistenceRecovery, akka.persistence.PersistenceStash, akka.persistence.Snapshotter, ExecuteInSelfActor

public class Shard
extends RaftActor

A Shard represents a portion of the logical data tree.

Our Shard uses InMemoryDataTree as it's internal representation and delegates all requests it

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	Shard.AbstractBuilder<T extends Shard.AbstractBuilder<T,S>,S extends Shard>
static class	Shard.Builder

Nested classes/interfaces inherited from interface akka.persistence.Eventsourced

akka.persistence.Eventsourced.AsyncHandlerInvocation, akka.persistence.Eventsourced.AsyncHandlerInvocation$, akka.persistence.Eventsourced.PendingHandlerInvocation, akka.persistence.Eventsourced.ProcessingState, akka.persistence.Eventsourced.RecoveryTick, akka.persistence.Eventsourced.RecoveryTick$, akka.persistence.Eventsourced.StashingHandlerInvocation, akka.persistence.Eventsourced.StashingHandlerInvocation$, akka.persistence.Eventsourced.State

Nested classes/interfaces inherited from interface akka.actor.Actor

akka.actor.Actor.emptyBehavior$, akka.actor.Actor.ignoringBehavior$

Field Summary

Fields

Modifier and Type	Field and Description
static String	DEFAULT_NAME

Fields inherited from class org.opendaylight.controller.cluster.common.actor.AbstractUntypedPersistentActor

LOG

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	Shard(Shard.AbstractBuilder<?,?> builder)

Method Summary

Modifier and Type	Method and Description
protected void	applyState(akka.actor.ActorRef clientActor, org.opendaylight.yangtools.concepts.Identifier identifier, Object data) The applyState method will be called by the RaftActor when some data needs to be applied to the actor's state.
static Shard.Builder	builder()
Collection<?>	convertPendingTransactionsToMessages() Clears all pending transactions and converts them to messages to be forwarded to a new leader.
int	getCohortCacheSize()
ShardDataTree	getDataStore()
DatastoreContext	getDatastoreContext()
int	getPendingTxCommitQueueSize()
protected RaftActorRecoveryCohort	getRaftActorRecoveryCohort() Returns the RaftActorRecoveryCohort to participate in persistence recovery.
RaftActorSnapshotCohort	getRaftActorSnapshotCohort() Returns the RaftActorSnapshotCohort to participate in snapshot captures.
protected com.google.common.base.Optional<akka.actor.ActorRef>	getRoleChangeNotifier() Notifier Actor for this RaftActor to notify when a role change happens.
protected void	handleBatchedModificationsLocal(BatchedModifications batched, akka.actor.ActorRef sender)
protected void	handleNonRaftCommand(Object message) Method exposed for subclasses to plug-in their logic.
protected void	handleRecover(Object message)
protected boolean	isIsolatedLeader()
protected LeaderStateChanged	newLeaderStateChanged(String memberId, String leaderId, short leaderPayloadVersion)
protected OnDemandRaftState.AbstractBuilder<?,?>	newOnDemandRaftStateBuilder()
protected void	onDatastoreContext(DatastoreContext context)
protected void	onLeaderChanged(String oldLeader, String newLeader)
protected void	onRecoveryComplete() This method is called when recovery is complete.
protected void	onStateChanged() This method will be called by the RaftActor when the state of the RaftActor changes.
protected void	pauseLeader(Runnable operation) This method is called prior to operations such as leadership transfer and actor shutdown when the leader must pause or stop its duties.
String	persistenceId()
void	postStop()
protected void	unpauseLeader() This method is invoked when the actions hooked to the leader becoming paused failed to execute and the leader should resume normal operations.

Methods inherited from class org.opendaylight.controller.cluster.raft.RaftActor

changeCurrentBehavior, getCurrentBehavior, getCurrentTerm, getId, getLeader, getLeaderId, getRaftActorContext, getRaftState, handleCommand, hasFollowers, isLeader, isLeaderActive, isLeadershipTransferInProgress, newRaftActorRecoverySupport, onVotingStateChangeComplete, persistData, persistence, preStart, setPeerAddress, setPersistence, setPersistence, snapshotSequenceNr, updateConfigParams

Methods inherited from class org.opendaylight.controller.cluster.common.actor.AbstractUntypedPersistentActor

executeInSelf, ignoreMessage, onReceiveCommand, onReceiveRecover, unknownMessage

Methods inherited from class akka.persistence.UntypedPersistentActor

akka$actor$StashSupport$_setter_$akka$actor$StashSupport$$capacity_$eq, akka$actor$StashSupport$_setter_$mailbox_$eq, akka$actor$StashSupport$$capacity, akka$actor$StashSupport$$theStash_$eq, akka$actor$StashSupport$$theStash, akka$persistence$Eventsourced$_setter_$akka$persistence$Eventsourced$$extension_$eq, akka$persistence$Eventsourced$_setter_$akka$persistence$Eventsourced$$instanceId_$eq, akka$persistence$Eventsourced$_setter_$akka$persistence$Eventsourced$$internalStash_$eq, akka$persistence$Eventsourced$_setter_$akka$persistence$Eventsourced$$maxMessageBatchSize_$eq, akka$persistence$Eventsourced$_setter_$akka$persistence$Eventsourced$$pendingInvocations_$eq, akka$persistence$Eventsourced$_setter_$akka$persistence$Eventsourced$$persistingEvents_$eq, akka$persistence$Eventsourced$_setter_$akka$persistence$Eventsourced$$processingCommands_$eq, akka$persistence$Eventsourced$_setter_$akka$persistence$Eventsourced$$unstashFilterPredicate_$eq, akka$persistence$Eventsourced$_setter_$akka$persistence$Eventsourced$$writerUuid_$eq, akka$persistence$Eventsourced$$_lastSequenceNr_$eq, akka$persistence$Eventsourced$$_lastSequenceNr, akka$persistence$Eventsourced$$currentState_$eq, akka$persistence$Eventsourced$$currentState, akka$persistence$Eventsourced$$eventBatch_$eq, akka$persistence$Eventsourced$$eventBatch, akka$persistence$Eventsourced$$extension, akka$persistence$Eventsourced$$instanceId, akka$persistence$Eventsourced$$internalStash, akka$persistence$Eventsourced$$journalBatch_$eq, akka$persistence$Eventsourced$$journalBatch, akka$persistence$Eventsourced$$maxMessageBatchSize, akka$persistence$Eventsourced$$pendingInvocations, akka$persistence$Eventsourced$$pendingStashingPersistInvocations_$eq, akka$persistence$Eventsourced$$pendingStashingPersistInvocations, akka$persistence$Eventsourced$$persistingEvents, akka$persistence$Eventsourced$$processingCommands, akka$persistence$Eventsourced$$sequenceNr_$eq, akka$persistence$Eventsourced$$sequenceNr, akka$persistence$Eventsourced$$unstashFilterPredicate, akka$persistence$Eventsourced$$writeInProgress_$eq, akka$persistence$Eventsourced$$writeInProgress, akka$persistence$Eventsourced$$writerUuid, aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, clearStash, createStash, defer, deferAsync, deleteMessages, deleteSnapshot, deleteSnapshots, internalDefer, internalDeferAsync, internalDeleteMessagesBeforeSnapshot, internalPersist, internalPersistAll, internalPersistAllAsync, internalPersistAsync, internalStashOverflowStrategy, journal, journalPluginId, lastSequenceNr, loadSnapshot, mailbox, onPersistFailure, onPersistRejected, onReceive, onRecoveryFailure, onReplaySuccess, persist, persistAll, persistAllAsync, persistAsync, prepend, preRestart, receiveCommand, receiveRecover, recovery, recoveryFinished, recoveryRunning, saveSnapshot, snapshotPluginId, snapshotStore, snapshotterId, stash, unhandled, unstash, unstashAll, unstashAll

Methods inherited from class akka.actor.UntypedActor

akka$actor$Actor$_setter_$context_$eq, akka$actor$Actor$_setter_$self_$eq, context, getContext, getSelf, getSender, postRestart, receive, self, sender, supervisorStrategy

Methods inherited from class java.lang.Object

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

Methods inherited from interface akka.persistence.Eventsourced

$init$, akka$persistence$Eventsourced$$changeState, akka$persistence$Eventsourced$$flushBatch, akka$persistence$Eventsourced$$flushJournalBatch, akka$persistence$Eventsourced$$peekApplyHandler, akka$persistence$Eventsourced$$recovering, akka$persistence$Eventsourced$$setLastSequenceNr, akka$persistence$Eventsourced$$startRecovery, akka$persistence$Eventsourced$$stashInternally, akka$persistence$Eventsourced$$unstashInternally, akka$persistence$Eventsourced$$updateLastSequenceNr, akka$persistence$Eventsourced$$writeEventFailed, akka$persistence$Eventsourced$$writeEventRejected, akka$persistence$Eventsourced$$writeEventSucceeded

Methods inherited from interface akka.persistence.Snapshotter

$init$

Methods inherited from interface akka.persistence.PersistenceStash

$init$

Methods inherited from interface akka.actor.UnrestrictedStash

$init$

Methods inherited from interface akka.actor.Actor

$init$, akka$actor$Actor$_setter_$context_$eq, akka$actor$Actor$_setter_$self_$eq, context, noSender, postRestart, receive, self, sender, supervisorStrategy

Methods inherited from interface akka.actor.StashSupport

$init$, context, self

Methods inherited from interface akka.actor.StashFactory

$init$

Methods inherited from interface akka.persistence.PersistenceIdentity

$init$

Methods inherited from interface akka.persistence.PersistenceRecovery

$init$

Field Detail

DEFAULT_NAME

public static final String DEFAULT_NAME

See Also:

Constant Field Values

Constructor Detail

Shard

protected Shard(Shard.AbstractBuilder<?,?> builder)

Method Detail

postStop

public void postStop()
              throws Exception

Specified by:

postStop in interface akka.actor.Actor

Specified by:

postStop in interface akka.actor.UnrestrictedStash

Overrides:

postStop in class RaftActor

Throws:

Exception

handleRecover

protected void handleRecover(Object message)

Overrides:

handleRecover in class RaftActor

handleNonRaftCommand

protected void handleNonRaftCommand(Object message)

Description copied from class: RaftActor

Method exposed for subclasses to plug-in their logic. This method is invoked by RaftActor.handleCommand(Object) for messages which are not handled by this class. Subclasses overriding this class should fall back to this implementation for messages which they do not handle

Overrides:

handleNonRaftCommand in class RaftActor

Parameters:

message - Incoming command message

getPendingTxCommitQueueSize

public int getPendingTxCommitQueueSize()

getCohortCacheSize

public int getCohortCacheSize()

getRoleChangeNotifier

protected com.google.common.base.Optional<akka.actor.ActorRef> getRoleChangeNotifier()

Description copied from class: RaftActor

Notifier Actor for this RaftActor to notify when a role change happens.

Specified by:

getRoleChangeNotifier in class RaftActor

Returns:

ActorRef - ActorRef of the notifier or Optional.absent if none.

newLeaderStateChanged

protected LeaderStateChanged newLeaderStateChanged(String memberId,
                                                   String leaderId,
                                                   short leaderPayloadVersion)

Overrides:

newLeaderStateChanged in class RaftActor

onDatastoreContext

protected void onDatastoreContext(DatastoreContext context)

handleBatchedModificationsLocal

protected void handleBatchedModificationsLocal(BatchedModifications batched,
                                               akka.actor.ActorRef sender)

isIsolatedLeader

protected boolean isIsolatedLeader()

getRaftActorSnapshotCohort

public RaftActorSnapshotCohort getRaftActorSnapshotCohort()

Description copied from class: RaftActor

Returns the RaftActorSnapshotCohort to participate in snapshot captures.

Specified by:

getRaftActorSnapshotCohort in class RaftActor

getRaftActorRecoveryCohort

@Nonnull
protected RaftActorRecoveryCohort getRaftActorRecoveryCohort()

Description copied from class: RaftActor

Returns the RaftActorRecoveryCohort to participate in persistence recovery.

Specified by:

getRaftActorRecoveryCohort in class RaftActor

onRecoveryComplete

protected void onRecoveryComplete()

Description copied from class: RaftActor

This method is called when recovery is complete.

Specified by:

onRecoveryComplete in class RaftActor

applyState

protected void applyState(akka.actor.ActorRef clientActor,
                          org.opendaylight.yangtools.concepts.Identifier identifier,
                          Object data)

Description copied from class: RaftActor

The applyState method will be called by the RaftActor when some data needs to be applied to the actor's state.

Specified by:

applyState in class RaftActor

Parameters:

clientActor - A reference to the client who sent this message. This is the same reference that was passed to persistData by the derived actor. clientActor may be null when the RaftActor is behaving as a follower or during recovery.

identifier - The identifier of the persisted data. This is also the same identifier that was passed to persistData by the derived actor. identifier may be null when the RaftActor is behaving as a follower or during recovery

data - A piece of data that was persisted by the persistData call. This should NEVER be null.

onStateChanged

protected void onStateChanged()

Description copied from class: RaftActor

This method will be called by the RaftActor when the state of the RaftActor changes. The derived actor can then use methods like isLeader or getLeader to do something useful

Specified by:

onStateChanged in class RaftActor

onLeaderChanged

protected void onLeaderChanged(String oldLeader,
                               String newLeader)

Overrides:

onLeaderChanged in class RaftActor

convertPendingTransactionsToMessages

public Collection<?> convertPendingTransactionsToMessages()

Clears all pending transactions and converts them to messages to be forwarded to a new leader.

Returns:

the converted messages

pauseLeader

protected void pauseLeader(Runnable operation)

Description copied from class: RaftActor

This method is called prior to operations such as leadership transfer and actor shutdown when the leader must pause or stop its duties. This method allows derived classes to gracefully pause or finish current work prior to performing the operation. On completion of any work, the run method must be called on the given Runnable to proceed with the given operation. Important: the run method must be called on this actor's thread dispatcher as as it modifies internal state.

The default implementation immediately runs the operation.

Overrides:

pauseLeader in class RaftActor

Parameters:

operation - the operation to run

unpauseLeader

protected void unpauseLeader()

Description copied from class: RaftActor

This method is invoked when the actions hooked to the leader becoming paused failed to execute and the leader should resume normal operations.

Note this method can be invoked even before the operation supplied to RaftActor.pauseLeader(Runnable) is invoked.

Overrides:

unpauseLeader in class RaftActor

newOnDemandRaftStateBuilder

protected OnDemandRaftState.AbstractBuilder<?,?> newOnDemandRaftStateBuilder()

Overrides:

newOnDemandRaftStateBuilder in class RaftActor

persistenceId

public String persistenceId()

getDatastoreContext

public DatastoreContext getDatastoreContext()

getDataStore

public ShardDataTree getDataStore()

builder

public static Shard.Builder builder()