Function newContainerHandler

container/docker/handler.go:127–298

newContainerHandler returns a new container.ContainerHandler

(
	client *dclient.Client,
	containerdClient containerd.ContainerdClient,
	name string,
	machineInfoFactory info.MachineInfoFactory,
	fsInfo fs.FsInfo,
	storageDriver StorageDriver,
	storageDir string,
	cgroupSubsystems map[string]string,
	inHostNamespace bool,
	metadataEnvAllowList []string,
	dockerVersion []int,
	metrics container.MetricSet,
	thinPoolName string,
	thinPoolWatcher *devicemapper.ThinPoolWatcher,
	zfsWatcher *zfs.ZfsWatcher,
)

// newContainerHandler returns a new container.ContainerHandler
func newContainerHandler(
	client *dclient.Client,
	containerdClient containerd.ContainerdClient,
	name string,
	machineInfoFactory info.MachineInfoFactory,
	fsInfo fs.FsInfo,
	storageDriver StorageDriver,
	storageDir string,
	cgroupSubsystems map[string]string,
	inHostNamespace bool,
	metadataEnvAllowList []string,
	dockerVersion []int,
	metrics container.MetricSet,
	thinPoolName string,
	thinPoolWatcher *devicemapper.ThinPoolWatcher,
	zfsWatcher *zfs.ZfsWatcher,
) (container.ContainerHandler, error) {
	// Create the cgroup paths.
	cgroupPaths := common.MakeCgroupPaths(cgroupSubsystems, name)

	// Generate the equivalent cgroup manager for this container.
	cgroupManager, err := containerlibcontainer.NewCgroupManager(name, cgroupPaths)
	if err != nil {
		return nil, err
	}

	rootFs := "/"
	if !inHostNamespace {
		rootFs = "/rootfs"
		storageDir = path.Join(rootFs, storageDir)
	}

	id := dockerutil.ContainerNameToId(name)

	// Add the Containers dir where the log files are stored.
	// FIXME: Give `otherStorageDir` a more descriptive name.
	otherStorageDir := path.Join(storageDir, pathToContainersDir, id)

	var rootfsStorageDir, zfsFilesystem, zfsParent string
	if storageDriver == ContainerdSnapshotterStorageDriver {
		ctx := namespaces.WithNamespace(context.Background(), "moby")
		cntr, err := containerdClient.LoadContainer(ctx, id)
		if err != nil {
			return nil, err
		}

		var spec specs.Spec
		if err := json.Unmarshal(cntr.Spec.Value, &spec); err != nil {
			return nil, err
		}
		rootfsStorageDir = spec.Root.Path
	} else {
		rwLayerID, err := getRwLayerID(id, storageDir, storageDriver, dockerVersion)
		if err != nil {
			return nil, err
		}

		// Determine the rootfs storage dir OR the pool name to determine the device.