return nil, err
}
- // lanDiscv := mdns.NewLANDiscover(mdns.NewProtocol(), int(l.ExternalAddress().Port))
- // return newSwitch(config, discv, lanDiscv, l, *privateKey, listenAddr, netID)
- return nil, nil
+ lanDiscv := mdns.NewLANDiscover(mdns.NewProtocol(), int(l.ExternalAddress().Port))
+ sw := &p2p.Switch{
+ Config: config,
+ peerConfig: p2p.DefaultPeerConfig(m.nodeCfg.P2P),
+ reactors: make(map[string]p2p.Reactor),
+ chDescs: make([]*conn.ChannelDescriptor, 0),
+ reactorsByCh: make(map[byte]Reactor),
+ peers: p2p.NewPeerSet(),
+ dialing: cmn.NewCMap(),
+ nodePrivKey: swPrivKey,
+ discv: discv,
+ lanDiscv: lanDiscv,
+ nodeInfo: p2p.NewNodeInfo(m.nodeCfg, swPrivKey.XPub(), listenAddr, netID),
+ security: security.NewSecurity(m.nodeCfg),
+ }
+ sw.AddListener(l)
+ sw.BaseService = *cmn.NewBaseService(nil, "P2P Switch", sw)
+ return sw, nil
}
func (m *monitor) monitorRountine() error {