// computePodActions checks whether the pod spec has changed and returns the changes if true.

func (m *kubeGenericRuntimeManager) computePodActions(pod *v1.Pod, podStatus *kubecontainer.PodStatus) podActions {

   // 1. 對(duì)比sandbox狀態(tài)，計(jì)算是否需要?jiǎng)?chuàng)建sandbox，以及當(dāng)前sandbox id

   createPodSandbox, attempt, sandboxID := m.podSandboxChanged(pod, podStatus)

   changes := podActions{

      KillPod:           createPodSandbox,

      CreateSandbox:     createPodSandbox,

      SandboxID:         sandboxID,

      Attempt:           attempt,

      ContainersToStart: []int{},

      ContainersToKill:  make(map[kubecontainer.ContainerID]containerToKillInfo),

   }

   // 2. 需要新建sandbox，一旦進(jìn)入該分支就必定return，之后代碼不再執(zhí)行

   if createPodSandbox {

      ....

      // 在新建sandbox分支中，若存在init容器，則取第一個(gè)，返回

     if len(pod.Spec.InitContainers) != 0 {

         // Pod has init containers, return the first one.

         changes.NextInitContainerToStart = &pod.Spec.InitContainers[0]

         return changes

      }

      // 不存在init容器，直接跑工作containers

      for idx, c := range pod.Spec.Containers {

         if containerSucceeded(&c, podStatus) && pod.Spec.RestartPolicy == v1.RestartPolicyOnFailure {

            continue

         }

         changes.ContainersToStart = append(changes.ContainersToStart, idx)

      }

      return changes

   }

   // 3. sandbox已運(yùn)行，啟動(dòng)init容器。尋找下一個(gè)需要執(zhí)行的init容器

   initLastStatus, next, done := findNextInitContainerToRun(pod, podStatus)

   if !done {

      if next != nil {

         initFailed := initLastStatus != nil && isContainerFailed(initLastStatus)

         if initFailed && !shouldRestartOnFailure(pod) {

            changes.KillPod = true

         } else {

            changes.NextInitContainerToStart = next

         }

      }

      // 若init未完成，直接返回

      return changes

   }

   // 4. init已完成，計(jì)算需要kill&start的工作container

   keepCount := 0

   for idx, container := range pod.Spec.Containers {

   .....

   }

   // 5. 是否需要kill pod

   if keepCount == 0 && len(changes.ContainersToStart) == 0 {

      changes.KillPod = true

   }

   return changes

}

func (m *kubeGenericRuntimeManager) SyncPod(pod *v1.Pod, _ v1.PodStatus, podStatus *kubecontainer.PodStatus, pullSecrets []v1.Secret, backOff *flowcontrol.Backoff) (result kubecontainer.PodSyncResult) {

   // 1. 計(jì)算pod actions，見(jiàn)上文

   podContainerChanges := m.computePodActions(pod, podStatus)

   .....

   // 2. 需要情況下執(zhí)行kill pod

   if podContainerChanges.KillPod {

      ....

      killResult := m.killPodWithSyncResult(pod, kubecontainer.ConvertPodStatusToRunningPod(m.runtimeName, podStatus), nil)

      ....

   } else {

      // 3. 不需要kill pod，但需要kill工作container

      for containerID, containerInfo := range podContainerChanges.ContainersToKill {

         ....

         if err := m.killContainer(pod, containerID, containerInfo.name, containerInfo.message, nil); err != nil {

            ...

            return

         }

      }

   }

   .....

   // 4. 按需創(chuàng)建sandbox

   podSandboxID := podContainerChanges.SandboxID

   if podContainerChanges.CreateSandbox {

      .....

      podSandboxID, msg, err = m.createPodSandbox(pod, podContainerChanges.Attempt)

      ....

   }

   ....

   // 5. 運(yùn)行next init container

   if container := podContainerChanges.NextInitContainerToStart; container != nil {

      ....

      if msg, err := m.startContainer(podSandboxID, podSandboxConfig, container, pod, podStatus, pullSecrets, podIP); err != nil {

         startContainerResult.Fail(err, msg)

         utilruntime.HandleError(fmt.Errorf("init container start failed: %v: %s", err, msg))

         return

      }

      ....

   }

   // 6. 運(yùn)行工作containers。注意，根據(jù)computePodActions，若NextInitContainerToStart不為空，則不存在ContainersToStart ，即這個(gè)循環(huán)在當(dāng)前這個(gè)SyncPod中不會(huì)被執(zhí)行

   for _, idx := range podContainerChanges.ContainersToStart {

      ....

      if msg, err := m.startContainer(podSandboxID, podSandboxConfig, container, pod, podStatus, pullSecrets, podIP); err != nil {

         startContainerResult.Fail(err, msg)

         // known errors that are logged in other places are logged at higher levels here to avoid

         // repetitive log spam

         switch {

         case err == images.ErrImagePullBackOff:

            glog.V(3).Infof("container start failed: %v: %s", err, msg)

         default:

            utilruntime.HandleError(fmt.Errorf("container start failed: %v: %s", err, msg))

         }

         continue

      }

   }

   return

}