(t *testing.T)
| 470 | } |
| 471 | |
| 472 | func TestGetNFilterRole(t *testing.T) { |
| 473 | kms.Unittest = true |
| 474 | utils.RemoveAll(testStorePath + "*") |
| 475 | kms.ResetBucket() |
| 476 | |
| 477 | x, _ := InitConsistent(testStorePath, new(KMSStorage), false) |
| 478 | defer utils.RemoveAll(testStorePath + "*") |
| 479 | n := NewNodeFromString("0000000000000000000000000000000000000000000000000000000000000000") |
| 480 | n.Role = Leader |
| 481 | x.Add(n) |
| 482 | x.Add(NewNodeFromString("1111111111111111111111111111111111111111111111111111111111111111")) |
| 483 | x.Add(NewNodeFromString("2222222222222222222222222222222222222222222222222222222222222222")) |
| 484 | members, err := x.GetNeighborsEx("9999999", 3, ServerRoles{Unknown}) |
| 485 | if err != nil { |
| 486 | t.Fatal(err) |
| 487 | } |
| 488 | if len(members) != 2 { |
| 489 | t.Errorf("expected 2 members instead of %d", len(members)) |
| 490 | } |
| 491 | if members[0].ID != "2222222222222222222222222222222222222222222222222222222222222222" { |
| 492 | t.Errorf("wrong members[0]: %v", members[0]) |
| 493 | } |
| 494 | if members[1].ID != "1111111111111111111111111111111111111111111111111111111111111111" { |
| 495 | t.Errorf("wrong members[1]: %v", members[1]) |
| 496 | } |
| 497 | |
| 498 | members, err = x.GetNeighborsEx("9999999", 3, ServerRoles{Leader, Follower}) |
| 499 | if err != nil { |
| 500 | t.Fatal(err) |
| 501 | } |
| 502 | if len(members) != 1 { |
| 503 | t.Errorf("expected 1 members instead of %d", len(members)) |
| 504 | } |
| 505 | if members[0].ID != "0000000000000000000000000000000000000000000000000000000000000000" { |
| 506 | t.Errorf("wrong members[0]: %v", members[0]) |
| 507 | } |
| 508 | } |
| 509 | |
| 510 | func TestGetNLess(t *testing.T) { |
| 511 | kms.Unittest = true |
nothing calls this directly
no test coverage detected