8 "github.com/anacrolix/multiless"
11 func worseConn(l, r *Peer) bool {
12 less, ok := multiless.New().Bool(
13 l.useful(), r.useful()).CmpInt64(
14 l.lastHelpful().Sub(r.lastHelpful()).Nanoseconds()).CmpInt64(
15 l.completedHandshake.Sub(r.completedHandshake).Nanoseconds()).LazySameLess(
16 func() (same, less bool) {
17 lpp, err := l.peerPriority()
22 rpp, err := r.peerPriority()
27 return lpp == rpp, lpp < rpp
29 uintptr(unsafe.Pointer(l)), uintptr(unsafe.Pointer(r)),
32 panic(fmt.Sprintf("cannot differentiate %#v and %#v", l, r))
37 type worseConnSlice struct {
41 var _ heap.Interface = &worseConnSlice{}
43 func (me worseConnSlice) Len() int {
47 func (me worseConnSlice) Less(i, j int) bool {
48 return worseConn(&me.conns[i].Peer, &me.conns[j].Peer)
51 func (me *worseConnSlice) Pop() interface{} {
52 i := len(me.conns) - 1
54 me.conns = me.conns[:i]
58 func (me *worseConnSlice) Push(x interface{}) {
59 me.conns = append(me.conns, x.(*PeerConn))
62 func (me worseConnSlice) Swap(i, j int) {
63 me.conns[i], me.conns[j] = me.conns[j], me.conns[i]