)
func waitCheck(ctx context.Context, timeout time.Duration, check func(ctx context.Context) error) error {
- ctx, _ = context.WithTimeout(ctx, timeout)
+ ctx, cancel := context.WithTimeout(ctx, timeout)
+ defer cancel()
var err error
for err = check(ctx); err != nil && ctx.Err() == nil; err = check(ctx) {
time.Sleep(time.Second)
if d.Size > 0 && d.Size != n {
return fmt.Errorf("Size mismatch: got %d bytes, expected %d", n, d.Size)
} else if d.Size == 0 {
- log.Printf("%s: size was %d", d, n)
+ log.Printf("%v: size was %d", d, n)
}
if err = out.Close(); err != nil {
return err