org.opendaylight.controller.clustering.it.provider

Class MdsalLowLevelTestProvider

java.lang.Object

org.opendaylight.controller.clustering.it.provider.MdsalLowLevelTestProvider

All Implemented Interfaces:

OdlMdsalLowlevelControlService, org.opendaylight.yangtools.yang.binding.RpcService

public class MdsalLowLevelTestProvider
extends Object
implements OdlMdsalLowlevelControlService

Constructor Summary

Constructors

Constructor and Description

MdsalLowLevelTestProvider(RpcProviderRegistry rpcRegistry, DOMRpcProviderService domRpcService, org.opendaylight.mdsal.singleton.common.api.ClusterSingletonServiceProvider singletonService, org.opendaylight.mdsal.dom.api.DOMSchemaService schemaService, org.opendaylight.mdsal.binding.dom.codec.api.BindingNormalizedNodeSerializer bindingNormalizedNodeSerializer, NotificationPublishService notificationPublishService, NotificationService notificationService, DOMDataBroker domDataBroker, org.opendaylight.mdsal.dom.api.DOMDataTreeService domDataTreeService, DistributedShardFactory distributedShardFactory, DistributedDataStoreInterface configDataStore, ActorSystemProvider actorSystemProvider)

Method Summary

Modifier and Type	Method and Description
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<AddShardReplicaOutput>>	addShardReplica(AddShardReplicaInput input) A specialised copy of cluster-admin:add-shard-replica.
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<BecomePrefixLeaderOutput>>	becomePrefixLeader(BecomePrefixLeaderInput input) Upon receiving this, the member shall ask the appropriate API to become Leader of the given shard (presumably the llt:list-ints one, created by produce-transactions) and return immediatelly.
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<CheckPublishNotificationsOutput>>	checkPublishNotifications(CheckPublishNotificationsInput input) Upon receiving this, the member shall immediatelly return the current tracking data related to the current (or previous) task started by start-publish-notifications with this id.
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<CreatePrefixShardOutput>>	createPrefixShard(CreatePrefixShardInput input) Upon receiving this, the member creates a prefix shard at the instance-identifier, with replicas on the required members.
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<DeconfigureIdIntsShardOutput>>	deconfigureIdIntsShard(DeconfigureIdIntsShardInput input) Upon receiving this, the member shall ask the appropriate API to remove the llt:id-ints shard (presumably created by produce-transactions) and return immediatelly.
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<IsClientAbortedOutput>>	isClientAborted(IsClientAbortedInput input) Return state of cds-access-client.
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<ProduceTransactionsOutput>>	produceTransactions(ProduceTransactionsInput input) Upon receiving this, the member shall make sure the outer list item of llt:in-ints exists for the given id, make sure a shard for the whole (config) id-ints is created (by creating and closing producer for the whole id-ints), and create a DOMDataTreeProducer for that item (using that shard).
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<RegisterBoundConstantOutput>>	registerBoundConstant(RegisterBoundConstantInput input) Upon receiving this, the member has to create and register a bound llt:get-contexted-constant implementation (routed RPC).
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<RegisterConstantOutput>>	registerConstant(RegisterConstantInput input) Upon receiving this, the member has to create llt:get-constant implementation (global RPC).
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<RegisterDefaultConstantOutput>>	registerDefaultConstant(RegisterDefaultConstantInput input) Upon receiving this, the member has to create and register a default llt:get-contexted-constant implementation (routed RPC).
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<RegisterFlappingSingletonOutput>>	registerFlappingSingleton(RegisterFlappingSingletonInput input) Upon receiving this, the member checks whether it has already created a 'flapping' application implementation and 'active' flag is set, and fails if yes.
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<RegisterSingletonConstantOutput>>	registerSingletonConstant(RegisterSingletonConstantInput input) Upon receiving this, the member checks whether it has already registered a singleton application, and fails if yes.
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<RemovePrefixShardOutput>>	removePrefixShard(RemovePrefixShardInput input) Upon receiving this, the member removes the prefix based shard identifier by this prefix.
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<RemoveShardReplicaOutput>>	removeShardReplica(RemoveShardReplicaInput input) A specialised copy of cluster-admin:remove-shard-replica.
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<ShutdownPrefixShardReplicaOutput>>	shutdownPrefixShardReplica(ShutdownPrefixShardReplicaInput input) Upon receiving this, the member will try to gracefully shutdown local configuration data store prefix-based shard replica.
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<ShutdownShardReplicaOutput>>	shutdownShardReplica(ShutdownShardReplicaInput input) Upon receiving this, the member will try to gracefully shutdown local configuration data store module-based shard replica.
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<StartPublishNotificationsOutput>>	startPublishNotifications(StartPublishNotificationsInput input) Upon receiving this, the member checks whether it is already in the middle of publishing, for this id, and fails if yes.
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<SubscribeDdtlOutput>>	subscribeDdtl(SubscribeDdtlInput input) Upon receiving this, the member checks whether it has already subscribed and fails if yes.
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<SubscribeDtclOutput>>	subscribeDtcl(SubscribeDtclInput input) Upon receiving this, the member checks whether it has already subscribed and fails if yes.
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<SubscribeYnlOutput>>	subscribeYnl(SubscribeYnlInput input) Upon receiving this, the member checks whether it has already subscribed a yang listener for the given id, and fails if yes.
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<UnregisterBoundConstantOutput>>	unregisterBoundConstant(UnregisterBoundConstantInput input) Upon receiving this, the member has to unregister any llt:get-contexted-constant implementations bound to the context.
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<UnregisterConstantOutput>>	unregisterConstant(UnregisterConstantInput input) Upon receiving this, the member has to unregister any llt:get-constant implementations it has registered.
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<UnregisterDefaultConstantOutput>>	unregisterDefaultConstant(UnregisterDefaultConstantInput input) Upon receiving this, the member has to unregister any llt:get-contexted-constant default implementations it has registered.
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<UnregisterFlappingSingletonOutput>>	unregisterFlappingSingleton(UnregisterFlappingSingletonInput input) Upon receiving this, the member checks whether it has created a flapping application, and fails if no.
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<UnregisterSingletonConstantOutput>>	unregisterSingletonConstant(UnregisterSingletonConstantInput input) Upon receiving this, the member checks whether it has currently registered a singleton application, and fails if no.
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<UnsubscribeDdtlOutput>>	unsubscribeDdtl(UnsubscribeDdtlInput input) Upon receiving this, the member checks whether it has currently subscribed a DOMDataTreeListener for llt:id-ints changes, and fails if no.
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<UnsubscribeDtclOutput>>	unsubscribeDtcl(UnsubscribeDtclInput input) Upon receiving this, the member checks whether it has currently subscribed a Data Tree Change Listener for llt:id-ints changes, and fails if no.
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<UnsubscribeYnlOutput>>	unsubscribeYnl(UnsubscribeYnlInput input) Upon receiving this, the member checks whether it has currently subscribed a yang listener for the given id, and fails if no.
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<WriteTransactionsOutput>>	writeTransactions(WriteTransactionsInput input) Upon receiving this, the member shall make sure the outer list item of llt:id-ints exists for the given id, and then start creating (one by one) and submitting transactions to randomly add or delete items on the inner list for that id.

