mirror of
https://gitlab.com/pulsechaincom/erigon-pulse.git
synced 2024-12-25 21:17:16 +00:00
Added faux latency for peeroverview
This commit is contained in:
parent
fb6ff61730
commit
2010fea088
@ -22,6 +22,7 @@ type Peer interface {
|
|||||||
Host() []byte
|
Host() []byte
|
||||||
Port() uint16
|
Port() uint16
|
||||||
Version() string
|
Version() string
|
||||||
|
PingTime() string
|
||||||
Connected() *int32
|
Connected() *int32
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -56,6 +56,7 @@ func (lib *PEthereum) GetPeers() []PPeer {
|
|||||||
var peers []PPeer
|
var peers []PPeer
|
||||||
for peer := lib.manager.Peers().Front(); peer != nil; peer = peer.Next() {
|
for peer := lib.manager.Peers().Front(); peer != nil; peer = peer.Next() {
|
||||||
p := peer.Value.(ethchain.Peer)
|
p := peer.Value.(ethchain.Peer)
|
||||||
|
// we only want connected peers
|
||||||
if atomic.LoadInt32(p.Connected()) != 0 {
|
if atomic.LoadInt32(p.Connected()) != 0 {
|
||||||
peers = append(peers, *NewPPeer(p))
|
peers = append(peers, *NewPPeer(p))
|
||||||
}
|
}
|
||||||
|
@ -20,6 +20,7 @@ type PPeer struct {
|
|||||||
Port int `json:"port"`
|
Port int `json:"port"`
|
||||||
Version string `json:"version"`
|
Version string `json:"version"`
|
||||||
LastResponse string `json:"lastResponse"`
|
LastResponse string `json:"lastResponse"`
|
||||||
|
Latency string `json:"latency"`
|
||||||
}
|
}
|
||||||
|
|
||||||
func NewPPeer(peer ethchain.Peer) *PPeer {
|
func NewPPeer(peer ethchain.Peer) *PPeer {
|
||||||
@ -34,7 +35,7 @@ func NewPPeer(peer ethchain.Peer) *PPeer {
|
|||||||
}
|
}
|
||||||
ipAddress := strings.Join(ip, ".")
|
ipAddress := strings.Join(ip, ".")
|
||||||
|
|
||||||
return &PPeer{ref: &peer, Inbound: peer.Inbound(), LastSend: peer.LastSend().Unix(), LastPong: peer.LastPong(), Version: peer.Version(), Ip: ipAddress, Port: int(peer.Port())}
|
return &PPeer{ref: &peer, Inbound: peer.Inbound(), LastSend: peer.LastSend().Unix(), LastPong: peer.LastPong(), Version: peer.Version(), Ip: ipAddress, Port: int(peer.Port()), Latency: peer.PingTime()}
|
||||||
}
|
}
|
||||||
|
|
||||||
// Block interface exposed to QML
|
// Block interface exposed to QML
|
||||||
|
20
peer.go
20
peer.go
@ -130,6 +130,10 @@ type Peer struct {
|
|||||||
blocksRequested int
|
blocksRequested int
|
||||||
|
|
||||||
version string
|
version string
|
||||||
|
|
||||||
|
// We use this to give some kind of pingtime to a node, not very accurate, could be improved.
|
||||||
|
pingTime time.Duration
|
||||||
|
pingStartTime time.Time
|
||||||
}
|
}
|
||||||
|
|
||||||
func NewPeer(conn net.Conn, ethereum *Ethereum, inbound bool) *Peer {
|
func NewPeer(conn net.Conn, ethereum *Ethereum, inbound bool) *Peer {
|
||||||
@ -185,6 +189,9 @@ func NewOutboundPeer(addr string, ethereum *Ethereum, caps Caps) *Peer {
|
|||||||
}
|
}
|
||||||
|
|
||||||
// Getters
|
// Getters
|
||||||
|
func (p *Peer) PingTime() string {
|
||||||
|
return p.pingTime.String()
|
||||||
|
}
|
||||||
func (p *Peer) Inbound() bool {
|
func (p *Peer) Inbound() bool {
|
||||||
return p.inbound
|
return p.inbound
|
||||||
}
|
}
|
||||||
@ -246,7 +253,7 @@ func (p *Peer) writeMessage(msg *ethwire.Msg) {
|
|||||||
// Outbound message handler. Outbound messages are handled here
|
// Outbound message handler. Outbound messages are handled here
|
||||||
func (p *Peer) HandleOutbound() {
|
func (p *Peer) HandleOutbound() {
|
||||||
// The ping timer. Makes sure that every 2 minutes a ping is send to the peer
|
// The ping timer. Makes sure that every 2 minutes a ping is send to the peer
|
||||||
pingTimer := time.NewTicker(2 * time.Minute)
|
pingTimer := time.NewTicker(30 * time.Second)
|
||||||
serviceTimer := time.NewTicker(5 * time.Minute)
|
serviceTimer := time.NewTicker(5 * time.Minute)
|
||||||
|
|
||||||
out:
|
out:
|
||||||
@ -255,12 +262,12 @@ out:
|
|||||||
// Main message queue. All outbound messages are processed through here
|
// Main message queue. All outbound messages are processed through here
|
||||||
case msg := <-p.outputQueue:
|
case msg := <-p.outputQueue:
|
||||||
p.writeMessage(msg)
|
p.writeMessage(msg)
|
||||||
|
|
||||||
p.lastSend = time.Now()
|
p.lastSend = time.Now()
|
||||||
|
|
||||||
// Ping timer sends a ping to the peer each 2 minutes
|
// Ping timer sends a ping to the peer each 2 minutes
|
||||||
case <-pingTimer.C:
|
case <-pingTimer.C:
|
||||||
p.writeMessage(ethwire.NewMessage(ethwire.MsgPingTy, ""))
|
p.writeMessage(ethwire.NewMessage(ethwire.MsgPingTy, ""))
|
||||||
|
p.pingStartTime = time.Now()
|
||||||
|
|
||||||
// Service timer takes care of peer broadcasting, transaction
|
// Service timer takes care of peer broadcasting, transaction
|
||||||
// posting or block posting
|
// posting or block posting
|
||||||
@ -290,8 +297,8 @@ clean:
|
|||||||
|
|
||||||
// Inbound handler. Inbound messages are received here and passed to the appropriate methods
|
// Inbound handler. Inbound messages are received here and passed to the appropriate methods
|
||||||
func (p *Peer) HandleInbound() {
|
func (p *Peer) HandleInbound() {
|
||||||
|
|
||||||
for atomic.LoadInt32(&p.disconnect) == 0 {
|
for atomic.LoadInt32(&p.disconnect) == 0 {
|
||||||
|
|
||||||
// HMM?
|
// HMM?
|
||||||
time.Sleep(500 * time.Millisecond)
|
time.Sleep(500 * time.Millisecond)
|
||||||
// Wait for a message from the peer
|
// Wait for a message from the peer
|
||||||
@ -319,6 +326,7 @@ func (p *Peer) HandleInbound() {
|
|||||||
// last pong so the peer handler knows this peer is still
|
// last pong so the peer handler knows this peer is still
|
||||||
// active.
|
// active.
|
||||||
p.lastPong = time.Now().Unix()
|
p.lastPong = time.Now().Unix()
|
||||||
|
p.pingTime = time.Now().Sub(p.pingStartTime)
|
||||||
case ethwire.MsgBlockTy:
|
case ethwire.MsgBlockTy:
|
||||||
// Get all blocks and process them
|
// Get all blocks and process them
|
||||||
var block, lastBlock *ethchain.Block
|
var block, lastBlock *ethchain.Block
|
||||||
@ -531,11 +539,15 @@ func (p *Peer) Start() {
|
|||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
// Run the outbound handler in a new goroutine
|
|
||||||
go p.HandleOutbound()
|
go p.HandleOutbound()
|
||||||
// Run the inbound handler in a new goroutine
|
// Run the inbound handler in a new goroutine
|
||||||
go p.HandleInbound()
|
go p.HandleInbound()
|
||||||
|
|
||||||
|
// Wait a few seconds for startup and then ask for an initial ping
|
||||||
|
time.Sleep(2 * time.Second)
|
||||||
|
p.writeMessage(ethwire.NewMessage(ethwire.MsgPingTy, ""))
|
||||||
|
p.pingStartTime = time.Now()
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
func (p *Peer) Stop() {
|
func (p *Peer) Stop() {
|
||||||
|
Loading…
Reference in New Issue
Block a user