Method Connect

p2pserver/net/netserver/netserver.go:252–325

Connect used to connect net address under sync or cons mode

(addr string)

//Connect used to connect net address under sync or cons mode
func (this *NetServer) Connect(addr string) error {
	if this.IsAddrInOutConnRecord(addr) {
		log.Debugf("[p2p]Address: %s is in OutConnectionRecord,", addr)
		return nil
	}
	if this.IsOwnAddress(addr) {
		return nil
	}
	if !this.AddrValid(addr) {
		return nil
	}

	this.connectLock.Lock()
	connCount := uint(this.GetOutConnRecordLen())
	if connCount >= config.DefConfig.P2PNode.MaxConnOutBound {
		log.Warnf("[p2p]Connect: out connections(%d) reach the max limit(%d)", connCount,
			config.DefConfig.P2PNode.MaxConnOutBound)
		this.connectLock.Unlock()
		return errors.New("[p2p]connect: out connections reach the max limit")
	}
	this.connectLock.Unlock()

	if this.IsNbrPeerAddr(addr) {
		return nil
	}
	this.connectLock.Lock()
	if addOK := this.AddOutConnectingList(addr); !addOK {
		log.Debug("[p2p]node exist in connecting list", addr)
	}
	this.connectLock.Unlock()

	isTls := config.DefConfig.P2PNode.IsTLS
	var conn net.Conn
	var err error
	var remotePeer *peer.Peer
	if isTls {
		conn, err = TLSDial(addr)
		if err != nil {
			this.RemoveFromConnectingList(addr)
			log.Debugf("[p2p]connect %s failed:%s", addr, err.Error())
			return err
		}
	} else {
		conn, err = nonTLSDial(addr)
		if err != nil {
			this.RemoveFromConnectingList(addr)
			log.Debugf("[p2p]connect %s failed:%s", addr, err.Error())
			return err
		}
	}

	addr = conn.RemoteAddr().String()
	log.Debugf("[p2p]peer %s connect with %s with %s",
		conn.LocalAddr().String(), conn.RemoteAddr().String(),
		conn.RemoteAddr().Network())

	this.AddOutConnRecord(addr)
	remotePeer = peer.NewPeer()