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
8 package org.opendaylight.controller.config.manager.impl.dependencyresolver;
10 import org.opendaylight.controller.config.api.DependencyResolver;
11 import org.opendaylight.controller.config.api.DependencyResolverFactory;
12 import org.opendaylight.controller.config.api.JmxAttribute;
13 import org.opendaylight.controller.config.api.ModuleIdentifier;
14 import org.opendaylight.controller.config.manager.impl.CommitInfo;
15 import org.opendaylight.controller.config.manager.impl.ModuleInternalTransactionalInfo;
16 import org.opendaylight.controller.config.manager.impl.TransactionStatus;
17 import org.opendaylight.controller.config.spi.Module;
18 import org.opendaylight.controller.config.spi.ModuleFactory;
20 import javax.annotation.concurrent.GuardedBy;
21 import javax.management.InstanceAlreadyExistsException;
22 import java.util.ArrayList;
23 import java.util.Collections;
24 import java.util.HashMap;
25 import java.util.List;
29 * Holds information about modules being created and destroyed within this
30 * transaction. Observes usage of DependencyResolver within modules to figure
31 * out dependency tree.
33 public class DependencyResolverManager implements TransactionHolder, DependencyResolverFactory {
35 private final Map<ModuleIdentifier, DependencyResolverImpl> moduleIdentifiersToDependencyResolverMap = new HashMap<>();
36 private final ModulesHolder modulesHolder;
37 private final TransactionStatus transactionStatus;
39 public DependencyResolverManager(String transactionName,
40 TransactionStatus transactionStatus) {
41 this.modulesHolder = new ModulesHolder(transactionName);
42 this.transactionStatus = transactionStatus;
46 public DependencyResolver createDependencyResolver(ModuleIdentifier moduleIdentifier) {
47 return getOrCreate(moduleIdentifier);
50 public synchronized DependencyResolverImpl getOrCreate(ModuleIdentifier name) {
51 DependencyResolverImpl dependencyResolver = moduleIdentifiersToDependencyResolverMap
53 if (dependencyResolver == null) {
54 transactionStatus.checkNotCommitted();
55 dependencyResolver = new DependencyResolverImpl(name,
56 transactionStatus, modulesHolder);
57 moduleIdentifiersToDependencyResolverMap.put(name,
60 return dependencyResolver;
64 * Get all dependency resolvers, including those that belong to destroyed
67 private List<DependencyResolverImpl> getAllSorted() {
68 transactionStatus.checkCommitted();
69 List<DependencyResolverImpl> sorted = new ArrayList<>(
70 moduleIdentifiersToDependencyResolverMap.values());
71 for (DependencyResolverImpl dri : sorted) {
72 dri.countMaxDependencyDepth(this);
74 Collections.sort(sorted);
78 public List<ModuleIdentifier> getSortedModuleIdentifiers() {
79 List<ModuleIdentifier> result = new ArrayList<>(
80 moduleIdentifiersToDependencyResolverMap.size());
81 for (DependencyResolverImpl dri : getAllSorted()) {
82 ModuleIdentifier driName = dri.getIdentifier();
89 public ModuleInternalTransactionalInfo destroyModule(
90 ModuleIdentifier moduleIdentifier) {
91 transactionStatus.checkNotCommitted();
92 ModuleInternalTransactionalInfo found = modulesHolder
93 .destroyModule(moduleIdentifier);
94 moduleIdentifiersToDependencyResolverMap.remove(moduleIdentifier);
98 // protect write access
101 ModuleInternalTransactionalInfo moduleInternalTransactionalInfo) {
102 transactionStatus.checkNotCommitted();
103 modulesHolder.put(moduleInternalTransactionalInfo);
109 public CommitInfo toCommitInfo() {
110 return modulesHolder.toCommitInfo();
114 public Module findModule(ModuleIdentifier moduleIdentifier,
115 JmxAttribute jmxAttributeForReporting) {
116 return modulesHolder.findModule(moduleIdentifier,
117 jmxAttributeForReporting);
121 public ModuleFactory findModuleFactory(ModuleIdentifier moduleIdentifier,
122 JmxAttribute jmxAttributeForReporting) {
123 return modulesHolder.findModuleFactory(moduleIdentifier,
124 jmxAttributeForReporting);
128 public Map<ModuleIdentifier, Module> getAllModules() {
129 return modulesHolder.getAllModules();
133 public void assertNotExists(ModuleIdentifier moduleIdentifier)
134 throws InstanceAlreadyExistsException {
135 modulesHolder.assertNotExists(moduleIdentifier);
138 public List<ModuleIdentifier> findAllByFactory(ModuleFactory factory) {
139 List<ModuleIdentifier> result = new ArrayList<>();
140 for( ModuleInternalTransactionalInfo info : modulesHolder.getAllInfos()) {
141 if (factory.equals(info.getModuleFactory())) {
142 result.add(info.getName());