2 * Copyright (c) 2014 Cisco Systems, Inc. and others. All rights reserved.
4 * This program and the accompanying materials are made available under the
5 * terms of the Eclipse Public License v1.0 which accompanies this distribution,
6 * and is available at http://www.eclipse.org/legal/epl-v10.html
9 package org.opendaylight.controller.md.sal.dom.broker.impl.mount;
11 import org.opendaylight.mdsal.dom.api.DOMMountPoint;
12 import org.opendaylight.mdsal.dom.api.DOMMountPointService;
13 import org.opendaylight.mdsal.dom.api.DOMService;
15 import com.google.common.base.Optional;
16 import com.google.common.base.Preconditions;
17 import com.google.common.collect.ClassToInstanceMap;
18 import com.google.common.collect.MutableClassToInstanceMap;
19 import java.util.HashMap;
21 import org.opendaylight.controller.md.sal.dom.broker.spi.mount.SimpleDOMMountPoint;
22 import org.opendaylight.controller.sal.core.api.mount.MountProvisionListener;
23 import org.opendaylight.yangtools.concepts.ListenerRegistration;
24 import org.opendaylight.yangtools.concepts.ObjectRegistration;
25 import org.opendaylight.yangtools.util.ListenerRegistry;
26 import org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier;
27 import org.opendaylight.yangtools.yang.model.api.SchemaContext;
29 public class DOMMountPointServiceImpl implements DOMMountPointService {
31 private final Map<YangInstanceIdentifier, DOMMountPoint> mountPoints = new HashMap<>();
33 private final ListenerRegistry<MountProvisionListener> listeners = ListenerRegistry.create();
36 public Optional<DOMMountPoint> getMountPoint(final YangInstanceIdentifier path) {
37 return Optional.fromNullable(mountPoints.get(path));
41 public DOMMountPointBuilder createMountPoint(final YangInstanceIdentifier path) {
42 Preconditions.checkState(!mountPoints.containsKey(path), "Mount point already exists");
43 return new DOMMountPointBuilderImpl(path);
46 public void notifyMountCreated(final YangInstanceIdentifier identifier) {
47 for (final ListenerRegistration<MountProvisionListener> listener : listeners
49 listener.getInstance().onMountPointCreated(identifier);
53 public void notifyMountRemoved(final YangInstanceIdentifier identifier) {
54 for (final ListenerRegistration<MountProvisionListener> listener : listeners
56 listener.getInstance().onMountPointRemoved(identifier);
61 public ListenerRegistration<MountProvisionListener> registerProvisionListener(
62 final MountProvisionListener listener) {
63 return listeners.register(listener);
66 public ObjectRegistration<DOMMountPoint> registerMountPoint(final DOMMountPoint mountPoint) {
67 synchronized (mountPoints) {
68 Preconditions.checkState(!mountPoints.containsKey(mountPoint.getIdentifier()), "Mount point already exists");
69 mountPoints.put(mountPoint.getIdentifier(), mountPoint);
71 notifyMountCreated(mountPoint.getIdentifier());
73 return new MountRegistration(mountPoint);
76 public void unregisterMountPoint(final YangInstanceIdentifier mountPointId) {
77 synchronized (mountPoints) {
78 Preconditions.checkState(mountPoints.containsKey(mountPointId), "Mount point does not exist");
79 mountPoints.remove(mountPointId);
81 notifyMountRemoved(mountPointId);
84 public class DOMMountPointBuilderImpl implements DOMMountPointBuilder {
86 ClassToInstanceMap<DOMService> services = MutableClassToInstanceMap.create();
87 private SimpleDOMMountPoint mountPoint;
88 private final YangInstanceIdentifier path;
89 private SchemaContext schemaContext;
91 public DOMMountPointBuilderImpl(final YangInstanceIdentifier path) {
96 public <T extends DOMService> DOMMountPointBuilder addService(final Class<T> type, final T impl) {
97 services.putInstance(type, impl);
102 public DOMMountPointBuilder addInitialSchemaContext(final SchemaContext ctx) {
108 public ObjectRegistration<DOMMountPoint> register() {
109 Preconditions.checkState(mountPoint == null, "Mount point is already built.");
110 mountPoint = SimpleDOMMountPoint.create(path, services,schemaContext);
111 return registerMountPoint(mountPoint);
115 private final class MountRegistration implements ObjectRegistration<DOMMountPoint> {
116 private final DOMMountPoint mountPoint;
118 public MountRegistration(final DOMMountPoint mountPoint) {
119 this.mountPoint = mountPoint;
123 public DOMMountPoint getInstance() {
128 public void close() throws Exception {
129 unregisterMountPoint(mountPoint.getIdentifier());