From 48854e1dbf1d02e1e19f59d0aee0e281d41b3b45 Mon Sep 17 00:00:00 2001
From: Mridul Muralidharan <mridul@gmail.com>
Date: Tue, 30 Apr 2013 23:59:33 +0530
Subject: [PATCH] If key is not valid, close connection
---
.gitignore | 2 --
core/src/main/scala/spark/network/ConnectionManager.scala | 3 +++
2 files changed, 3 insertions(+), 2 deletions(-)
diff --git a/.gitignore b/.gitignore
index 155e785b01..5bb2f33574 100644
--- a/.gitignore
+++ b/.gitignore
@@ -29,8 +29,6 @@ project/build/target/
project/plugins/target/
project/plugins/lib_managed/
project/plugins/src_managed/
-logs/
-log/
spark-tests.log
streaming-tests.log
dependency-reduced-pom.xml
diff --git a/core/src/main/scala/spark/network/ConnectionManager.scala b/core/src/main/scala/spark/network/ConnectionManager.scala
index a79fce8697..2d9b4be4b3 100644
--- a/core/src/main/scala/spark/network/ConnectionManager.scala
+++ b/core/src/main/scala/spark/network/ConnectionManager.scala
@@ -281,6 +281,9 @@ private[spark] class ConnectionManager(port: Int) extends Logging {
if (key.isWritable) {
triggerWrite(key)
}
+ } else {
+ logInfo("Key not valid ? " + key)
+ throw new CancelledKeyException()
}
} catch {
// weird, but we saw this happening - even though key.isValid was true, key.isAcceptable would throw CancelledKeyException.
--
GitLab