Merge "Move a Timer (scheduler) Submit Transaction from TxChain"

[openflowplugin.git] / openflowplugin-impl / src / main / java / org / opendaylight / openflowplugin / impl / device / DeviceManagerImpl.java

diff --git a/openflowplugin-impl/src/main/java/org/opendaylight/openflowplugin/impl/device/DeviceManagerImpl.java b/openflowplugin-impl/src/main/java/org/opendaylight/openflowplugin/impl/device/DeviceManagerImpl.java
index bcdb76413ef6d37d56e452eaf17fa603bdfc0d73..40020aee7cc0601a4950e9cacae6da52a6e08f1d 100644 (file)
--- a/openflowplugin-impl/src/main/java/org/opendaylight/openflowplugin/impl/device/DeviceManagerImpl.java
+++ b/openflowplugin-impl/src/main/java/org/opendaylight/openflowplugin/impl/device/DeviceManagerImpl.java
@@ -7,6 +7,8 @@
  */
 package org.opendaylight.openflowplugin.impl.device;
 
+import org.opendaylight.controller.sal.binding.api.NotificationProviderService;
+
 import com.google.common.base.Preconditions;
 import com.google.common.util.concurrent.FutureCallback;
 import com.google.common.util.concurrent.Futures;
@@ -94,6 +96,7 @@ public class DeviceManagerImpl implements DeviceManager {
     private RequestContextStack dummyRequestContextStack;
     private TranslatorLibrary translatorLibrary;
     private DeviceInitializationPhaseHandler deviceInitPhaseHandler;
+    private NotificationProviderService notificationService;
 
 
     public DeviceManagerImpl(@Nonnull final DataBroker dataBroker) {
@@ -143,6 +146,7 @@ public class DeviceManagerImpl implements DeviceManager {
 
         final DeviceContextImpl deviceContext = new DeviceContextImpl(connectionContext, deviceState, dataBroker, hashedWheelTimer);
 
+        deviceContext.setNotificationService(notificationService);
         deviceContext.writeToTransaction(LogicalDatastoreType.OPERATIONAL, deviceState.getNodeInstanceIdentifier(), new NodeBuilder().setId(deviceState.getNodeId()).build());
 
         deviceContext.setTranslatorLibrary(translatorLibrary);
@@ -302,6 +306,7 @@ public class DeviceManagerImpl implements DeviceManager {
                         final NodeConnector connector = new NodeConnectorBuilder(portUpd).addAugmentation(FlowCapableNodeConnectorStatisticsData.class,
                                 new FlowCapableNodeConnectorStatisticsDataBuilder().build()).build();
                         dContext.writeToTransaction(LogicalDatastoreType.OPERATIONAL, connectorII, connector);
+                        //FlowCapableNodeConnectorBuilder
                     }
 
                 default:
@@ -309,4 +314,9 @@ public class DeviceManagerImpl implements DeviceManager {
             }
         }
     }
+
+    @Override
+    public void setNotificationService(final NotificationProviderService notificationServiceParam) {
+        notificationService = notificationServiceParam;
+    }
 }