type Server struct {
ConnTracker ConnectionTracker
- SendResponse func(data []byte, addr net.Addr) (int, error)
+ SendResponse func(ctx context.Context, data []byte, addr net.Addr) (int, error)
Announce *trackerServer.AnnounceHandler
}
return err
}
buf.Write(b)
- n, err := me.SendResponse(buf.Bytes(), source)
+ n, err := me.SendResponse(ctx, buf.Bytes(), source)
if err != nil {
return err
}
TransactionId: tid,
})
udp.Write(&buf, udp.ConnectionResponse{connId})
- n, err := me.SendResponse(buf.Bytes(), source)
+ n, err := me.SendResponse(ctx, buf.Bytes(), source)
if err != nil {
return err
}