OSDN Git Service

add
authorHAOYUatHZ <haoyu@protonmail.com>
Thu, 8 Aug 2019 08:07:25 +0000 (16:07 +0800)
committerHAOYUatHZ <haoyu@protonmail.com>
Thu, 8 Aug 2019 08:07:25 +0000 (16:07 +0800)
toolbar/precog/monitor/monitor.go

index 41d6ce8..3549ad5 100644 (file)
@@ -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 {