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.mdsal.dom.broker;
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.mdsal.dom.api.DOMMountPoint;
18 import org.opendaylight.mdsal.dom.api.DOMMountPointListener;
19 import org.opendaylight.mdsal.dom.api.DOMMountPointService;
20 import org.opendaylight.mdsal.dom.api.DOMService;
21 import org.opendaylight.mdsal.dom.spi.SimpleDOMMountPoint;
22 import org.opendaylight.yangtools.concepts.ListenerRegistration;
23 import org.opendaylight.yangtools.concepts.ObjectRegistration;
24 import org.opendaylight.yangtools.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<DOMMountPointListener> 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<DOMMountPointListener> listener : listeners
48 listener.getInstance().onMountPointCreated(identifier);
52 public void notifyMountRemoved(final YangInstanceIdentifier identifier) {
53 for (final ListenerRegistration<DOMMountPointListener> listener : listeners
55 listener.getInstance().onMountPointRemoved(identifier);
60 public ListenerRegistration<DOMMountPointListener> registerProvisionListener(
61 final DOMMountPointListener listener) {
62 return listeners.register(listener);
65 public ObjectRegistration<DOMMountPoint> registerMountPoint(final DOMMountPoint mountPoint) {
66 synchronized (mountPoints) {
67 Preconditions.checkState(!mountPoints.containsKey(mountPoint.getIdentifier()),
68 "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 MountRegistration(final DOMMountPoint mountPoint) {
119 this.mountPoint = mountPoint;
123 public DOMMountPoint getInstance() {
128 public void close() throws Exception {
129 unregisterMountPoint(mountPoint.getIdentifier());