org.opendaylight.controller.cluster.sharding

Class DistributedShardedDOMDataTree

java.lang.Object

org.opendaylight.controller.cluster.sharding.DistributedShardedDOMDataTree

All Implemented Interfaces:

DistributedShardFactory, org.opendaylight.mdsal.dom.api.DOMDataTreeProducerFactory, org.opendaylight.mdsal.dom.api.DOMDataTreeService, org.opendaylight.mdsal.dom.api.DOMDataTreeShardingService, org.opendaylight.mdsal.dom.api.DOMExtensibleService<org.opendaylight.mdsal.dom.api.DOMDataTreeService,org.opendaylight.mdsal.dom.api.DOMDataTreeServiceExtension>, org.opendaylight.mdsal.dom.api.DOMService

public class DistributedShardedDOMDataTree
extends Object
implements org.opendaylight.mdsal.dom.api.DOMDataTreeService, org.opendaylight.mdsal.dom.api.DOMDataTreeShardingService, DistributedShardFactory

A layer on top of DOMDataTreeService that distributes producer/shard registrations to remote nodes via ShardedDataTreeActor. Also provides QoL method for addition of prefix based clustered shard into the system.

Nested Class Summary

Nested classes/interfaces inherited from interface org.opendaylight.controller.cluster.sharding.DistributedShardFactory

DistributedShardFactory.DistributedShardRegistration

Constructor Summary

Constructors

Constructor and Description
DistributedShardedDOMDataTree(ActorSystemProvider actorSystemProvider, AbstractDataStore distributedOperDatastore, AbstractDataStore distributedConfigDatastore)

Method Summary

Modifier and Type	Method and Description
CompletionStage<DistributedShardFactory.DistributedShardRegistration>	createDistributedShard(org.opendaylight.mdsal.dom.api.DOMDataTreeIdentifier prefix, Collection<MemberName> replicaMembers) Register a new shard that is rooted at the desired prefix with replicas on the provided members.
org.opendaylight.mdsal.dom.api.DOMDataTreeProducer	createProducer(Collection<org.opendaylight.mdsal.dom.api.DOMDataTreeIdentifier> subtrees)
com.google.common.collect.ClassToInstanceMap<org.opendaylight.mdsal.dom.api.DOMDataTreeServiceExtension>	getExtensions()
void	init() This will try to initialize prefix configuration shards upon their successful start.
<T extends org.opendaylight.mdsal.dom.api.DOMDataTreeShard> org.opendaylight.yangtools.concepts.ListenerRegistration<T>	registerDataTreeShard(org.opendaylight.mdsal.dom.api.DOMDataTreeIdentifier prefix, T shard, org.opendaylight.mdsal.dom.api.DOMDataTreeProducer producer)
<T extends org.opendaylight.mdsal.dom.api.DOMDataTreeListener> org.opendaylight.yangtools.concepts.ListenerRegistration<T>	registerListener(T listener, Collection<org.opendaylight.mdsal.dom.api.DOMDataTreeIdentifier> subtrees, boolean allowRxMerges, Collection<org.opendaylight.mdsal.dom.api.DOMDataTreeProducer> producers)

Methods inherited from class java.lang.Object

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

Constructor Detail

DistributedShardedDOMDataTree

public DistributedShardedDOMDataTree(ActorSystemProvider actorSystemProvider,
                                     AbstractDataStore distributedOperDatastore,
                                     AbstractDataStore distributedConfigDatastore)

Method Detail

init

public void init()

This will try to initialize prefix configuration shards upon their successful start. We need to create writers to these shards, so we can satisfy future createDistributedShard(org.opendaylight.mdsal.dom.api.DOMDataTreeIdentifier, java.util.Collection<org.opendaylight.controller.cluster.access.concepts.MemberName>) and resolveShardAdditions(java.util.Set<org.opendaylight.mdsal.dom.api.DOMDataTreeIdentifier>) requests and update prefix configuration shards accordingly.

