X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?p=controller.git;a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-distributed-datastore%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Fdatastore%2FDistributedDataStore.java;h=4964b92ab75a0d3d7f85c5404c22e0df7c80fbff;hp=1bc554f3ed653c3a50012044178e4a247489785a;hb=18a4539ad844c05fcd30373efa43f873aca4c142;hpb=f6609a5ab258b69a0d8ae2a97ee140b4da3b82ba diff --git a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/DistributedDataStore.java b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/DistributedDataStore.java index 1bc554f3ed..4964b92ab7 100644 --- a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/DistributedDataStore.java +++ b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/DistributedDataStore.java @@ -1,5 +1,19 @@ +/* + * Copyright (c) 2014 Cisco Systems, Inc. and others. All rights reserved. + * + * This program and the accompanying materials are made available under the + * terms of the Eclipse Public License v1.0 which accompanies this distribution, + * and is available at http://www.eclipse.org/legal/epl-v10.html + */ + package org.opendaylight.controller.cluster.datastore; +import akka.actor.ActorRef; +import akka.actor.ActorSystem; +import org.opendaylight.controller.cluster.datastore.messages.RegisterChangeListener; +import org.opendaylight.controller.cluster.datastore.messages.RegisterChangeListenerReply; +import org.opendaylight.controller.cluster.datastore.messages.UpdateSchemaContext; +import org.opendaylight.controller.cluster.datastore.utils.ActorContext; import org.opendaylight.controller.md.sal.common.api.data.AsyncDataBroker; import org.opendaylight.controller.md.sal.common.api.data.AsyncDataChangeListener; import org.opendaylight.controller.sal.core.spi.data.DOMStore; @@ -10,34 +24,75 @@ import org.opendaylight.controller.sal.core.spi.data.DOMStoreWriteTransaction; import org.opendaylight.yangtools.concepts.ListenerRegistration; import org.opendaylight.yangtools.yang.data.api.InstanceIdentifier; import org.opendaylight.yangtools.yang.data.api.schema.NormalizedNode; +import org.opendaylight.yangtools.yang.model.api.SchemaContext; +import org.opendaylight.yangtools.yang.model.api.SchemaContextListener; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; /** * */ -public class DistributedDataStore implements DOMStore { +public class DistributedDataStore implements DOMStore, SchemaContextListener { + + private static final Logger + LOG = LoggerFactory.getLogger(DistributedDataStore.class); + + + private final String type; + private final ActorContext actorContext; + + public DistributedDataStore(ActorSystem actorSystem, String type) { + this(new ActorContext(actorSystem, actorSystem.actorOf(ShardManager.props(type))), type); + } + + public DistributedDataStore(ActorContext actorContext, String type) { + this.type = type; + this.actorContext = actorContext; + } + @Override - public >> ListenerRegistration registerChangeListener(InstanceIdentifier path, L listener, AsyncDataBroker.DataChangeScope scope) { - return new ListenerRegistrationProxy(); + public >> ListenerRegistration registerChangeListener( + InstanceIdentifier path, L listener, + AsyncDataBroker.DataChangeScope scope) { + + ActorRef dataChangeListenerActor = actorContext.getActorSystem().actorOf( + DataChangeListener.props()); + + Object result = actorContext.executeShardOperation(Shard.DEFAULT_NAME, + new RegisterChangeListener(path, dataChangeListenerActor.path(), + AsyncDataBroker.DataChangeScope.BASE), + ActorContext.ASK_DURATION + ); + + RegisterChangeListenerReply reply = (RegisterChangeListenerReply) result; + return new DataChangeListenerRegistrationProxy(actorContext.actorSelection(reply.getListenerRegistrationPath()), listener); } + + @Override public DOMStoreTransactionChain createTransactionChain() { - return new TransactionChainProxy(); + return new TransactionChainProxy(actorContext); } @Override public DOMStoreReadTransaction newReadOnlyTransaction() { - return new TransactionProxy(); + return new TransactionProxy(actorContext, TransactionProxy.TransactionType.READ_ONLY); } @Override public DOMStoreWriteTransaction newWriteOnlyTransaction() { - return new TransactionProxy(); + return new TransactionProxy(actorContext, TransactionProxy.TransactionType.WRITE_ONLY); } @Override public DOMStoreReadWriteTransaction newReadWriteTransaction() { - return new TransactionProxy(); + return new TransactionProxy(actorContext, TransactionProxy.TransactionType.READ_WRITE); + } + + @Override public void onGlobalContextUpdated(SchemaContext schemaContext) { + actorContext.getShardManager().tell( + new UpdateSchemaContext(schemaContext), null); } }