From 6bc2a2a6ace24d5ea620a02acb920a224a0d57ae Mon Sep 17 00:00:00 2001 From: Matt Joiner Date: Wed, 3 Feb 2021 18:55:54 +1100 Subject: [PATCH] Revert "Fix stalls for responsive transfer tests" This reverts commit d48c6ae6dc69b7ce23a109cc9ba401e6ab44d831. --- reader.go | 5 +---- torrent.go | 3 +-- 2 files changed, 2 insertions(+), 6 deletions(-) diff --git a/reader.go b/reader.go index 35d3b32c..42910a86 100644 --- a/reader.go +++ b/reader.go @@ -224,11 +224,8 @@ func (r *reader) readOnceAt(b []byte, pos int64, ctxErr *error) (n int, err erro r.log(log.Fstr("error reading torrent %s piece %d offset %d, %d bytes: %v", r.t.infoHash.HexString(), firstPieceIndex, firstPieceOffset, len(b1), err)) if !r.t.updatePieceCompletion(firstPieceIndex) { - r.log(log.Fstr("piece %d completion unchanged (%+v)", firstPieceIndex, r.t.piece(firstPieceIndex).completion())) + r.log(log.Fstr("piece %d completion unchanged", firstPieceIndex)) } - r.t.iterPeers(func(c *Peer) { - c.updateRequests() - }) // Update the rest of the piece completions in the readahead window, without alerting to // changes (since only the first piece, the one above, could have generated the read error // we're currently handling). diff --git a/torrent.go b/torrent.go index 66c83454..26f49b82 100644 --- a/torrent.go +++ b/torrent.go @@ -1760,14 +1760,13 @@ func (t *Torrent) pieceHashed(piece pieceIndex, passed bool, hashIoErr error) { c._stats.incrementPiecesDirtiedGood() } t.clearPieceTouchers(piece) - p.incrementPendingWrites() t.cl.unlock() err := p.Storage().MarkComplete() if err != nil { t.logger.Printf("%T: error marking piece complete %d: %s", t.storage, piece, err) } t.cl.lock() - p.decrementPendingWrites() + if t.closed.IsSet() { return } -- 2.44.0