BUG 6396 groupbasedpolicy project migration to blueprint

[groupbasedpolicy.git] / groupbasedpolicy / src / main / java / org / opendaylight / controller / config / yang / config / groupbasedpolicy / PolicyValidatorRegistryModule.java

diff --git a/groupbasedpolicy/src/main/java/org/opendaylight/controller/config/yang/config/groupbasedpolicy/PolicyValidatorRegistryModule.java b/groupbasedpolicy/src/main/java/org/opendaylight/controller/config/yang/config/groupbasedpolicy/PolicyValidatorRegistryModule.java
index e81f89baa8d3b571f204f5a4f4894bd2af6156fd..8f72579280853c96d1f16c06317688366f23b74b 100644 (file)
--- a/groupbasedpolicy/src/main/java/org/opendaylight/controller/config/yang/config/groupbasedpolicy/PolicyValidatorRegistryModule.java
+++ b/groupbasedpolicy/src/main/java/org/opendaylight/controller/config/yang/config/groupbasedpolicy/PolicyValidatorRegistryModule.java
@@ -8,14 +8,21 @@
 
 package org.opendaylight.controller.config.yang.config.groupbasedpolicy;
 
-import org.opendaylight.controller.md.sal.binding.api.DataBroker;
-import org.opendaylight.groupbasedpolicy.resolver.PolicyResolver;
+import org.opendaylight.controller.config.api.osgi.WaitingServiceTracker;
+import org.opendaylight.groupbasedpolicy.api.PolicyValidatorRegistry;
+import org.opendaylight.groupbasedpolicy.api.Validator;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.common.rev140421.ActionDefinitionId;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.common.rev140421.ClassifierDefinitionId;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.policy.rev140421.tenants.tenant.policy.subject.feature.instances.ActionInstance;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.policy.rev140421.tenants.tenant.policy.subject.feature.instances.ClassifierInstance;
+import org.osgi.framework.BundleContext;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
 public class PolicyValidatorRegistryModule extends org.opendaylight.controller.config.yang.config.groupbasedpolicy.AbstractPolicyValidatorRegistryModule {
 
     private static final Logger LOG = LoggerFactory.getLogger(PolicyValidatorRegistryModule.class);
+    private BundleContext bundleContext;
 
     public PolicyValidatorRegistryModule(org.opendaylight.controller.config.api.ModuleIdentifier identifier, org.opendaylight.controller.config.api.DependencyResolver dependencyResolver) {
         super(identifier, dependencyResolver);
@@ -32,11 +39,43 @@ public class PolicyValidatorRegistryModule extends org.opendaylight.controller.c
 
     @Override
     public java.lang.AutoCloseable createInstance() {
-        final DataBroker dataProvider = getDataBrokerDependency();
+        final WaitingServiceTracker<PolicyValidatorRegistry> tracker = WaitingServiceTracker.create(
+                PolicyValidatorRegistry.class, bundleContext);
+        final PolicyValidatorRegistry service = tracker.waitForService(WaitingServiceTracker.FIVE_MINUTES);
 
-        PolicyResolver policyResolver = new PolicyResolver(dataProvider);
-        LOG.info("{} successfully started.", PolicyValidatorRegistryModule.class.getCanonicalName());
-        return policyResolver;
+        final class Instance implements PolicyValidatorRegistry, AutoCloseable {
+            @Override
+            public void close() {
+                tracker.close();
+            }
+
+            @Override
+            public void register(ActionDefinitionId actionDefinitionId, Validator<ActionInstance> validator) {
+                service.register(actionDefinitionId, validator);
+            }
+
+            @Override
+            public void unregister(ActionDefinitionId actionDefinitionId, Validator<ActionInstance> validator) {
+                service.unregister(actionDefinitionId, validator);
+            }
+
+            @Override
+            public void register(ClassifierDefinitionId classifierDefinitionId,
+                    Validator<ClassifierInstance> validator) {
+                service.register(classifierDefinitionId, validator);
+            }
+
+            @Override
+            public void unregister(ClassifierDefinitionId classifierDefinitionId,
+                    Validator<ClassifierInstance> validator) {
+                service.unregister(classifierDefinitionId, validator);
+            }
+        }
+
+        return new Instance();
     }
 
+    void setBundleContext(BundleContext bundleContext) {
+        this.bundleContext = bundleContext;
+    }
 }