67 lines
1.4 KiB
Go
67 lines
1.4 KiB
Go
package supervisor
|
|
|
|
import (
|
|
"path/filepath"
|
|
"time"
|
|
|
|
"github.com/docker/containerd/runtime"
|
|
)
|
|
|
|
type StartTask struct {
|
|
baseTask
|
|
ID string
|
|
BundlePath string
|
|
Stdout string
|
|
Stderr string
|
|
Stdin string
|
|
StartResponse chan StartResponse
|
|
Labels []string
|
|
NoPivotRoot bool
|
|
Checkpoint *runtime.Checkpoint
|
|
CheckpointDir string
|
|
Runtime string
|
|
RuntimeArgs []string
|
|
}
|
|
|
|
func (s *Supervisor) start(t *StartTask) error {
|
|
start := time.Now()
|
|
rt := s.runtime
|
|
rtArgs := s.runtimeArgs
|
|
if t.Runtime != "" {
|
|
rt = t.Runtime
|
|
rtArgs = t.RuntimeArgs
|
|
}
|
|
container, err := runtime.New(runtime.ContainerOpts{
|
|
Root: s.stateDir,
|
|
ID: t.ID,
|
|
Bundle: t.BundlePath,
|
|
Runtime: rt,
|
|
RuntimeArgs: rtArgs,
|
|
Shim: s.shim,
|
|
Labels: t.Labels,
|
|
NoPivotRoot: t.NoPivotRoot,
|
|
Timeout: s.timeout,
|
|
})
|
|
if err != nil {
|
|
return err
|
|
}
|
|
s.containers[t.ID] = &containerInfo{
|
|
container: container,
|
|
}
|
|
ContainersCounter.Inc(1)
|
|
task := &startTask{
|
|
Err: t.ErrorCh(),
|
|
Container: container,
|
|
StartResponse: t.StartResponse,
|
|
Stdin: t.Stdin,
|
|
Stdout: t.Stdout,
|
|
Stderr: t.Stderr,
|
|
}
|
|
if t.Checkpoint != nil {
|
|
task.CheckpointPath = filepath.Join(t.CheckpointDir, t.Checkpoint.Name)
|
|
}
|
|
|
|
s.startTasks <- task
|
|
ContainerCreateTimer.UpdateSince(start)
|
|
return errDeferredResponse
|
|
}
|