From f3b4013e2b9f354734964d5faacbc021cfd77145 Mon Sep 17 00:00:00 2001 From: Paul Mach Date: Tue, 23 Apr 2013 11:45:57 -0700 Subject: [PATCH] Update and Receive status correctly --- client/client.go | 8 ++++---- worker/job.go | 1 + 2 files changed, 5 insertions(+), 4 deletions(-) diff --git a/client/client.go b/client/client.go index 5ad046e..b0265c6 100644 --- a/client/client.go +++ b/client/client.go @@ -265,14 +265,14 @@ func (client *Client) handleStatus(job *Job) { status.Known = (data[1][0] == '1') status.Running = (data[2][0] == '1') var err error - status.Numerator, err = strconv.ParseUint(string(data[3][0]), 10, 0) + status.Numerator, err = strconv.ParseUint(string(data[3]), 10, 0) if err != nil { - client.err(common.Errorf("Invalid handle: %s", data[3][0])) + client.err(common.Errorf("Invalid Integer: %s", data[3])) return } - status.Denominator, err = strconv.ParseUint(string(data[4][0]), 10, 0) + status.Denominator, err = strconv.ParseUint(string(data[4]), 10, 0) if err != nil { - client.err(common.Errorf("Invalid handle: %s", data[4][0])) + client.err(common.Errorf("Invalid Integer: %s", data[4])) return } client.status <- status diff --git a/worker/job.go b/worker/job.go index 01924d7..361fdce 100644 --- a/worker/job.go +++ b/worker/job.go @@ -112,6 +112,7 @@ func (job *Job) UpdateStatus(numerator, denominator int) { d := []byte(strconv.Itoa(denominator)) result := append([]byte(job.Handle), 0) result = append(result, n...) + result = append(result, '\x00') result = append(result, d...) job.agent.WriteJob(newJob(common.REQ, common.WORK_STATUS, result)) }