Function BenchmarkRebalance

bench/integration/act_bench_test.go:152–186

(b *testing.B)

}

func BenchmarkRebalance(b *testing.B) {
	const (
		bckSize = cos.GiB
	)
	var (
		proxyURL   = tutils.RandomProxyURL()
		baseParams = tutils.BaseAPIParams(proxyURL)
		bck        = cmn.Bck{
			Name:     "bench-reb",
			Provider: apc.ProviderAIS,
		}
	)

	for _, size := range objSizes {
		objCount := int(bckSize/size) + 1
		tutils.CreateBucketWithCleanup(b, proxyURL, bck, nil)

		smap, err := api.GetClusterMap(baseParams)
		tassert.CheckFatal(b, err)
		tgtLost, err := smap.GetRandTarget()
		tassert.CheckFatal(b, err)

		args := &apc.ActValRmNode{DaemonID: tgtLost.ID(), SkipRebalance: true}
		_, err = api.StartMaintenance(baseParams, args)
		tassert.CheckFatal(b, err)
		fillBucket(b, proxyURL, bck, uint64(size), objCount)

		b.Run("rebalance", func(b *testing.B) {
			args := &apc.ActValRmNode{DaemonID: tgtLost.ID()}
			_, err := api.StopMaintenance(baseParams, args)
			tassert.CheckError(b, err)
			tutils.WaitForRebalAndResil(b, baseParams, rebalanceTime)
		})
	}
}