We also need to initialize listeners on these shards, so we can react on changes made on them by other cluster members or even by ourselves.

Finally, we need to be sure that default shards for both operational and configuration data stores are up and running and we have distributed shards frontend created for them.

This is intended to be invoked by blueprint as initialization method.

registerListener

@Nonnull
public <T extends org.opendaylight.mdsal.dom.api.DOMDataTreeListener> org.opendaylight.yangtools.concepts.ListenerRegistration<T> registerListener(T listener,
                                                                                                                                                            Collection<org.opendaylight.mdsal.dom.api.DOMDataTreeIdentifier> subtrees,
                                                                                                                                                            boolean allowRxMerges,
                                                                                                                                                            Collection<org.opendaylight.mdsal.dom.api.DOMDataTreeProducer> producers)
                                                                                                                                                     throws org.opendaylight.mdsal.dom.api.DOMDataTreeLoopException

Specified by:

registerListener in interface org.opendaylight.mdsal.dom.api.DOMDataTreeService

Throws:

org.opendaylight.mdsal.dom.api.DOMDataTreeLoopException

getExtensions

public com.google.common.collect.ClassToInstanceMap<org.opendaylight.mdsal.dom.api.DOMDataTreeServiceExtension> getExtensions()

Specified by:

getExtensions in interface org.opendaylight.mdsal.dom.api.DOMExtensibleService<org.opendaylight.mdsal.dom.api.DOMDataTreeService,org.opendaylight.mdsal.dom.api.DOMDataTreeServiceExtension>

createProducer

@Nonnull
public org.opendaylight.mdsal.dom.api.DOMDataTreeProducer createProducer(@Nonnull
                                                                                  Collection<org.opendaylight.mdsal.dom.api.DOMDataTreeIdentifier> subtrees)

Specified by:

createProducer in interface org.opendaylight.mdsal.dom.api.DOMDataTreeProducerFactory

createDistributedShard

public CompletionStage<DistributedShardFactory.DistributedShardRegistration> createDistributedShard(org.opendaylight.mdsal.dom.api.DOMDataTreeIdentifier prefix,
                                                                                                    Collection<MemberName> replicaMembers)
                                                                                             throws org.opendaylight.mdsal.dom.api.DOMDataTreeShardingConflictException

Description copied from interface: DistributedShardFactory

Register a new shard that is rooted at the desired prefix with replicas on the provided members. Note to register a shard without replicas you still need to provide at least one Member for the shard.

Specified by:

createDistributedShard in interface DistributedShardFactory

Parameters:

prefix - Shard root

replicaMembers - Members that this shard is replicated on, has to have at least one Member even if the shard should not be replicated.

Returns:

A future that will be completed with a DistributedShardRegistration once the backend and frontend shards are spawned.

Throws:

org.opendaylight.mdsal.dom.api.DOMDataTreeShardingConflictException - If the initial check for a conflict on the local node fails, the sharding configuration won't be updated if this exception is thrown.

registerDataTreeShard

@Nonnull
public <T extends org.opendaylight.mdsal.dom.api.DOMDataTreeShard> org.opendaylight.yangtools.concepts.ListenerRegistration<T> registerDataTreeShard(@Nonnull
                                                                                                                                                              org.opendaylight.mdsal.dom.api.DOMDataTreeIdentifier prefix,
                                                                                                                                                              @Nonnull
                                                                                                                                                              T shard,
                                                                                                                                                              @Nonnull
                                                                                                                                                              org.opendaylight.mdsal.dom.api.DOMDataTreeProducer producer)
                                                                                                                                                       throws org.opendaylight.mdsal.dom.api.DOMDataTreeShardingConflictException

Specified by:

registerDataTreeShard in interface org.opendaylight.mdsal.dom.api.DOMDataTreeShardingService

Throws:

org.opendaylight.mdsal.dom.api.DOMDataTreeShardingConflictException