Method WaitLock

internal/lock/lock.go:240–267

WaitLock tries to acquire all locks within a specified waiting period. It will attempt to acquire locks with exponential backoff if any lock is held. If lock acquisition fails after the wait timeout, all acquired locks are released. Parameters: - ctx: The context for managing the wait request lifecy

(ctx context.Context, lockTimeout, waitTimeout time.Duration)

// - waitTimeout: The maximum time to wait for all locks to become available.
// Returns an error if all locks could not be acquired within the wait timeout.
func (m *MultiLocker) WaitLock(ctx context.Context, lockTimeout, waitTimeout time.Duration) error {
	if err := ctx.Err(); err != nil {
		return fmt.Errorf("lock wait cancelled: %w", err)
	}

	deadline := time.Now().Add(waitTimeout)

	for time.Now().Before(deadline) {
		err := m.Lock(ctx, lockTimeout)
		if err == nil {
			return nil
		}
		if !errors.Is(err, ErrLockHeld) {
			if ctxErr := ctx.Err(); ctxErr != nil {
				return fmt.Errorf("lock wait cancelled: %w", ctxErr)
			}
			return err
		}
		if err := sleepWithJitter(ctx, deadline); err != nil {
			return fmt.Errorf("lock wait cancelled: %w", err)
		}
	}

	return &lockError{
		err: ErrLockWaitTimeout,
		msg: "failed to acquire all locks within the wait timeout",
	}
}

// Unlock releases all locks in reverse order of acquisition.
// Releasing in reverse order is a best practice for multi-lock scenarios.