Function testCalcParticipantPeers

consensus/vbft/node_utils_test.go:180–232

(t *testing.T, n, c int)

}

func testCalcParticipantPeers(t *testing.T, n, c int) {
	server := constructServer()

	pos := make([]uint32, 0)
	for i := 0; i < n; i++ {
		for j := 0; j < 4; j++ {
			pos = append(pos, uint32(i))
		}
	}

	chainCfg := server.config
	chainCfg.N = uint32(n)
	chainCfg.C = uint32(c)
	chainCfg.PosTable = pos
	chainCfg.Peers = make([]*vconfig.PeerConfig, 0)
	for i := 0; i < n; i++ {
		chainCfg.Peers = append(chainCfg.Peers, &vconfig.PeerConfig{
			Index: uint32(i),
			ID:    fmt.Sprintf("test-%d", i)})
	}

	cfg := &BlockParticipantConfig{
		BlockNum:    100,
		Vrf:         newTestVrfValue(),
		ChainConfig: chainCfg,
	}

	pp, pe, pc := calcParticipantPeers(cfg, chainCfg)
	if len(pp) != c+1 {
		t.Fatalf("invalid proposal peer(%d, %d): %v, %v, %v", n, c, pp, pe, pc)
	}
	if len(pe) < 2*c {
		t.Fatalf("invalid endorse peer(%d, %d): %v, %v, %v", n, c, pp, pe, pc)
	}
	if len(pc) < 2*c {
		t.Fatalf("invalid commit peer(%d, %d): %v, %v, %v", n, c, pp, pe, pc)
	}

	// check how many peers are selected
	peers := make(map[uint32]bool)
	for _, p := range pp {
		peers[p] = true
	}
	for _, p := range pe {
		peers[p] = true
	}
	for _, p := range pc {
		peers[p] = true
	}
	if len(peers) < 2*c+1 {
		t.Fatalf("peers(%d, %d, %d, %d, %d, %d): %v, %v, %v", n, c, len(peers), len(pp), len(pe), len(pc), pp, pe, pc)
	}
}