check cpu suffience when realloc

Author: jschwinger233

cluster/calcium/realloc.go

@@ -138,6 +138,10 @@ func (c *Calcium) doReallocContainer(ctx context.Context, ch chan *types.Realloc
 							}
 							// 得到最终方案
 							cpusets = nodeCPUPlans[node.Name][:containerWithCPUBind]
+						} else if newCPU != 0 { // nolint
+							if cap := float64(len(node.InitCPU)) / newCPU; int(cap) < len(containers) {
+								return types.NewDetailedErr(types.ErrInsufficientCPU, node.Name)
+							}
 						}
 
 						newResource := &enginetypes.VirtualizationResource{

cluster/calcium/realloc_test.go

@@ -50,6 +50,7 @@ func TestRealloc(t *testing.T) {
 		Name:       "node1",
 		MemCap:     int64(units.GiB),
 		CPU:        types.CPUMap{"0": 10, "1": 70, "2": 10, "3": 100},
+		InitCPU:    types.CPUMap{"0": 100, "1": 100, "2": 100, "3": 100},
 		Engine:     engine,
 		Endpoint:   "http://1.1.1.1:1",
 		NUMA:       types.NUMA{"2": "0"},
@@ -210,6 +211,7 @@ func TestRealloc(t *testing.T) {
 		Name:       "node2",
 		MemCap:     int64(units.GiB),
 		CPU:        types.CPUMap{"0": 10, "1": 70, "2": 10, "3": 100},
+		InitCPU:    types.CPUMap{"0": 100, "1": 100, "2": 100, "3": 100},
 		Engine:     engine,
 		Endpoint:   "http://1.1.1.1:1",
 		NUMA:       types.NUMA{"2": "0"},
@@ -445,6 +447,7 @@ func TestReallocBindCpu(t *testing.T) {
 		Name:       "node3",
 		MemCap:     int64(units.GiB),
 		CPU:        types.CPUMap{"0": 10, "1": 70, "2": 10, "3": 100},
+		InitCPU:    types.CPUMap{"0": 100, "1": 100, "2": 100, "3": 100},
 		CPUUsed:    2.1,
 		Engine:     engine,
 		Endpoint:   "http://1.1.1.1:1",