diff options
| author | Christian Weiske <cweiske@cweiske.de> | 2016-02-01 20:18:59 +0100 |
|---|---|---|
| committer | Christian Weiske <cweiske@cweiske.de> | 2016-02-01 20:18:59 +0100 |
| commit | 7b4425b096fa8c18d0db9fd9b1ae96d63ee8af55 (patch) | |
| tree | 2dc5d998a1fd0238592b451ff88b5c4cec064f9b /bin/phinde-worker.php | |
| download | phinde-7b4425b096fa8c18d0db9fd9b1ae96d63ee8af55.tar.gz phinde-7b4425b096fa8c18d0db9fd9b1ae96d63ee8af55.zip | |
first kinda working version
Diffstat (limited to 'bin/phinde-worker.php')
| -rwxr-xr-x | bin/phinde-worker.php | 34 |
1 files changed, 34 insertions, 0 deletions
diff --git a/bin/phinde-worker.php b/bin/phinde-worker.php new file mode 100755 index 0000000..e8253ff --- /dev/null +++ b/bin/phinde-worker.php @@ -0,0 +1,34 @@ +#!/usr/bin/env php +<?php +namespace phinde; + +chdir(dirname($argv[0])); + +$gmworker = new \GearmanWorker(); +$gmworker->addServer('127.0.0.1'); + +$gmworker->addFunction( + 'phinde_crawl', + function(\GearmanJob $job) { + $data = unserialize($job->workload()); + echo "-- Crawling " . $data['url'] . "\n"; + passthru('./crawl.php ' . escapeshellarg($data['url'])); + } +); +$gmworker->addFunction( + 'phinde_index', + function(\GearmanJob $job) { + $data = unserialize($job->workload()); + echo "-- Indexing " . $data['url'] . "\n"; + passthru('./index.php ' . escapeshellarg($data['url'])); + //exit(); + } +); + +while ($gmworker->work()) { + if ($gmworker->returnCode() != GEARMAN_SUCCESS) { + echo 'Error running job: ' . $gmworker->returnCode() . "\n"; + break; + } +} +?> |
