git.cweiske.de
/
phinde.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
script to renew websub subscriptions
[phinde.git]
/
bin
/
phinde-worker.php
diff --git
a/bin/phinde-worker.php
b/bin/phinde-worker.php
index 9f8c35aa9ff95f9e3cca309150f33349c4e3317b..9b65e324d679c0dcbe2f61932aadfb80e090df3c 100755
(executable)
--- a/
bin/phinde-worker.php
+++ b/
bin/phinde-worker.php
@@
-13,9
+13,10
@@
$gmworker->addFunction(
$GLOBALS['phinde']['queuePrefix'] . 'phinde_process',
function(\GearmanJob $job) {
$data = unserialize($job->workload());
$GLOBALS['phinde']['queuePrefix'] . 'phinde_process',
function(\GearmanJob $job) {
$data = unserialize($job->workload());
- echo "-- Processing " . $data['url']
+ Log::info(
+ "-- Processing " . $data['url']
. ' (' . implode(',', $data['actions']) . ')'
. ' (' . implode(',', $data['actions']) . ')'
-
. "\n"
;
+
)
;
passthru(
'./process.php ' . escapeshellarg($data['url'])
. ' ' . implode(' ', $data['actions'])
passthru(
'./process.php ' . escapeshellarg($data['url'])
. ' ' . implode(' ', $data['actions'])
@@
-26,7
+27,7
@@
$gmworker->addFunction(
$gmworker->addFunction(
$GLOBALS['phinde']['queuePrefix'] . 'phinde_quit',
function(\GearmanJob $job) {
$gmworker->addFunction(
$GLOBALS['phinde']['queuePrefix'] . 'phinde_quit',
function(\GearmanJob $job) {
-
echo "Got exit job\n"
;
+
Log::info('Got exit job')
;
$job->sendComplete('');
exit(0);
}
$job->sendComplete('');
exit(0);
}
@@
-34,7
+35,7
@@
$gmworker->addFunction(
while ($gmworker->work()) {
if ($gmworker->returnCode() != GEARMAN_SUCCESS) {
while ($gmworker->work()) {
if ($gmworker->returnCode() != GEARMAN_SUCCESS) {
-
echo 'Error running job: ' . $gmworker->returnCode() . "\n"
;
+
Log::error('Error running job: ' . $gmworker->returnCode())
;
break;
}
}
break;
}
}