Netty: Close idle tcp connections between controller instances

Change-Id: Ieb6fddce85f015c64e5f0276f0d361a3a93b8fb4

Netty: Close idle tcp connections between controller instances
Change-Id: Ieb6fddce85f015c64e5f0276f0d361a3a93b8fb4
Madan Jampani
Commit cca4bdb280463c09dc1aa6704df2fe154fb08156 cca4bdb2 1 parent 3d1727c1
Showing 1 changed file with 4 additions and 1 deletions
utils/netty/src/main/java/org/onlab/netty/NettyMessaging.java
--- a/utils/netty/src/main/java/org/onlab/netty/NettyMessaging.java
View file @cca4bdb
+++ b/utils/netty/src/main/java/org/onlab/netty/NettyMessaging.java
View file @cca4bdb
@@ -117,9 +117,11 @@ public class NettyMessaging implements MessagingService {
             return;
         }
         this.localEp = localEp;
-         channels.setLifo(false);
+         channels.setLifo(true);
         channels.setTestOnBorrow(true);
         channels.setTestOnReturn(true);
+         channels.setMinEvictableIdleTimeMillis(60_000L);
+         channels.setTimeBetweenEvictionRunsMillis(30_000L);
         initEventLoopGroup();
         startAcceptingConnections();
         started.set(true);
@@ -265,6 +267,7 @@ public class NettyMessaging implements MessagingService {
 
         @Override
         public void destroyObject(Endpoint ep, Channel channel) throws Exception {
+             log.info("Closing connection to {}", ep);
             channel.close();
         }