Revert "改名"
This reverts commit fdf58326
This commit is contained in:
@@ -23,6 +23,9 @@ class Broadcast
|
|||||||
|
|
||||||
$total = $server->setting['worker_num'] + $server->setting['task_worker_num'];
|
$total = $server->setting['worker_num'] + $server->setting['task_worker_num'];
|
||||||
for ($i = 0; $i < $total; $i++) {
|
for ($i = 0; $i < $total; $i++) {
|
||||||
|
if ($i == env('environmental_workerId')) {
|
||||||
|
continue;
|
||||||
|
}
|
||||||
$server->sendMessage(serialize(new Message($message)), $i);
|
$server->sendMessage(serialize(new Message($message)), $i);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -4,10 +4,10 @@ namespace Kiri\Server\Handler;
|
|||||||
|
|
||||||
use Exception;
|
use Exception;
|
||||||
use Kiri\Abstracts\Config;
|
use Kiri\Abstracts\Config;
|
||||||
|
use Kiri\Annotation\Inject;
|
||||||
use Kiri\Core\Help;
|
use Kiri\Core\Help;
|
||||||
use Kiri\Events\EventDispatch;
|
use Kiri\Events\EventDispatch;
|
||||||
use Kiri\Kiri;
|
use Kiri\Kiri;
|
||||||
use Kiri\Annotation\Inject;
|
|
||||||
use Kiri\Server\Events\OnAfterWorkerStart;
|
use Kiri\Server\Events\OnAfterWorkerStart;
|
||||||
use Kiri\Server\Events\OnBeforeWorkerStart;
|
use Kiri\Server\Events\OnBeforeWorkerStart;
|
||||||
use Kiri\Server\Events\OnTaskerStart as OnTaskStart;
|
use Kiri\Server\Events\OnTaskerStart as OnTaskStart;
|
||||||
@@ -42,6 +42,7 @@ class OnServerWorker extends \Kiri\Server\Abstracts\Server
|
|||||||
public function onWorkerStart(Server $server, int $workerId)
|
public function onWorkerStart(Server $server, int $workerId)
|
||||||
{
|
{
|
||||||
$this->eventDispatch->dispatch(new OnBeforeWorkerStart($workerId));
|
$this->eventDispatch->dispatch(new OnBeforeWorkerStart($workerId));
|
||||||
|
set_env('environmental_workerId', $workerId);
|
||||||
if ($workerId < $server->setting['worker_num']) {
|
if ($workerId < $server->setting['worker_num']) {
|
||||||
$this->eventDispatch->dispatch(new OnWorkerStart($server, $workerId));
|
$this->eventDispatch->dispatch(new OnWorkerStart($server, $workerId));
|
||||||
$this->setProcessName(sprintf('Worker[%d].%d', $server->worker_pid, $workerId));
|
$this->setProcessName(sprintf('Worker[%d].%d', $server->worker_pid, $workerId));
|
||||||
|
|||||||
Reference in New Issue
Block a user