summaryrefslogtreecommitdiff
path: root/worker.go
diff options
context:
space:
mode:
authorWolfy-J <[email protected]>2019-06-29 23:58:57 +0300
committerWolfy-J <[email protected]>2019-06-29 23:58:57 +0300
commit53ed5e5dc6836ac1d6222fed602204257583a549 (patch)
tree1f637b61cf629bec4dde74ba4ea9b0e1ad5fbd33 /worker.go
parent297031a523070040cf2de63b409135c5098bc393 (diff)
parent216b6a3d3717f9212c94721d1a1b89d3730f419c (diff)
Merge remote-tracking branch 'origin/master'
Diffstat (limited to 'worker.go')
-rw-r--r--worker.go4
1 files changed, 3 insertions, 1 deletions
diff --git a/worker.go b/worker.go
index ac0ba38e..a95a80b3 100644
--- a/worker.go
+++ b/worker.go
@@ -230,7 +230,9 @@ func (w *Worker) execPayload(rqs *Payload) (rsp *Payload, err error) {
return nil, errors.Wrap(err, "header error")
}
- w.rl.Send(rqs.Body, 0)
+ if err = w.rl.Send(rqs.Body, 0); err != nil {
+ return nil, errors.Wrap(err, "sender error")
+ }
var pr goridge.Prefix
rsp = new(Payload)