8

我听说这个数字不等于在图像中加在一起的所有大小的图层。它也不是它占用的磁盘空间大小。

现在我想通过源代码检查逻辑(在这个 repo 中:https ://github.com/docker/docker-ce ),因为眼见为实!但是在代码中浏览了很多时间后,我发现我无法找到真正的 imag-size-computing 代码。

那么 docker 用于执行大小逻辑的函数/文件是什么?

4

2 回答 2

13

在深入挖掘之前,您可能会发现了解 Linux 如何实现覆盖文件系统很有用。我在介绍演示的构建部分的第一个练习中包含了一些内容。演示说明包括我正在运行的每个命令,它让您了解层是如何合并的,以及当您从层中添加/修改/删除时会发生什么。


这取决于实现,取决于您的主机操作系统和正在使用的图形驱动程序。我以 Linux 操作系统和 Overlay2 为例,因为这是最常见的用例。

首先查看图像层存储大小

// GetContainerLayerSize returns the real size & virtual size of the container.
func (i *ImageService) GetContainerLayerSize(containerID string) (int64, int64) {
    var (
        sizeRw, sizeRootfs int64
        err                error
    )

    // Safe to index by runtime.GOOS as Unix hosts don't support multiple
    // container operating systems.
    rwlayer, err := i.layerStores[runtime.GOOS].GetRWLayer(containerID)
    if err != nil {
        logrus.Errorf("Failed to compute size of container rootfs %v: %v", containerID, err)
        return sizeRw, sizeRootfs
    }
    defer i.layerStores[runtime.GOOS].ReleaseRWLayer(rwlayer)

    sizeRw, err = rwlayer.Size()
    if err != nil {
        logrus.Errorf("Driver %s couldn't return diff size of container %s: %s",
            i.layerStores[runtime.GOOS].DriverName(), containerID, err)
        // FIXME: GetSize should return an error. Not changing it now in case
        // there is a side-effect.
        sizeRw = -1
    }

    if parent := rwlayer.Parent(); parent != nil {
        sizeRootfs, err = parent.Size()
        if err != nil {
            sizeRootfs = -1
        } else if sizeRw != -1 {
            sizeRootfs += sizeRw
        }
    }
    return sizeRw, sizeRootfs
}

有一个调用,layerStores它本身就是对 layer.Store 的映射

// ImageServiceConfig is the configuration used to create a new ImageService
type ImageServiceConfig struct {
    ContainerStore            containerStore
    DistributionMetadataStore metadata.Store
    EventsService             *daemonevents.Events
    ImageStore                image.Store
    LayerStores               map[string]layer.Store
    MaxConcurrentDownloads    int
    MaxConcurrentUploads      int
    MaxDownloadAttempts       int
    ReferenceStore            dockerreference.Store
    RegistryService           registry.Service
    TrustKey                  libtrust.PrivateKey
}

深入研究 for 的layer.Store实现GetRWLayer,有以下定义

func (ls *layerStore) GetRWLayer(id string) (RWLayer, error) {
    ls.locker.Lock(id)
    defer ls.locker.Unlock(id)

    ls.mountL.Lock()
    mount := ls.mounts[id]
    ls.mountL.Unlock()
    if mount == nil {
        return nil, ErrMountDoesNotExist
    }

    return mount.getReference(), nil
}

之后要找到Size挂载引用的实现,这个函数可以进入特定的图形驱动程序:

func (ml *mountedLayer) Size() (int64, error) {
    return ml.layerStore.driver.DiffSize(ml.mountID, ml.cacheParent())
}

查看 overlay2 图形驱动程序以找到DiffSize 函数

func (d *Driver) DiffSize(id, parent string) (size int64, err error) {
    if useNaiveDiff(d.home) || !d.isParent(id, parent) {
        return d.naiveDiff.DiffSize(id, parent)
    }
    return directory.Size(context.TODO(), d.getDiffPath(id))
}

那就是在 graphDriver 包naiveDiff中实现 Size 的调用:

func (gdw *NaiveDiffDriver) DiffSize(id, parent string) (size int64, err error) {
    driver := gdw.ProtoDriver

    changes, err := gdw.Changes(id, parent)
    if err != nil {
        return
    }

    layerFs, err := driver.Get(id, "")
    if err != nil {
        return
    }
    defer driver.Put(id)

    return archive.ChangesSize(layerFs.Path(), changes), nil
}

下面archive.ChangeSize我们可以看到这个实现

// ChangesSize calculates the size in bytes of the provided changes, based on newDir.
func ChangesSize(newDir string, changes []Change) int64 {
    var (
        size int64
        sf   = make(map[uint64]struct{})
    )
    for _, change := range changes {
        if change.Kind == ChangeModify || change.Kind == ChangeAdd {
            file := filepath.Join(newDir, change.Path)
            fileInfo, err := os.Lstat(file)
            if err != nil {
                logrus.Errorf("Can not stat %q: %s", file, err)
                continue
            }

            if fileInfo != nil && !fileInfo.IsDir() {
                if hasHardlinks(fileInfo) {
                    inode := getIno(fileInfo)
                    if _, ok := sf[inode]; !ok {
                        size += fileInfo.Size()
                        sf[inode] = struct{}{}
                    }
                } else {
                    size += fileInfo.Size()
                }
            }
        }
    }
    return size
}

在这一点上,我们正在使用os.Lstat返回一个结构,该结构包含Size在每个条目上,该条目是对每个目录的添加或修改。请注意,这是代码采用的几种可能路径之一,但我相信它是这种情况下最常见的路径之一。

于 2020-04-26T20:07:22.797 回答
0

你可以得到尺寸

$ docker image ls
REPOSITORY  TAG                 IMAGE ID            CREATED             SIZE
nginx       1.12-alpine         24ed1c575f81        2 years ago        15.5MB

这个功能代码在这里 https://github.com/docker/docker-ce/blob/5a0987be9​​3654b685927c2e5c2d18ac01022d20c/components/cli/cli/command/image/list.go

并从此代码获取大小 https://github.com/docker/docker-ce/blob/524986b1d978e1613bdc7b0448ba2cd16b3988b6/components/cli/cli/command/formatter/image.go

最后你需要 https://github.com/docker/docker-ce/blob/531930f3294c31db414f17f80fa8650d4ae66644/components/engine/daemon/images/images.go

于 2020-04-26T19:05:42.583 回答