if !me.deleteRequest(r) {
panic("request not existing should have been guarded")
}
- if me.actualRequestState.Requests.GetCardinality() == 0 {
+ if me.actualRequestState.Requests.IsEmpty() {
me.updateRequests("Peer.cancel")
}
}
func (c *Peer) remoteRejectedRequest(r RequestIndex) {
if c.deleteRequest(r) {
- if c.actualRequestState.Requests.GetCardinality() == 0 {
+ if c.actualRequestState.Requests.IsEmpty() {
c.updateRequests("Peer.remoteRejectedRequest")
}
c.decExpectedChunkReceive(r)
if !c.peerChoking {
c._chunksReceivedWhileExpecting++
}
- if c.actualRequestState.Requests.GetCardinality() == 0 {
+ if c.actualRequestState.Requests.IsEmpty() {
c.updateRequests("Peer.receiveChunk deleted request")
}
} else {
if c.actualRequestState.Interested {
return
}
- if c.actualRequestState.Requests.GetCardinality() != 0 {
+ if !c.actualRequestState.Requests.IsEmpty() {
return
}
if !c.peerHasPiece(piece) {
if !ws.peer.deleteRequest(r) {
panic("cancelled webseed request should exist")
}
- if ws.peer.actualRequestState.Requests.GetCardinality() == 0 {
+ if ws.peer.actualRequestState.Requests.IsEmpty() {
ws.peer.updateRequests("webseedPeer._cancel")
}
}