1 package org.opendaylight.controller.sal.dom.broker
3 import org.opendaylight.controller.sal.core.api.data.DataProviderService
4 import org.opendaylight.controller.sal.common.DataStoreIdentifier
5 import org.opendaylight.controller.sal.core.api.data.DataProviderService.DataRefresher
6 import org.opendaylight.controller.sal.core.api.data.DataValidator
7 import org.opendaylight.yangtools.yang.data.api.InstanceIdentifier
8 import org.opendaylight.controller.sal.dom.broker.impl.DataReaderRouter
9 import org.opendaylight.controller.sal.core.api.data.DataChangeListener
10 import org.opendaylight.controller.md.sal.common.api.data.DataCommitHandler
11 import org.opendaylight.yangtools.yang.data.api.CompositeNode
12 import org.opendaylight.controller.md.sal.common.api.data.DataReader
14 class DataBrokerImpl implements DataProviderService {
16 val readRouter = new DataReaderRouter();
18 override addRefresher(DataStoreIdentifier store, DataRefresher refresher) {
22 override addValidator(DataStoreIdentifier store, DataValidator validator) {
26 override beginTransaction() {
30 override readConfigurationData(InstanceIdentifier path) {
31 readRouter.readConfigurationData(path)
34 override readOperationalData(InstanceIdentifier path) {
35 readRouter.readOperationalData(path)
38 override registerConfigurationReader(InstanceIdentifier path, DataReader<InstanceIdentifier, CompositeNode> reader) {
39 readRouter.registerConfigurationReader(path, reader);
42 override registerOperationalReader(InstanceIdentifier path, DataReader<InstanceIdentifier, CompositeNode> reader) {
43 readRouter.registerOperationalReader(path, reader);
46 override removeRefresher(DataStoreIdentifier store, DataRefresher refresher) {
50 override removeValidator(DataStoreIdentifier store, DataValidator validator) {
54 override registerDataChangeListener(InstanceIdentifier path, DataChangeListener listener) {
58 override registerCommitHandler(InstanceIdentifier path,
59 DataCommitHandler<InstanceIdentifier, CompositeNode> commitHandler) {