Fix job register with timeout set

Fixed issue where timeout is sent as binary encoded uint but server expects a string
mikespook · Feb 13, 2019 · f333ba6 · f333ba6
1 parent d0e6ec4
commit f333ba6
Showing 1 changed file with 5 additions and 3 deletions.
diff --git 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
 }