parent
e992bb78b9
commit
4dee11efe9
|
@ -1160,9 +1160,10 @@ func (c *PeerConn) mainReadLoop() (err error) {
|
|||
}
|
||||
|
||||
func (c *peer) remoteRejectedRequest(r request) {
|
||||
c.deleteRequest(r)
|
||||
if c.deleteRequest(r) {
|
||||
c.decExpectedChunkReceive(r)
|
||||
}
|
||||
}
|
||||
|
||||
func (c *peer) decExpectedChunkReceive(r request) {
|
||||
count := c.validReceiveChunks[r]
|
||||
|
|
Loading…
Reference in New Issue