This commit is contained in:
2021-12-06 18:07:33 +08:00
parent d02337ec22
commit d2acd50352
+4 -3
View File
@@ -5,13 +5,12 @@ namespace Kiri\Error;
use Exception; use Exception;
use JetBrains\PhpStorm\Pure;
use Kiri\Core\Json; use Kiri\Core\Json;
use Kiri\Exception\ComponentException; use Kiri\Exception\ComponentException;
use Kiri\Kiri; use Kiri\Kiri;
use Server\Abstracts\BaseProcess;
use Swoole\Coroutine; use Swoole\Coroutine;
use Swoole\Process; use Swoole\Process;
use Server\Abstracts\BaseProcess;
/** /**
* Class LoggerProcess * Class LoggerProcess
@@ -24,7 +23,6 @@ class LoggerProcess extends BaseProcess
public string $name = 'logger process'; public string $name = 'logger process';
/** /**
* @param Process $process * @param Process $process
* @throws ComponentException * @throws ComponentException
@@ -43,6 +41,9 @@ class LoggerProcess extends BaseProcess
*/ */
public function message(Process $process) public function message(Process $process)
{ {
if ($this->isStop()) {
return;
}
$message = Json::decode($process->read()); $message = Json::decode($process->read());
if (!empty($message)) { if (!empty($message)) {
Kiri::writeFile($this->getDirName($message), $message[0], FILE_APPEND); Kiri::writeFile($this->getDirName($message), $message[0], FILE_APPEND);