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 com.google.common.base.Optional;
12 import com.google.common.base.Preconditions;
13 import com.google.common.collect.ClassToInstanceMap;
14 import com.google.common.collect.MutableClassToInstanceMap;
15 import java.util.HashMap;
17 import org.opendaylight.controller.md.sal.dom.api.DOMMountPoint;
18 import org.opendaylight.controller.md.sal.dom.api.DOMMountPointService;
19 import org.opendaylight.controller.md.sal.dom.api.DOMService;
20 import org.opendaylight.controller.md.sal.dom.broker.spi.mount.SimpleDOMMountPoint;
21 import org.opendaylight.controller.sal.core.api.mount.MountProvisionListener;
22 import org.opendaylight.yangtools.concepts.ListenerRegistration;
23 import org.opendaylight.yangtools.concepts.ObjectRegistration;
24 import org.opendaylight.yangtools.concepts.util.ListenerRegistry;
25 import org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier;
26 import org.opendaylight.yangtools.yang.model.api.SchemaContext;
28 public class DOMMountPointServiceImpl implements DOMMountPointService {
30 private final Map<YangInstanceIdentifier, DOMMountPoint> mountPoints = new HashMap<>();
32 private final ListenerRegistry<MountProvisionListener> listeners = ListenerRegistry.create();
35 public Optional<DOMMountPoint> getMountPoint(final YangInstanceIdentifier path) {
36 return Optional.fromNullable(mountPoints.get(path));
40 public DOMMountPointBuilder createMountPoint(final YangInstanceIdentifier path) {
41 Preconditions.checkState(!mountPoints.containsKey(path), "Mount point already exists");
42 return new DOMMountPointBuilderImpl(path);
45 public void notifyMountCreated(final YangInstanceIdentifier identifier) {
46 for (final ListenerRegistration<MountProvisionListener> listener : listeners
48 listener.getInstance().onMountPointCreated(identifier);
52 public void notifyMountRemoved(final YangInstanceIdentifier identifier) {
53 for (final ListenerRegistration<MountProvisionListener> listener : listeners
55 listener.getInstance().onMountPointRemoved(identifier);
60 public ListenerRegistration<MountProvisionListener> registerProvisionListener(
61 final MountProvisionListener listener) {
62 return listeners.register(listener);
65 public ObjectRegistration<DOMMountPoint> registerMountPoint(final DOMMountPoint mountPoint) {
66 synchronized (mountPoints) {
67 Preconditions.checkState(!mountPoints.containsKey(mountPoint.getIdentifier()), "Mount point already exists");
68 mountPoints.put(mountPoint.getIdentifier(), mountPoint);
70 notifyMountCreated(mountPoint.getIdentifier());
72 return new MountRegistration(mountPoint);
75 public void unregisterMountPoint(final YangInstanceIdentifier mountPointId) {
76 synchronized (mountPoints) {
77 Preconditions.checkState(mountPoints.containsKey(mountPointId), "Mount point does not exist");
78 mountPoints.remove(mountPointId);
80 notifyMountRemoved(mountPointId);
83 public class DOMMountPointBuilderImpl implements DOMMountPointBuilder {
85 ClassToInstanceMap<DOMService> services = MutableClassToInstanceMap.create();
86 private SimpleDOMMountPoint mountPoint;
87 private final YangInstanceIdentifier path;
88 private SchemaContext schemaContext;
90 public DOMMountPointBuilderImpl(final YangInstanceIdentifier path) {
95 public <T extends DOMService> DOMMountPointBuilder addService(final Class<T> type, final T impl) {
96 services.putInstance(type, impl);
101 public DOMMountPointBuilder addInitialSchemaContext(final SchemaContext ctx) {
107 public ObjectRegistration<DOMMountPoint> register() {
108 Preconditions.checkState(mountPoint == null, "Mount point is already built.");
109 mountPoint = SimpleDOMMountPoint.create(path, services,schemaContext);
110 return registerMountPoint(mountPoint);
114 private final class MountRegistration implements ObjectRegistration<DOMMountPoint> {
115 private final DOMMountPoint mountPoint;
117 public MountRegistration(final DOMMountPoint mountPoint) {
118 this.mountPoint = mountPoint;
122 public DOMMountPoint getInstance() {
127 public void close() throws Exception {
128 unregisterMountPoint(mountPoint.getIdentifier());