status-im
/
torrent
mirror of
2
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Cache chunksPerRegularPiece

This commit is contained in:
Matt Joiner 2022-05-12 10:34:26 +10:00
parent 7d4f64ce3c
commit eb7811f909
No known key found for this signature in database
GPG Key ID: 6B990B8185E7F782
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
torrent.go
View File

@ -87,6 +87,8 @@ type Torrent struct {
fileIndex segments.Index fileIndex segments.Index
files *[]*File files *[]*File
_chunksPerRegularPiece chunkIndexType
webSeeds map[string]*Peer webSeeds map[string]*Peer
// Active peer connections, running message stream loops. TODO: Make this // Active peer connections, running message stream loops. TODO: Make this
// open (not-closed) connections only. // open (not-closed) connections only.
@ -434,6 +436,7 @@ func (t *Torrent) setInfo(info *metainfo.Info) error {
t.nameMu.Lock() t.nameMu.Lock()
t.info = info t.info = info
t.nameMu.Unlock() t.nameMu.Unlock()
t._chunksPerRegularPiece = chunkIndexType((pp.Integer(t.usualPieceSize()) + t.chunkSize - 1) / t.chunkSize)
t.updateComplete() t.updateComplete()
t.fileIndex = segments.NewIndex(common.LengthIterFromUpvertedFiles(info.UpvertedFiles())) t.fileIndex = segments.NewIndex(common.LengthIterFromUpvertedFiles(info.UpvertedFiles()))
t.displayName = "" // Save a few bytes lol. t.displayName = "" // Save a few bytes lol.
@ -919,7 +922,7 @@ func (t *Torrent) pieceNumChunks(piece pieceIndex) chunkIndexType {
} }
func (t *Torrent) chunksPerRegularPiece() chunkIndexType { func (t *Torrent) chunksPerRegularPiece() chunkIndexType {
return chunkIndexType((pp.Integer(t.usualPieceSize()) + t.chunkSize - 1) / t.chunkSize) return t._chunksPerRegularPiece
} }
func (t *Torrent) numRequests() RequestIndex { func (t *Torrent) numRequests() RequestIndex {