docker v18.09.4-rc1系列源码解读之docker info 命令请求流程
内容导读
互联网集市收集整理的这篇技术教程文章主要介绍了docker v18.09.4-rc1系列源码解读之docker info 命令请求流程,小编现在分享给大家,供广大互联网技能从业者学习和参考。文章包含5361字,纯文字阅读大概需要8分钟。
内容图文
先上一个流程图示仅供自己梳理了解最新代码流程,有些细节并不会展开深挖
1、进入客户端接收代码块,由runInfo方法返回内容
github.com/docker/cli/cli/command/system/info.go
// NewInfoCommand creates a new cobra.Command for `docker info`
func NewInfoCommand(dockerCli command.Cli) *cobra.Command {
var opts infoOptions
cmd := &cobra.Command{
Use: "info [OPTIONS]",
Short: "Display system-wide information",
Args: cli.NoArgs,
RunE: func(cmd *cobra.Command, args []string) error {
return runInfo(dockerCli, &opts)
},
}
func runInfo(dockerCli command.Cli, opts *infoOptions) error {
ctx := context.Background()
info, err := dockerCli.Client().Info(ctx)
2、 请求转发给docker daemon处理
github.com/docker/cli/vendor/github.com/docker/docker/client/info.go
// Info returns information about the docker server.
func (cli *Client) Info(ctx context.Context) (types.Info, error) {
var info types.Info
serverResp, err := cli.get(ctx, "/info", url.Values{}, nil)
3、docker daemon的监听路由,进入到SystemInfo处理
github.com/docker/docker/api/server/router/system/system.go
// NewRouter initializes a new system router
func NewRouter(b Backend, c ClusterBackend, fscache *fscache.FSCache, builder *buildkit.Builder, features *map[string]bool) router.Router {
router.NewGetRoute("/info", r.getInfo),
github.com/docker/docker/api/server/router/system/system_routes.go
func (s *systemRouter) getInfo(ctx context.Context, w http.ResponseWriter, r *http.Request, vars map[string]string) error {
info, err := s.backend.SystemInfo()
4、经过进入systemInfo处理方法,可知container状态信息是已经在内存中数据
github.com/docker/docker/daemon/info.go
// SystemInfo returns information about the host server the daemon is running on.
func (daemon *Daemon) SystemInfo() (*types.Info, error) {
sysInfo := sysinfo.New(true)
cRunning, cPaused, cStopped := stateCtr.get()
v := &types.Info{
ID: daemon.ID,
Containers: cRunning + cPaused + cStopped,
ContainersRunning: cRunning,
ContainersPaused: cPaused,
ContainersStopped: cStopped,
5、找到设置container运行状态的数据方法
github.com/docker/docker/daemon/metrics.go
func (ctr *stateCounter) set(id, label string) {
ctr.mu.Lock()
ctr.states[id] = label
ctr.mu.Unlock()
}
6、容器状态数据来源
6.1、顺着设置方法找到在创建container时会设置一条数据,这是初始化的数据
github.com/docker/docker/daemon/create.go
// Create creates a new container from the given configuration with a given name.
func (daemon *Daemon) create(params types.ContainerCreateConfig, managed bool) (retC *container.Container, retErr error) {
stateCtr.set(container.ID, "stopped")
6.2、容器操作(暂停、启动、恢复)
github.com/docker/docker/daemon/pause.go
// containerPause pauses the container execution without stopping the process.
// The execution can be resumed by calling containerUnpause.
func (daemon *Daemon) containerPause(container *container.Container) error {
container.Paused = true
daemon.setStateCounter(container)
github.com/docker/docker/daemon/start.go
// containerStart prepares the container to run by setting up everything the
// container needs, such as storage and networking, as well as links
// between containers. The container is left waiting for a signal to
// begin running.
func (daemon *Daemon) containerStart(container *container.Container, checkpoint string, checkpointDir string, resetRestartManager bool) (err error) {
container.SetRunning(pid, true)
container.HasBeenManuallyStopped = false
container.HasBeenStartedBefore = true
daemon.setStateCounter(container)
github.com/docker/docker/daemon/unpause.go
// containerUnpause resumes the container execution after the container is paused.
func (daemon *Daemon) containerUnpause(container *container.Container) error {
container.Paused = false
daemon.setStateCounter(container)
6.3、docker重启后,从目录中获取容器状态
github.com/docker/docker/daemon/daemon.go
func (daemon *Daemon) restore() error {
for _, c := range containers {
//从文件config.v2.json中获取容器状态
daemon.setStateCounter(c)
//如文件中的状态是运行或暂停,再进行检查,并重置状态
if c.IsRunning() || c.IsPaused() {
default:
// running
c.Lock()
c.Paused = false
daemon.setStateCounter(c)
7、事件变更重置容器状态(windows)
7.1、container状态变更的信息方法
github.com/docker/docker/daemon/monitor.go
func (daemon *Daemon) setStateCounter(c *container.Container) {
switch c.StateString() {
case "paused":
stateCtr.set(c.ID, "paused")
case "running":
stateCtr.set(c.ID, "running")
default:
stateCtr.set(c.ID, "stopped")
}
}
7.2、windows事件监听
github.com/docker/docker/daemon/monitor.go
// ProcessEvent is called by libcontainerd whenever an event occurs
func (daemon *Daemon) ProcessEvent(id string, e libcontainerd.EventType, ei libcontainerd.EventInfo) error {
case libcontainerd.EventExit:
daemon.setStateCounter(c)
case libcontainerd.EventStart:
// This is here to handle start not generated by docker
if !c.Running {
c.SetRunning(int(ei.Pid), false)
c.HasBeenManuallyStopped = false
c.HasBeenStartedBefore = true
daemon.setStateCounter(c)
case libcontainerd.EventPaused:
if !c.Paused {
c.Paused = true
daemon.setStateCounter(c)
case libcontainerd.EventResumed:
if c.Paused {
c.Paused = false
daemon.setStateCounter(c)
8、开启启动docker时的debug模式,获取文件描述、goroute等信息
dockerd --debug
github.com/docker/cli/cli/command/system/info.go
if info.Debug {
fmt.Fprintln(dockerCli.Out(), " File Descriptors:", info.NFd)
fmt.Fprintln(dockerCli.Out(), " Goroutines:", info.NGoroutines)
fmt.Fprintln(dockerCli.Out(), " System Time:", info.SystemTime)
fmt.Fprintln(dockerCli.Out(), " EventsListeners:", info.NEventsListener)
}
原文:https://blog.51cto.com/bingdian/2370407
内容总结
以上是互联网集市为您收集整理的docker v18.09.4-rc1系列源码解读之docker info 命令请求流程全部内容,希望文章能够帮你解决docker v18.09.4-rc1系列源码解读之docker info 命令请求流程所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错,欢迎将互联网集市网站推荐给程序员好友。
内容备注
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 gblab@vip.qq.com 举报,一经查实,本站将立刻删除。
内容手机端
扫描二维码推送至手机访问。