From 8717fc40f23e52c458100fbe5ce3086a46a61767 Mon Sep 17 00:00:00 2001 From: HAOYUatHZ Date: Thu, 8 Aug 2019 16:07:25 +0800 Subject: [PATCH] add --- toolbar/precog/monitor/monitor.go | 21 ++++++++++++++++++--- 1 file changed, 18 insertions(+), 3 deletions(-) diff --git a/toolbar/precog/monitor/monitor.go b/toolbar/precog/monitor/monitor.go index 41d6ce88..3549ad5a 100644 --- a/toolbar/precog/monitor/monitor.go +++ b/toolbar/precog/monitor/monitor.go @@ -125,9 +125,24 @@ func (m *monitor) makeSwitch() (*p2p.Switch, error) { 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 { -- 2.11.0