Function checkUpdates

pkg/v1/remote/progress_test.go:432–458

checkUpdates checks that updates show steady progress toward a total, and don't describe errors.

(updates <-chan v1.Update)

// checkUpdates checks that updates show steady progress toward a total, and
// don't describe errors.
func checkUpdates(updates <-chan v1.Update) error {
	var high, total int64
	for u := range updates {
		if u.Error != nil {
			return u.Error
		}

		if u.Total < total {
			return fmt.Errorf("total changed: was %d, saw %d", total, u.Total)
		}

		total = u.Total

		if u.Complete < high {
			return fmt.Errorf("saw progress revert: was high of %d, saw %d", high, u.Complete)
		}
		high = u.Complete
	}

	if high > total {
		return fmt.Errorf("final progress (%d) exceeded total (%d) by %d", high, total, high-total)
	} else if high < total {
		return fmt.Errorf("final progress (%d) did not reach total (%d) by %d", high, total, total-high)
	}

	return nil
}