Skip to content

Commit

Permalink
Rename config.Network.IP to config.Network.Host (#34)
Browse files Browse the repository at this point in the history
* Rename config.Network.IP to config.Network.Host

* Rename ip to host
  • Loading branch information
FishMeat authored and lizhefeng committed Aug 6, 2018
1 parent 015f32a commit b6bad29
Show file tree
Hide file tree
Showing 8 changed files with 21 additions and 21 deletions.
6 changes: 3 additions & 3 deletions blocksync/blocksync_test.go
Expand Up @@ -61,7 +61,7 @@ func TestSyncTaskInterval(t *testing.T) {

func generateP2P() network.Overlay {
c := &config.Network{
IP: "127.0.0.1",
Host: "127.0.0.1",
Port: 10001,
MsgLogsCleaningInterval: 2 * time.Second,
MsgLogRetention: 10 * time.Second,
Expand All @@ -70,7 +70,7 @@ func generateP2P() network.Overlay {
PeerMaintainerInterval: time.Second,
NumPeersLowerBound: 5,
NumPeersUpperBound: 5,
AllowMultiConnsPerIP: true,
AllowMultiConnsPerHost: true,
RateLimitEnabled: false,
PingInterval: time.Second,
BootstrapNodes: []string{"127.0.0.1:10001", "127.0.0.1:10002"},
Expand Down Expand Up @@ -321,7 +321,7 @@ func newTestConfig() (*config.Config, error) {
cfg.Chain.ChainDBPath = "db.test"
cfg.BlockSync.Interval = time.Millisecond << 4
cfg.Consensus.Scheme = config.NOOPScheme
cfg.Network.IP = "127.0.0.1"
cfg.Network.Host = "127.0.0.1"
cfg.Network.Port = 10000
cfg.Network.BootstrapNodes = []string{"127.0.0.1:10000", "127.0.0.1:4689"}
return &cfg, nil
Expand Down
8 changes: 4 additions & 4 deletions config/config.go
Expand Up @@ -56,14 +56,14 @@ var (
Default = Config{
NodeType: FullNodeType,
Network: Network{
IP: "127.0.0.1",
Host: "127.0.0.1",
Port: 4689,
MsgLogsCleaningInterval: 2 * time.Second,
MsgLogRetention: 5 * time.Second,
HealthCheckInterval: time.Second,
SilentInterval: 5 * time.Second,
PeerMaintainerInterval: time.Second,
AllowMultiConnsPerIP: false,
AllowMultiConnsPerHost: false,
NumPeersLowerBound: 5,
NumPeersUpperBound: 5,
PingInterval: time.Second,
Expand Down Expand Up @@ -152,14 +152,14 @@ var (
// Network is the config struct for network package
type (
Network struct {
IP string `yaml:"ip"`
Host string `yaml:"host"`
Port int `yaml:"port"`
MsgLogsCleaningInterval time.Duration `yaml:"msgLogsCleaningInterval"`
MsgLogRetention time.Duration `yaml:"msgLogRetention"`
HealthCheckInterval time.Duration `yaml:"healthCheckInterval"`
SilentInterval time.Duration `yaml:"silentInterval"`
PeerMaintainerInterval time.Duration `yaml:"peerMaintainerInterval"`
AllowMultiConnsPerIP bool `yaml:"allowMultiConnsPerIP"`
AllowMultiConnsPerHost bool `yaml:"allowMultiConnsPerHost"`
NumPeersLowerBound uint `yaml:"numPeersLowerBound"`
NumPeersUpperBound uint `yaml:"numPeersUpperBound"`
PingInterval time.Duration `yaml:"pingInterval"`
Expand Down
2 changes: 1 addition & 1 deletion e2etest/config_local_delegate.yaml
Expand Up @@ -4,7 +4,7 @@
nodeType: "delegate" # should be one of "delegate", "full_node", and "lightweight"

network:
ip: "127.0.0.1"
host: "127.0.0.1"
port: 4689
bootstrapNodes:
- "127.0.0.1:4689"
Expand Down
2 changes: 1 addition & 1 deletion e2etest/net_test.go
Expand Up @@ -30,7 +30,7 @@ func TestNetSync(t *testing.T) {
defer testutil.CleanupPath(t, testDBPath)

cfg := config.Default
cfg.Network.IP = "127.0.0.1"
cfg.Network.Host = "127.0.0.1"
cfg.Network.Port = 10000
cfg.Network.BootstrapNodes = []string{"127.0.0.1:4689"}
cfg.Chain.TrieDBPath = testTriePath
Expand Down
16 changes: 8 additions & 8 deletions network/overlay_test.go
Expand Up @@ -31,19 +31,19 @@ import (
"github.com/iotexproject/iotex-core/testutil"
)

func LoadTestConfig(addr string, allowMultiConnsPerIP bool) *config.Network {
func LoadTestConfig(addr string, allowMultiConnsPerHost bool) *config.Network {
var (
ip = "127.0.0.1"
host = "127.0.0.1"
port int
)
if addrComp := strings.Split(addr, ":"); len(addrComp) == 2 {
ip = addrComp[0]
host = addrComp[0]
port, _ = strconv.Atoi(addrComp[1])
}
config := config.Config{
NodeType: config.DelegateType,
Network: config.Network{
IP: ip,
Host: host,
Port: port,
MsgLogsCleaningInterval: 2 * time.Second,
MsgLogRetention: 10 * time.Second,
Expand All @@ -52,7 +52,7 @@ func LoadTestConfig(addr string, allowMultiConnsPerIP bool) *config.Network {
PeerMaintainerInterval: time.Second,
NumPeersLowerBound: 5,
NumPeersUpperBound: 5,
AllowMultiConnsPerIP: allowMultiConnsPerIP,
AllowMultiConnsPerHost: allowMultiConnsPerHost,
RateLimitEnabled: false,
PingInterval: time.Second,
BootstrapNodes: []string{"127.0.0.1:10001", "127.0.0.1:10002"},
Expand All @@ -64,8 +64,8 @@ func LoadTestConfig(addr string, allowMultiConnsPerIP bool) *config.Network {
return &config.Network
}

func LoadTestConfigWithTLSEnabled(addr string, allowMultiConnsPerIP bool) *config.Network {
cfg := LoadTestConfig(addr, allowMultiConnsPerIP)
func LoadTestConfigWithTLSEnabled(addr string, allowMultiConnsPerHost bool) *config.Network {
cfg := LoadTestConfig(addr, allowMultiConnsPerHost)
cfg.TLSEnabled = true
cfg.CACrtPath = "../test/assets/ssl/iotex.io.crt"
cfg.PeerCrtPath = "../test/assets/ssl/127.0.0.1.crt"
Expand Down Expand Up @@ -214,7 +214,7 @@ func TestTell(t *testing.T) {
require.Nil(t, err)
}

func TestOneConnPerIP(t *testing.T) {
func TestOneConnPerHost(t *testing.T) {
ctx := context.Background()
dp1 := &MockDispatcher2{T: t}
addr1 := randomAddress()
Expand Down
4 changes: 2 additions & 2 deletions network/peermanager.go
Expand Up @@ -49,7 +49,7 @@ func (pm *PeerManager) AddPeer(addr string) {
Msg("Node at address is already the peer")
return
}
if !pm.Overlay.Config.AllowMultiConnsPerIP {
if !pm.Overlay.Config.AllowMultiConnsPerHost {
nHost, _, err := net.SplitHostPort(addr)
if err != nil {
logger.Error().
Expand All @@ -76,7 +76,7 @@ func (pm *PeerManager) AddPeer(addr string) {
if found {
logger.Debug().
Str("nHost", nHost).
Msg("Another node on the same IP is already the peer")
Msg("Another node on the same Host is already the peer")
return
}
}
Expand Down
2 changes: 1 addition & 1 deletion network/rpcserver.go
Expand Up @@ -45,7 +45,7 @@ type RPCServer struct {
func NewRPCServer(o *IotxOverlay) *RPCServer {
s := &RPCServer{Overlay: o}
portStr := strconv.Itoa(o.Config.Port)
s.Addr = strings.Join([]string{o.Config.IP, portStr}, ":")
s.Addr = strings.Join([]string{o.Config.Host, portStr}, ":")
s.rateLimit = o.Config.RateLimitPerSec * uint64(o.Config.RateLimitWindowSize) / uint64(time.Second)
return s
}
Expand Down
2 changes: 1 addition & 1 deletion simulator/consensus_sim_server.go
Expand Up @@ -80,7 +80,7 @@ func (s *server) Init(in *pb.InitRequest, stream pb.Simulator_InitServer) error
cfg.Consensus.RollDPoS.AcceptVoteTTL = 1000 * time.Second

// handle node address, delegate addresses, etc.
cfg.Network.IP = "127.0.0.1"
cfg.Network.Host = "127.0.0.1"
cfg.Network.Port = 10000
cfg.Network.NumPeersLowerBound = 6
cfg.Network.NumPeersUpperBound = 12
Expand Down

0 comments on commit b6bad29

Please sign in to comment.