Method SuspendDevice

plugins/snapshots/devmapper/pool_device.go:394–424

SuspendDevice flushes the outstanding IO and blocks the further IO

(ctx context.Context, deviceName string)

// SuspendDevice flushes the outstanding IO and blocks the further IO
func (p *PoolDevice) SuspendDevice(ctx context.Context, deviceName string) error {
	// Retry logic for suspend 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, Suspending, Suspended, func() error {
			return dmsetup.SuspendDevice(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("suspend device %q failed (attempt %d/3), retrying", deviceName, attempt+1)
			continue
		}

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

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

// ResumeDevice resumes IO for the given device
func (p *PoolDevice) ResumeDevice(ctx context.Context, deviceName string) error {