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%2Fsal%2Fdom%2Fbroker%2FMountPointManagerImpl.xtend;h=19634d79c2203fafe5aaa0156c41bf45a62f905f;hb=caee336f062eba4909ba53cbaccdde0714236134;hp=c64d1e56dd9638d28d9dee0d1d508aaead85e030;hpb=6350e149e3c698012ee469e2e6a5df29fcbd08c6;p=controller.git diff --git a/opendaylight/md-sal/sal-dom-broker/src/main/java/org/opendaylight/controller/sal/dom/broker/MountPointManagerImpl.xtend b/opendaylight/md-sal/sal-dom-broker/src/main/java/org/opendaylight/controller/sal/dom/broker/MountPointManagerImpl.xtend index c64d1e56dd..19634d79c2 100644 --- a/opendaylight/md-sal/sal-dom-broker/src/main/java/org/opendaylight/controller/sal/dom/broker/MountPointManagerImpl.xtend +++ b/opendaylight/md-sal/sal-dom-broker/src/main/java/org/opendaylight/controller/sal/dom/broker/MountPointManagerImpl.xtend @@ -6,15 +6,27 @@ import org.opendaylight.yangtools.yang.data.api.InstanceIdentifier import java.util.concurrent.ConcurrentMap import java.util.concurrent.ConcurrentHashMap import static com.google.common.base.Preconditions.*; +import org.opendaylight.controller.sal.core.api.data.DataProviderService class MountPointManagerImpl implements MountProvisionService { + @Property + DataProviderService dataBroker; + ConcurrentMap mounts = new ConcurrentHashMap(); override createMountPoint(InstanceIdentifier path) { checkState(!mounts.containsKey(path),"Mount already created"); val mount = new MountPointImpl(path); + registerMountPoint(mount); mounts.put(path,mount); + return mount; + } + + def registerMountPoint(MountPointImpl impl) { + dataBroker?.registerConfigurationReader(impl.mountPath,impl.readWrapper); + dataBroker?.registerOperationalReader(impl.mountPath,impl.readWrapper); + } @@ -30,6 +42,4 @@ class MountPointManagerImpl implements MountProvisionService { override getMountPoint(InstanceIdentifier path) { mounts.get(path); } - - }