diff options
| author | Jeffrey Wilcke <jeffrey@ethereum.org> | 2015-06-25 23:18:42 +0800 |
|---|---|---|
| committer | Jeffrey Wilcke <jeffrey@ethereum.org> | 2015-06-25 23:18:42 +0800 |
| commit | b0a5be4495962c291a25cbea793e43bad0781510 (patch) | |
| tree | e058201e7b29c3cb8efd710e20ec1e1f97f64368 /p2p/server.go | |
| parent | e64625aa8215985c85f97f914a98db081e07714f (diff) | |
| parent | e9c0b5431cbd7430ddec9fd17983241018fd8a55 (diff) | |
| download | go-tangerine-b0a5be4495962c291a25cbea793e43bad0781510.tar.gz go-tangerine-b0a5be4495962c291a25cbea793e43bad0781510.tar.zst go-tangerine-b0a5be4495962c291a25cbea793e43bad0781510.zip | |
Merge pull request #1321 from karalabe/cut-it-open-3000
Metrics collecting and reporting support
Diffstat (limited to 'p2p/server.go')
| -rw-r--r-- | p2p/server.go | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/p2p/server.go b/p2p/server.go index 5eff70345..9078841a8 100644 --- a/p2p/server.go +++ b/p2p/server.go @@ -548,9 +548,11 @@ func (srv *Server) listenLoop() { if err != nil { return } - glog.V(logger.Debug).Infof("Accepted conn %v\n", fd.RemoteAddr()) + mfd := newMeteredConn(fd, true) + + glog.V(logger.Debug).Infof("Accepted conn %v\n", mfd.RemoteAddr()) go func() { - srv.setupConn(fd, inboundConn, nil) + srv.setupConn(mfd, inboundConn, nil) slots <- struct{}{} }() } |