Methods inherited from class java.lang.Object

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

Constructor Detail

MdsalLowLevelTestProvider

public MdsalLowLevelTestProvider(RpcProviderRegistry rpcRegistry,
                                 DOMRpcProviderService domRpcService,
                                 org.opendaylight.mdsal.singleton.common.api.ClusterSingletonServiceProvider singletonService,
                                 org.opendaylight.mdsal.dom.api.DOMSchemaService schemaService,
                                 org.opendaylight.mdsal.binding.dom.codec.api.BindingNormalizedNodeSerializer bindingNormalizedNodeSerializer,
                                 NotificationPublishService notificationPublishService,
                                 NotificationService notificationService,
                                 DOMDataBroker domDataBroker,
                                 org.opendaylight.mdsal.dom.api.DOMDataTreeService domDataTreeService,
                                 DistributedShardFactory distributedShardFactory,
                                 DistributedDataStoreInterface configDataStore,
                                 ActorSystemProvider actorSystemProvider)

Method Detail

unregisterSingletonConstant

public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<UnregisterSingletonConstantOutput>> unregisterSingletonConstant(UnregisterSingletonConstantInput input)

Description copied from interface: OdlMdsalLowlevelControlService

Upon receiving this, the member checks whether it has currently registered a singleton application, and fails if no. If yes, the member shall unregister the application, presumably causing application instantiation on other member, and closing of the local application instance (unregistering llt:get-singleton-constant). If the unregistration fails for any reason, propagate the corresponding error.

