"sync"
"github.com/anacrolix/chansync"
+ "github.com/anacrolix/log"
)
type Reservation struct {
func (me *Reservation) Wait(ctx context.Context) error {
if me.n > me.l.Max {
- return fmt.Errorf("reservation for %v exceeds limiter max %v", me.n, me.l.Max)
+ return log.WithLevel(
+ log.Warning,
+ fmt.Errorf("reservation for %v exceeds limiter max %v", me.n, me.l.Max),
+ )
}
select {
case <-ctx.Done():