"container/list"
"encoding"
"errors"
+ "expvar"
"fmt"
"io"
- "log"
"net"
"sync"
"time"
pp "bitbucket.org/anacrolix/go.torrent/peer_protocol"
)
+var optimizedCancels = expvar.NewInt("optimizedCancels")
+
type peerSource byte
const (
elemMsg := e.Value.(pp.Message)
if elemMsg.Type == pp.Request && msg.Index == elemMsg.Index && msg.Begin == elemMsg.Begin && msg.Length == elemMsg.Length {
pending.Remove(e)
- log.Printf("optimized cancel! %v", msg)
+ optimizedCancels.Add(1)
break event
}
}