Method ResumeDevice

plugins/snapshots/devmapper/pool_device.go:427–457

ResumeDevice resumes IO for the given device

(ctx context.Context, deviceName string)

// ResumeDevice resumes IO for the given device
func (p *PoolDevice) ResumeDevice(ctx context.Context, deviceName string) error {
	// Retry logic for resume operations to handle resource contention
	var lastErr error
	for attempt := range 3 {
		if attempt > 0 {
			// Add exponential backoff between retry attempts
			time.Sleep(time.Duration(100*attempt) * time.Millisecond)
		}

		err := p.transition(ctx, deviceName, Resuming, Resumed, func() error {
			return dmsetup.ResumeDevice(deviceName)
		})

		if err == nil {
			return nil
		}

		lastErr = err

		// Check if this is a recoverable error
		if strings.Contains(err.Error(), "invalid argument") || strings.Contains(err.Error(), "device busy") {
			log.G(ctx).WithError(err).Warnf("resume device %q failed (attempt %d/3), retrying", deviceName, attempt+1)
			continue
		}

		// Non-recoverable error, fail immediately
		return fmt.Errorf("failed to resume device %q: %w", deviceName, err)
	}

	return fmt.Errorf("failed to resume device %q after 3 attempts: %w", deviceName, lastErr)
}

// DeactivateDevice deactivates thin device
func (p *PoolDevice) DeactivateDevice(ctx context.Context, deviceName string, deferred, withForce bool) error {