Updated SAL Binding APIs

[controller.git] / opendaylight / md-sal / sal-binding-api / src / main / java / org / opendaylight / controller / sal / binding / api / AbstractBindingAwareProvider.java

diff --git a/opendaylight/md-sal/sal-binding-api/src/main/java/org/opendaylight/controller/sal/binding/api/AbstractBindingAwareProvider.java b/opendaylight/md-sal/sal-binding-api/src/main/java/org/opendaylight/controller/sal/binding/api/AbstractBindingAwareProvider.java
index 20a7c0d779310037372a1a7ae5c4e1c6e8e59043..994d3f40a85946299693d285d61e79f308f01e6e 100644 (file)
--- a/opendaylight/md-sal/sal-binding-api/src/main/java/org/opendaylight/controller/sal/binding/api/AbstractBindingAwareProvider.java
+++ b/opendaylight/md-sal/sal-binding-api/src/main/java/org/opendaylight/controller/sal/binding/api/AbstractBindingAwareProvider.java
@@ -1,5 +1,9 @@
 package org.opendaylight.controller.sal.binding.api;
 
+import java.util.Collection;
+
+import org.opendaylight.controller.sal.binding.api.BindingAwareBroker.ProviderContext;
+import org.opendaylight.yangtools.yang.binding.RpcService;
 import org.osgi.framework.BundleActivator;
 import org.osgi.framework.BundleContext;
 import org.osgi.framework.ServiceReference;
@@ -10,16 +14,53 @@ public abstract class AbstractBindingAwareProvider implements BindingAwareProvid
     public final void start(BundleContext context) throws Exception {
             ServiceReference<BindingAwareBroker> brokerRef = context.getServiceReference(BindingAwareBroker.class);
             BindingAwareBroker broker = context.getService(brokerRef);
-            broker.registerProvider(this, context);
+            
+            ProviderContext ctx = broker.registerProvider(this, context);
+            registerRpcImplementations(ctx);
+            registerFunctionality(ctx);
+            
             startImpl(context);
     }
     
-    @Deprecated
-    abstract protected void startImpl(BundleContext context);
+    private void registerFunctionality(ProviderContext ctx) {
+        Collection<? extends ProviderFunctionality> functionality = this.getFunctionality();
+        if(functionality == null || functionality.isEmpty()) {
+            return;
+        }
+        for (ProviderFunctionality providerFunctionality : functionality) {
+            ctx.registerFunctionality(providerFunctionality);
+        }
+        
+    }
+
+    private void registerRpcImplementations(ProviderContext ctx) {
+        Collection<? extends RpcService> rpcs = this.getImplementations();
+        if(rpcs == null || rpcs.isEmpty()) {
+            return;
+        }
+        for (RpcService rpcService : rpcs) {
+            //ctx.addRpcImplementation(type, implementation);
+        }
+        
+    }
+
+    protected void startImpl(BundleContext context) {
+        // NOOP
+    }
     
     @Override
     public final void stop(BundleContext context) throws Exception {
             
             
     }
+    
+    @Override
+    public Collection<? extends ProviderFunctionality> getFunctionality() {
+        return null;
+    }
+    
+    @Override
+    public Collection<? extends RpcService> getImplementations() {
+        return null;
+    }
 }