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

Update code comments

This commit is contained in:
Matt Joiner 2020-01-23 13:51:14 +11:00
parent 1d5b8f7451
commit dc643d2ed3
1 changed files with 1 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
connection.go
View File

@ -1400,8 +1400,6 @@ func (c *connection) receiveChunk(msg *pp.Message) error {
return nil return nil
} }
// It's important that the piece is potentially queued before we check if
// the piece is still wanted, because if it is queued, it won't be wanted.
if t.pieceAllDirty(pieceIndex(req.Index)) { if t.pieceAllDirty(pieceIndex(req.Index)) {
t.queuePieceCheck(pieceIndex(req.Index)) t.queuePieceCheck(pieceIndex(req.Index))
t.pendAllChunkSpecs(pieceIndex(req.Index)) t.pendAllChunkSpecs(pieceIndex(req.Index))
@ -1410,6 +1408,7 @@ func (c *connection) receiveChunk(msg *pp.Message) error {
c.onDirtiedPiece(pieceIndex(req.Index)) c.onDirtiedPiece(pieceIndex(req.Index))
cl.event.Broadcast() cl.event.Broadcast()
// We do this because we've written a chunk, and may change PieceState.Partial.
t.publishPieceChange(pieceIndex(req.Index)) t.publishPieceChange(pieceIndex(req.Index))
return nil return nil