Specified by:

unregisterSingletonConstant in interface OdlMdsalLowlevelControlService

startPublishNotifications

public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<StartPublishNotificationsOutput>> startPublishNotifications(StartPublishNotificationsInput input)

Description copied from interface: OdlMdsalLowlevelControlService

Upon receiving this, the member checks whether it is already in the middle of publishing, for this id, and fails if yes. If no, the member shall clear any state tracking data possibly present from the previous call wth this id, and start publishing llt:id-sequence notifications with the given id and sequence numbers increasing from 1. The RPC shall return immediatelly before the first notification is published. The publishing task stops on first error of after the given time.

Specified by:

startPublishNotifications in interface OdlMdsalLowlevelControlService

subscribeDtcl

public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<SubscribeDtclOutput>> subscribeDtcl(SubscribeDtclInput input)

Description copied from interface: OdlMdsalLowlevelControlService

Upon receiving this, the member checks whether it has already subscribed and fails if yes. If no, the member subscribes a Data Tree Change Listener to listen for changes on whole llt:id-ints. The first notification received is stored immediately. Every notification received after the first one has the data(getDataBefore()) compared with the last stored notification(called local copy), if they match the local copy is overwritten with this notifications data(getDataAfter()). If they don't match the new notification is ignored.

Specified by:

subscribeDtcl in interface OdlMdsalLowlevelControlService

writeTransactions

public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<WriteTransactionsOutput>> writeTransactions(WriteTransactionsInput input)

Description copied from interface: OdlMdsalLowlevelControlService

Upon receiving this, the member shall make sure the outer list item of llt:id-ints exists for the given id, and then start creating (one by one) and submitting transactions to randomly add or delete items on the inner list for that id. The randomness should avoid creating conflicting writes (at least for non-chained transactions). The recommended way is to require the random number has low significant bits different than the past ~100k numbers. To ensure balanced number of deletes, the first write can create a random set of numbers. Other writes shall be one per number. The writes shall use the old API, transaction (chains) created directly on datastore (as opposed to DOMDataTreeProducer). .get with a timeout on currently earliest non-complete Future (from .submit) shall be used as the primary wait method to throttle the submission rate. This RPC shall not return until all transactions are confirmed successful, or an exception is raised (the exception should propagate to restconf response). OptimisticLockException is always considered an error.

Specified by:

writeTransactions in interface OdlMdsalLowlevelControlService

isClientAborted

public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<IsClientAbortedOutput>> isClientAborted(IsClientAbortedInput input)

Description copied from interface: OdlMdsalLowlevelControlService

Return state of cds-access-client. FIXME: Is an input needed?

Specified by:

isClientAborted in interface OdlMdsalLowlevelControlService

removeShardReplica

public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<RemoveShardReplicaOutput>> removeShardReplica(RemoveShardReplicaInput input)

Description copied from interface: OdlMdsalLowlevelControlService

A specialised copy of cluster-admin:remove-shard-replica. FIXME: Is this really needed for prefix shards, or even module shards (or is the cluster-admin RPC sufficient)?

Specified by:

removeShardReplica in interface OdlMdsalLowlevelControlService

subscribeYnl

