Function buildBlockProducerInfos

blockproducer/bpinfo.go:37–80

(
	localNodeID proto.NodeID, peers *proto.Peers, isAPINode bool,
)

}

func buildBlockProducerInfos(
	localNodeID proto.NodeID, peers *proto.Peers, isAPINode bool,
) (
	localBPInfo *blockProducerInfo, bpInfos []*blockProducerInfo, err error,
) {
	var (
		total = len(peers.PeersHeader.Servers)
		index int32
		found bool
	)

	bpInfos = make([]*blockProducerInfo, total)
	for i, v := range peers.PeersHeader.Servers {
		var role = "F"
		if v == peers.Leader {
			role = "L"
		}
		bpInfos[i] = &blockProducerInfo{
			rank:   uint32(i),
			total:  uint32(total),
			role:   role,
			nodeID: v,
		}
	}

	if isAPINode {
		localBPInfo = &blockProducerInfo{
			rank:   0,
			total:  uint32(total),
			role:   "A",
			nodeID: localNodeID,
		}
		return localBPInfo, bpInfos, nil
	}

	if index, found = peers.Find(localNodeID); !found {
		err = ErrLocalNodeNotFound
		return
	}

	localBPInfo = bpInfos[index]

	return
}