From d2301626cdb4833a5296b7cf27b47319b97d9581 Mon Sep 17 00:00:00 2001
From: mikespook <none@none>
Date: Mon, 28 May 2012 10:56:01 +0800
Subject: [PATCH] fixed the infinite loop issue

---
 worker/agent.go | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/worker/agent.go b/worker/agent.go
index a8ff6d2..c997878 100644
--- a/worker/agent.go
+++ b/worker/agent.go
@@ -36,8 +36,9 @@ func newAgent(addr string, worker *Worker) (a *agent, err error) {
 // outputing loop
 func (a *agent) outLoop() {
     ok := true
+    var job *Job
     for ok {
-        if job, ok := <-a.out; ok {
+        if job, ok = <-a.out; ok {
             if err := a.write(job.Encode()); err != nil {
                 a.worker.err(err)
             }