From 32be149ec5790510a697ec707defd21716316a94 Mon Sep 17 00:00:00 2001 From: andris9 Date: Wed, 23 Nov 2011 15:24:42 +0200 Subject: [PATCH] updated readme --- examples/client.js | 12 +++++------- examples/streamClient.js | 2 +- examples/streamWorker.js | 2 +- examples/worker.js | 24 +++++++++++------------- 4 files changed, 18 insertions(+), 22 deletions(-) diff --git a/examples/client.js b/examples/client.js index 46f53b1..75fc2a0 100644 --- a/examples/client.js +++ b/examples/client.js @@ -1,18 +1,16 @@ var Gearman = require("../lib/gearman"), - gearman = new Gearman("pangalink.net"); + gearman = new Gearman(); // defaults to localhost -var job = gearman.submitJob("reverse", "test"); +var job = gearman.submitJob("reverse", "test string"); job.on("error", function(err){ console.log("ERROR: ", err.message || err); }); -job.on("data", function(chunk){ - if(chunk){ - console.log(chunk.toString()); - } +job.on("data", function(reversed){ + console.log(reversed.toString()); }); job.on("end", function(){ console.log("Ready!"); -}); +}); \ No newline at end of file diff --git a/examples/streamClient.js b/examples/streamClient.js index 3a6f5eb..7361bf1 100644 --- a/examples/streamClient.js +++ b/examples/streamClient.js @@ -1,6 +1,6 @@ var Gearman = require("../lib/gearman"), fs = require("fs"), - gearman = new Gearman("pangalink.net"); + gearman = new Gearman(); // defaults to localhost var job = gearman.submitJob("stream", null), output = fs.createWriteStream(__dirname+"/../../wordlist.txt.copy"); diff --git a/examples/streamWorker.js b/examples/streamWorker.js index 6df99e1..7c95dad 100644 --- a/examples/streamWorker.js +++ b/examples/streamWorker.js @@ -1,7 +1,7 @@ var Gearman = require("../lib/gearman"), fs = require("fs"); -var gearman = new Gearman("pangalink.net",0,1); +var gearman = new Gearman(); // defaults to localhost var filepath = __dirname+"/../../wordlist.txt"; diff --git a/examples/worker.js b/examples/worker.js index 0e09705..d264e31 100644 --- a/examples/worker.js +++ b/examples/worker.js @@ -1,18 +1,16 @@ var Gearman = require("../lib/gearman"), - gearman = new Gearman("pangalink.net"); + gearman = new Gearman(); // defaults to localhost gearman.registerWorker("reverse", function(payload, worker){ - var str = "", i; - payload = payload.toString("utf-8"); - - var counter = 0; - var timer = setInterval(function(){ - counter++; - worker.write(counter); - if(counter>=10){ - worker.error(); - clearInterval(timer); - } - }, 1000); + if(!payload){ + worker.error(); + return; + } + var reversed = payload.toString("utf-8").split("").reverse().join(""); + // delay for 1 sec before returning + setTimeout(function(){ + worker.end(reversed); + },1000); + });