From 871dcaa97a94dc37e2e0a34e9c8ad0f9a0951892 Mon Sep 17 00:00:00 2001 From: "as2252258@163.com" Date: Sat, 24 Apr 2021 20:06:21 +0800 Subject: [PATCH] modify --- 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 a11a2615..61de1d6e 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) { $return = $handler->isRecover(); if ($return === 999) { diff --git a/System/Crontab/Zookeeper.php b/System/Crontab/Zookeeper.php index 338e5a4e..4546c699 100644 --- a/System/Crontab/Zookeeper.php +++ b/System/Crontab/Zookeeper.php @@ -85,7 +85,7 @@ class Zookeeper extends Process if (empty($handler = $redis->get('crontab:' . $value))) { return; } - $params['handler'] = $handler; + $params['handler'] = unserialize($handler); $this->server->sendMessage($params, $this->getWorker()); } catch (Throwable $exception) {