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 <[email protected]> Authored: Fri Aug 29 14:08:21 2014 -0700 Committer: Joel Koshy <[email protected]> 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() }
