Method Mount

plugins/mount/erofs/plugin_linux.go:52–160

(ctx context.Context, m mount.Mount, mp string, _ []mount.ActiveMount)

}

func (h *erofsMountHandler) Mount(ctx context.Context, m mount.Mount, mp string, _ []mount.ActiveMount) (_ mount.ActiveMount, retErr error) {
	if m.Type != "erofs" {
		return mount.ActiveMount{}, errdefs.ErrNotImplemented
	}

	var dmverityDevice string
	defer func() {
		if retErr == nil || dmverityDevice == "" {
			return
		}
		dmverity.Close(dmverityDevice)
	}()

	// Parse dm-verity metadata path from mount options
	metadataPath := ""
	for _, opt := range m.Options {
		if path, ok := strings.CutPrefix(opt, "X-containerd.dmverity="); ok {
			metadataPath = path
			break
		}
	}

	// Set up dm-verity device if metadata path is provided
	if metadataPath != "" {
		log.G(ctx).WithFields(log.Fields{
			"source":        m.Source,
			"metadata-path": metadataPath,
		}).Debug("setting up dm-verity device from mount option")

		metadata, err := dmverity.ReadMetadata(metadataPath)
		if err != nil {
			return mount.ActiveMount{}, fmt.Errorf("failed to read dm-verity metadata from %s: %w", metadataPath, err)
		}

		devicePath, cleanupName, err := setupDmVerityDevice(ctx, m.Source, metadata)
		dmverityDevice = cleanupName
		if err != nil {
			return mount.ActiveMount{}, err
		}
		m.Source = devicePath
	}

	filteredOptions := make([]string, 0, len(m.Options))
	for _, v := range m.Options {
		// Skip loop option (handled by loop device setup) and dmverity options (already processed)
		if v == "loop" || strings.HasPrefix(v, "X-containerd.dmverity=") {
			continue
		}
		filteredOptions = append(filteredOptions, v)
	}
	m.Options = filteredOptions

	if err := os.MkdirAll(mp, 0700); err != nil {
		return mount.ActiveMount{}, err
	}

	err := error(unix.ENOTBLK)
	if !forceloop {