summaryrefslogtreecommitdiffstats
path: root/application/controllers/GearmanController.php
diff options
context:
space:
mode:
authorBjörn Geiger2011-07-21 11:46:58 +0200
committerBjörn Geiger2011-07-21 11:46:58 +0200
commite601af15facf87dd074afe7148fe9dbbe1c7d18f (patch)
treec4f6b4e52d3178a2e09fd2f4a1c21989ca9f4b02 /application/controllers/GearmanController.php
parentminor (diff)
downloadpoolctrl-e601af15facf87dd074afe7148fe9dbbe1c7d18f.tar.gz
poolctrl-e601af15facf87dd074afe7148fe9dbbe1c7d18f.tar.xz
poolctrl-e601af15facf87dd074afe7148fe9dbbe1c7d18f.zip
boot Action im GearmanController
Diffstat (limited to 'application/controllers/GearmanController.php')
-rw-r--r--application/controllers/GearmanController.php50
1 files changed, 28 insertions, 22 deletions
diff --git a/application/controllers/GearmanController.php b/application/controllers/GearmanController.php
index 8538432..0891612 100644
--- a/application/controllers/GearmanController.php
+++ b/application/controllers/GearmanController.php
@@ -17,28 +17,34 @@ class GearmanController extends Zend_Controller_Action
public function somepingAction()
{
- $gearmanNamespace = Zend_Session::namespaceGet('gearman');
- if(!isset($gearmanNamespace['somePingJobHandle'])) {
- $ipString = '132.230.4.1; 132.230.4.2; 132.230.4.3; 132.230.4.4; 132.230.4.5; 132.230.4.6; 132.230.4.7; 132.230.4.8; 132.230.4.9; 132.230.4.10; 132.230.4.11; 132.230.4.12; 132.230.4.13; 132.230.4.14; 132.230.4.15; 132.230.4.16; 132.230.4.17; 132.230.4.18; 132.230.4.19; 132.230.4.20; 132.230.4.21; 132.230.4.22; 132.230.4.23; 132.230.4.24; 132.230.4.25; 132.230.4.26; 132.230.4.27; 132.230.4.28; 132.230.4.29; 132.230.4.30';
- $jobHandle = $this->gearmanClient->doBackground("somePing", $ipString);
- $gearmanSession = new Zend_Session_Namespace('gearman');
- $gearmanSession->somePingJobHandle = $jobHandle;
- } else {
- $jobHandle = $gearmanNamespace['somePingJobHandle'];
- $result = $this->gearmanClient->jobStatus($jobHandle);
- $resultsExp = explode('; ', $result);
- print_r($result);
- if(is_array($resultsExp)) {
- foreach($resultsExp as $result) {
- $resultDecode = json_decode($result);
- $resultDecode->rawoutput = sprintf('%s', $resultDecode->rawoutput);
- $resultDecode->alive = sprintf('%s', $resultDecode->alive);
- $resultDecode->rc = sprintf('%s', $resultDecode->rc);
- $results[] = $resultDecode;
- }
- Zend_Session::namespaceUnset('gearman');
- $this->view->results = $results;
+ $ipString = '132.230.4.1; 132.230.4.2; 132.230.4.3; 132.230.4.4; 132.230.4.5; 132.230.4.6; 132.230.4.7; 132.230.4.8; 132.230.4.9; 132.230.4.10; 132.230.4.11; 132.230.4.12; 132.230.4.13; 132.230.4.14; 132.230.4.15; 132.230.4.16; 132.230.4.17; 132.230.4.18; 132.230.4.19; 132.230.4.20; 132.230.4.21; 132.230.4.22; 132.230.4.23; 132.230.4.24; 132.230.4.25; 132.230.4.26; 132.230.4.27; 132.230.4.28; 132.230.4.29; 132.230.4.30';
+ $result = $this->gearmanClient->do("somePing", $ipString, 'somePing');
+ if (! $this->gearmanClient->runTasks())
+ {
+ echo "ERROR " . $gmc->error() . "\n";
+ exit;
+ }
+ $resultsExp = explode('; ', $result);
+ if(is_array($resultsExp)) {
+ foreach($resultsExp as $result) {
+ $resultDecode = json_decode($result);
+ $resultDecode->rawoutput = sprintf('%s', $resultDecode->rawoutput);
+ $resultDecode->alive = sprintf('%s', $resultDecode->alive);
+ $resultDecode->rc = sprintf('%s', $resultDecode->rc);
+ $results[] = $resultDecode;
}
}
+ $this->view->results = $results;
+ }
+
+ public function BootAction() {
+ $ipString = '132.230.4.1; 132.230.4.2; 132.230.4.3; 132.230.4.4; 132.230.4.5; 132.230.4.6; 132.230.4.7; 132.230.4.8; 132.230.4.9; 132.230.4.10; 132.230.4.11; 132.230.4.12; 132.230.4.13; 132.230.4.14; 132.230.4.15; 132.230.4.16; 132.230.4.17; 132.230.4.18; 132.230.4.19; 132.230.4.20; 132.230.4.21; 132.230.4.22; 132.230.4.23; 132.230.4.24; 132.230.4.25; 132.230.4.26; 132.230.4.27; 132.230.4.28; 132.230.4.29; 132.230.4.30';
+ $result = $this->gearmanClient->do("somePing", $ipString, 'somePing');
+ if (! $this->gearmanClient->runTasks())
+ {
+ echo "ERROR " . $gmc->error() . "\n";
+ exit;
+ }
+ $this->view->result = $result;
}
-} \ No newline at end of file
+}