From d62193bd49d4a8ad6d670b332d1d2f8b0936f7dc Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Mr=C2=B7x?= Date: Fri, 9 Oct 2020 17:33:50 +0800 Subject: [PATCH] =?UTF-8?q?=E6=94=B9=E5=90=8D?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- Kafka/Socket.php | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/Kafka/Socket.php b/Kafka/Socket.php index 571b810c..4bea1f86 100644 --- a/Kafka/Socket.php +++ b/Kafka/Socket.php @@ -417,7 +417,7 @@ class Socket */ protected function isSocketDead() { - return !is_resource($this->stream) || @feof($this->stream); + return $this->stream instanceof \Swoole\Coroutine\Socket && $this->stream->checkLiveness(); } // }}}