kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jjko...@apache.org
Subject git commit: KAFKA-1577; Swallow errors from connection-quotas in closing sockets on shutdown; reviewed by Joel Koshy
Date Fri, 29 Aug 2014 21:14:55 GMT
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 <schintalapani@hortonworks.com>
Authored: Fri Aug 29 14:08:21 2014 -0700
Committer: Joel Koshy <jjkoshy@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()
   }


Mime
View raw message