update

server/workerManager.go

@@ -141,8 +141,13 @@ func (wm *WorkerManager) AddNewWorker(uuid int64, worker omanager.NodeManagerSer
 type Callback func(err error) bool
 
 func (wm *WorkerManager) doCallback(hook string, response *odysseus.TaskResponse) {
-	d, _ := proto.Marshal(response)
-	err := utils.Post(hook, d)
+	d, err := proto.Marshal(response)
+	if err != nil {
+		log.WithError(err).Error("marshal task response failed")
+	} else {
+		log.WithField("taskid", response.TaskUuid).Debug("marshal task response")
+	}
+	err = utils.Post(hook, d)
 	if err != nil {
 		log.WithError(err).Error("post task result failed")
 	} else {

utils/post.go

@@ -2,9 +2,14 @@ package utils
 
 import (
 	"github.com/astaxie/beego/httplib"
+	log "github.com/sirupsen/logrus"
 )
 
 func Post(url string, data []byte) error {
+	log.WithFields(log.Fields{
+		"url":     url,
+		"datalen": len(data),
+	})
 	_, err := httplib.Post(url).Body(data).Response()
 	if err != nil {
 		return err