X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;ds=sidebyside;f=opendaylight%2Fmd-sal%2Fsal-dom-broker%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fsal%2Fdom%2Fbroker%2FMountPointManagerImpl.xtend;fp=opendaylight%2Fmd-sal%2Fsal-dom-broker%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fsal%2Fdom%2Fbroker%2FMountPointManagerImpl.xtend;h=0000000000000000000000000000000000000000;hb=0cb415cf4cb61d85d545a1940bdde33734fa23a3;hp=023f906a67e90f495ae610ff0190687ecab54462;hpb=26da3c2a206a753356b507b018052cbb9cccca7d;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 deleted file mode 100644 index 023f906a67..0000000000 --- a/opendaylight/md-sal/sal-dom-broker/src/main/java/org/opendaylight/controller/sal/dom/broker/MountPointManagerImpl.xtend +++ /dev/null @@ -1,66 +0,0 @@ -/* - * 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.sal.dom.broker - - -import org.opendaylight.controller.sal.core.api.mount.MountProvisionService -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 -import org.opendaylight.controller.sal.core.api.mount.MountProvisionService.MountProvisionListener -import org.opendaylight.yangtools.concepts.util.ListenerRegistry - -class MountPointManagerImpl implements MountProvisionService { - - @Property - DataProviderService dataBroker; - - val ListenerRegistry listeners = ListenerRegistry.create() - - 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); - notifyMountCreated(path); - return mount; - } - - def notifyMountCreated(InstanceIdentifier identifier) { - for(listener : listeners) { - listener.instance.onMountPointCreated(identifier); - } - } - - def registerMountPoint(MountPointImpl impl) { - //dataBroker?.registerConfigurationReader(impl.mountPath,impl.readWrapper); - //dataBroker?.registerOperationalReader(impl.mountPath,impl.readWrapper); - } - - override registerProvisionListener(MountProvisionListener listener) { - listeners.register(listener) - } - - - override createOrGetMountPoint(InstanceIdentifier path) { - val mount = mounts.get(path); - if(mount === null) { - return createMountPoint(path) - } - return mount; - } - - - override getMountPoint(InstanceIdentifier path) { - mounts.get(path); - } -}