as2252258/kiri-core
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 2 Wiki Activity

modify

Browse Source
This commit is contained in:
as2252258@163.com
2021-04-24 00:23:15 +08:00
parent d000afb3d0
commit 5554a032ae
2 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
HttpServer/Events/OnPipeMessage.php
+2 -1
View File
@@ -46,10 +46,11 @@ class OnPipeMessage extends Callback
*/ */
private function onCrontabWorker(array $message): string private function onCrontabWorker(array $message): string
{ {
if (empty($handler = $message['handler'] ?? null)) { if (empty($message['handler'] ?? null)) {
throw new Exception('unknown handler'); throw new Exception('unknown handler');
} }
/** @var Crontab $handler */ /** @var Crontab $handler */
$handler = swoole_unserialize($message['handler']);
defer(function () use ($handler) { defer(function () use ($handler) {
$return = $handler->isRecover(); $return = $handler->isRecover();
if ($return === 999) { if ($return === 999) {
System/Crontab/Zookeeper.php
+1 -1
View File
@@ -85,7 +85,7 @@ class Zookeeper extends Process
if (empty($handler = $redis->get('crontab:' . $value))) { if (empty($handler = $redis->get('crontab:' . $value))) {
return; return;
} }
$params['handler'] = swoole_unserialize($handler); $params['handler'] = $handler;
$this->server->sendMessage($params, $this->getWorker()); $this->server->sendMessage($params, $this->getWorker());
} catch (Throwable $exception) { } catch (Throwable $exception) {