Docker源码分析（三）之Docker Daemon

ゝ一世哀愁。 2022-06-11 03:22 993阅读 0赞

# 一、Docker Daemon架构示意图 #

![Center][]

Docker Daemon是Docker架构中运行在后台的守护进程，大致可以分为Docker Server、Engine和Job三部分。

Docker Daemon可以认为是通过Docker Server模块接受Docker Client的请求，并在Engine中处理请求，然后根据请求类型，创建出指定的Job并运行。

运行过程的作用有以下几种可能：

*  向Docker Registry获取镜像，
 *  通过graphdriver执行容器镜像的本地化操作，
 *  通过networkdriver执行容器网络环境的配置，
 *  通过execdriver执行容器内部运行的执行工作等。

说明：本文分析的代码为Docker 1.2.0版本。

# 二、Docker Daemon启动流程图 #

![Center 1][]

启动Docker Daemon时，一般可以使用以下命令：docker --daemon=true; docker –d; docker –d=true等。接着由docker的main()函数来解析以上命令的相应flag参数，并最终完成Docker Daemon的启动。

**/docker/docker.go**

<table> 
 <tbody> 
 <tr> 
 <td style="vertical-align:baseline;"> <code>func main() { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>...</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>if</code>&nbsp;<code>*flDaemon { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>mainDaemon()</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>...</code> <code>}</code> </td> 
 </tr> 
 </tbody> 
</table>

# 三、mainDaemon的具体实现 #

宏观来讲，mainDaemon()完成创建一个daemon进程，并使其正常运行。

从功能的角度来说，mainDaemon()实现了两部分内容：

*  第一，创建Docker运行环境；
 *  第二，服务于Docker Client，接收并处理相应请求。

## （一）配置初始化 ##

**/docker/daemon.go**

<table> 
 <tbody> 
 <tr> 
 <td style="vertical-align:baseline;"> <code>var (</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>daemonCfg = &amp;daemon.Config{}</code> <code>)</code> <code>func init() { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>daemonCfg.InstallFlags()</code> <code>}</code> </td> 
 </tr> 
 </tbody> 
</table>

在mainDaemon()运行之前，关于Docker Daemon所需要的config配置信息均已经初始化完毕。

声明一个为daemon包中Config类型的变量，名为daemonCfg。而Config对象，定义了Docker Daemon所需的配置信息。在Docker Daemon在启动时，daemonCfg变量被传递至Docker Daemon并被使用。

**/daemon/config.go**

<table> 
 <tbody> 
 <tr> 
 <td style="vertical-align:baseline;"> <code>type Config&nbsp;</code><code>struct</code>&nbsp;<code>{ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>Pidfile&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; string&nbsp;&nbsp;&nbsp;</code><code>//Docker Daemon所属进程的PID文件</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>Root&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; string&nbsp;&nbsp;&nbsp;</code><code>//Docker运行时所使用的root路径</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>AutoRestart&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>bool</code>&nbsp;&nbsp;&nbsp;&nbsp;<code>//已被启用，转而支持docker run时的重启</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>Dns&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; []string&nbsp;&nbsp;</code><code>//Docker使用的DNS Server地址</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>DnsSearch&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; []string&nbsp;&nbsp;</code><code>//Docker使用的指定的DNS查找域名</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>Mirrors&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; []string&nbsp;&nbsp;</code><code>//指定的优先Docker Registry镜像</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>EnableIptables&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>bool</code>&nbsp;&nbsp;&nbsp;&nbsp;<code>//启用Docker的iptables功能</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>EnableIpForward&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>bool</code>&nbsp;&nbsp;&nbsp;&nbsp;<code>//启用net.ipv4.ip_forward功能</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>EnableIpMasq&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>bool</code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<code>//启用IP伪装技术</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>DefaultIp&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; net.IP&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>//绑定容器端口时使用的默认IP</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>BridgeIface&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; string&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>//添加容器网络至已有的网桥</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>BridgeIP&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; string&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>//创建网桥的IP地址</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>FixedCIDR&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; string&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>//指定IP的IPv4子网，必须被网桥子网包含</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>InterContainerCommunication&nbsp;&nbsp;&nbsp;</code><code>bool</code>&nbsp;&nbsp;<code>//是否允许相同host上容器间的通信</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>GraphDriver&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; string&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>//Docker运行时使用的特定存储驱动</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>GraphOptions&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; []string&nbsp;&nbsp;&nbsp;</code><code>//可设置的存储驱动选项</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>ExecDriver&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; string&nbsp;&nbsp;&nbsp;&nbsp;</code><code>// Docker运行时使用的特定exec驱动</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>Mtu&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>int</code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<code>//设置容器网络的MTU</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>DisableNetwork&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>bool</code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<code>//有定义，之后未初始化</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>EnableSelinuxSupport&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>bool</code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<code>//启用SELinux功能的支持</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>Context&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; map[string][]string&nbsp;&nbsp;&nbsp;</code><code>//有定义，之后未初始化</code> <code>}</code> </td> 
 </tr> 
 </tbody> 
</table>

init()函数实现了daemonCfg变量中各属性的赋值，具体的实现为：daemonCfg.InstallFlags()

**/daemon/config.go**

<table> 
 <tbody> 
 <tr> 
 <td style="vertical-align:baseline;"> <code>// InstallFlags adds command-line options to the top-level flag parser for</code> <code>// the current process.</code> <code>// Subsequent calls to `flag.Parse` will populate config with values parsed</code> <code>// from the command-line.</code> <code>func (config *Config) InstallFlags() { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>flag.StringVar(&amp;config.Pidfile, []string{ </code><code>"p"</code><code>,&nbsp;</code><code>"-pidfile"</code><code>},&nbsp;</code><code>"/var/run/docker.pid"</code><code>,&nbsp;</code><code>"Path to use for daemon PID file"</code><code>)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>flag.StringVar(&amp;config.Root, []string{ </code><code>"g"</code><code>,&nbsp;</code><code>"-graph"</code><code>},&nbsp;</code><code>"/var/lib/docker"</code><code>,&nbsp;</code><code>"Path to use as the root of the Docker runtime"</code><code>)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>flag.BoolVar(&amp;config.AutoRestart, []string{ </code><code>"#r"</code><code>,&nbsp;</code><code>"#-restart"</code><code>},&nbsp;</code><code>true</code><code>,&nbsp;</code><code>"--restart on the daemon has been deprecated infavor of --restart policies on docker run"</code><code>)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>flag.BoolVar(&amp;config.EnableIptables, []string{ </code><code>"#iptables"</code><code>,&nbsp;</code><code>"-iptables"</code><code>},&nbsp;</code><code>true</code><code>,&nbsp;</code><code>"Enable Docker's addition of iptables rules"</code><code>)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>flag.BoolVar(&amp;config.EnableIpForward, []string{ </code><code>"#ip-forward"</code><code>,&nbsp;</code><code>"-ip-forward"</code><code>},&nbsp;</code><code>true</code><code>,&nbsp;</code><code>"Enable net.ipv4.ip_forward"</code><code>)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>flag.StringVar(&amp;config.BridgeIP, []string{ </code><code>"#bip"</code><code>,&nbsp;</code><code>"-bip"</code><code>},&nbsp;</code><code>""</code><code>,&nbsp;</code><code>"Use this CIDR notation address for the network bridge's IP, not compatible with -b"</code><code>)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>flag.StringVar(&amp;config.BridgeIface, []string{ </code><code>"b"</code><code>,&nbsp;</code><code>"-bridge"</code><code>},&nbsp;</code><code>""</code><code>,&nbsp;</code><code>"Attach containers to a pre-existing network bridge\nuse 'none' to disable container networking"</code><code>)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>flag.BoolVar(&amp;config.InterContainerCommunication, []string{ </code><code>"#icc"</code><code>,&nbsp;</code><code>"-icc"</code><code>},&nbsp;</code><code>true</code><code>,&nbsp;</code><code>"Enable inter-container communication"</code><code>)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>flag.StringVar(&amp;config.GraphDriver, []string{ </code><code>"s"</code><code>,&nbsp;</code><code>"-storage-driver"</code><code>},&nbsp;</code><code>""</code><code>,&nbsp;</code><code>"Force the Docker runtime to use a specific storage driver"</code><code>)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>flag.StringVar(&amp;config.ExecDriver, []string{ </code><code>"e"</code><code>,&nbsp;</code><code>"-exec-driver"</code><code>},&nbsp;</code><code>"native"</code><code>,&nbsp;</code><code>"Force the Docker runtime to use a specific exec driver"</code><code>)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>flag.BoolVar(&amp;config.EnableSelinuxSupport, []string{ </code><code>"-selinux-enabled"</code><code>},&nbsp;</code><code>false</code><code>,&nbsp;</code><code>"Enable selinux support. SELinux does not presently support the BTRFS storage driver"</code><code>)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>flag.IntVar(&amp;config.Mtu, []string{ </code><code>"#mtu"</code><code>,&nbsp;</code><code>"-mtu"</code><code>}, 0,&nbsp;</code><code>"Set the containers network MTU\nif no value is provided: default to the default route MTU or 1500 if no default route is available"</code><code>)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>opts.IPVar(&amp;config.DefaultIp, []string{ </code><code>"#ip"</code><code>,&nbsp;</code><code>"-ip"</code><code>},&nbsp;</code><code>"0.0.0.0"</code><code>,&nbsp;</code><code>"Default IP address to use when binding container ports"</code><code>)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>opts.ListVar(&amp;config.GraphOptions, []string{ </code><code>"-storage-opt"</code><code>},&nbsp;</code><code>"Set storage driver options"</code><code>)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>// FIXME: why the inconsistency between "hosts" and "sockets"?</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>opts.IPListVar(&amp;config.Dns, []string{ </code><code>"#dns"</code><code>,&nbsp;</code><code>"-dns"</code><code>},&nbsp;</code><code>"Force Docker to use specific DNS servers"</code><code>)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>opts.DnsSearchListVar(&amp;config.DnsSearch, []string{ </code><code>"-dns-search"</code><code>},&nbsp;</code><code>"Force Docker to use specific DNS search domains"</code><code>)</code> <code>}</code> </td> 
 </tr> 
 </tbody> 
</table>

在InstallFlags()函数的实现过程中，主要是定义某种类型的flag参数，并将该参数的值绑定在config变量的指定属性上，如：

flag.StringVar(&config.Pidfile, \[\]string\{"p", "-pidfile"\}, " /var/run/docker.pid", "Path to use for daemon PID file")

以上语句的含义为：

*  定义一个为String类型的flag参数；
 *  该flag的名称为”p”或者”-pidfile”;
 *  该flag的值为” /var/run/docker.pid”,并将该值绑定在变量config.Pidfile上；
 *  该flag的描述信息为"Path to use for daemon PID file"。

## （二）flag参数检查 ##

**/docker/daemon.go**

<table> 
 <tbody> 
 <tr> 
 <td style="vertical-align:baseline;"> <code>if</code>&nbsp;<code>flag.NArg() != 0 { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>flag.Usage()</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code> <code>}</code> </td> 
 </tr> 
 </tbody> 
</table>

*  参数个数不为0，则说明在启动Docker Daemon的时候，传入了多余的参数，此时会输出错误提示，并退出运行程序。
 *  若为0，则说明Docker Daemon的启动命令无误，正常运行。

## （三）创建engine对象 ##

**/docker/daemon.go**

<table> 
 <tbody> 
 <tr> 
 <td style="vertical-align:baseline;"> <code>eng := engine.New()</code> </td> 
 </tr> 
 </tbody> 
</table>

Engine是Docker架构中的运行引擎，同时也是Docker运行的核心模块。Engine扮演着Docker container存储仓库的角色，并且通过job的形式来管理这些容器。

**/engine/engine.go**

<table> 
 <tbody> 
 <tr> 
 <td style="vertical-align:baseline;"> <code>type Engine&nbsp;</code><code>struct</code>&nbsp;<code>{ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>handlers&nbsp;&nbsp; map[string]Handler</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>catchall&nbsp;&nbsp; Handler</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>hack&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Hack&nbsp;</code><code>// data for temporary hackery (see hack.go)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>id&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; string</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>Stdout&nbsp;&nbsp;&nbsp;&nbsp; io.Writer</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>Stderr&nbsp;&nbsp;&nbsp;&nbsp; io.Writer</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>Stdin&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; io.Reader</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>Logging&nbsp;&nbsp;&nbsp;&nbsp;</code><code>bool</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>tasks&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; sync.WaitGroup</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>l&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; sync.RWMutex&nbsp;</code><code>// lock for shutdown</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>shutdown&nbsp;&nbsp;&nbsp;</code><code>bool</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>onShutdown []func()&nbsp;</code><code>// shutdown handlers</code> <code>}</code> </td> 
 </tr> 
 </tbody> 
</table>

Engine结构体中最为重要的即为handlers属性。该handlers属性为map类型，key为string类型，value为Handler类型。Handler为一个定义的函数。该函数传入的参数为Job指针，返回为Status状态。

**/engine/engine.go**

<table> 
 <tbody> 
 <tr> 
 <td style="vertical-align:baseline;"> <code>type Handler func(*Job) Status</code> </td> 
 </tr> 
 </tbody> 
</table>

New()函数的实现:

**/engine/engine.go**

<table> 
 <tbody> 
 <tr> 
 <td style="vertical-align:baseline;"> <code>// New initializes a new engine.</code> <code>func New() *Engine { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>eng := &amp;Engine{ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>handlers: make(map[string]Handler),</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>id:&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; utils.RandomString(),</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>Stdout:&nbsp;&nbsp; os.Stdout,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>Stderr:&nbsp;&nbsp; os.Stderr,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>Stdin:&nbsp;&nbsp;&nbsp; os.Stdin,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>Logging:&nbsp;&nbsp;</code><code>true</code><code>,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>eng.Register(</code><code>"commands"</code><code>, func(job *Job) Status { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>for</code>&nbsp;<code>_, name := range eng.commands() { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>job.Printf(</code><code>"%s\n"</code><code>, name)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code>&nbsp;<code>StatusOK</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>})</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>// Copy existing global handlers</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>for</code>&nbsp;<code>k, v := range globalHandlers { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>eng.handlers[k] = v</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code>&nbsp;<code>eng</code> <code>}</code> </td> 
 </tr> 
 </tbody> 
</table>

1.  创建一个Engine结构体实例eng
2.  向eng对象注册名为commands的Handler，其中Handler为临时定义的函数func(job \*Job) Status\{ \} , 该函数的作用是通过job来打印所有已经注册完毕的command名称，最终返回状态StatusOK。
3.  将已定义的变量globalHandlers中的所有的Handler，都复制到eng对象的handlers属性中。最后成功返回eng对象。

## （四）设置engine的信号捕获 ##

**/daemon/daemon.go**

<table> 
 <tbody> 
 <tr> 
 <td style="vertical-align:baseline;"> <code>signal</code><code>.Trap(eng.Shutdown)</code> </td> 
 </tr> 
 </tbody> 
</table>

在Docker Daemon的运行中，设置Trap特定信号的处理方法，特定信号有SIGINT，SIGTERM以及SIGQUIT；当程序捕获到SIGINT或者SIGTERM信号时，执行相应的善后操作，最后保证Docker Daemon程序退出。

**/pkg/signal/trap.go**

<table> 
 <tbody> 
 <tr> 
 <td style="vertical-align:baseline;"> <code>/ Trap sets up a simplified&nbsp;</code><code>signal</code>&nbsp;<code>"trap"</code><code>, appropriate&nbsp;</code><code>for</code>&nbsp;<code>common</code> <code>// behavior expected from a vanilla unix command-line tool in general</code> <code>// (and the Docker engine in particular).</code> <code>//</code> <code>// * If SIGINT or SIGTERM are received, `cleanup` is called, then the process is terminated.</code> <code>// * If SIGINT or SIGTERM are repeated 3 times before cleanup is complete, then cleanup is</code> <code>// skipped and the process terminated directly.</code> <code>// * If "DEBUG" is set in the environment, SIGQUIT causes an exit without cleanup.</code> <code>//</code> <code>func Trap(cleanup func()) { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>c := make(chan os.Signal, 1)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>signals := []os.Signal{os.Interrupt, syscall.SIGTERM}</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>if</code>&nbsp;<code>os.Getenv(</code><code>"DEBUG"</code><code>) ==&nbsp;</code><code>""</code>&nbsp;<code>{ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>signals = append(signals, syscall.SIGQUIT)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>gosignal.Notify(c, signals...)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>go func() { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>interruptCount := uint32(0)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>for</code>&nbsp;<code>sig := range c { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>go func(sig os.Signal) { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>log</code><code>.Printf(</code><code>"Received signal '%v', starting shutdown of docker...\n"</code><code>, sig)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>switch</code>&nbsp;<code>sig { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>case</code>&nbsp;<code>os.Interrupt, syscall.SIGTERM:</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>// If the user really wants to interrupt, let him do so.</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>if</code>&nbsp;<code>atomic.LoadUint32(&amp;interruptCount) &lt; 3 { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>atomic.AddUint32(&amp;interruptCount, 1)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>// Initiate the cleanup only once</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>if</code>&nbsp;<code>atomic.LoadUint32(&amp;interruptCount) == 1 { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>// Call cleanup handler</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>cleanup()</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>os.Exit(0)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}&nbsp;</code><code>else</code>&nbsp;<code>{ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}&nbsp;</code><code>else</code>&nbsp;<code>{ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>log</code><code>.Printf(</code><code>"Force shutdown of docker, interrupting cleanup\n"</code><code>)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>case</code>&nbsp;<code>syscall.SIGQUIT:</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>os.Exit(128 +&nbsp;</code><code>int</code><code>(sig.(syscall.Signal)))</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}(sig)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}()</code> <code>}&nbsp;</code> </td> 
 </tr> 
 </tbody> 
</table>

*  创建并设置一个channel，用于发送信号通知；
 *  定义signals数组变量，初始值为os.SIGINT, os.SIGTERM;若环境变量DEBUG为空的话，则添加os.SIGQUIT至signals数组；
 *  通过gosignal.Notify(c, signals...)中Notify函数来实现将接收到的signal信号传递给c。需要注意的是只有signals中被罗列出的信号才会被传递给c，其余信号会被直接忽略；
 *  创建一个goroutine来处理具体的signal信号，当信号类型为os.Interrupt或者syscall.SIGTERM时，执行传入Trap函数的具体执行方法，形参为cleanup(),实参为eng.Shutdown。

Shutdown()函数的定义位于[./docker/engine/engine.go][._docker_engine_engine.go]，主要做的工作是为Docker Daemon的关闭做一些善后工作。

**/engine/engine.go**

<table> 
 <tbody> 
 <tr> 
 <td style="vertical-align:baseline;"> <code>// Shutdown permanently shuts down eng as follows:</code> <code>// - It refuses all new jobs, permanently.</code> <code>// - It waits for all active jobs to complete (with no timeout)</code> <code>// - It calls all shutdown handlers concurrently (if any)</code> <code>// - It returns when all handlers complete, or after 15 seconds,</code> <code>//&nbsp;&nbsp;&nbsp; whichever happens first.</code> <code>func (eng *Engine) Shutdown() { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>eng.l.Lock()</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>if</code>&nbsp;<code>eng.shutdown { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>eng.l.Unlock()</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>eng.shutdown =&nbsp;</code><code>true</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>eng.l.Unlock()</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>// We don't need to protect the rest with a lock, to allow</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>// for other calls to immediately fail with "shutdown" instead</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>// of hanging for 15 seconds.</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>// This requires all concurrent calls to check for shutdown, otherwise</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>// it might cause a race.</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>// Wait for all jobs to complete.</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>// Timeout after 5 seconds.</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>tasksDone := make(chan&nbsp;</code><code>struct</code><code>{})</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>go func() { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>eng.tasks.Wait()</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>close(tasksDone)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}()</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>select { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>case</code>&nbsp;<code>&lt;-</code><code>time</code><code>.After(</code><code>time</code><code>.Second * 5):</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>case</code>&nbsp;<code>&lt;-tasksDone:</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>// Call shutdown handlers, if any.</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>// Timeout after 10 seconds.</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>var wg sync.WaitGroup</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>for</code>&nbsp;<code>_, h := range eng.onShutdown { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>wg.Add(1)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>go func(h func()) { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>defer wg.Done()</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>h()</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}(h)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>done := make(chan&nbsp;</code><code>struct</code><code>{})</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>go func() { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>wg.Wait()</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>close(done)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}()</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>select { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>case</code>&nbsp;<code>&lt;-</code><code>time</code><code>.After(</code><code>time</code><code>.Second * 10):</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>case</code>&nbsp;<code>&lt;-done:</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code> <code>}</code> </td> 
 </tr> 
 </tbody> 
</table>

*  Docker Daemon不再接收任何新的Job；
 *  Docker Daemon等待所有存活的Job执行完毕；
 *  Docker Daemon调用所有shutdown的处理方法；
 *  当所有的handler执行完毕，或者15秒之后，Shutdown()函数返回。

由于在signal.Trap( eng.Shutdown )函数的具体实现中执行eng.Shutdown，在执行完eng.Shutdown之后，随即执行[os.Exit(0)][os.Exit_0]，完成当前程序的立即退出。

## （五）加载builtins ##

**/docker/daemon.go**

<table> 
 <tbody> 
 <tr> 
 <td style="vertical-align:baseline;"> <code>if</code>&nbsp;<code>err := builtins.Register(eng); err != nil { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>log</code><code>.Fatal(err)</code> <code>}</code> </td> 
 </tr> 
 </tbody> 
</table>

为engine注册多个Handler，以便后续在执行相应任务时，运行指定的Handler。

这些Handler包括：

*  网络初始化、
 *  web API服务、
 *  事件查询、
 *  版本查看、
 *  Docker Registry验证与搜索。

**/builtins/builtins.go**

<table> 
 <tbody> 
 <tr> 
 <td style="vertical-align:baseline;"> <code>func Register(eng *engine.Engine) error { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>if</code>&nbsp;<code>err := daemon(eng); err != nil { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code>&nbsp;<code>err</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>if</code>&nbsp;<code>err := remote(eng); err != nil { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code>&nbsp;<code>err</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>if</code>&nbsp;<code>err := events.New().Install(eng); err != nil { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code>&nbsp;<code>err</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>if</code>&nbsp;<code>err := eng.Register(</code><code>"version"</code><code>, dockerVersion); err != nil { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code>&nbsp;<code>err</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code>&nbsp;<code>registry.NewService().Install(eng)</code> <code>}</code> </td> 
 </tr> 
 </tbody> 
</table>

### 1、注册初始化网络驱动的Handler ###

daemon(eng)的实现过程，主要为eng对象注册了一个key为”init\_networkdriver”的Handler，该Handler的值为bridge.InitDriver函数，代码如下：

**/builtins/builtins.go**

<table> 
 <tbody> 
 <tr> 
 <td style="vertical-align:baseline;"> <code>func daemon(eng *engine.Engine) error { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code>&nbsp;<code>eng.Register(</code><code>"init_networkdriver"</code><code>, bridge.InitDriver)</code> <code>}</code> </td> 
 </tr> 
 </tbody> 
</table>

需要注意的是，向eng对象注册Handler，并不代表Handler的值函数会被直接运行，如bridge.InitDriver，并不会直接运行，而是将bridge.InitDriver的函数入口，写入eng的handlers属性中。

**/daemon/networkdriver/bridge/driver.go**

<table> 
 <tbody> 
 <tr> 
 <td style="vertical-align:baseline;"> <code>func InitDriver(job *engine.Job) engine.Status { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>var (</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>network&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; *net.IPNet</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>enableIPTables = job.GetenvBool(</code><code>"EnableIptables"</code><code>)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>icc&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; = job.GetenvBool(</code><code>"InterContainerCommunication"</code><code>)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>ipForward&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; = job.GetenvBool(</code><code>"EnableIpForward"</code><code>)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>bridgeIP&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; = job.Getenv(</code><code>"BridgeIP"</code><code>)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>)</code> &nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>if</code>&nbsp;<code>defaultIP := job.Getenv(</code><code>"DefaultBindingIP"</code><code>); defaultIP !=&nbsp;</code><code>""</code>&nbsp;<code>{ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>defaultBindingIP = net.ParseIP(defaultIP)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> &nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>bridgeIface = job.Getenv(</code><code>"BridgeIface"</code><code>)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>usingDefaultBridge :=&nbsp;</code><code>false</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>if</code>&nbsp;<code>bridgeIface ==&nbsp;</code><code>""</code>&nbsp;<code>{ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>usingDefaultBridge =&nbsp;</code><code>true</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>bridgeIface = DefaultNetworkBridge</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> &nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>addr, err := networkdriver.GetIfaceAddr(bridgeIface)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>if</code>&nbsp;<code>err != nil { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>// If we're not using the default bridge, fail without trying to create it</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>if</code>&nbsp;<code>!usingDefaultBridge { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>job.Logf(</code><code>"bridge not found: %s"</code><code>, bridgeIface)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code>&nbsp;<code>job.Error(err)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>// If the iface is not found, try to create it</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>job.Logf(</code><code>"creating new bridge for %s"</code><code>, bridgeIface)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>if</code>&nbsp;<code>err := createBridge(bridgeIP); err != nil { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code>&nbsp;<code>job.Error(err)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> &nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>job.Logf(</code><code>"getting iface addr"</code><code>)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>addr, err = networkdriver.GetIfaceAddr(bridgeIface)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>if</code>&nbsp;<code>err != nil { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code>&nbsp;<code>job.Error(err)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>network = addr.(*net.IPNet)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}&nbsp;</code><code>else</code>&nbsp;<code>{ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>network = addr.(*net.IPNet)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>// validate that the bridge ip matches the ip specified by BridgeIP</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>if</code>&nbsp;<code>bridgeIP !=&nbsp;</code><code>""</code>&nbsp;<code>{ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>bip, _, err := net.ParseCIDR(bridgeIP)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>if</code>&nbsp;<code>err != nil { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code>&nbsp;<code>job.Error(err)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>if</code>&nbsp;<code>!network.IP.Equal(bip) { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code>&nbsp;<code>job.Errorf(</code><code>"bridge ip (%s) does not match existing bridge configuration %s"</code><code>, network.IP, bip)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> &nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>// Configure iptables for link support</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>if</code>&nbsp;<code>enableIPTables { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>if</code>&nbsp;<code>err := setupIPTables(addr, icc); err != nil { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code>&nbsp;<code>job.Error(err)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> &nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>if</code>&nbsp;<code>ipForward { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>// Enable IPv4 forwarding</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>if</code>&nbsp;<code>err := ioutil.WriteFile(</code><code>"/proc/sys/net/ipv4/ip_forward"</code><code>, []byte{ </code><code>'1'</code><code>,&nbsp;</code><code>'\n'</code><code>}, 0644); err != nil { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>job.Logf(</code><code>"WARNING: unable to enable IPv4 forwarding: %s\n"</code><code>, err)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> &nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>// We can always try removing the iptables</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>if</code>&nbsp;<code>err := iptables.RemoveExistingChain(</code><code>"DOCKER"</code><code>); err != nil { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code>&nbsp;<code>job.Error(err)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> &nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>if</code>&nbsp;<code>enableIPTables { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>chain, err := iptables.NewChain(</code><code>"DOCKER"</code><code>, bridgeIface)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>if</code>&nbsp;<code>err != nil { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code>&nbsp;<code>job.Error(err)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>portmapper.SetIptablesChain(chain)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> &nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>bridgeNetwork = network</code> &nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>//&nbsp;<a href="https://github.com/docker/docker/issues/2768" rel="nofollow">https://github.com/docker/docker/issues/2768</a></code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>job.Eng.Hack_SetGlobalVar(</code><code>"httpapi.bridgeIP"</code><code>, bridgeNetwork.IP)</code> &nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>for</code>&nbsp;<code>name, f := range map[string]engine.Handler{ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"allocate_interface"</code><code>: Allocate,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"release_interface"</code><code>:&nbsp; Release,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"allocate_port"</code><code>:&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; AllocatePort,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"link"</code><code>:&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; LinkContainers,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>} { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>if</code>&nbsp;<code>err := job.Eng.Register(name, f); err != nil { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code>&nbsp;<code>job.Error(err)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code>&nbsp;<code>engine.StatusOK</code> <code>}</code> </td> 
 </tr> 
 </tbody> 
</table>

Bridge.InitDriver的作用：

*  获取为Docker服务的网络设备的地址；
 *  创建指定IP地址的网桥；
 *  配置网络iptables规则；
 *  另外还为eng对象注册了多个Handler,如 ”allocate\_interface”， ”release\_interface”， ”allocate\_port”，”link”。

### 2、注册API服务的Handler ###

remote(eng)的实现过程，主要为eng对象注册了两个Handler，分别为”serveapi”与”acceptconnections”。代码实现如下：

**/builtins/builtins.go**

<table> 
 <tbody> 
 <tr> 
 <td style="vertical-align:baseline;"> <code>func remote(eng *engine.Engine) error { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>if</code>&nbsp;<code>err := eng.Register(</code><code>"serveapi"</code><code>, apiserver.ServeApi); err != nil { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code>&nbsp;<code>err</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code>&nbsp;<code>eng.Register(</code><code>"acceptconnections"</code><code>, apiserver.AcceptConnections)</code> <code>}</code> </td> 
 </tr> 
 </tbody> 
</table>

注册的两个Handler名称分别为”serveapi”与”acceptconnections”

*  ServeApi执行时，通过循环多种协议，创建出goroutine来配置指定的http.Server，最终为不同的协议请求服务；
 *  AcceptConnections的实现主要是为了通知init守护进程，Docker Daemon已经启动完毕，可以让Docker Daemon进程接受请求。(守护进程)

### 3、注册events事件的Handler ###

events.New().Install(eng)的实现过程，为Docker注册了多个event事件，功能是给Docker用户提供API，使得用户可以通过这些API查看Docker内部的events信息，log信息以及subscribers\_count信息。

**/events/events.go**

<table> 
 <tbody> 
 <tr> 
 <td style="vertical-align:baseline;"> <code>type Events&nbsp;</code><code>struct</code>&nbsp;<code>{ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>mu&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; sync.RWMutex</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>events&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; []*utils.JSONMessage</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>subscribers []listener</code> <code>}</code> <code>func New() *Events { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code>&nbsp;<code>&amp;Events{ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>events: make([]*utils.JSONMessage, 0, eventsLimit),</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>}</code> <code>// Install installs events public api in docker engine</code> <code>func (e *Events) Install(eng *engine.Engine) error { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>// Here you should describe public interface</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>jobs := map[string]engine.Handler{ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"events"</code><code>:&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; e.Get,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"log"</code><code>:&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; e.Log,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"subscribers_count"</code><code>: e.SubscribersCount,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>for</code>&nbsp;<code>name, job := range jobs { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>if</code>&nbsp;<code>err := eng.Register(name, job); err != nil { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code>&nbsp;<code>err</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code>&nbsp;<code>nil</code> <code>}</code> </td> 
 </tr> 
 </tbody> 
</table>

### 4、注册版本的Handler ###

eng.Register(“version”,dockerVersion)的实现过程，向eng对象注册key为”version”，value为”dockerVersion”执行方法的Handler，dockerVersion的执行过程中，会向名为version的job的标准输出中写入Docker的版本，Docker API的版本，git版本，Go语言运行时版本以及操作系统等版本信息。

**/builtins/builtins.go**

<table> 
 <tbody> 
 <tr> 
 <td style="vertical-align:baseline;"> <code>// builtins jobs independent of any subsystem</code> <code>func dockerVersion(job *engine.Job) engine.Status { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>v := &amp;engine.Env{}</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>v.SetJson(</code><code>"Version"</code><code>, dockerversion.VERSION)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>v.SetJson(</code><code>"ApiVersion"</code><code>, api.APIVERSION)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>v.Set(</code><code>"GitCommit"</code><code>, dockerversion.GITCOMMIT)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>v.Set(</code><code>"GoVersion"</code><code>, runtime.Version())</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>v.Set(</code><code>"Os"</code><code>, runtime.GOOS)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>v.Set(</code><code>"Arch"</code><code>, runtime.GOARCH)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>if</code>&nbsp;<code>kernelVersion, err := kernel.GetKernelVersion(); err == nil { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>v.Set(</code><code>"KernelVersion"</code><code>, kernelVersion.String())</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>if</code>&nbsp;<code>_, err := v.WriteTo(job.Stdout); err != nil { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code>&nbsp;<code>job.Error(err)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code>&nbsp;<code>engine.StatusOK</code> <code>}</code> </td> 
 </tr> 
 </tbody> 
</table>

### 5、注册registry的Handler ###

registry.NewService().Install(eng)的实现过程位于[./docker/registry/service.go][._docker_registry_service.go]，在eng对象对外暴露的API信息中添加docker registry的信息。当registry.NewService()成功被Install安装完毕的话，则有两个调用能够被eng使用：”auth”，向公有registry进行认证；”search”，在公有registry上搜索指定的镜像。

**/registry/service.go**

<table> 
 <tbody> 
 <tr> 
 <td style="vertical-align:baseline;"> <code>// NewService returns a new instance of Service ready to be</code> <code>// installed no an engine.</code> <code>func NewService() *Service { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code>&nbsp;<code>&amp;Service{}</code> <code>}</code> <code>// Install installs registry capabilities to eng.</code> <code>func (s *Service) Install(eng *engine.Engine) error { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>eng.Register(</code><code>"auth"</code><code>, s.Auth)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>eng.Register(</code><code>"search"</code><code>, s.Search)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code>&nbsp;<code>nil</code> <code>}</code> </td> 
 </tr> 
 </tbody> 
</table>

## （六）使用goroutine加载daemon对象 ##

执行完builtins的加载，回到mainDaemon()的执行，通过一个goroutine来加载daemon对象并开始运行。这一环节的执行，主要包含三个步骤：

*  通过init函数中初始化的daemonCfg与eng对象来创建一个daemon对象d；(守护进程)
 *  通过daemon对象的Install函数，向eng对象中注册众多的Handler；
 *  在Docker Daemon启动完毕之后，运行名为”acceptconnections”的job，主要工作为向init守护进程发送”READY=1”信号，以便开始正常接受请求。

**/docker/daemon.go**

<table> 
 <tbody> 
 <tr> 
 <td style="vertical-align:baseline;"> <code>// load the daemon in the background so we can immediately start</code> <code>// the http api so that connections don't fail while the daemon</code> <code>// is booting</code> <code>go func() { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>d, err := daemon.NewDaemon(daemonCfg, eng)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>if</code>&nbsp;<code>err != nil { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>log</code><code>.Fatal(err)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>if</code>&nbsp;<code>err := d.Install(eng); err != nil { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>log</code><code>.Fatal(err)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>// after the daemon is done setting up we can tell the api to start</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>// accepting connections</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>if</code>&nbsp;<code>err := eng.Job(</code><code>"acceptconnections"</code><code>).Run(); err != nil { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>log</code><code>.Fatal(err)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>}()</code> </td> 
 </tr> 
 </tbody> 
</table>

### 1、创建daemon对象 ###

**/docker/daemon.go**

<table> 
 <tbody> 
 <tr> 
 <td style="vertical-align:baseline;"> <code>d, err := daemon.NewDaemon(daemonCfg, eng)</code> <code>if</code>&nbsp;<code>err != nil { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>log</code><code>.Fatal(err)</code> <code>}</code> </td> 
 </tr> 
 </tbody> 
</table>

daemon.NewDaemon(daemonCfg, eng)是创建daemon对象d的核心部分。主要作用为初始化Docker Daemon的基本环境，如处理config参数，验证系统支持度，配置Docker工作目录，设置与加载多种driver，创建graph环境等，验证DNS配置等。具体参考[NewDaemon][] 。

### 2、通过daemon对象为engine注册Handler ###

当创建完daemon对象，goroutine执行d.Install(eng)

**/daemon/daemon.go**

<table> 
 <tbody> 
 <tr> 
 <td style="vertical-align:baseline;"> <code>type Daemon&nbsp;</code><code>struct</code>&nbsp;<code>{ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>repository&nbsp;&nbsp;&nbsp;&nbsp; string</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>sysInitPath&nbsp;&nbsp;&nbsp; string</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>containers&nbsp;&nbsp;&nbsp;&nbsp; *contStore</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>graph&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; *graph.Graph</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>repositories&nbsp;&nbsp; *graph.TagStore</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>idIndex&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; *truncindex.TruncIndex</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>sysInfo&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; *sysinfo.SysInfo</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>volumes&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; *graph.Graph</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>eng&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; *engine.Engine</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>config&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; *Config</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>containerGraph *graphdb.Database</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>driver&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; graphdriver.Driver</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>execDriver&nbsp;&nbsp;&nbsp;&nbsp; execdriver.Driver</code> <code>}</code> <code>// Install installs daemon capabilities to eng.</code> <code>func (daemon *Daemon) Install(eng *engine.Engine) error { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>// FIXME: rename "delete" to "rm" for consistency with the CLI command</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>// FIXME: rename ContainerDestroy to ContainerRm for consistency with the CLI command</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>// FIXME: remove ImageDelete's dependency on Daemon, then move to graph/</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>for</code>&nbsp;<code>name, method := range map[string]engine.Handler{ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"attach"</code><code>:&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; daemon.ContainerAttach,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"build"</code><code>:&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; daemon.CmdBuild,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"commit"</code><code>:&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; daemon.ContainerCommit,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"container_changes"</code><code>: daemon.ContainerChanges,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"container_copy"</code><code>:&nbsp;&nbsp;&nbsp; daemon.ContainerCopy,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"container_inspect"</code><code>: daemon.ContainerInspect,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"containers"</code><code>:&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; daemon.Containers,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"create"</code><code>:&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; daemon.ContainerCreate,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"delete"</code><code>:&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; daemon.ContainerDestroy,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"export"</code><code>:&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; daemon.ContainerExport,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"info"</code><code>:&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; daemon.CmdInfo,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"kill"</code><code>:&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; daemon.ContainerKill,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"logs"</code><code>:&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; daemon.ContainerLogs,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"pause"</code><code>:&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; daemon.ContainerPause,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"resize"</code><code>:&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; daemon.ContainerResize,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"restart"</code><code>:&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; daemon.ContainerRestart,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"start"</code><code>:&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; daemon.ContainerStart,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"stop"</code><code>:&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; daemon.ContainerStop,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"top"</code><code>:&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; daemon.ContainerTop,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"unpause"</code><code>:&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; daemon.ContainerUnpause,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"wait"</code><code>:&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; daemon.ContainerWait,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"image_delete"</code><code>:&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; daemon.ImageDelete,&nbsp;</code><code>// FIXME: see above</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>} { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>if</code>&nbsp;<code>err := eng.Register(name, method); err != nil { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code>&nbsp;<code>err</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>if</code>&nbsp;<code>err := daemon.Repositories().Install(eng); err != nil { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code>&nbsp;<code>err</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>// FIXME: this hack is necessary for legacy integration tests to access</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>// the daemon object.</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>eng.Hack_SetGlobalVar(</code><code>"httpapi.daemon"</code><code>, daemon)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code>&nbsp;<code>nil</code> <code>}</code> </td> 
 </tr> 
 </tbody> 
</table>

以上代码的实现分为三部分：

*  向eng对象中注册众多的Handler对象；
 *  daemon.Repositories().Install(eng)实现了向eng对象注册多个与image相关的Handler，Install的实现位于[./docker/graph/service.go][._docker_graph_service.go]；
 *  eng.Hack\_SetGlobalVar("httpapi.daemon", daemon)实现向eng对象中map类型的hack对象中添加一条记录，key为”httpapi.daemon”，value为daemon。

### 3、运行acceptconnections的job ###

**/docker/daemon.go**

<table> 
 <tbody> 
 <tr> 
 <td style="vertical-align:baseline;"> <code>if</code>&nbsp;<code>err := eng.Job(</code><code>"acceptconnections"</code><code>).Run(); err != nil { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>log</code><code>.Fatal(err)</code> <code>}</code> </td> 
 </tr> 
 </tbody> 
</table>

在goroutine内部最后运行名为”acceptconnections”的job，主要作用是通知init守护进程，Docker Daemon可以开始接受请求了。

首先执行eng.Job("acceptconnections")，返回一个Job，随后再执行eng.Job("acceptconnections").Run()，也就是该执行Job的run函数。

**/engine/engine.go**

<table> 
 <tbody> 
 <tr> 
 <td style="vertical-align:baseline;"> <code>// Job creates a new job which can later be executed.</code> <code>// This function mimics `Command` from the standard os/exec package.</code> <code>func (eng *Engine) Job(name string, args ...string) *Job { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>job := &amp;Job{ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>Eng:&nbsp;&nbsp;&nbsp; eng,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>Name:&nbsp;&nbsp; name,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>Args:&nbsp;&nbsp; args,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>Stdin:&nbsp; NewInput(),</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>Stdout: NewOutput(),</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>Stderr: NewOutput(),</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>env:&nbsp;&nbsp;&nbsp; &amp;Env{},</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>if</code>&nbsp;<code>eng.Logging { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>job.Stderr.Add(utils.NopWriteCloser(eng.Stderr))</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>// Catchall is shadowed by specific Register.</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>if</code>&nbsp;<code>handler, exists := eng.handlers[name]; exists { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>job.handler = handler</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}&nbsp;</code><code>else</code>&nbsp;<code>if</code>&nbsp;<code>eng.catchall != nil &amp;&amp; name !=&nbsp;</code><code>""</code>&nbsp;<code>{ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>// empty job names are illegal, catchall or not.</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>job.handler = eng.catchall</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code>&nbsp;<code>job</code> <code>}&nbsp;</code> </td> 
 </tr> 
 </tbody> 
</table>

1.  首先创建一个类型为Job的job对象，该对象中Eng属性为函数的调用者eng，Name属性为”acceptconnections”，没有参数传入。
2.  另外在eng对象所有的handlers属性中寻找键为”acceptconnections”记录的值，由于在加载builtins操作中的remote(eng)中已经向eng注册过这样的一条记录，key为”acceptconnections”，value为apiserver.AcceptConnections。
3.  因此job对象的handler为apiserver.AcceptConnections。
4.  最后返回已经初始化完毕的对象job。

创建完job对象之后，随即执行该job对象的run()函数。

**/engine/job.go**

<table> 
 <tbody> 
 <tr> 
 <td style="vertical-align:baseline;"> <code>// A job is the fundamental unit of work in the docker engine.</code> <code>// Everything docker can do should eventually be exposed as a job.</code> <code>// For example: execute a process in a container, create a new container,</code> <code>// download an archive from the internet, serve the http api, etc.</code> <code>//</code> <code>// The job API is designed after unix processes: a job has a name, arguments,</code> <code>// environment variables, standard streams for input, output and error, and</code> <code>// an exit status which can indicate success (0) or error (anything else).</code> <code>//</code> <code>// One slight variation is that jobs report their status as a string. The</code> <code>// string "0" indicates success, and any other strings indicates an error.</code> <code>// This allows for richer error reporting.</code> <code>//</code> <code>type Job&nbsp;</code><code>struct</code>&nbsp;<code>{ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>Eng&nbsp;&nbsp;&nbsp;&nbsp; *Engine</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>Name&nbsp;&nbsp;&nbsp; string</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>Args&nbsp;&nbsp;&nbsp; []string</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>env&nbsp;&nbsp;&nbsp;&nbsp; *Env</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>Stdout&nbsp; *Output</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>Stderr&nbsp; *Output</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>Stdin&nbsp;&nbsp; *Input</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>handler Handler</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>status&nbsp; Status</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>end&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>time</code><code>.Time</code> <code>}</code> <code>type Status&nbsp;</code><code>int</code> <code>const</code>&nbsp;<code>(</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>StatusOK&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Status = 0</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>StatusErr&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Status = 1</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>StatusNotFound Status = 127</code> <code>)</code> <code>// Run executes the job and blocks until the job completes.</code> <code>// If the job returns a failure status, an error is returned</code> <code>// which includes the status.</code> <code>func (job *Job) Run() error { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>if</code>&nbsp;<code>job.Eng.IsShutdown() { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code>&nbsp;<code>fmt.Errorf(</code><code>"engine is shutdown"</code><code>)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>// FIXME: this is a temporary workaround to avoid Engine.Shutdown</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>// waiting 5 seconds for server/api.ServeApi to complete (which it never will)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>// everytime the daemon is cleanly restarted.</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>// The permanent fix is to implement Job.Stop and Job.OnStop so that</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>// ServeApi can cooperate and terminate cleanly.</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>if</code>&nbsp;<code>job.Name !=&nbsp;</code><code>"serveapi"</code>&nbsp;<code>{ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>job.Eng.l.Lock()</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>job.Eng.tasks.Add(1)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>job.Eng.l.Unlock()</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>defer job.Eng.tasks.Done()</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>// FIXME: make this thread-safe</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>// FIXME: implement wait</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>if</code>&nbsp;<code>!job.end.IsZero() { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code>&nbsp;<code>fmt.Errorf(</code><code>"%s: job has already completed"</code><code>, job.Name)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>// Log beginning and end of the job</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>job.Eng.Logf(</code><code>"+job %s"</code><code>, job.CallString())</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>defer func() { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>job.Eng.Logf(</code><code>"-job %s%s"</code><code>, job.CallString(), job.StatusString())</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}()</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>var errorMessage = bytes.NewBuffer(nil)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>job.Stderr.Add(errorMessage)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>if</code>&nbsp;<code>job.handler == nil { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>job.Errorf(</code><code>"%s: command not found"</code><code>, job.Name)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>job.status = 127</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}&nbsp;</code><code>else</code>&nbsp;<code>{ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>job.status = job.handler(job)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>job.end =&nbsp;</code><code>time</code><code>.Now()</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>// Wait for all background tasks to complete</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>if</code>&nbsp;<code>err := job.Stdout.Close(); err != nil { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code>&nbsp;<code>err</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>if</code>&nbsp;<code>err := job.Stderr.Close(); err != nil { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code>&nbsp;<code>err</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>if</code>&nbsp;<code>err := job.Stdin.Close(); err != nil { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code>&nbsp;<code>err</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>if</code>&nbsp;<code>job.status != 0 { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code>&nbsp;<code>fmt.Errorf(</code><code>"%s"</code><code>, Tail(errorMessage, 1))</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code>&nbsp;<code>nil</code> <code>}</code> </td> 
 </tr> 
 </tbody> 
</table>

Run()函数的实现位于[./docker/engine/job.go][._docker_engine_job.go]，该函数执行指定的job，并在job执行完成前一直阻塞。对于名为”acceptconnections”的job对象，运行代码为[job.status = job.handler(job)][job.status _ job.handler_job]，由于job.handler值为apiserver.AcceptConnections，故真正执行的是job.status = apiserver.AcceptConnections(job)。

进入AcceptConnections的具体实现，位于[./docker/api/server/server.go][._docker_api_server_server.go],如下：

**/api/server/server.go**

<table> 
 <tbody> 
 <tr> 
 <td style="vertical-align:baseline;"> <code>func AcceptConnections(job *engine.Job) engine.Status { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>// Tell the init daemon we are accepting requests</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>go&nbsp; systemd.SdNotify(</code><code>"READY=1"</code><code>)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>if</code>&nbsp;<code>activationLock != nil { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>close(activationLock)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code>&nbsp;<code>engine.StatusOK</code> <code>}</code> </td> 
 </tr> 
 </tbody> 
</table>

重点为go systemd.SdNotify("READY=1")的实现，位于[./docker/pkg/system/sd\_notify.go][._docker_pkg_system_sd_notify.go]，主要作用是通知init守护进程Docker Daemon的启动已经全部完成，潜在的功能是使得Docker Daemon开始接受Docker Client发送来的API请求。

至此，已经完成通过goroutine来加载daemon对象并运行。

## （七）打印Docker版本及驱动信息 ##

显示docker的版本信息，以及ExecDriver和GraphDriver这两个驱动的具体信息

**/docker/daemon.go**

<table> 
 <tbody> 
 <tr> 
 <td style="vertical-align:baseline;"> <code>// TODO actually have a resolved graphdriver to show?</code> <code>log</code><code>.Printf(</code><code>"docker daemon: %s %s; execdriver: %s; graphdriver: %s"</code><code>,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>dockerversion.VERSION,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>dockerversion.GITCOMMIT,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>daemonCfg.ExecDriver,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>daemonCfg.GraphDriver,</code> <code>)</code> </td> 
 </tr> 
 </tbody> 
</table>

## （八）serveapi的创建与运行 ##

打印部分Docker具体信息之后，Docker Daemon立即创建并运行名为”serveapi”的job，主要作用为让Docker Daemon提供API访问服务。

**/docker/daemon.go**

<table> 
 <tbody> 
 <tr> 
 <td style="vertical-align:baseline;"> <code>// Serve api</code> <code>job := eng.Job(</code><code>"serveapi"</code><code>, flHosts...)</code> <code>job.SetenvBool(</code><code>"Logging"</code><code>,&nbsp;</code><code>true</code><code>)</code> <code>job.SetenvBool(</code><code>"EnableCors"</code><code>, *flEnableCors)</code> <code>job.Setenv(</code><code>"Version"</code><code>, dockerversion.VERSION)</code> <code>job.Setenv(</code><code>"SocketGroup"</code><code>, *flSocketGroup)</code> <code>job.SetenvBool(</code><code>"Tls"</code><code>, *flTls)</code> <code>job.SetenvBool(</code><code>"TlsVerify"</code><code>, *flTlsVerify)</code> <code>job.Setenv(</code><code>"TlsCa"</code><code>, *flCa)</code> <code>job.Setenv(</code><code>"TlsCert"</code><code>, *flCert)</code> <code>job.Setenv(</code><code>"TlsKey"</code><code>, *flKey)</code> <code>job.SetenvBool(</code><code>"BufferRequests"</code><code>,&nbsp;</code><code>true</code><code>)</code> <code>if</code>&nbsp;<code>err := job.Run(); err != nil { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>log</code><code>.Fatal(err)</code> <code>}</code> </td> 
 </tr> 
 </tbody> 
</table>

1.  创建一个名为”serveapi”的job，并将flHosts的值赋给job.Args。flHost的作用主要是为Docker Daemon提供使用的协议与监听的地址。
2.  Docker Daemon为该job设置了众多的环境变量，如安全传输层协议的环境变量等。最后通过job.Run()运行该serveapi的job。

由于在eng中key为”serveapi”的handler，value为apiserver.ServeApi，故该job运行时，执行apiserver.ServeApi函数，位于[./docker/api/server/server.go][._docker_api_server_server.go 1]。ServeApi函数的作用主要是对于用户定义的所有支持协议，Docker Daemon均创建一个goroutine来启动相应的http.Server，分别为不同的协议服务。具体参考[Docker源码分析（四）之Docker Server][Docker_Docker Server]。

文章参考：

《Docker源码分析》

[Center]: /images/20220611/f336e297168347678a6f92741ec692eb.png
[Center 1]: /images/20220611/20ee0765bf9245719854db882282aa5f.png
[._docker_engine_engine.go]: https://github.com/docker/docker/blob/v1.2.0/engine/engine.go#L153
[os.Exit_0]: https://github.com/docker/docker/blob/v1.2.0/pkg/signal/trap.go#L41
[._docker_registry_service.go]: https://github.com/docker/docker/blob/v1.2.0/registry/service.go#L25
[NewDaemon]: http://wiki.haplat.net/display/~huwh/NewDaemon
[._docker_graph_service.go]: https://github.com/docker/docker/blob/v1.2.0/graph/service.go#L12
[._docker_engine_job.go]: https://github.com/docker/docker/blob/v1.2.0/engine/job.go#L48
[job.status _ job.handler_job]: https://github.com/docker/docker/blob/v1.2.0/engine/job.go#L79
[._docker_api_server_server.go]: https://github.com/docker/docker/blob/v1.2.0/api/server/server.go#L1370
[._docker_pkg_system_sd_notify.go]: https://github.com/docker/docker/blob/v1.2.0/pkg/systemd/sd_notify.go#L12
[._docker_api_server_server.go 1]: https://github.com/docker/docker/blob/v1.2.0/api/server/server.go#L1339
[Docker_Docker Server]: http://blog.csdn.net/huwh_/article/details/76284223