p := make([]byte, msg.Length)
n, err := t.Data.ReadAt(p, int64(t.PieceLength(0))*int64(msg.Index)+int64(msg.Begin))
if err != nil {
- return fmt.Errorf("reading t data to serve request %s: %s", request, err)
+ return fmt.Errorf("reading t data to serve request %q: %s", request, err)
}
if n != int(msg.Length) {
- return fmt.Errorf("bad request: %s", msg)
+ return fmt.Errorf("bad request: %v", msg)
}
c.Post(pp.Message{
Type: pp.Piece,
// Cancel pending requests for this chunk.
for _, c := range t.Conns {
if me.connCancel(t, c, req) {
- log.Print("cancelled concurrent request for %s", req)
+ log.Print("cancelled concurrent request for %v", req)
me.replenishConnRequests(t, c)
}
}
elemMsg := e.Value.(peer_protocol.Message)
if elemMsg.Type == peer_protocol.Request && msg.Index == elemMsg.Index && msg.Begin == elemMsg.Begin && msg.Length == elemMsg.Length {
pending.Remove(e)
- log.Print("optimized cancel! %q", msg)
+ log.Printf("optimized cancel! %v", msg)
break event
}
}