OSDN Git Service

config networkID
authorHAOYUatHZ <haoyu@protonmail.com>
Mon, 12 Aug 2019 02:25:36 +0000 (10:25 +0800)
committerHAOYUatHZ <haoyu@protonmail.com>
Mon, 12 Aug 2019 02:25:36 +0000 (10:25 +0800)
docs/precog/config_example.json
toolbar/precog/config/config.go
toolbar/precog/monitor/monitor.go

index 472a210..eb2b6c1 100644 (file)
@@ -1,4 +1,5 @@
 {
+    "network_id": 10817814959495988245,
     "mysql" : {
         "connection" : {
             "host": "127.0.0.1",
index 09d03be..753bac3 100644 (file)
@@ -34,6 +34,7 @@ func NewConfigWithPath(path string) *Config {
 }
 
 type Config struct {
+       NetworkID        uint64             `json:"network_id"`
        MySQLConfig      common.MySQLConfig `json:"mysql"`
        CheckFreqSeconds uint64             `json:"check_frequency_seconds"`
        Policy           Policy             `json:"policy"`
index 6586a6f..e11a657 100644 (file)
@@ -24,8 +24,6 @@ import (
        "github.com/vapor/toolbar/precog/database/orm"
 )
 
-const vaporNetID = 10817814959495988245
-
 type monitor struct {
        cfg     *config.Config
        db      *gorm.DB
@@ -107,13 +105,13 @@ func (m *monitor) makeSwitch() (*p2p.Switch, error) {
        }
 
        l, listenAddr := p2p.GetListener(m.nodeCfg.P2P)
-       discv, err := dht.NewDiscover(m.nodeCfg, swPrivKey, l.ExternalAddress().Port, vaporNetID)
+       discv, err := dht.NewDiscover(m.nodeCfg, swPrivKey, l.ExternalAddress().Port, m.cfg.NetworkID)
        if err != nil {
                return nil, err
        }
 
        lanDiscv := mdns.NewLANDiscover(mdns.NewProtocol(), int(l.ExternalAddress().Port))
-       return p2p.NewSwitch(m.nodeCfg, discv, lanDiscv, l, swPrivKey, listenAddr, vaporNetID)
+       return p2p.NewSwitch(m.nodeCfg, discv, lanDiscv, l, swPrivKey, listenAddr, m.cfg.NetworkID)
 }
 
 func (m *monitor) monitorRountine() error {