Function initBPNodeIDs

route/dns.go:123–174

initBPNodeIDs initializes BlockProducer route and map from config file and DNS Seed.

()

// initBPNodeIDs initializes BlockProducer route and map from config file and DNS Seed.
func initBPNodeIDs() (bpNodeIDs NodeIDAddressMap) {
	if conf.GConf == nil {
		log.Fatal("call conf.LoadConfig to init conf first")
	}

	// clear address map before init
	resolver.bpNodeIDs = make(NodeIDAddressMap)
	bpNodeIDs = resolver.bpNodeIDs

	var err error

	if conf.GConf.DNSSeed.Domain != "" {
		var bpIndex int
		dc := IPv6SeedClient{}
		bpIndex = rand.Intn(conf.GConf.DNSSeed.BPCount)
		bpDomain := fmt.Sprintf("bp%02d.%s", bpIndex, conf.GConf.DNSSeed.Domain)
		log.Infof("Geting bp address from dns: %v", bpDomain)
		resolver.bpNodes, err = dc.GetBPFromDNSSeed(bpDomain)
		if err != nil {
			log.WithField("seed", bpDomain).WithError(err).Error(
				"getting BP info from DNS failed")
			return
		}
	}

	if resolver.bpNodes == nil {
		resolver.bpNodes = make(IDNodeMap)
	}
	if conf.GConf.KnownNodes != nil {
		for _, n := range conf.GConf.KnownNodes {
			rawID := n.ID.ToRawNodeID()
			if rawID != nil {
				if n.Role == proto.Leader || n.Role == proto.Follower {
					resolver.bpNodes[*rawID] = n
				}
				setNodeAddrCache(rawID, n.Addr)
			}
		}
	}

	conf.GConf.SeedBPNodes = make([]proto.Node, 0, len(resolver.bpNodes))
	for _, n := range resolver.bpNodes {
		rawID := n.ID.ToRawNodeID()
		if rawID != nil {
			conf.GConf.SeedBPNodes = append(conf.GConf.SeedBPNodes, n)
			setNodeAddrCache(rawID, n.Addr)
			resolver.bpNodeIDs[*rawID] = n.Addr
		}
	}

	return resolver.bpNodeIDs
}

// GetBPs returns the known BP node id list.
func GetBPs() (bpAddrs []proto.NodeID) {