public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<SubscribeYnlOutput>> subscribeYnl(SubscribeYnlInput input)

Description copied from interface: OdlMdsalLowlevelControlService

Upon receiving this, the member checks whether it has already subscribed a yang listener for the given id, and fails if yes. If no, the member subscribes a Yang notification listener to listen for llt:id-sequence notifications. The member also creates a local variable (called local-number) for the sequence number and initialize that to 0. Also three local counters are initialized to 0: all-not, id-not, err-not. Upon receiving any id-sequence notification, all-not is incremented. Each id-sequence notification of matching id shall increment id-not. If local-number was one less than the sequence number (from a notification matching id), increment local-number, else increment err-not.

Specified by:

subscribeYnl in interface OdlMdsalLowlevelControlService

removePrefixShard

public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<RemovePrefixShardOutput>> removePrefixShard(RemovePrefixShardInput input)

Description copied from interface: OdlMdsalLowlevelControlService

Upon receiving this, the member removes the prefix based shard identifier by this prefix. This must be called from the same node that created the shard.

Specified by:

removePrefixShard in interface OdlMdsalLowlevelControlService

becomePrefixLeader

public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<BecomePrefixLeaderOutput>> becomePrefixLeader(BecomePrefixLeaderInput input)

Description copied from interface: OdlMdsalLowlevelControlService

Upon receiving this, the member shall ask the appropriate API to become Leader of the given shard (presumably the llt:list-ints one, created by produce-transactions) and return immediatelly.

Specified by:

becomePrefixLeader in interface OdlMdsalLowlevelControlService

unregisterBoundConstant

public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<UnregisterBoundConstantOutput>> unregisterBoundConstant(UnregisterBoundConstantInput input)

Description copied from interface: OdlMdsalLowlevelControlService

Upon receiving this, the member has to unregister any llt:get-contexted-constant implementations bound to the context. If no bound implementation for the context has been registered, do nothing.

Specified by:

unregisterBoundConstant in interface OdlMdsalLowlevelControlService

registerSingletonConstant

public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<RegisterSingletonConstantOutput>> registerSingletonConstant(RegisterSingletonConstantInput input)

Description copied from interface: OdlMdsalLowlevelControlService

Upon receiving this, the member checks whether it has already registered a singleton application, and fails if yes. If no, the member creates an application implementation based on the given constant and registers the implementation as a singleton application. If the registration fails for any reason, propagate the corresponding error. If the application is instantiated, it creates and registers a llt:get-singleton-constant implementation, which returns the given costant. When the application instance is closed, it unregisters that llt:get-singleton-constant implementation.

Specified by:

registerSingletonConstant in interface OdlMdsalLowlevelControlService

registerDefaultConstant

public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<RegisterDefaultConstantOutput>> registerDefaultConstant(RegisterDefaultConstantInput input)

Description copied from interface: OdlMdsalLowlevelControlService

Upon receiving this, the member has to create and register a default llt:get-contexted-constant implementation (routed RPC). If the registration fails for any reason, propagate the corresponding error.

Specified by:

registerDefaultConstant in interface OdlMdsalLowlevelControlService

unregisterConstant

public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<UnregisterConstantOutput>> unregisterConstant(UnregisterConstantInput input)

Description copied from interface: OdlMdsalLowlevelControlService

Upon receiving this, the member has to unregister any llt:get-constant implementations it has registered. If no implementation has been registered, do nothing.

Specified by:

unregisterConstant in interface OdlMdsalLowlevelControlService

unregisterFlappingSingleton

public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<UnregisterFlappingSingletonOutput>> unregisterFlappingSingleton(UnregisterFlappingSingletonInput input)

Description copied from interface: OdlMdsalLowlevelControlService

Upon receiving this, the member checks whether it has created a flapping application, and fails if no. If yes, the member shall set the active flag to false and return the current flap-count value.

Specified by:

unregisterFlappingSingleton in interface OdlMdsalLowlevelControlService

addShardReplica

public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<AddShardReplicaOutput>> addShardReplica(AddShardReplicaInput input)

