From 2f3c9bf79b0330962009411d756235ec80d68780 Mon Sep 17 00:00:00 2001 From: pjing Date: Wed, 27 Feb 2019 12:19:36 -0800 Subject: [PATCH] Enable return error in worker Echo() --- worker/worker.go | 12 ++++++++---- 1 file changed, 8 insertions(+), 4 deletions(-) diff --git a/worker/worker.go b/worker/worker.go index e23ee4e..4565f6f 100644 --- a/worker/worker.go +++ b/worker/worker.go @@ -79,10 +79,14 @@ func (worker *Worker) AddServer(net, addr string) (err error) { } // Broadcast an outpack to all Gearman server. -func (worker *Worker) broadcast(outpack *outPack) { +func (worker *Worker) broadcast(outpack *outPack) (err error) { for _, v := range worker.agents { - v.write(outpack) + err = v.write(outpack) + if err != nil { + return + } } + return nil } // Add a function. @@ -258,11 +262,11 @@ func (worker *Worker) Reconnect() error { } // Echo -func (worker *Worker) Echo(data []byte) { +func (worker *Worker) Echo(data []byte) error { outpack := getOutPack() outpack.dataType = rt.PT_EchoReq outpack.data = data - worker.broadcast(outpack) + return worker.broadcast(outpack) } // Remove all of functions.