From 9567aa901c2f5e9f3fc2dc3237645fe0b2d6a5a2 Mon Sep 17 00:00:00 2001 From: Matt Joiner Date: Sat, 3 Feb 2018 11:53:11 +1100 Subject: [PATCH] Add missing increments to some stats --- client.go | 1 + connection.go | 4 ++++ torrent.go | 4 ++++ 3 files changed, 9 insertions(+) diff --git a/client.go b/client.go index 3072dcd1..bab9e560 100644 --- a/client.go +++ b/client.go @@ -948,6 +948,7 @@ func (cl *Client) gotMetadataExtensionMsg(payload []byte, t *Torrent, c *connect } t.saveMetadataPiece(piece, payload[begin:]) c.stats.ChunksReadUseful++ + c.t.stats.ChunksReadUseful++ c.lastUsefulChunkReceived = time.Now() return t.maybeCompleteMetadata() case pp.RequestMetadataExtensionMsgType: diff --git a/connection.go b/connection.go index 73d74604..c3a56650 100644 --- a/connection.go +++ b/connection.go @@ -1080,6 +1080,7 @@ func (c *connection) receiveChunk(msg *pp.Message) { if !t.wantPiece(req) { unwantedChunksReceived.Add(1) c.stats.ChunksReadUnwanted++ + c.t.stats.ChunksReadUnwanted++ return } @@ -1087,6 +1088,9 @@ func (c *connection) receiveChunk(msg *pp.Message) { piece := &t.pieces[index] c.stats.ChunksReadUseful++ + c.t.stats.ChunksReadUseful++ + c.stats.BytesReadUsefulData += int64(len(msg.Piece)) + c.t.stats.BytesReadUsefulData += int64(len(msg.Piece)) c.lastUsefulChunkReceived = time.Now() // if t.fastestConn != c { // log.Printf("setting fastest connection %p", c) diff --git a/torrent.go b/torrent.go index 99908a92..a58d6b8f 100644 --- a/torrent.go +++ b/torrent.go @@ -1514,6 +1514,9 @@ func (t *Torrent) pieceHashed(piece int, correct bool) { } p.everHashed = true if correct { + if len(touchers) != 0 { + t.stats.PiecesDirtiedGood++ + } for _, c := range touchers { c.stats.PiecesDirtiedGood++ } @@ -1523,6 +1526,7 @@ func (t *Torrent) pieceHashed(piece int, correct bool) { } } else { if len(touchers) != 0 { + t.stats.PiecesDirtiedBad++ for _, c := range touchers { // Y u do dis peer?! c.stats.PiecesDirtiedBad++ -- 2.50.0