mirror of
https://github.com/fluencelabs/tendermint
synced 2025-06-25 10:41:41 +00:00
rpc: dial_seeds msg. addresses #403
This commit is contained in:
@ -1,6 +1,8 @@
|
|||||||
package core
|
package core
|
||||||
|
|
||||||
import (
|
import (
|
||||||
|
"fmt"
|
||||||
|
|
||||||
ctypes "github.com/tendermint/tendermint/rpc/core/types"
|
ctypes "github.com/tendermint/tendermint/rpc/core/types"
|
||||||
)
|
)
|
||||||
|
|
||||||
@ -31,10 +33,17 @@ func NetInfo() (*ctypes.ResultNetInfo, error) {
|
|||||||
|
|
||||||
// Dial given list of seeds
|
// Dial given list of seeds
|
||||||
func UnsafeDialSeeds(seeds []string) (*ctypes.ResultDialSeeds, error) {
|
func UnsafeDialSeeds(seeds []string) (*ctypes.ResultDialSeeds, error) {
|
||||||
|
|
||||||
|
if len(seeds) == 0 {
|
||||||
|
return &ctypes.ResultDialSeeds{}, fmt.Errorf("No seeds provided")
|
||||||
|
}
|
||||||
// starts go routines to dial each seed after random delays
|
// starts go routines to dial each seed after random delays
|
||||||
log.Info("DialSeeds", "addrBook", addrBook, "seeds", seeds)
|
log.Info("DialSeeds", "addrBook", addrBook, "seeds", seeds)
|
||||||
err := p2pSwitch.DialSeeds(addrBook, seeds)
|
err := p2pSwitch.DialSeeds(addrBook, seeds)
|
||||||
return &ctypes.ResultDialSeeds{}, err
|
if err != nil {
|
||||||
|
return &ctypes.ResultDialSeeds{}, err
|
||||||
|
}
|
||||||
|
return &ctypes.ResultDialSeeds{"Dialing seeds in progress. See /net_info for details"}, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
//-----------------------------------------------------------------------------
|
//-----------------------------------------------------------------------------
|
||||||
|
@ -45,6 +45,7 @@ type ResultNetInfo struct {
|
|||||||
}
|
}
|
||||||
|
|
||||||
type ResultDialSeeds struct {
|
type ResultDialSeeds struct {
|
||||||
|
Log string `json:"log"`
|
||||||
}
|
}
|
||||||
|
|
||||||
type Peer struct {
|
type Peer struct {
|
||||||
|
Reference in New Issue
Block a user