Fixed registry contex
This commit is contained in:
parent
1017a2fb6b
commit
a5b70e9476
1 changed files with 4 additions and 2 deletions
|
@ -39,12 +39,12 @@ $subscriptions = [];
|
||||||
$connections = [];
|
$connections = [];
|
||||||
|
|
||||||
$server->on('workerStart', function ($server, $workerId) use (&$subscriptions, &$connections, &$register) {
|
$server->on('workerStart', function ($server, $workerId) use (&$subscriptions, &$connections, &$register) {
|
||||||
Console::success('Worker ' . ++$workerId . ' started succefully');
|
Console::success('Worker ' . $workerId . ' started succefully');
|
||||||
|
|
||||||
$attempts = 0;
|
$attempts = 0;
|
||||||
$start = time();
|
$start = time();
|
||||||
|
|
||||||
// $register->context('realtime-' . $workerId);
|
$register->context('realtime-pubsub-' . $workerId);
|
||||||
|
|
||||||
while ($attempts < 300) {
|
while ($attempts < 300) {
|
||||||
try {
|
try {
|
||||||
|
@ -121,6 +121,8 @@ $server->on('start', function (Server $server) {
|
||||||
$server->on('open', function (Server $server, Request $request) use (&$connections, &$subscriptions, &$register) {
|
$server->on('open', function (Server $server, Request $request) use (&$connections, &$subscriptions, &$register) {
|
||||||
Console::info("Connection open (user: {$request->fd}, connections: {}, worker: {$server->getWorkerId()})");
|
Console::info("Connection open (user: {$request->fd}, connections: {}, worker: {$server->getWorkerId()})");
|
||||||
|
|
||||||
|
$register->context('realtime-' . $server->getWorkerId());
|
||||||
|
|
||||||
$app = new App('');
|
$app = new App('');
|
||||||
$connection = $request->fd;
|
$connection = $request->fd;
|
||||||
$request = new SwooleRequest($request);
|
$request = new SwooleRequest($request);
|
||||||
|
|
Loading…
Reference in a new issue