Commit ed7f546a authored by duanjinfei's avatar duanjinfei

add bit map print

parent e6786a62
......@@ -74,7 +74,7 @@ func HeartbeatResp(params ...interface{}) *nodemanagerV1.WorkerMessage {
}
func SubmitResourceMapRes(params ...interface{}) *nodemanagerV1.WorkerMessage {
log.Info("Heartbeat response received params: ", params)
log.Info("Submit resource map response received params: ", params)
taskIdLength := params[0].(uint64)
b := bitmap.New(taskIdLength)
for i := 1; i < len(params); i++ {
......@@ -90,6 +90,7 @@ func SubmitResourceMapRes(params ...interface{}) *nodemanagerV1.WorkerMessage {
log.Error("bitmap marshal binary failed with error: ", err)
return nil
}
log.WithField("", binary).Info("Bit map binary byte")
heartRes := &nodemanagerV1.WorkerMessage{
Message: &nodemanagerV1.WorkerMessage_ResourceMap{
ResourceMap: &nodemanagerV1.SubmitResourceMap{
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment