diff --git a/example/client.go b/example/client.go index c138790..c41d24a 100644 --- a/example/client.go +++ b/example/client.go @@ -40,13 +40,4 @@ func main() { } else { log.Println("Not running") } - log.Println("read") - if job, err := client.ReadJob(); err != nil { - log.Println(err) - } else { - data, err := job.Result(); - log.Println(err) - log.Println(data) - } - } diff --git a/src/pkg/gearman/client.go b/src/pkg/gearman/client.go index 25c50f1..55577a3 100644 --- a/src/pkg/gearman/client.go +++ b/src/pkg/gearman/client.go @@ -4,7 +4,7 @@ import ( "os" "net" "sync" -// "log" + "log" "strconv" ) @@ -182,8 +182,12 @@ func (client *Client) Status(handle string) (known, running bool, numerator, den } known = data[1][0] == '1' running = data[2][0] == '1' - numerator = uint(data[3][0]) - denominator = uint(data[4][0]) + if numerator, err = strconv.Atoui(string(data[3][0])); err != nil { + return + } + if denominator, err = strconv.Atoui(string(data[4][0])); err != nil { + return + } return } @@ -195,7 +199,7 @@ func (client *Client) Echo(data []byte) (echo []byte, err os.Error) { if job, err = client.readLastJob(ECHO_RES); err != nil { return } - echo, err = job.Result() + echo = job.Data return }