Bc Group population during cluster reboot

[netvirt.git] / elanmanager / impl / src / main / java / org / opendaylight / netvirt / elan / l2gw / jobs / BcGroupUpdateJob.java

diff --git a/elanmanager/impl/src/main/java/org/opendaylight/netvirt/elan/l2gw/jobs/BcGroupUpdateJob.java b/elanmanager/impl/src/main/java/org/opendaylight/netvirt/elan/l2gw/jobs/BcGroupUpdateJob.java
index 88a8078ea868295c187a223682836a8967cc10dd..48c13ffcc9eb013b2445b9a44afebda9714eae31 100644 (file)
--- a/elanmanager/impl/src/main/java/org/opendaylight/netvirt/elan/l2gw/jobs/BcGroupUpdateJob.java
+++ b/elanmanager/impl/src/main/java/org/opendaylight/netvirt/elan/l2gw/jobs/BcGroupUpdateJob.java
@@ -35,16 +35,18 @@ public class BcGroupUpdateJob implements Callable<List<ListenableFuture<Void>>>
     private final ElanRefUtil elanRefUtil;
     private final ManagedNewTransactionRunner txRunner;
     protected String jobKey;
+    private final boolean createCase;
 
     public BcGroupUpdateJob(String elanName,
                             ElanRefUtil elanRefUtil,
                             ElanL2GatewayMulticastUtils elanL2GatewayMulticastUtils,
-                            DataBroker dataBroker) {
+                            DataBroker dataBroker, boolean createCase) {
         this.jobKey = ElanUtils.getBcGroupUpdateKey(elanName);
         this.txRunner = new ManagedNewTransactionRunnerImpl(dataBroker);
         this.elanName = elanName;
         this.elanRefUtil = elanRefUtil;
         this.elanL2GatewayMulticastUtils = elanL2GatewayMulticastUtils;
+        this.createCase = createCase;
     }
 
     public void submit() {
@@ -57,7 +59,7 @@ public class BcGroupUpdateJob implements Callable<List<ListenableFuture<Void>>>
         if (elanInstanceOptional.isPresent()) {
             return Lists.newArrayList(txRunner.callWithNewWriteOnlyTransactionAndSubmit(CONFIGURATION,
                 confTx -> elanL2GatewayMulticastUtils.updateRemoteBroadcastGroupForAllElanDpns(
-                        elanInstanceOptional.get(), confTx)));
+                        elanInstanceOptional.get(), createCase, confTx)));
         }
         return null;
     }
@@ -65,7 +67,7 @@ public class BcGroupUpdateJob implements Callable<List<ListenableFuture<Void>>>
     public static void updateAllBcGroups(String elanName,
                                          ElanRefUtil elanRefUtil,
                                          ElanL2GatewayMulticastUtils elanL2GatewayMulticastUtils,
-                                         DataBroker dataBroker) {
-        new BcGroupUpdateJob(elanName, elanRefUtil, elanL2GatewayMulticastUtils, dataBroker).submit();
+                                         DataBroker dataBroker, boolean createCase) {
+        new BcGroupUpdateJob(elanName, elanRefUtil, elanL2GatewayMulticastUtils, dataBroker, createCase).submit();
     }
 }