Description copied from interface: OdlMdsalLowlevelControlService

A specialised copy of cluster-admin:add-shard-replica. FIXME: Is this really needed for prefix shards, or even module shards (or is the cluster-admin RPC sufficient)?

Specified by:

addShardReplica in interface OdlMdsalLowlevelControlService

subscribeDdtl

public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<SubscribeDdtlOutput>> subscribeDdtl(SubscribeDdtlInput input)

Description copied from interface: OdlMdsalLowlevelControlService

Upon receiving this, the member checks whether it has already subscribed and fails if yes. If no, the member subscribes a DOMDataTreeListener to listen for changes on whole llt:id-ints, and stores the state from the initial notification to a local variable (called the local copy). Each Data Tree Change from further notifications shall be applied to the local copy if it is compatible (the old state from notification is equal to the local copy state). If a notification is not compatible, it shall be ignored.

Specified by:

subscribeDdtl in interface OdlMdsalLowlevelControlService

registerBoundConstant

public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<RegisterBoundConstantOutput>> registerBoundConstant(RegisterBoundConstantInput input)

Description copied from interface: OdlMdsalLowlevelControlService

Upon receiving this, the member has to create and register a bound llt:get-contexted-constant implementation (routed RPC). If the registration fails for any reason, propagate the corresponding error.

Specified by:

registerBoundConstant in interface OdlMdsalLowlevelControlService

registerFlappingSingleton

public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<RegisterFlappingSingletonOutput>> registerFlappingSingleton(RegisterFlappingSingletonInput input)

Description copied from interface: OdlMdsalLowlevelControlService

Upon receiving this, the member checks whether it has already created a 'flapping' application implementation and 'active' flag is set, and fails if yes. If no, the member (creates a flapping application implementation,) sets the active flag, initializes local variable flap-count to 0, and registers the implementation as a singleton application. If the registration fails for any reason, propagate the corresponding error. If the application is instantiated, it immediatelly un-registers itself. When the application instance is closed, it increments flap-count and if active flag is set, re-registers the application implementation as a singleton. If either un-registration or re-registration fails, 'active' flag is unset, flap-count is set to negative of its previous value (minus one in case of un-registration) to signal a failure has happened.

Specified by:

registerFlappingSingleton in interface OdlMdsalLowlevelControlService

unsubscribeDtcl

public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<UnsubscribeDtclOutput>> unsubscribeDtcl(UnsubscribeDtclInput input)

Description copied from interface: OdlMdsalLowlevelControlService

Upon receiving this, the member checks whether it has currently subscribed a Data Tree Change Listener for llt:id-ints changes, and fails if no. If yes, the member shall unsubscribe the listener, read state of id-ints, compare that to the local copy, and return whether the local copy is the same.

Specified by:

unsubscribeDtcl in interface OdlMdsalLowlevelControlService

createPrefixShard

public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<CreatePrefixShardOutput>> createPrefixShard(CreatePrefixShardInput input)

Description copied from interface: OdlMdsalLowlevelControlService

Upon receiving this, the member creates a prefix shard at the instance-identifier, with replicas on the required members.

Specified by:

createPrefixShard in interface OdlMdsalLowlevelControlService

deconfigureIdIntsShard

public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<DeconfigureIdIntsShardOutput>> deconfigureIdIntsShard(DeconfigureIdIntsShardInput input)

Description copied from interface: OdlMdsalLowlevelControlService

Upon receiving this, the member shall ask the appropriate API to remove the llt:id-ints shard (presumably created by produce-transactions) and return immediatelly. It is expected the data would move to the root prefix shard seamlessly. TODO: Make shard name configurable by input?

Specified by:

deconfigureIdIntsShard in interface OdlMdsalLowlevelControlService

unsubscribeYnl

public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<UnsubscribeYnlOutput>> unsubscribeYnl(UnsubscribeYnlInput input)

Description copied from interface: OdlMdsalLowlevelControlService

