X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?p=controller.git;a=blobdiff_plain;f=opendaylight%2Fforwardingrulesmanager_mdsal%2Fopenflow%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fforwardingrulesmanager_mdsal%2Fconsumer%2Fimpl%2FFRMConsumerImpl.java;fp=opendaylight%2Fforwardingrulesmanager_mdsal%2Fopenflow%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fforwardingrulesmanager_mdsal%2Fconsumer%2Fimpl%2FFRMConsumerImpl.java;h=ae488b689f4788c95d017a07c53cb0ddecb9f0fd;hp=0000000000000000000000000000000000000000;hb=421d43013a16c9c2e025c66fea06f97e3f927bb9;hpb=25563418e1867be44ab8d829db30360df60ee1c9

diff --git a/opendaylight/forwardingrulesmanager_mdsal/openflow/src/main/java/org/opendaylight/controller/forwardingrulesmanager_mdsal/consumer/impl/FRMConsumerImpl.java b/opendaylight/forwardingrulesmanager_mdsal/openflow/src/main/java/org/opendaylight/controller/forwardingrulesmanager_mdsal/consumer/impl/FRMConsumerImpl.java
new file mode 100644
index 0000000000..ae488b689f
--- /dev/null
+++ b/opendaylight/forwardingrulesmanager_mdsal/openflow/src/main/java/org/opendaylight/controller/forwardingrulesmanager_mdsal/consumer/impl/FRMConsumerImpl.java
@@ -0,0 +1,98 @@
+
+/*
+ * Copyright (c) 2013 Ericsson , 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.forwardingrulesmanager_mdsal.consumer.impl;
+
+
+import org.opendaylight.controller.sal.binding.api.AbstractBindingAwareProvider;
+import org.opendaylight.controller.sal.binding.api.BindingAwareBroker.ProviderContext;
+import org.opendaylight.controller.sal.binding.api.NotificationService;
+import org.opendaylight.controller.sal.binding.api.data.DataBrokerService;
+import org.opendaylight.controller.sal.binding.api.data.DataProviderService;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+
+public class FRMConsumerImpl extends AbstractBindingAwareProvider {
+	protected static final Logger logger = LoggerFactory.getLogger(FRMConsumerImpl.class);
+	private static ProviderContext p_session;
+    private static DataBrokerService dataBrokerService; 	 
+    private static NotificationService notificationService;	
+    private FlowConsumerImpl flowImplRef;
+	private GroupConsumerImpl groupImplRef;
+	private static DataProviderService dataProviderService;  
+
+	@Override
+    public void onSessionInitiated(ProviderContext session) {
+    	
+        FRMConsumerImpl.p_session = session;
+        
+        if (null != session) {
+          	notificationService = session.getSALService(NotificationService.class);
+        	
+        	if (null != notificationService) {
+        		dataBrokerService = session.getSALService(DataBrokerService.class);
+        		
+        		if (null != dataBrokerService) {
+        			dataProviderService = session.getSALService(DataProviderService.class);
+        			
+        			if (null != dataProviderService) {
+        				flowImplRef = new FlowConsumerImpl();
+        				groupImplRef = new GroupConsumerImpl();
+        			}
+        			else {
+        				logger.error("Data Provider Service is down or NULL. " +
+        						"Accessing data from configuration data store will not be possible");
+                    	System.out.println("Data Broker Service is down or NULL.");
+        			}
+        				
+        		}
+        		else {
+        			logger.error("Data Broker Service is down or NULL.");
+                	System.out.println("Data Broker Service is down or NULL.");
+        		}
+        	}
+        	else {
+        		logger.error("Notification Service is down or NULL.");
+            	System.out.println("Notification Service is down or NULL.");
+        	}        		
+        }
+        else {
+        	logger.error("Consumer session is NULL. Please check if provider is registered");
+        	System.out.println("Consumer session is NULL. Please check if provider is registered");
+        }
+  
+    }
+
+	public static DataProviderService getDataProviderService() {
+		return dataProviderService;
+	}
+
+	public FlowConsumerImpl getFlowImplRef() {
+		return flowImplRef;
+	}
+
+	public GroupConsumerImpl getGroupImplRef() {
+			return groupImplRef;
+	}
+	 
+	public static ProviderContext getProviderSession() {
+		return p_session;
+	}	
+
+	public static NotificationService getNotificationService() {
+		return notificationService;
+	}
+
+	public static DataBrokerService getDataBrokerService() {
+		return dataBrokerService;
+	}
+
+}
+