summaryrefslogtreecommitdiffstats
path: root/gearman
diff options
context:
space:
mode:
authorSebastian Wagner2011-07-26 11:43:29 +0200
committerSebastian Wagner2011-07-26 11:43:29 +0200
commit756ebc32d8df206fd7118be273c8b0fddf450005 (patch)
tree35dfec45802f2833b7c29faecc3e235f62ca60f9 /gearman
parent.zfproject.xml aus git gelöscht (diff)
downloadpoolctrl-756ebc32d8df206fd7118be273c8b0fddf450005.tar.gz
poolctrl-756ebc32d8df206fd7118be273c8b0fddf450005.tar.xz
poolctrl-756ebc32d8df206fd7118be273c8b0fddf450005.zip
minor
Diffstat (limited to 'gearman')
-rwxr-xr-xgearman/pingWorker.py5
1 files changed, 3 insertions, 2 deletions
diff --git a/gearman/pingWorker.py b/gearman/pingWorker.py
index a880fc7..fa13602 100755
--- a/gearman/pingWorker.py
+++ b/gearman/pingWorker.py
@@ -7,7 +7,7 @@ import time
import re
def pingTask(worker, job):
- total = 1
+ total = 2
timeout = 1
ret = {"rawoutput": "", "alive": False, "rc": -1}
target = job.data.strip()
@@ -24,6 +24,7 @@ def pingTask(worker, job):
out = pingcmd.stdout.readline()
if out != None:
ret['rawoutput'] += out
+ print '.'
time.sleep(0.05)
pingcmd.poll()
@@ -40,4 +41,4 @@ def pingTask(worker, job):
worker = GearmanWorker(["127.0.0.1"])
worker.register_task('ping', pingTask)
print 'Starting gearman ping worker'
-worker.work() \ No newline at end of file
+worker.work()