X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-dom-broker%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fconfig%2Fyang%2Fmd%2Fsal%2Fdom%2Fimpl%2FDomBrokerImplModule.java;h=b8861b3465aa963647bec8b138204218288b189a;hb=464b8b3ed84c6750905c3ded5dbd9328a18d7652;hp=17b78f4ebd0e6602532f4fd7f5869d184d8125ba;hpb=d255fdd0b14660a22ff63771d954ac3fe5d0cb7e;p=controller.git diff --git a/opendaylight/md-sal/sal-dom-broker/src/main/java/org/opendaylight/controller/config/yang/md/sal/dom/impl/DomBrokerImplModule.java b/opendaylight/md-sal/sal-dom-broker/src/main/java/org/opendaylight/controller/config/yang/md/sal/dom/impl/DomBrokerImplModule.java index 17b78f4ebd..b8861b3465 100644 --- a/opendaylight/md-sal/sal-dom-broker/src/main/java/org/opendaylight/controller/config/yang/md/sal/dom/impl/DomBrokerImplModule.java +++ b/opendaylight/md-sal/sal-dom-broker/src/main/java/org/opendaylight/controller/config/yang/md/sal/dom/impl/DomBrokerImplModule.java @@ -17,18 +17,14 @@ import org.opendaylight.controller.sal.core.api.BrokerService; import org.opendaylight.controller.sal.core.api.RpcProvisionRegistry; import org.opendaylight.controller.sal.core.api.data.DataBrokerService; import org.opendaylight.controller.sal.core.api.data.DataProviderService; -import org.opendaylight.controller.sal.core.api.data.DataStore; import org.opendaylight.controller.sal.core.api.model.SchemaService; import org.opendaylight.controller.sal.core.api.mount.MountProvisionService; import org.opendaylight.controller.sal.core.api.mount.MountService; import org.opendaylight.controller.sal.dom.broker.BackwardsCompatibleMountPointManager; import org.opendaylight.controller.sal.dom.broker.BrokerImpl; -import org.opendaylight.controller.sal.dom.broker.DataBrokerImpl; import org.opendaylight.controller.sal.dom.broker.GlobalBundleScanningSchemaServiceImpl; -import org.opendaylight.controller.sal.dom.broker.impl.SchemaAwareDataStoreAdapter; import org.opendaylight.controller.sal.dom.broker.impl.SchemaAwareRpcBroker; import org.opendaylight.controller.sal.dom.broker.impl.SchemaContextProviders; -import org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier; /** * @@ -51,25 +47,19 @@ public final class DomBrokerImplModule extends org.opendaylight.controller.confi @Override public java.lang.AutoCloseable createInstance() { - final DataStore legacyStore = getDataStoreDependency(); final DOMDataBroker asyncBroker= getAsyncDataBrokerDependency(); - ClassToInstanceMap services = MutableClassToInstanceMap.create(); + final ClassToInstanceMap services = MutableClassToInstanceMap.create(); - SchemaService schemaService = getSchemaServiceImpl(); + final SchemaService schemaService = getSchemaServiceImpl(); services.putInstance(SchemaService.class, schemaService); - SchemaAwareRpcBroker router = new SchemaAwareRpcBroker("/", SchemaContextProviders + final SchemaAwareRpcBroker router = new SchemaAwareRpcBroker("/", SchemaContextProviders .fromSchemaService(schemaService)); services.putInstance(RpcProvisionRegistry.class, router); - final DataProviderService legacyData; - if(asyncBroker != null) { - services.putInstance(DOMDataBroker.class, asyncBroker); - legacyData = new BackwardsCompatibleDataBroker(asyncBroker,schemaService); - } else { - legacyData = createLegacyDataService(legacyStore,schemaService); - } + services.putInstance(DOMDataBroker.class, asyncBroker); + final DataProviderService legacyData = new BackwardsCompatibleDataBroker(asyncBroker,schemaService); services.putInstance(DataProviderService.class,legacyData); services.putInstance(DataBrokerService.class, legacyData); @@ -84,21 +74,6 @@ public final class DomBrokerImplModule extends org.opendaylight.controller.confi return new BrokerImpl(router, services); } - private DataProviderService createLegacyDataService(final DataStore legacyStore, final SchemaService schemaService) { - YangInstanceIdentifier rootPath = YangInstanceIdentifier.builder().toInstance(); - DataBrokerImpl dataService = new DataBrokerImpl(); - SchemaAwareDataStoreAdapter wrappedStore = new SchemaAwareDataStoreAdapter(); - wrappedStore.changeDelegate(legacyStore); - wrappedStore.setValidationEnabled(false); - - schemaService.registerSchemaServiceListener(wrappedStore); - - dataService.registerConfigurationReader(rootPath, wrappedStore); - dataService.registerCommitHandler(rootPath, wrappedStore); - dataService.registerOperationalReader(rootPath, wrappedStore); - return dataService; - } - private SchemaService getSchemaServiceImpl() { final SchemaService schemaService; if(getRootSchemaService() != null) {