aboutsummaryrefslogtreecommitdiffstats
path: root/p2p/dial.go
diff options
context:
space:
mode:
authorPéter Szilágyi <peterke@gmail.com>2015-06-22 01:23:37 +0800
committerPéter Szilágyi <peterke@gmail.com>2015-06-24 23:33:33 +0800
commit6994a3daaa0acfc8431e33da535c85e23ab319e0 (patch)
tree124b792dfa89a7897b2414d156814e2c56cd0ed0 /p2p/dial.go
parent821e01b0139eee9bfab9647e4ac1f2d6f1fb01bc (diff)
downloaddexon-6994a3daaa0acfc8431e33da535c85e23ab319e0.tar.gz
dexon-6994a3daaa0acfc8431e33da535c85e23ab319e0.tar.zst
dexon-6994a3daaa0acfc8431e33da535c85e23ab319e0.zip
p2p: instrument P2P networking layer
Diffstat (limited to 'p2p/dial.go')
-rw-r--r--p2p/dial.go4
1 files changed, 3 insertions, 1 deletions
diff --git a/p2p/dial.go b/p2p/dial.go
index b82d6d1f5..45cd8116b 100644
--- a/p2p/dial.go
+++ b/p2p/dial.go
@@ -196,7 +196,9 @@ func (t *dialTask) Do(srv *Server) {
glog.V(logger.Detail).Infof("dial error: %v", err)
return
}
- srv.setupConn(fd, t.flags, t.dest)
+ mfd := newMeteredConn(fd, false)
+
+ srv.setupConn(mfd, t.flags, t.dest)
}
func (t *dialTask) String() string {
return fmt.Sprintf("%v %x %v:%d", t.flags, t.dest.ID[:8], t.dest.IP, t.dest.TCP)