Revert "Fix stalls for responsive transfer tests"

This reverts commit d48c6ae6dc69b7ce23a109cc9ba401e6ab44d831.

diff --git a/reader.go b/reader.go
index 35d3b32c57cd661c5ff6debd83207bc4d431b60e..42910a869ec3c8aab53ebb30fb60c0321a277054 100644 (file)
--- 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 66c834545cfaa5870f4d6bde6a33f545003d19d1..26f49b82a6b289a08e9526d015b5d974db90f902 100644 (file)
--- 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
                }