(t *testing.T)
| 616 | } |
| 617 | |
| 618 | func TestGetNLessQuick(t *testing.T) { |
| 619 | kms.Unittest = true |
| 620 | utils.RemoveAll(testStorePath + "*") |
| 621 | kms.ResetBucket() |
| 622 | |
| 623 | x, _ := InitConsistent(testStorePath, new(KMSStorage), false) |
| 624 | defer utils.RemoveAll(testStorePath + "*") |
| 625 | x.Add(NewNodeFromString("0000000000000000000000000000000000000000000000000000000000000000")) |
| 626 | x.Add(NewNodeFromString("1111111111111111111111111111111111111111111111111111111111111111")) |
| 627 | x.Add(NewNodeFromString("2222222222222222222222222222222222222222222222222222222222222222")) |
| 628 | f := func(s string) bool { |
| 629 | members, err := x.GetNeighbors(s, 2) |
| 630 | if err != nil { |
| 631 | t.Logf("error: %v", err) |
| 632 | return false |
| 633 | } |
| 634 | if len(members) != 2 { |
| 635 | t.Logf("expected 2 members instead of %d", len(members)) |
| 636 | return false |
| 637 | } |
| 638 | set := make(map[NodeID]Node, 4) |
| 639 | for _, member := range members { |
| 640 | if set[member.ID].ID != "" { |
| 641 | t.Log("duplicate error") |
| 642 | return false |
| 643 | } |
| 644 | set[member.ID] = Node{} |
| 645 | if member.ID != "0000000000000000000000000000000000000000000000000000000000000000" && member.ID != "1111111111111111111111111111111111111111111111111111111111111111" && member.ID != "2222222222222222222222222222222222222222222222222222222222222222" { |
| 646 | t.Logf("invalid member: %v", member) |
| 647 | return false |
| 648 | } |
| 649 | } |
| 650 | return true |
| 651 | } |
| 652 | if err := quick.Check(f, nil); err != nil { |
| 653 | t.Fatal(err) |
| 654 | } |
| 655 | } |
| 656 | |
| 657 | func TestGetNMoreQuick(t *testing.T) { |
| 658 | kms.Unittest = true |
nothing calls this directly
no test coverage detected