idanoo/php-resque
1
0
Fork 0
mirror of https://github.com/idanoo/php-resque.git synced 2024-11-22 00:11:53 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Clean up bin/resque file

Browse Source
This commit is contained in:
Daniel Mason 2018-05-27 14:52:05 +12:00
parent e0914efdd5
commit 2a3dcd8537
1 changed files with 26 additions and 30 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

48
bin/resque
View File

@ -2,12 +2,12 @@
<?php <?php
// Find and initialize Composer // Find and initialize Composer
$files = array( $files = [
__DIR__ . '/../../vendor/autoload.php', __DIR__ . '/../../vendor/autoload.php',
__DIR__ . '/../../../autoload.php', __DIR__ . '/../../../autoload.php',
__DIR__ . '/../../../../autoload.php', __DIR__ . '/../../../../autoload.php',
__DIR__ . '/../vendor/autoload.php', __DIR__ . '/../vendor/autoload.php',
); ];
$found = false; $found = false;
foreach ($files as $file) { foreach ($files as $file) {
@ -26,7 +26,7 @@ if (!class_exists('Composer\Autoload\ClassLoader', false)) {
} }
$QUEUE = getenv('QUEUE'); $QUEUE = getenv('QUEUE');
if(empty($QUEUE)) { if (empty($QUEUE)) {
die("Set QUEUE env var containing the list of queues to work.\n"); die("Set QUEUE env var containing the list of queues to work.\n");
} }
@ -40,7 +40,7 @@ $REDIS_BACKEND = getenv('REDIS_BACKEND');
// A redis database number // A redis database number
$REDIS_BACKEND_DB = getenv('REDIS_BACKEND_DB'); $REDIS_BACKEND_DB = getenv('REDIS_BACKEND_DB');
if(!empty($REDIS_BACKEND)) { if (!empty($REDIS_BACKEND)) {
if (empty($REDIS_BACKEND_DB)) if (empty($REDIS_BACKEND_DB))
Resque::setBackend($REDIS_BACKEND); Resque::setBackend($REDIS_BACKEND);
else else
@ -51,17 +51,16 @@ $logLevel = false;
$LOGGING = getenv('LOGGING'); $LOGGING = getenv('LOGGING');
$VERBOSE = getenv('VERBOSE'); $VERBOSE = getenv('VERBOSE');
$VVERBOSE = getenv('VVERBOSE'); $VVERBOSE = getenv('VVERBOSE');
if(!empty($LOGGING) || !empty($VERBOSE)) { if (!empty($LOGGING) || !empty($VERBOSE)) {
$logLevel = true; $logLevel = true;
} } else if (!empty($VVERBOSE)) {
else if(!empty($VVERBOSE)) {
$logLevel = true; $logLevel = true;
} }
$APP_INCLUDE = getenv('APP_INCLUDE'); $APP_INCLUDE = getenv('APP_INCLUDE');
if($APP_INCLUDE) { if ($APP_INCLUDE) {
if(!file_exists($APP_INCLUDE)) { if (!file_exists($APP_INCLUDE)) {
die('APP_INCLUDE ('.$APP_INCLUDE.") does not exist.\n"); die('APP_INCLUDE (' . $APP_INCLUDE . ") does not exist.\n");
} }
require_once $APP_INCLUDE; require_once $APP_INCLUDE;
@ -77,42 +76,40 @@ $BLOCKING = getenv('BLOCKING') !== FALSE;
$interval = 5; $interval = 5;
$INTERVAL = getenv('INTERVAL'); $INTERVAL = getenv('INTERVAL');
if(!empty($INTERVAL)) { if (!empty($INTERVAL)) {
$interval = $INTERVAL; $interval = $INTERVAL;
} }
$count = 1; $count = 1;
$COUNT = getenv('COUNT'); $COUNT = getenv('COUNT');
if(!empty($COUNT) && $COUNT > 1) { if (!empty($COUNT) && $COUNT > 1) {
$count = $COUNT; $count = $COUNT;
} }
$PREFIX = getenv('PREFIX'); $PREFIX = getenv('PREFIX');
if(!empty($PREFIX)) { if (!empty($PREFIX)) {
$logger->log(Psr\Log\LogLevel::INFO, 'Prefix set to {prefix}', array('prefix' => $PREFIX)); $logger->log(Psr\Log\LogLevel::INFO, 'Prefix set to {prefix}', ['prefix' => $PREFIX]);
Resque_Redis::prefix($PREFIX); Resque_Redis::prefix($PREFIX);
} }
if($count > 1) { if ($count > 1) {
for($i = 0; $i < $count; ++$i) { for ($i = 0; $i < $count; ++$i) {
$pid = Resque::fork(); $pid = Resque::fork();
if($pid === false || $pid === -1) { if ($pid === false || $pid === -1) {
$logger->log(Psr\Log\LogLevel::EMERGENCY, 'Could not fork worker {count}', array('count' => $i)); $logger->log(Psr\Log\LogLevel::EMERGENCY, 'Could not fork worker {count}', ['count' => $i]);
die(); die();
} } elseif (!$pid) {
// Child, start the worker // Child, start the worker
else if(!$pid) {
$queues = explode(',', $QUEUE); $queues = explode(',', $QUEUE);
$worker = new Resque_Worker($queues); $worker = new Resque_Worker($queues);
$worker->setLogger($logger); $worker->setLogger($logger);
$logger->log(Psr\Log\LogLevel::NOTICE, 'Starting worker {worker}', array('worker' => $worker)); $logger->log(Psr\Log\LogLevel::NOTICE, 'Starting worker {worker}', ['worker' => $worker]);
$worker->work($interval, $BLOCKING); $worker->work($interval, $BLOCKING);
break; break;
} }
} }
} } else {
// Start a single worker // Start a single worker
else {
$queues = explode(',', $QUEUE); $queues = explode(',', $QUEUE);
$worker = new Resque_Worker($queues); $worker = new Resque_Worker($queues);
$worker->setLogger($logger); $worker->setLogger($logger);
@ -123,7 +120,6 @@ else {
die('Could not write PID information to ' . $PIDFILE); die('Could not write PID information to ' . $PIDFILE);
} }
$logger->log(Psr\Log\LogLevel::NOTICE, 'Starting worker {worker}', array('worker' => $worker)); $logger->log(Psr\Log\LogLevel::NOTICE, 'Starting worker {worker}', ['worker' => $worker]);
$worker->work($interval, $BLOCKING); $worker->work($interval, $BLOCKING);
} }
?>