Commit b5dd802d authored by duanjinfei's avatar duanjinfei

update bit map submit

parent fe4d3e03
...@@ -77,7 +77,7 @@ func SubmitResourceMapRes(params ...interface{}) *nodemanagerV1.WorkerMessage { ...@@ -77,7 +77,7 @@ func SubmitResourceMapRes(params ...interface{}) *nodemanagerV1.WorkerMessage {
log.Info("Submit resource map response received params: ", params) log.Info("Submit resource map response received params: ", params)
taskIdIndexes := params[0].([]uint64) taskIdIndexes := params[0].([]uint64)
taskIdLength := taskIdIndexes[len(taskIdIndexes)-1] taskIdLength := taskIdIndexes[len(taskIdIndexes)-1]
b := bitmap.New(taskIdLength) b := bitmap.New(taskIdLength + 1)
for i := 0; i < len(taskIdIndexes)-1; i++ { for i := 0; i < len(taskIdIndexes)-1; i++ {
taskIdIndex := taskIdIndexes[i] taskIdIndex := taskIdIndexes[i]
err := b.Set(taskIdIndex) err := b.Set(taskIdIndex)
......
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