Browse Source

revert removing private peers from persistent

pull/1282/head
Anton Kaliaev 7 years ago
parent
commit
2a258a2c3f
No known key found for this signature in database GPG Key ID: 7B6881D965918214
4 changed files with 4 additions and 30 deletions
  1. +1
    -0
      config/config.go
  2. +1
    -0
      config/toml.go
  3. +1
    -0
      docs/specification/configuration.rst
  4. +1
    -30
      node/node.go

+ 1
- 0
config/config.go View File

@ -251,6 +251,7 @@ type P2PConfig struct {
Seeds string `mapstructure:"seeds"`
// Comma separated list of nodes to keep persistent connections to
// Do not add private peers to this list if you don't want them advertised
PersistentPeers string `mapstructure:"persistent_peers"`
// Skip UPNP port forwarding


+ 1
- 0
config/toml.go View File

@ -127,6 +127,7 @@ laddr = "{{ .P2P.ListenAddress }}"
seeds = ""
# Comma separated list of nodes to keep persistent connections to
# Do not add private peers to this list if you don't want them advertised
persistent_peers = ""
# Path to address book


+ 1
- 0
docs/specification/configuration.rst View File

@ -89,6 +89,7 @@ like the file below, however, double check by inspecting the
seeds = ""
# Comma separated list of nodes to keep persistent connections to
# Do not add private peers to this list if you don't want them advertised
persistent_peers = ""
# Path to address book


+ 1
- 30
node/node.go View File

@ -422,39 +422,10 @@ func (n *Node) OnStart() error {
// Always connect to persistent peers
if n.config.P2P.PersistentPeers != "" {
// are any of the persistent peers private?
persistentPeers := []string{}
persistentAndPrivatePeers := []string{}
var privatePeerIDs []string
if n.config.P2P.PrivatePeerIDs != "" {
privatePeerIDs = strings.Split(n.config.P2P.PrivatePeerIDs, ",")
}
PP_LOOP:
for _, peer := range strings.Split(n.config.P2P.PersistentPeers, ",") {
spl := strings.Split(peer, "@")
if len(spl) == 2 {
for _, ppID := range privatePeerIDs {
if spl[0] == ppID {
persistentAndPrivatePeers = append(persistentAndPrivatePeers, peer)
continue PP_LOOP
}
}
}
persistentPeers = append(persistentPeers, peer)
}
err = n.sw.DialPeersAsync(n.addrBook, persistentPeers, true)
err = n.sw.DialPeersAsync(n.addrBook, strings.Split(n.config.P2P.PersistentPeers, ","), true)
if err != nil {
return err
}
// if any of the persistent peers are private, do not add them to addrbook
if len(persistentAndPrivatePeers) > 0 {
err = n.sw.DialPeersAsync(nil, persistentAndPrivatePeers, true)
if err != nil {
return err
}
}
}
// start tx indexer


Loading…
Cancel
Save