From 0c6f4174547055f45df3c12232cb91176e0d966a Mon Sep 17 00:00:00 2001 From: Kevin Meijer Date: Thu, 4 Jun 2020 12:08:15 +0200 Subject: [PATCH 1/2] Bumped VERSION --- VERSION | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/VERSION b/VERSION index 6a6a3d8..097a15a 100644 --- a/VERSION +++ b/VERSION @@ -1 +1 @@ -2.6.1 +2.6.2 From 93d2f4590d8e350896014f8892853f670196ebec Mon Sep 17 00:00:00 2001 From: Kevin Meijer Date: Thu, 4 Jun 2020 12:08:41 +0200 Subject: [PATCH 2/2] Fixed handling of Error::C_ASYNC_CONNECT_FAILED by the updates wrapper --- src/PHPWebSockets/UpdatesWrapper.php | 11 ++++++++++- 1 file changed, 10 insertions(+), 1 deletion(-) diff --git a/src/PHPWebSockets/UpdatesWrapper.php b/src/PHPWebSockets/UpdatesWrapper.php index 67b93eb..c9f42bc 100644 --- a/src/PHPWebSockets/UpdatesWrapper.php +++ b/src/PHPWebSockets/UpdatesWrapper.php @@ -261,7 +261,7 @@ public function update(float $timeout = NULL, array $tempStreams = []) { $this->_onInvalidStream($update); break; case Update\Error::C_ASYNC_CONNECT_FAILED: - $this->_onDisconnect($update); + $this->_onAsyncConnectFailed($update); break; default: throw new \UnexpectedValueException('Unknown or unsupported update code for error: ' . $code); @@ -597,4 +597,13 @@ private function _onInvalidStream(Update\Error $update) { private function _onDisconnectDuringHandshake(Update\Error $update) { $this->_triggerErrorHandler($update->getSourceConnection(), $update->getCode()); } + + private function _onAsyncConnectFailed(Update\Error $update) { + + $source = $update->getSourceConnection(); + + $this->_triggerDisconnectHandler($source, FALSE, NULL); + $this->_handledDisconnects[$source->getResourceIndex()] = TRUE; + + } }