X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?p=controller.git;a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-dom-broker%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fsal%2Fdom%2Fbroker%2FMountPointManagerImpl.java;h=d84f1dc03105389b81f9a8c239c5b33d7fcf3c6c;hp=20f79eea714f4666f0e2b1cd9f29287c25018e55;hb=de3e413b633b7555ae8f3fe2ec163dbb7dda5da8;hpb=2f1946537e63cc66950d4359b77fd49dbe1bdea3 diff --git a/opendaylight/md-sal/sal-dom-broker/src/main/java/org/opendaylight/controller/sal/dom/broker/MountPointManagerImpl.java b/opendaylight/md-sal/sal-dom-broker/src/main/java/org/opendaylight/controller/sal/dom/broker/MountPointManagerImpl.java index 20f79eea71..d84f1dc031 100644 --- a/opendaylight/md-sal/sal-dom-broker/src/main/java/org/opendaylight/controller/sal/dom/broker/MountPointManagerImpl.java +++ b/opendaylight/md-sal/sal-dom-broker/src/main/java/org/opendaylight/controller/sal/dom/broker/MountPointManagerImpl.java @@ -14,22 +14,23 @@ import java.util.concurrent.ConcurrentMap; import org.opendaylight.controller.sal.core.api.data.DataProviderService; import org.opendaylight.controller.sal.core.api.mount.MountProvisionInstance; +import org.opendaylight.controller.sal.core.api.mount.MountProvisionListener; import org.opendaylight.controller.sal.core.api.mount.MountProvisionService; import org.opendaylight.yangtools.concepts.ListenerRegistration; import org.opendaylight.yangtools.concepts.util.ListenerRegistry; -import org.opendaylight.yangtools.yang.data.api.InstanceIdentifier; +import org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier; @Deprecated public class MountPointManagerImpl implements MountProvisionService { private final ListenerRegistry listeners = ListenerRegistry.create(); - private final ConcurrentMap mounts = + private final ConcurrentMap mounts = new ConcurrentHashMap<>(); private DataProviderService dataBroker = null; @Override - public MountProvisionInstance createMountPoint(final InstanceIdentifier path) { + public MountProvisionInstance createMountPoint(final YangInstanceIdentifier path) { checkState(!mounts.containsKey(path), "Mount already created"); final MountPointImpl mount = new MountPointImpl(path); registerMountPoint(mount); @@ -38,7 +39,7 @@ public class MountPointManagerImpl implements MountProvisionService { return mount; } - public void notifyMountCreated(final InstanceIdentifier identifier) { + public void notifyMountCreated(final YangInstanceIdentifier identifier) { for (final ListenerRegistration listener : listeners .getListeners()) { listener.getInstance().onMountPointCreated(identifier); @@ -54,7 +55,7 @@ public class MountPointManagerImpl implements MountProvisionService { @Override public MountProvisionInstance createOrGetMountPoint( - final InstanceIdentifier path) { + final YangInstanceIdentifier path) { final MountPointImpl mount = mounts.get(path); if (mount == null) { return createMountPoint(path); @@ -63,7 +64,7 @@ public class MountPointManagerImpl implements MountProvisionService { } @Override - public MountProvisionInstance getMountPoint(final InstanceIdentifier path) { + public MountProvisionInstance getMountPoint(final YangInstanceIdentifier path) { return mounts.get(path); }