Method createContainer

internal/cri/server/container_create.go:234–498

(r *createContainerRequest)

}

func (c *criService) createContainer(r *createContainerRequest) (_ string, retErr error) {
	span := tracing.SpanFromContext(r.ctx)
	// Create container root directory.
	containerRootDir := c.getContainerRootDir(r.containerID)
	if err := c.os.MkdirAll(containerRootDir, 0755); err != nil {
		return "", fmt.Errorf(
			"failed to create container root directory %q: %w",
			containerRootDir,
			err,
		)
	}
	defer func() {
		if retErr != nil {
			// Cleanup the container root directory.
			if err := c.os.RemoveAll(containerRootDir); err != nil {
				log.G(r.ctx).WithError(err).Errorf(
					"Failed to remove container root directory %q",
					containerRootDir,
				)
			}
		}
	}()
	volatileContainerRootDir := c.getVolatileContainerRootDir(r.containerID)
	if err := c.os.MkdirAll(volatileContainerRootDir, 0755); err != nil {
		return "", fmt.Errorf(
			"failed to create volatile container root directory %q: %w",
			volatileContainerRootDir,
			err,
		)
	}
	defer func() {
		if retErr != nil {
			// Cleanup the volatile container root directory.
			if err := c.os.RemoveAll(volatileContainerRootDir); err != nil {
				log.G(r.ctx).WithError(err).Errorf(
					"Failed to remove volatile container root directory %q",
					volatileContainerRootDir,
				)
			}
		}
	}()

	platform, err := c.sandboxService.SandboxPlatform(r.ctx, r.sandbox.Sandboxer, r.sandboxID)
	if err != nil {
		return "", fmt.Errorf("failed to query sandbox platform: %w", err)
	}
	ociRuntime, err := c.getPodSandboxRuntime(r.sandboxID)
	if err != nil {
		return "", fmt.Errorf("failed to get sandbox runtime: %w", err)
	}

	// mutate the extra CRI volume mounts from the runtime spec to properly specify the OCI image volume mount requests as bind mounts for this container
	err = c.mutateMounts(r.ctx, r.containerConfig.GetMounts(), c.RuntimeSnapshotter(r.ctx, ociRuntime), r.sandboxID, platform)
	if err != nil {
		return "", fmt.Errorf("failed to mount image volume: %w", err)
	}

	var volumeMounts []*runtime.Mount