You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by jj...@apache.org on 2014/08/29 23:14:55 UTC
git commit: KAFKA-1577;
Swallow errors from connection-quotas in closing sockets on shutdown;
reviewed by Joel Koshy
Repository: kafka
Updated Branches:
refs/heads/trunk 2cdc83e85 -> 538122fa7
KAFKA-1577; Swallow errors from connection-quotas in closing sockets on shutdown; reviewed by Joel Koshy
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/538122fa
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/538122fa
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/538122fa
Branch: refs/heads/trunk
Commit: 538122fa793fe59021ac35feaef22e302b194030
Parents: 2cdc83e
Author: Sriharsha Chintalapani <sc...@hortonworks.com>
Authored: Fri Aug 29 14:08:21 2014 -0700
Committer: Joel Koshy <jj...@gmail.com>
Committed: Fri Aug 29 14:08:21 2014 -0700
----------------------------------------------------------------------
core/src/main/scala/kafka/network/SocketServer.scala | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/kafka/blob/538122fa/core/src/main/scala/kafka/network/SocketServer.scala
----------------------------------------------------------------------
diff --git a/core/src/main/scala/kafka/network/SocketServer.scala b/core/src/main/scala/kafka/network/SocketServer.scala
index 9693bc0..ff0c4ba 100644
--- a/core/src/main/scala/kafka/network/SocketServer.scala
+++ b/core/src/main/scala/kafka/network/SocketServer.scala
@@ -334,7 +334,7 @@ private[kafka] class Processor(val id: Int,
}
}
debug("Closing selector.")
- closeAll()
+ swallowError(closeAll())
swallowError(selector.close())
shutdownComplete()
}