Nosial/tamerlib
2
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions

Updated \TamerLib\Protocols\Gearman with more logging calls

Browse source
This commit is contained in:
Netkas 2023-02-28 21:32:47 -05:00
parent 47da4c8df7
commit ce173976cd
1 changed files with 10 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

16
src/TamerLib/Protocols/Gearman/Client.php
View file

@ -286,20 +286,22 @@
$this->tasks[] = $task;
$job = new Job($task);
$job_data = msgpack_pack($job->toArray());
Log::debug('net.nosial.tamerlib', 'sending closure to gearman server: ' . strlen($job_data) . ' bytes');
switch($task->getPriority())
{
case TaskPriority::High:
$this->client->doHighBackground($task->getFunctionName(), msgpack_pack($job->toArray()));
$this->client->doHighBackground($task->getFunctionName(), $job_data);
break;
case TaskPriority::Low:
$this->client->doLowBackground($task->getFunctionName(), msgpack_pack($job->toArray()));
$this->client->doLowBackground($task->getFunctionName(), $job_data);
break;
default:
case TaskPriority::Normal:
$this->client->doBackground($task->getFunctionName(), msgpack_pack($job->toArray()));
$this->client->doBackground($task->getFunctionName(), $job_data);
break;
}
}
@ -316,20 +318,22 @@
$this->tasks[] = $task;
$job = new Job($task);
$job_data = msgpack_pack($job->toArray());
Log::debug('net.nosial.tamerlib', 'sending closure to gearman server: ' . strlen($job_data) . ' bytes');
switch($task->getPriority())
{
case TaskPriority::High:
$this->client->addTaskHigh($task->getFunctionName(), msgpack_pack($job->toArray()));
$this->client->addTaskHigh($task->getFunctionName(), $job_data);
break;
case TaskPriority::Low:
$this->client->addTaskLow($task->getFunctionName(), msgpack_pack($job->toArray()));
$this->client->addTaskLow($task->getFunctionName(), $job_data);
break;
default:
case TaskPriority::Normal:
$this->client->addTask($task->getFunctionName(), msgpack_pack($job->toArray()));
$this->client->addTask($task->getFunctionName(), $job_data);
break;
}
}