[Falcon] Fixed to avoid exception cases for compute node bootstrap

- Handled network config event with thread
- Considered ONOS restart situation, where node state in the store
is not the same as real state

Change-Id: Iec8c063317f1292052f299b680b7944821e60b7f

@@ -264,13 +264,7 @@ public class CordVtn implements CordVtnService {
             return;
             return;
         }
         }
 
 
-        NodeState state = getNodeState(node);
-        if (state == null) {
-            return;
-        } else if (state.equals(NodeState.INCOMPLETE)) {
-            state = checkNodeState(node);
-        }
-
+        NodeState state = checkNodeState(node);
         state.process(this, node);
         state.process(this, node);
     }
     }
 
 

@@ -30,6 +30,10 @@ import org.onosproject.net.config.NetworkConfigService;
 import org.onosproject.net.config.basics.SubjectFactories;
 import org.onosproject.net.config.basics.SubjectFactories;
 import org.slf4j.Logger;
 import org.slf4j.Logger;
 
 
+import java.util.concurrent.ExecutorService;
+
+import static java.util.concurrent.Executors.newSingleThreadScheduledExecutor;
+import static org.onlab.util.Tools.groupedThreads;
 import static org.slf4j.LoggerFactory.getLogger;
 import static org.slf4j.LoggerFactory.getLogger;
 
 
 /**
 /**
@@ -63,13 +67,15 @@ public class CordVtnConfigManager {
             };
             };
 
 
     private final NetworkConfigListener configListener = new InternalConfigListener();
     private final NetworkConfigListener configListener = new InternalConfigListener();
-
     private ApplicationId appId;
     private ApplicationId appId;
+    protected ExecutorService eventExecutor;
+
 
 
     @Activate
     @Activate
     protected void active() {
     protected void active() {
         appId = coreService.getAppId(CordVtnService.CORDVTN_APP_ID);
         appId = coreService.getAppId(CordVtnService.CORDVTN_APP_ID);
 
 
+        eventExecutor = newSingleThreadScheduledExecutor(groupedThreads("onos/cordvtncfg", "event-handler"));
         configService.addListener(configListener);
         configService.addListener(configListener);
         configRegistry.registerConfigFactory(configFactory);
         configRegistry.registerConfigFactory(configFactory);
     }
     }
@@ -78,6 +84,7 @@ public class CordVtnConfigManager {
     protected void deactivate() {
     protected void deactivate() {
         configRegistry.unregisterConfigFactory(configFactory);
         configRegistry.unregisterConfigFactory(configFactory);
         configService.removeListener(configListener);
         configService.removeListener(configListener);
+        eventExecutor.shutdown();
     }
     }
 
 
     private void readConfiguration() {
     private void readConfiguration() {
@@ -106,11 +113,11 @@ public class CordVtnConfigManager {
             switch (event.type()) {
             switch (event.type()) {
                 case CONFIG_ADDED:
                 case CONFIG_ADDED:
                     log.info("Network configuration added");
                     log.info("Network configuration added");
-                    readConfiguration();
+                    eventExecutor.execute(CordVtnConfigManager.this::readConfiguration);
                     break;
                     break;
                 case CONFIG_UPDATED:
                 case CONFIG_UPDATED:
                     log.info("Network configuration updated");
                     log.info("Network configuration updated");
-                    readConfiguration();
+                    eventExecutor.execute(CordVtnConfigManager.this::readConfiguration);
                     break;
                     break;
                 default:
                 default:
                     break;
                     break;