From f333ba6102e529d657f89610a105c5b543a5cae5 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Christoffer=20Fjellstr=C3=B6m?= Date: Wed, 13 Feb 2019 11:45:35 +0100 Subject: [PATCH] Fix job register with timeout set Fixed issue where timeout is sent as binary encoded uint but server expects a string --- worker/worker.go | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) diff --git a/worker/worker.go b/worker/worker.go index 25d6a60..dbaf49d 100644 --- a/worker/worker.go +++ b/worker/worker.go @@ -3,10 +3,10 @@ package worker import ( - "encoding/binary" "fmt" "sync" "time" + "strconv" ) const ( @@ -106,10 +106,12 @@ func prepFuncOutpack(funcname string, timeout uint32) *outPack { } else { outpack.dataType = dtCanDoTimeout l := len(funcname) - outpack.data = getBuffer(l + 5) + + timeoutString := strconv.FormatUint(uint64(timeout), 10) + outpack.data = getBuffer(l + len(timeoutString) + 1) copy(outpack.data, []byte(funcname)) outpack.data[l] = '\x00' - binary.BigEndian.PutUint32(outpack.data[l+1:], timeout) + copy(outpack.data[l+1:], []byte(timeoutString)) } return outpack }