]> Sergey Matveev's repositories - btrtrc.git/blobdiff - conn_stats.go
Drop support for go 1.20
[btrtrc.git] / conn_stats.go
index d2d52003d552bfabfd39ce3e020314d58cf21b8c..0c5bfc784e88d4ce142cff68bb552e681cac9e1e 100644 (file)
@@ -79,14 +79,9 @@ func (cs *ConnStats) wroteMsg(msg *pp.Message) {
        }
 }
 
-func (cs *ConnStats) readMsg(msg *pp.Message) {
-       // We want to also handle extended metadata pieces here, but we wouldn't
-       // have decoded the extended payload yet.
-       switch msg.Type {
-       case pp.Piece:
-               cs.ChunksRead.Add(1)
-               cs.BytesReadData.Add(int64(len(msg.Piece)))
-       }
+func (cs *ConnStats) receivedChunk(size int64) {
+       cs.ChunksRead.Add(1)
+       cs.BytesReadData.Add(size)
 }
 
 func (cs *ConnStats) incrementPiecesDirtiedGood() {