panic(n)
}
c.updateRequests()
+ // TODO: Other connections that aren't interested, and can provide this
+ // chunk might be wakeable?
return true
}
return
}
msg.Keepalive = false
- r := &io.LimitedReader{R:d.R, N:int64(length)}
+ r := &io.LimitedReader{R: d.R, N: int64(length)}
// Check that all of r was utilized.
defer func() {
if err != nil {
Cancel MessageType = 8
Port MessageType = 9
- // BEP 6
+ // BEP 6 - Fast extension
Suggest MessageType = 0x0d // 13
HaveAll MessageType = 0x0e // 14
HaveNone MessageType = 0x0f // 15
assert.True(t, ok)
assert.True(t, hr.PeerExtensionBits.GetBit(pp.ExtensionBitExtended))
assert.EqualValues(t, cl.PeerID(), hr.PeerID)
- assert.Equal(t, ih, hr.Hash)
+ assert.EqualValues(t, ih, hr.Hash)
assert.EqualValues(t, 0, tt.metadataSize())