diff options
| author | Kurkó Mihály <kurkomisi@users.noreply.github.com> | 2018-10-16 06:40:51 +0800 |
|---|---|---|
| committer | Felix Lange <fjl@users.noreply.github.com> | 2018-10-16 06:40:51 +0800 |
| commit | 16e4d0e0055f7fce620ff6881a1393d955c06cee (patch) | |
| tree | c612d19c404de92d63b09bf395a18b11b74cb389 /p2p/dial.go | |
| parent | 331fa6d3075cb89fc295b36d9039620ec1d741ad (diff) | |
| download | dexon-16e4d0e0055f7fce620ff6881a1393d955c06cee.tar.gz dexon-16e4d0e0055f7fce620ff6881a1393d955c06cee.tar.zst dexon-16e4d0e0055f7fce620ff6881a1393d955c06cee.zip | |
p2p: meter peer traffic, emit metered peer events (#17695)
This change extends the peer metrics collection:
- traces the life-cycle of the peers
- meters the peer traffic separately for every peer
- creates event feed for the peer events
- emits the peer events
Diffstat (limited to 'p2p/dial.go')
| -rw-r--r-- | p2p/dial.go | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/p2p/dial.go b/p2p/dial.go index d228514fc..075a0f936 100644 --- a/p2p/dial.go +++ b/p2p/dial.go @@ -350,7 +350,7 @@ func (t *dialTask) dial(srv *Server, dest *enode.Node) error { if err != nil { return &dialError{err} } - mfd := newMeteredConn(fd, false) + mfd := newMeteredConn(fd, false, dest.IP()) return srv.SetupConn(mfd, t.flags, dest) } |