Upon receiving this, the member checks whether it has currently subscribed a yang listener for the given id, and fails if no. If yes, the member shall unsubscribe the listener and return values of the local variables.

Specified by:

unsubscribeYnl in interface OdlMdsalLowlevelControlService

checkPublishNotifications

public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<CheckPublishNotificationsOutput>> checkPublishNotifications(CheckPublishNotificationsInput input)

Description copied from interface: OdlMdsalLowlevelControlService

Upon receiving this, the member shall immediatelly return the current tracking data related to the current (or previous) task started by start-publish-notifications with this id.

Specified by:

checkPublishNotifications in interface OdlMdsalLowlevelControlService

produceTransactions

public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<ProduceTransactionsOutput>> produceTransactions(ProduceTransactionsInput input)

Description copied from interface: OdlMdsalLowlevelControlService

Upon receiving this, the member shall make sure the outer list item of llt:in-ints exists for the given id, make sure a shard for the whole (config) id-ints is created (by creating and closing producer for the whole id-ints), and create a DOMDataTreeProducer for that item (using that shard). FIXME: Is the above the normal way of creating prefix-based chards? Then start creating (one by one) and submitting transactions to randomly add or delete items on the inner list for that id. To ensure balanced number of deletes, the first write can create a random set of random numbers. Other writes shall be one per number. The writes shall use DOMDataTreeProducer API, as opposed to transaction (chains) created directly on datastore. .get with a timeout on currently earliest non-complete Future (from .submit) shall be used as the primary wait method to throttle the submission rate. This RPC shall not return until all transactions are confirmed successful, or an exception is raised (the exception should propagate to restconf response). OptimisticLockException is always considered an error. In either case, the producer should be closed before returning, but the shard and the whole id item shall be kept as they are.

Specified by:

produceTransactions in interface OdlMdsalLowlevelControlService

shutdownShardReplica

public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<ShutdownShardReplicaOutput>> shutdownShardReplica(ShutdownShardReplicaInput input)

Description copied from interface: OdlMdsalLowlevelControlService

Upon receiving this, the member will try to gracefully shutdown local configuration data store module-based shard replica.

Specified by:

shutdownShardReplica in interface OdlMdsalLowlevelControlService

shutdownPrefixShardReplica

public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<ShutdownPrefixShardReplicaOutput>> shutdownPrefixShardReplica(ShutdownPrefixShardReplicaInput input)

Description copied from interface: OdlMdsalLowlevelControlService

Upon receiving this, the member will try to gracefully shutdown local configuration data store prefix-based shard replica.

Specified by:

shutdownPrefixShardReplica in interface OdlMdsalLowlevelControlService

registerConstant

public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<RegisterConstantOutput>> registerConstant(RegisterConstantInput input)

Description copied from interface: OdlMdsalLowlevelControlService

Upon receiving this, the member has to create llt:get-constant implementation (global RPC). If the registration fails for any reason, propagate the corresponding error.

Specified by:

registerConstant in interface OdlMdsalLowlevelControlService

unregisterDefaultConstant

public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<UnregisterDefaultConstantOutput>> unregisterDefaultConstant(UnregisterDefaultConstantInput input)

Description copied from interface: OdlMdsalLowlevelControlService

Upon receiving this, the member has to unregister any llt:get-contexted-constant default implementations it has registered. If no default implementation has been registered, do nothing.

Specified by:

unregisterDefaultConstant in interface OdlMdsalLowlevelControlService

unsubscribeDdtl

public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<UnsubscribeDdtlOutput>> unsubscribeDdtl(UnsubscribeDdtlInput input)

Description copied from interface: OdlMdsalLowlevelControlService

Upon receiving this, the member checks whether it has currently subscribed a DOMDataTreeListener for llt:id-ints changes, and fails if no. If yes, the member shall unsubscribe the listener, read state of id-ints (by briefly subscribing and ubsubscribing again), compare that to the local copy, and return whether the local copy is the same.

Specified by:

unsubscribeDdtl in interface OdlMdsalLowlevelControlService