docker 1.13中docker system prune的浅析

docker rm `docker ps -a | grep -i 'exited' | awk {'print $1'}`

// docker system prune command handler
func runPrune(dockerCli *command.DockerCli, options pruneOptions) error {
	var message string

	// 这个选项针对image清理
	// 如果有all标识，就清理所有image，而不单单是dangling
	if options.all {
		message = fmt.Sprintf(warning, allImageDesc)
	} else {
		message = fmt.Sprintf(warning, danglingImageDesc)
	}

	if !options.force && !command.PromptForConfirmation(dockerCli.In(), dockerCli.Out(), message) {
		return nil
	}

	var spaceReclaimed uint64

	/* 
	分析业务逻辑： 
		首先依次处理没有option的3个清理维度
			- container清理
			- volume清理
			- network清理
	*/   
	/* 
	分析代码写法：
		range后面跟的是初始化的数组，类型是func（看起来像是匿名函数），内容是填充dockerCli这个字段
	*/
	for _, pruneFn := range []func(dockerCli *command.DockerCli, filter opts.FilterOpt) (uint64, string, error){
		prune.RunContainerPrune,
		prune.RunVolumePrune,
		prune.RunNetworkPrune,
	} {
		// 循环体内，是依次执行这3个具有不同dockerCli值的函数
		spc, output, err := pruneFn(dockerCli, options.filter)
		if err != nil {
			return err
		}
		spaceReclaimed += spc
		if output != "" {
			fmt.Fprintln(dockerCli.Out(), output)
		}
	}

    // 由于接受的参数不同，image清理函数被独立执行
	spc, output, err := prune.RunImagePrune(dockerCli, options.all, options.filter)
	if err != nil {
		return err
	}
	if spc > 0 {
		spaceReclaimed += spc
		fmt.Fprintln(dockerCli.Out(), output)
	}

	fmt.Fprintln(dockerCli.Out(), "Total reclaimed space:", units.HumanSize(float64(spaceReclaimed)))

	return nil
}

// actual function to do the prune operation for docker container
func (daemon *Daemon) ContainersPrune(pruneFilters filters.Args) (*types.ContainersPruneReport, error) {
	rep := &types.ContainersPruneReport{}

	// 这个方法目的是在于截取请求option当中until字段的值，并系列化成对象，后面会用到。
	// 这里对pruneFilters做的特殊处理，是为了docker image/container prune这些命令，因为他们可以有--filter until=这样的选项
        // 详细可参见：https://github.com/docker/docker/commit/58738cdee327f5de481dcf7d3d377374cbb5f13a
	until, err := getUntilFromPruneFilters(pruneFilters)
	if err != nil {
		return nil, err
	}
	/*
	分析业务逻辑：
		- 拿到本机所有container，包含运行和退出的
		- 遍历每个container是不是在运行，
		- 符合条件的container，就进行删除操作，并记录大小用于统计报告
	*/
	allContainers := daemon.List()
	for _, c := range allContainers {
		if !c.IsRunning() {
			// until字段，从字面意思就是说，会把这个字段指定的时间之后创建的container过滤掉,不做处理
			if !until.IsZero() && c.Created.After(until) {
				continue
			}
			// 获取container的大小
			cSize, _ := daemon.getSize(c)
			// TODO: sets RmLink to true?
			err := daemon.ContainerRm(c.ID, &types.ContainerRmConfig{})
			if err != nil {
				logrus.Warnf("failed to prune container %s: %v", c.ID, err)
				continue
			}
			// 把成功删除的container大小加到最终显示的清理值中去
			if cSize > 0 {
				rep.SpaceReclaimed += uint64(cSize)
			}
			rep.ContainersDeleted = append(rep.ContainersDeleted, c.ID)
		}
	}

	return rep, nil
}