X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=openflowplugin-impl%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fopenflowplugin%2Fimpl%2Fdevice%2FDeviceContextImpl.java;h=872a0df1fa5de427253b3f6303068f655ff17639;hb=9688b3b10ee4113753705f0080b29cd30e61a85d;hp=c2582a1d7f08fcd40b1119321a8d163f4b429acc;hpb=13eb3071fdfcbfbf086f8f8bb516cb81b52be6ac;p=openflowplugin.git diff --git a/openflowplugin-impl/src/main/java/org/opendaylight/openflowplugin/impl/device/DeviceContextImpl.java b/openflowplugin-impl/src/main/java/org/opendaylight/openflowplugin/impl/device/DeviceContextImpl.java index c2582a1d7f..872a0df1fa 100644 --- a/openflowplugin-impl/src/main/java/org/opendaylight/openflowplugin/impl/device/DeviceContextImpl.java +++ b/openflowplugin-impl/src/main/java/org/opendaylight/openflowplugin/impl/device/DeviceContextImpl.java @@ -573,7 +573,7 @@ public class DeviceContextImpl implements DeviceContext, ExtensionConverterProvi transactionChainManager.close(); transactionChainManager = null; } - }); + }, MoreExecutors.directExecutor()); } requestContexts.forEach(requestContext -> RequestContextUtil @@ -630,7 +630,8 @@ public class DeviceContextImpl implements DeviceContext, ExtensionConverterProvi final ListenableFuture>> deviceFlowRegistryFill = getDeviceFlowRegistry().fill(); Futures.addCallback(deviceFlowRegistryFill, - new DeviceFlowRegistryCallback(deviceFlowRegistryFill, contextChainMastershipWatcher)); + new DeviceFlowRegistryCallback(deviceFlowRegistryFill, contextChainMastershipWatcher), + MoreExecutors.directExecutor()); } @VisibleForTesting