commit 537018f034b24d2af8525ccc007e052f1358b1a6
author Hyunsun Moon <hyunsun.moon@gmail.com> Wed Jul 27 18:51:00 2016 -0700
committer Hyunsun Moon <hyunsun.moon@gmail.com> Wed Jul 27 18:54:23 2016 -0700
tree 5a2fc99e3034c1d35e3fc497186534a21dff661a
parent 7afdb1c47caf5f7be8c58e520ea06ebb2612a5f4

Fixed exception in runnable is swallowed by scheduled thread

Change-Id: I82d6e296fca1783fc127b13c5133363f2e9a6cf3

src/main/java/org/opencord/cordvtn/impl/AbstractInstanceHandler.java

diff --git a/src/main/java/org/opencord/cordvtn/impl/AbstractInstanceHandler.java b/src/main/java/org/opencord/cordvtn/impl/AbstractInstanceHandler.java
index d714e3e..ff58107 100644
--- a/src/main/java/org/opencord/cordvtn/impl/AbstractInstanceHandler.java
+++ b/src/main/java/org/opencord/cordvtn/impl/AbstractInstanceHandler.java
@@ -51,7 +51,7 @@
 import java.util.stream.StreamSupport;
 
 import static com.google.common.base.Preconditions.checkNotNull;
-import static java.util.concurrent.Executors.newSingleThreadScheduledExecutor;
+import static java.util.concurrent.Executors.newSingleThreadExecutor;
 import static org.onlab.util.Tools.groupedThreads;
 import static org.opencord.cordvtn.api.Constants.ERROR_OPENSTACK_ACCESS;
 import static org.opencord.cordvtn.api.Constants.ERROR_XOS_ACCESS;
@@ -77,8 +77,8 @@
 
     private XosAccess xosAccess = null;
     private OpenStackAccess osAccess = null;
-    private final ExecutorService eventExecutor = newSingleThreadScheduledExecutor(
-            groupedThreads(this.getClass().getSimpleName(), "event-handler"));
+    private final ExecutorService eventExecutor = newSingleThreadExecutor(
+            groupedThreads(this.getClass().getSimpleName(), "event-handler", log));
 
     protected void activate() {
         ServiceDirectory services = new DefaultServiceDirectory();

src/main/java/org/opencord/cordvtn/impl/CordVtnNodeManager.java

diff --git a/src/main/java/org/opencord/cordvtn/impl/CordVtnNodeManager.java b/src/main/java/org/opencord/cordvtn/impl/CordVtnNodeManager.java
index fbac581..8f30931 100644
--- a/src/main/java/org/opencord/cordvtn/impl/CordVtnNodeManager.java
+++ b/src/main/java/org/opencord/cordvtn/impl/CordVtnNodeManager.java
@@ -83,7 +83,7 @@
 import java.util.stream.Collectors;
 
 import static com.google.common.base.Preconditions.checkNotNull;
-import static java.util.concurrent.Executors.newSingleThreadScheduledExecutor;
+import static java.util.concurrent.Executors.newSingleThreadExecutor;
 import static org.onlab.util.Tools.groupedThreads;
 import static org.onosproject.net.Device.Type.SWITCH;
 import static org.onosproject.net.behaviour.TunnelDescription.Type.VXLAN;
@@ -155,7 +155,7 @@
     protected CordVtnPipeline pipeline;
 
     private final ExecutorService eventExecutor =
-            newSingleThreadScheduledExecutor(groupedThreads("onos/cordvtn-node", "event-handler"));
+            newSingleThreadExecutor(groupedThreads("onos/cordvtn-node", "event-handler", log));
 
     private final NetworkConfigListener configListener = new InternalConfigListener();
     private final DeviceListener deviceListener = new InternalDeviceListener();

src/main/java/org/opencord/cordvtn/impl/InstanceManager.java

diff --git a/src/main/java/org/opencord/cordvtn/impl/InstanceManager.java b/src/main/java/org/opencord/cordvtn/impl/InstanceManager.java
index 3041bbf..3d4af38 100644
--- a/src/main/java/org/opencord/cordvtn/impl/InstanceManager.java
+++ b/src/main/java/org/opencord/cordvtn/impl/InstanceManager.java
@@ -66,7 +66,7 @@
 import java.util.concurrent.ExecutorService;
 
 import static com.google.common.base.Preconditions.checkNotNull;
-import static java.util.concurrent.Executors.newSingleThreadScheduledExecutor;
+import static java.util.concurrent.Executors.newSingleThreadExecutor;
 import static org.onlab.util.Tools.groupedThreads;
 import static org.onosproject.dhcp.IpAssignment.AssignmentStatus.Option_RangeNotEnforced;
 import static org.onosproject.xosclient.api.VtnServiceApi.NetworkType.MANAGEMENT;
@@ -116,7 +116,7 @@
             };
 
     private final ExecutorService eventExecutor =
-            newSingleThreadScheduledExecutor(groupedThreads("onos/cordvtn-instance", "event-handler"));
+            newSingleThreadExecutor(groupedThreads("onos/cordvtn-instance", "event-handler", log));
     private final NetworkConfigListener configListener = new InternalConfigListener();
 
     private ApplicationId appId;