dlss
/
FedP2P
4
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Comment out pending requests tests and asserts 

These need to be updated. BSI for pending requests removes an enormous amount of memory use for very large torrents.
This commit is contained in:
Matt Joiner 2021-11-25 22:59:20 +11:00
parent 8ddbf5a852
commit 560b463983
2 changed files with 24 additions and 32 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

27
pending-requests_test.go
View File

@ -1,19 +1,12 @@
package torrent package torrent
import ( // // Ensure that cmp.Diff will detect errors as required.
"testing" // func TestPendingRequestsDiff(t *testing.T) {
// var a, b pendingRequests
qt "github.com/frankban/quicktest" // c := qt.New(t)
"github.com/google/go-cmp/cmp" // diff := func() string { return cmp.Diff(a.m, b.m) }
) // c.Check(diff(), qt.ContentEquals, "")
// a.m = []int{1, 3}
// Ensure that cmp.Diff will detect errors as required. // b.m = []int{1, 2, 3}
func TestPendingRequestsDiff(t *testing.T) { // c.Check(diff(), qt.Not(qt.Equals), "")
var a, b pendingRequests // }
c := qt.New(t)
diff := func() string { return cmp.Diff(a.m, b.m) }
c.Check(diff(), qt.ContentEquals, "")
a.m = []int{1, 3}
b.m = []int{1, 2, 3}
c.Check(diff(), qt.Not(qt.Equals), "")
}

29
torrent.go
View File

@ -28,7 +28,6 @@ import (
"github.com/anacrolix/multiless" "github.com/anacrolix/multiless"
"github.com/anacrolix/sync" "github.com/anacrolix/sync"
"github.com/davecgh/go-spew/spew" "github.com/davecgh/go-spew/spew"
"github.com/google/go-cmp/cmp"
"github.com/pion/datachannel" "github.com/pion/datachannel"
"github.com/anacrolix/torrent/bencode" "github.com/anacrolix/torrent/bencode"
@ -1381,20 +1380,20 @@ func (t *Torrent) assertPendingRequests() {
if !check { if !check {
return return
} }
var actual pendingRequests // var actual pendingRequests
if t.haveInfo() { // if t.haveInfo() {
actual.m = make([]int, t.numRequests()) // actual.m = make([]int, t.numRequests())
} // }
t.iterPeers(func(p *Peer) { // t.iterPeers(func(p *Peer) {
p.actualRequestState.Requests.Iterate(func(x uint32) bool { // p.actualRequestState.Requests.Iterate(func(x uint32) bool {
actual.Inc(x) // actual.Inc(x)
return true // return true
}) // })
}) // })
diff := cmp.Diff(actual.m, t.pendingRequests.m) // diff := cmp.Diff(actual.m, t.pendingRequests.m)
if diff != "" { // if diff != "" {
panic(diff) // panic(diff)
} // }
} }
func (t *Torrent) dropConnection(c *PeerConn) { func (t *Torrent) dropConnection(c *PeerConn) {