From efa8e76011f0c3f2aed7f6d67a694b8a4279f19a Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Mr=C2=B7x?= Date: Wed, 28 Apr 2021 11:57:49 +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 --- HttpServer/Events/OnPipeMessage.php | 2 +- System/Crontab/Zookeeper.php | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/HttpServer/Events/OnPipeMessage.php b/HttpServer/Events/OnPipeMessage.php index 98b4544b..1629335b 100644 --- a/HttpServer/Events/OnPipeMessage.php +++ b/HttpServer/Events/OnPipeMessage.php @@ -47,7 +47,7 @@ class OnPipeMessage extends Callback throw new Exception('unknown handler'); } /** @var Crontab $handler */ - $handler = swoole_unserialize($message['handler']); + $handler = $message['handler']; defer(function () use ($handler) { if ($handler->isRecover() !== 999) { return; diff --git a/System/Crontab/Zookeeper.php b/System/Crontab/Zookeeper.php index 6b774ec9..d626f0b1 100644 --- a/System/Crontab/Zookeeper.php +++ b/System/Crontab/Zookeeper.php @@ -86,7 +86,7 @@ class Zookeeper extends Process if (empty($handler = $redis->get('crontab:' . $value))) { return; } - $params['handler'] = $handler; + $params['handler'] = swoole_unserialize($handler); $this->server->sendMessage($params, $this->getWorker()); } catch (Throwable $exception) {