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-03-20 02:48:29 +08:00
parent 8a56598d73
commit 3d539c8b54
1 changed files with 11 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files
System/Process/CrontabProcess.php
+11 -7
View File
@@ -34,13 +34,16 @@ class CrontabProcess extends Process
public function onHandler(\Swoole\Process $process): void public function onHandler(\Swoole\Process $process): void
{ {
while (true) { while (true) {
$content = $process->read(); try {
$_content = json_decode($content, true); $content = $process->read();
var_dump($content, $_content); $_content = json_decode($content, true);
if (is_null($_content)) { if (is_null($_content)) {
$this->jobDelivery($content); $this->jobDelivery($content);
} else { } else {
$this->otherAction($_content); $this->otherAction($_content);
}
} catch (\Throwable $exception) {
$this->application->error($exception->getMessage());
} }
} }
} }
@@ -77,6 +80,7 @@ class CrontabProcess extends Process
{ {
$content = unserialize($content); $content = unserialize($content);
$this->names[$content->getName()] = $content; $this->names[$content->getName()] = $content;
var_dump($content);
if (!($content instanceof Crontab)) { if (!($content instanceof Crontab)) {
return; return;
} }