fix/(curveadm-deploy): create pool need calc chunkservers

Signed-off-by: caoxianfei1 <[email protected]>
opencurve · Nov 23, 2023 · 003ad85 · 003ad85
1 parent 2728b7d
commit 003ad85
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 0 deletions.
diff --git a/cli/command/deploy.go b/cli/command/deploy.go
@@ -252,10 +252,12 @@ func genDeployPlaybook(curveadm *cli.CurveAdm,
 		if step == CREATE_PHYSICAL_POOL {
 			options[comm.KEY_CREATE_POOL_TYPE] = comm.POOL_TYPE_PHYSICAL
 			options[comm.KEY_POOLSET] = poolset
+			options[comm.KEY_NUMBER_OF_CHUNKSERVER] = calcNumOfChunkserver(curveadm, dcs)
 		} else if step == CREATE_LOGICAL_POOL {
 			options[comm.KEY_CREATE_POOL_TYPE] = comm.POOL_TYPE_LOGICAL
 			options[comm.POOLSET] = poolset
 			options[comm.POOLSET_DISK_TYPE] = diskType
+			options[comm.KEY_NUMBER_OF_CHUNKSERVER] = calcNumOfChunkserver(curveadm, dcs)
 		}
 
 		pb.AddStep(&playbook.PlaybookStep{

diff --git a/cli/command/scale_out.go b/cli/command/scale_out.go
@@ -339,6 +339,8 @@ func genScaleOutPlaybook(curveadm *cli.CurveAdm,
 			options[comm.KEY_CREATE_POOL_TYPE] = comm.POOL_TYPE_PHYSICAL
 			options[comm.KEY_SCALE_OUT_CLUSTER] = dcs2scaleOut
 			options[comm.KEY_NEW_TOPOLOGY_DATA] = data
+			options[comm.KEY_NUMBER_OF_CHUNKSERVER] = calcNumOfChunkserver(curveadm, dcs) +
+				calcNumOfChunkserver(curveadm, dcs2scaleOut)
 			options[comm.KEY_POOLSET] = poolset
 		case CREATE_LOGICAL_POOL:
 			options[comm.KEY_CREATE_POOL_TYPE] = comm.POOL_TYPE_LOGICAL