zlei6/go-zero
1
0
Fork 0
mirror of https://github.com/zeromicro/go-zero.git synced 2026-05-14 02:10:00 +08:00
Code Issues Packages Projects Releases Wiki Activity

test(hash): modify TestConsistentHashTransferOnFailure to more reasonable test transfer ratio (#4874)

Browse Source
This commit is contained in:
燕归来
2025-05-20 20:51:50 +08:00
committed by GitHub
parent 4d3681b71c
commit 15eb6f4f6d
1 changed files with 10 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
core/hash/consistenthash_test.go
View File

@@ -86,6 +86,14 @@ func TestConsistentHashIncrementalTransfer(t *testing.T) {
func TestConsistentHashTransferOnFailure(t *testing.T) { func TestConsistentHashTransferOnFailure(t *testing.T) {
index := 41 index := 41
ratioNotExists := getTransferRatioOnFailure(t, index)
assert.True(t, ratioNotExists == 0, fmt.Sprintf("%d: %f", index, ratioNotExists))
index = 13
ratio := getTransferRatioOnFailure(t, index)
assert.True(t, ratio < 2.5/keySize, fmt.Sprintf("%d: %f", index, ratio))
}
func getTransferRatioOnFailure(t *testing.T, index int) float32 {
keys, newKeys := getKeysBeforeAndAfterFailure(t, "localhost:", index) keys, newKeys := getKeysBeforeAndAfterFailure(t, "localhost:", index)
var transferred int var transferred int
for k, v := range newKeys { for k, v := range newKeys {
@@ -93,14 +101,12 @@ func TestConsistentHashTransferOnFailure(t *testing.T) {
transferred++ transferred++
} }
} }
return float32(transferred) / float32(requestSize)
ratio := float32(transferred) / float32(requestSize)
assert.True(t, ratio < 2.5/float32(keySize), fmt.Sprintf("%d: %f", index, ratio))
} }
func TestConsistentHashLeastTransferOnFailure(t *testing.T) { func TestConsistentHashLeastTransferOnFailure(t *testing.T) {
prefix := "localhost:" prefix := "localhost:"
index := 41 index := 13
keys, newKeys := getKeysBeforeAndAfterFailure(t, prefix, index) keys, newKeys := getKeysBeforeAndAfterFailure(t, prefix, index)
for k, v := range keys { for k, v := range keys {
newV := newKeys[k] newV := newKeys[k]