revert changes to geth_node.go
This commit is contained in:
parent
e8c1421997
commit
e80e6d5b02
|
@ -3,7 +3,6 @@ package node
|
||||||
import (
|
import (
|
||||||
"errors"
|
"errors"
|
||||||
"fmt"
|
"fmt"
|
||||||
"net"
|
|
||||||
"os"
|
"os"
|
||||||
"path/filepath"
|
"path/filepath"
|
||||||
|
|
||||||
|
@ -65,36 +64,6 @@ func MakeNode(config *params.NodeConfig, accs *accounts.Manager, db *leveldb.DB)
|
||||||
return stack, nil
|
return stack, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
func getUsableTCPPort() (int, error) {
|
|
||||||
conn, err := net.ListenTCP("tcp", &net.TCPAddr{
|
|
||||||
IP: net.IPv4zero,
|
|
||||||
Port: 0,
|
|
||||||
})
|
|
||||||
if err != nil {
|
|
||||||
return 0, err
|
|
||||||
}
|
|
||||||
defer conn.Close()
|
|
||||||
return conn.Addr().(*net.TCPAddr).Port, nil
|
|
||||||
}
|
|
||||||
|
|
||||||
func handleListenAddr(listenAddr string) (string, error) {
|
|
||||||
if listenAddr == "" {
|
|
||||||
return "", nil
|
|
||||||
}
|
|
||||||
ip, port, err := net.SplitHostPort(listenAddr)
|
|
||||||
if err != nil {
|
|
||||||
return "", err
|
|
||||||
}
|
|
||||||
if port == "0" {
|
|
||||||
randomPort, err := getUsableTCPPort()
|
|
||||||
if err != nil {
|
|
||||||
return "", err
|
|
||||||
}
|
|
||||||
listenAddr = net.JoinHostPort(ip, fmt.Sprintf("%d", randomPort))
|
|
||||||
}
|
|
||||||
return listenAddr, nil
|
|
||||||
}
|
|
||||||
|
|
||||||
// newGethNodeConfig returns default stack configuration for mobile client node
|
// newGethNodeConfig returns default stack configuration for mobile client node
|
||||||
func newGethNodeConfig(config *params.NodeConfig) (*node.Config, error) {
|
func newGethNodeConfig(config *params.NodeConfig) (*node.Config, error) {
|
||||||
// NOTE: I haven't changed anything related to this parameters, but
|
// NOTE: I haven't changed anything related to this parameters, but
|
||||||
|
@ -111,11 +80,6 @@ func newGethNodeConfig(config *params.NodeConfig) (*node.Config, error) {
|
||||||
maxPendingPeers = config.MaxPendingPeers
|
maxPendingPeers = config.MaxPendingPeers
|
||||||
}
|
}
|
||||||
|
|
||||||
listenAddr, err := handleListenAddr(config.ListenAddr)
|
|
||||||
if err != nil {
|
|
||||||
return nil, err
|
|
||||||
}
|
|
||||||
|
|
||||||
nc := &node.Config{
|
nc := &node.Config{
|
||||||
DataDir: config.DataDir,
|
DataDir: config.DataDir,
|
||||||
KeyStoreDir: config.KeyStoreDir,
|
KeyStoreDir: config.KeyStoreDir,
|
||||||
|
@ -125,7 +89,7 @@ func newGethNodeConfig(config *params.NodeConfig) (*node.Config, error) {
|
||||||
Version: config.Version,
|
Version: config.Version,
|
||||||
P2P: p2p.Config{
|
P2P: p2p.Config{
|
||||||
NoDiscovery: true, // we always use only v5 server
|
NoDiscovery: true, // we always use only v5 server
|
||||||
ListenAddr: listenAddr,
|
ListenAddr: config.ListenAddr,
|
||||||
NAT: nat.Any(),
|
NAT: nat.Any(),
|
||||||
MaxPeers: maxPeers,
|
MaxPeers: maxPeers,
|
||||||
MaxPendingPeers: maxPendingPeers,
|
MaxPendingPeers: maxPendingPeers,
|
||||||
|
|
Loading…
Reference in New Issue