commit 6f5460bb79fcd1d966079cb0612048ca827cd36b
author alshabib <alshabibi.ali@gmail.com> Wed Sep 03 14:46:17 2014 -0700
committer alshabib <alshabibi.ali@gmail.com> Wed Sep 03 14:46:17 2014 -0700
tree a1c7d70dd835e021484a3c34ac033882cdf6e353
parent 3b746c6dda69ba52ab4998e575ead3dd35514904

graceful shutdown

of/ctl/src/main/java/org/onlab/onos/of/controller/impl/Controller.java

diff --git a/of/ctl/src/main/java/org/onlab/onos/of/controller/impl/Controller.java b/of/ctl/src/main/java/org/onlab/onos/of/controller/impl/Controller.java
index d45bb07..44d70ac 100644
--- a/of/ctl/src/main/java/org/onlab/onos/of/controller/impl/Controller.java
+++ b/of/ctl/src/main/java/org/onlab/onos/of/controller/impl/Controller.java
@@ -74,6 +74,8 @@
     protected boolean alwaysClearFlowsOnSwAdd = false;
     private OpenFlowAgent agent;
 
+    private NioServerSocketChannelFactory execFactory;
+
     // Perf. related configuration
     protected static final int SEND_BUFFER_SIZE = 4 * 1024 * 1024;
     protected static final int BATCH_MAX_SIZE = 100;
@@ -155,16 +157,17 @@
     }
 
     private ServerBootstrap createServerBootStrap() {
+
         if (workerThreads == 0) {
-            return new ServerBootstrap(
-                    new NioServerSocketChannelFactory(
-                            Executors.newCachedThreadPool(),
-                            Executors.newCachedThreadPool()));
+            execFactory =  new NioServerSocketChannelFactory(
+                    Executors.newCachedThreadPool(),
+                    Executors.newCachedThreadPool());
+            return new ServerBootstrap(execFactory);
         } else {
-            return new ServerBootstrap(
-                    new NioServerSocketChannelFactory(
-                            Executors.newCachedThreadPool(),
-                            Executors.newCachedThreadPool(), workerThreads));
+            execFactory = new NioServerSocketChannelFactory(
+                    Executors.newCachedThreadPool(),
+                    Executors.newCachedThreadPool(), workerThreads);
+            return new ServerBootstrap(execFactory);
         }
     }
 
@@ -237,6 +240,7 @@
 
 
     public void stop() {
+        execFactory.shutdown();
         cg.close();
     }