commit 0a714720a0a0c3a7b876a2a1bade41cc584fb1d2
author Pavlin Radoslavov <pavlin@onlab.us> Wed Dec 03 13:44:08 2014 -0800
committer Pavlin Radoslavov <pavlin@onlab.us> Wed Dec 03 21:50:59 2014 +0000
tree 3786d5fbfef3ee82b06b201e967c83677abb0064
parent db8a9d21f9b5d451342fd68edf7770c9d92fb2df

Added missing BgpSession.exceptionCaught() method to handle
exceptions on the Netty channel.

Change-Id: I9b927abfb21f87d52575158cbecc193d6102f094

apps/sdnip/src/main/java/org/onosproject/sdnip/bgp/BgpSession.java

diff --git a/apps/sdnip/src/main/java/org/onosproject/sdnip/bgp/BgpSession.java b/apps/sdnip/src/main/java/org/onosproject/sdnip/bgp/BgpSession.java
index 7a3fe45..f2c5233 100644
--- a/apps/sdnip/src/main/java/org/onosproject/sdnip/bgp/BgpSession.java
+++ b/apps/sdnip/src/main/java/org/onosproject/sdnip/bgp/BgpSession.java
@@ -32,6 +32,7 @@
 import org.jboss.netty.buffer.ChannelBuffers;
 import org.jboss.netty.channel.ChannelHandlerContext;
 import org.jboss.netty.channel.ChannelStateEvent;
+import org.jboss.netty.channel.ExceptionEvent;
 import org.jboss.netty.channel.SimpleChannelHandler;
 import org.jboss.netty.util.HashedWheelTimer;
 import org.jboss.netty.util.Timeout;
@@ -236,7 +237,7 @@
     }
 
     /**
-     * Closes the netty channel.
+     * Closes the Netty channel.
      *
      * @param ctx the Channel Handler Context
      */
@@ -289,7 +290,22 @@
         log.debug("BGP Session Disconnected from {} on {}",
                   ctx.getChannel().getRemoteAddress(),
                   ctx.getChannel().getLocalAddress());
+        processChannelDisconnected();
+    }
 
+    @Override
+    public void exceptionCaught(ChannelHandlerContext ctx, ExceptionEvent e) {
+        log.debug("BGP Session Exception Caught from {} on {}: {}",
+                  ctx.getChannel().getRemoteAddress(),
+                  ctx.getChannel().getLocalAddress(),
+                  e);
+        processChannelDisconnected();
+    }
+
+    /**
+     * Processes the channel being disconnected.
+     */
+    private void processChannelDisconnected() {
         //
         // Withdraw the routes advertised by this BGP peer
         //