Containerd解析(6) - restart

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11

switch status {
// 对于一个已经处于Created状态的容器，执行Exec
case libcontainer.Created:
   return container.Exec()
case libcontainer.Stopped:
   return errors.New("cannot start a container that has stopped")
case libcontainer.Running:
   return errors.New("cannot start an already running container")
default:
   return fmt.Errorf("cannot start a container in the %s state\n", status)
}

1
2
3
4
5
6

if err := stopContainer(ctx, found.Container, timeout); err != nil {
	return err
}
if err := startContainer(ctx, found.Container, false, client); err != nil {
	return err
}

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20

func startContainer(ctx context.Context, container containerd.Container, flagA bool, client *containerd.Client) error {
    ...
    ...
	if oldTask, err := container.Task(ctx, nil); err == nil {
		if _, err := oldTask.Delete(ctx); err != nil {
			logrus.WithError(err).Debug("failed to delete old task")
		}
	}
	task, err := container.NewTask(ctx, taskCIO)
	if err != nil {
		return err
	}
	...
    ...
	if err := task.Start(ctx); err != nil {
		return err
	}
    ...
    ...
}

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31

func (p *Init) delete(ctx context.Context) error {
   waitTimeout(ctx, &p.wg, 2*time.Second)
   // 1 runc delete
   err := p.runtime.Delete(ctx, p.id, nil)
   // ignore errors if a runtime has already deleted the process
   // but we still hold metadata and pipes
   //
   // this is common during a checkpoint, runc will delete the container state
   // after a checkpoint and the container will no longer exist within runc
   if err != nil {
      if strings.Contains(err.Error(), "does not exist") {
         err = nil
      } else {
         err = p.runtimeError(err, "failed to delete task")
      }
   }
   if p.io != nil {
      for _, c := range p.closers {
         c.Close()
      }
      p.io.Close()
   }
   // 取消rootfs挂载
   if err2 := mount.UnmountAll(p.Rootfs, 0); err2 != nil {
      log.G(ctx).WithError(err2).Warn("failed to cleanup rootfs mount")
      if err == nil {
         err = fmt.Errorf("failed rootfs umount: %w", err2)
      }
   }
   return err
}

1

err := p.runtime.Delete(ctx, p.id, nil)

1
2
3
4
5
6

if err2 := mount.UnmountAll(p.Rootfs, 0); err2 != nil {
	log.G(ctx).WithError(err2).Warn("failed to cleanup rootfs mount")
	if err == nil {
		err = fmt.Errorf("failed rootfs umount: %w", err2)
	}
}