2 * Copyright (c) 2013 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.netconf.impl;
11 import com.google.common.base.Optional;
12 import com.google.common.base.Preconditions;
13 import com.google.common.collect.Maps;
14 import org.opendaylight.controller.netconf.impl.mapping.CapabilityProvider;
15 import org.opendaylight.controller.netconf.impl.osgi.NetconfOperationServiceSnapshot;
16 import org.opendaylight.controller.netconf.mapping.api.Capability;
17 import org.opendaylight.controller.netconf.mapping.api.NetconfOperationService;
18 import org.slf4j.Logger;
19 import org.slf4j.LoggerFactory;
21 import java.util.Collections;
25 public class CapabilityProviderImpl implements CapabilityProvider {
26 private final NetconfOperationServiceSnapshot netconfOperationServiceSnapshot;
27 private final Set<String> capabilityURIs;
29 private static final Logger logger = LoggerFactory.getLogger(DefaultCommitNotificationProducer.class);
31 public CapabilityProviderImpl(NetconfOperationServiceSnapshot netconfOperationServiceSnapshot) {
32 this.netconfOperationServiceSnapshot = netconfOperationServiceSnapshot;
33 Map<String, Capability> urisToCapabilitiesInternalMap = getCapabilitiesInternal(netconfOperationServiceSnapshot);
34 capabilityURIs = Collections.unmodifiableSet(urisToCapabilitiesInternalMap.keySet());
37 private static Map<String, Capability> getCapabilitiesInternal(
38 NetconfOperationServiceSnapshot netconfOperationServiceSnapshot) {
39 Map<String, Capability> capabilityMap = Maps.newHashMap();
41 for (NetconfOperationService netconfOperationService : netconfOperationServiceSnapshot.getServices()) {
42 final Set<Capability> caps = netconfOperationService.getCapabilities();
44 for (Capability cap : caps) {
46 if(capabilityMap.containsKey(cap.getCapabilityUri())) {
47 logger.debug("Duplicate capability {} from service {}", cap.getCapabilityUri(), netconfOperationService);
50 capabilityMap.put(cap.getCapabilityUri(), cap);
58 public synchronized String getSchemaForCapability(String moduleName, Optional<String> revision) {
60 Map<String, Map<String, String>> mappedModulesToRevisionToSchema = Maps.newHashMap();
62 for (NetconfOperationService netconfOperationService : netconfOperationServiceSnapshot.getServices()) {
63 final Set<Capability> caps = netconfOperationService.getCapabilities();
65 for (Capability cap : caps) {
66 if (cap.getModuleName().isPresent() == false)
68 if (cap.getRevision().isPresent() == false)
70 if (cap.getCapabilitySchema().isPresent() == false)
73 final String currentModuleName = cap.getModuleName().get();
74 Map<String, String> revisionMap = mappedModulesToRevisionToSchema.get(currentModuleName);
75 if (revisionMap == null) {
76 revisionMap = Maps.newHashMap();
77 mappedModulesToRevisionToSchema.put(currentModuleName, revisionMap);
80 String currentRevision = cap.getRevision().get();
81 revisionMap.put(currentRevision, cap.getCapabilitySchema().get());
85 Map<String, String> revisionMapRequest = mappedModulesToRevisionToSchema.get(moduleName);
86 Preconditions.checkState(revisionMapRequest != null, "Capability for module %s not present, " + ""
87 + "available modules : %s", moduleName, capabilityURIs);
89 if (revision.isPresent()) {
90 String schema = revisionMapRequest.get(revision.get());
92 Preconditions.checkState(schema != null,
93 "Capability for module %s:%s not present, available revisions for module: %s", moduleName,
94 revision.get(), revisionMapRequest.keySet());
98 Preconditions.checkState(revisionMapRequest.size() == 1,
99 "Expected 1 capability for module %s, available revisions : %s", moduleName,
100 revisionMapRequest.keySet());
101 return revisionMapRequest.values().iterator().next();
106 public synchronized Set<String> getCapabilities() {
107 return capabilityURIs;