改名
This commit is contained in:
@@ -51,7 +51,6 @@ class OnTask extends Callback
|
||||
*/
|
||||
public function onTask(Server $server, int $task_id, int $from_id, string $data): mixed
|
||||
{
|
||||
var_dump($task_id, $from_id, $data);
|
||||
if (empty($data)) {
|
||||
return $server->finish('null data');
|
||||
}
|
||||
@@ -77,7 +76,6 @@ class OnTask extends Callback
|
||||
*/
|
||||
public function onContinueTask(Server $server, Server\Task $task): mixed
|
||||
{
|
||||
var_dump($task);
|
||||
if (empty($task->data)) {
|
||||
return $task->finish('null data');
|
||||
}
|
||||
@@ -103,7 +101,6 @@ class OnTask extends Callback
|
||||
*/
|
||||
private function runTaskHandler($data): ?array
|
||||
{
|
||||
$app = Snowflake::app()->increment();
|
||||
try {
|
||||
$serialize = $this->before($data);
|
||||
$params = $serialize->getParams();
|
||||
@@ -118,8 +115,6 @@ class OnTask extends Callback
|
||||
$finish['status'] = 'error';
|
||||
$finish['info'] = $this->format($exception);
|
||||
$this->error($exception, 'Task');
|
||||
} finally {
|
||||
$app->decrement();
|
||||
}
|
||||
return $finish;
|
||||
}
|
||||
|
||||
@@ -23,10 +23,6 @@ use Swoole\Timer;
|
||||
class OnWorkerStart extends Callback
|
||||
{
|
||||
|
||||
|
||||
/** @var int 重启信号 */
|
||||
private int $signal = SIGUSR1 | SIGKILL | SIGKILL;
|
||||
|
||||
|
||||
/**
|
||||
* @param Server $server
|
||||
@@ -85,36 +81,6 @@ class OnWorkerStart extends Callback
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
* @param $server
|
||||
* @param $worker_id
|
||||
* @return void
|
||||
*/
|
||||
public function onSignal(Server $server, $worker_id): mixed
|
||||
{
|
||||
$ret = Coroutine::waitSignal($this->signal, -1);
|
||||
if ($ret === true) {
|
||||
$this->ticker();
|
||||
}
|
||||
return $server->stop();
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
* @return void
|
||||
*/
|
||||
private function ticker(): void
|
||||
{
|
||||
if (!Snowflake::app()->isRun()) {
|
||||
return;
|
||||
}
|
||||
|
||||
sleep(1);
|
||||
|
||||
$this->ticker();
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
* @param $socket
|
||||
* @param $worker_id
|
||||
|
||||
Reference in New Issue
Block a user