Initial code drop of yang model driven configuration system

[controller.git] / opendaylight / config / config-manager / src / main / java / org / opendaylight / controller / config / manager / impl / dependencyresolver / DependencyResolverManager.java

diff --git a/opendaylight/config/config-manager/src/main/java/org/opendaylight/controller/config/manager/impl/dependencyresolver/DependencyResolverManager.java b/opendaylight/config/config-manager/src/main/java/org/opendaylight/controller/config/manager/impl/dependencyresolver/DependencyResolverManager.java
new file mode 100644 (file)
index 0000000..34b3093
--- /dev/null
+++ b/opendaylight/config/config-manager/src/main/java/org/opendaylight/controller/config/manager/impl/dependencyresolver/DependencyResolverManager.java
@@ -0,0 +1,131 @@
+/*
+ * Copyright (c) 2013 Cisco Systems, Inc. and others.  All rights reserved.
+ *
+ * This program and the accompanying materials are made available under the
+ * terms of the Eclipse Public License v1.0 which accompanies this distribution,
+ * and is available at http://www.eclipse.org/legal/epl-v10.html
+ */
+package org.opendaylight.controller.config.manager.impl.dependencyresolver;
+
+import java.util.ArrayList;
+import java.util.Collections;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+import javax.annotation.concurrent.GuardedBy;
+import javax.management.InstanceAlreadyExistsException;
+
+import org.opendaylight.controller.config.api.JmxAttribute;
+import org.opendaylight.controller.config.api.ModuleIdentifier;
+import org.opendaylight.controller.config.manager.impl.CommitInfo;
+import org.opendaylight.controller.config.manager.impl.ModuleInternalTransactionalInfo;
+import org.opendaylight.controller.config.manager.impl.TransactionStatus;
+import org.opendaylight.controller.config.spi.Module;
+import org.opendaylight.controller.config.spi.ModuleFactory;
+
+/**
+ * Holds information about modules being created and destroyed within this
+ * transaction. Observes usage of DependencyResolver within modules to figure
+ * out dependency tree.
+ */
+public class DependencyResolverManager implements TransactionHolder {
+    @GuardedBy("this")
+    private final Map<ModuleIdentifier, DependencyResolverImpl> moduleIdentifiersToDependencyResolverMap = new HashMap<>();
+    private final ModulesHolder modulesHolder;
+    private final TransactionStatus transactionStatus;
+
+    public DependencyResolverManager(String transactionName,
+            TransactionStatus transactionStatus) {
+        this.modulesHolder = new ModulesHolder(transactionName);
+        this.transactionStatus = transactionStatus;
+    }
+
+    public synchronized DependencyResolverImpl getOrCreate(ModuleIdentifier name) {
+        DependencyResolverImpl dependencyResolver = moduleIdentifiersToDependencyResolverMap
+                .get(name);
+        if (dependencyResolver == null) {
+            transactionStatus.checkNotCommitted();
+            dependencyResolver = new DependencyResolverImpl(name,
+                    transactionStatus, modulesHolder);
+            moduleIdentifiersToDependencyResolverMap.put(name,
+                    dependencyResolver);
+        }
+        return dependencyResolver;
+    }
+
+    /**
+     * Get all dependency resolvers, including those that belong to destroyed
+     * things?
+     */
+    private List<DependencyResolverImpl> getAllSorted() {
+        transactionStatus.checkCommitted();
+        List<DependencyResolverImpl> sorted = new ArrayList<>(
+                moduleIdentifiersToDependencyResolverMap.values());
+        for (DependencyResolverImpl dri : sorted) {
+            dri.countMaxDependencyDepth(this);
+        }
+        Collections.sort(sorted);
+        return sorted;
+    }
+
+    public List<ModuleIdentifier> getSortedModuleIdentifiers() {
+        List<ModuleIdentifier> result = new ArrayList<>(
+                moduleIdentifiersToDependencyResolverMap.size());
+        for (DependencyResolverImpl dri : getAllSorted()) {
+            ModuleIdentifier driName = dri.getName();
+            result.add(driName);
+        }
+        return result;
+    }
+
+    @Override
+    public ModuleInternalTransactionalInfo destroyModule(
+            ModuleIdentifier moduleIdentifier) {
+        transactionStatus.checkNotCommitted();
+        ModuleInternalTransactionalInfo found = modulesHolder
+                .destroyModule(moduleIdentifier);
+        moduleIdentifiersToDependencyResolverMap.remove(moduleIdentifier);
+        return found;
+    }
+
+    // protect write access
+    @Override
+    public void put(
+            ModuleInternalTransactionalInfo moduleInternalTransactionalInfo) {
+        transactionStatus.checkNotCommitted();
+        modulesHolder.put(moduleInternalTransactionalInfo);
+    }
+
+    // wrapped methods:
+
+    @Override
+    public CommitInfo toCommitInfo() {
+        return modulesHolder.toCommitInfo();
+    }
+
+    @Override
+    public Module findModule(ModuleIdentifier moduleIdentifier,
+            JmxAttribute jmxAttributeForReporting) {
+        return modulesHolder.findModule(moduleIdentifier,
+                jmxAttributeForReporting);
+    }
+
+    @Override
+    public ModuleFactory findModuleFactory(ModuleIdentifier moduleIdentifier,
+            JmxAttribute jmxAttributeForReporting) {
+        return modulesHolder.findModuleFactory(moduleIdentifier,
+                jmxAttributeForReporting);
+    }
+
+    @Override
+    public Map<ModuleIdentifier, Module> getAllModules() {
+        return modulesHolder.getAllModules();
+    }
+
+    @Override
+    public void assertNotExists(ModuleIdentifier moduleIdentifier)
+            throws InstanceAlreadyExistsException {
+        modulesHolder.assertNotExists(moduleIdentifier);
+    }
+}