| 123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128 |
- package libcontainer
- import (
- "errors"
- "os"
- "os/exec"
- "github.com/opencontainers/runc/libcontainer/system"
- )
- func newRestoredProcess(cmd *exec.Cmd, fds []string) (*restoredProcess, error) {
- var err error
- pid := cmd.Process.Pid
- stat, err := system.Stat(pid)
- if err != nil {
- return nil, err
- }
- return &restoredProcess{
- cmd: cmd,
- processStartTime: stat.StartTime,
- fds: fds,
- }, nil
- }
- type restoredProcess struct {
- cmd *exec.Cmd
- processStartTime uint64
- fds []string
- }
- func (p *restoredProcess) start() error {
- return errors.New("restored process cannot be started")
- }
- func (p *restoredProcess) pid() int {
- return p.cmd.Process.Pid
- }
- func (p *restoredProcess) terminate() error {
- err := p.cmd.Process.Kill()
- if _, werr := p.wait(); err == nil {
- err = werr
- }
- return err
- }
- func (p *restoredProcess) wait() (*os.ProcessState, error) {
- // TODO: how do we wait on the actual process?
- // maybe use --exec-cmd in criu
- err := p.cmd.Wait()
- if err != nil {
- var exitErr *exec.ExitError
- if !errors.As(err, &exitErr) {
- return nil, err
- }
- }
- st := p.cmd.ProcessState
- return st, nil
- }
- func (p *restoredProcess) startTime() (uint64, error) {
- return p.processStartTime, nil
- }
- func (p *restoredProcess) signal(s os.Signal) error {
- return p.cmd.Process.Signal(s)
- }
- func (p *restoredProcess) externalDescriptors() []string {
- return p.fds
- }
- func (p *restoredProcess) setExternalDescriptors(newFds []string) {
- p.fds = newFds
- }
- func (p *restoredProcess) forwardChildLogs() chan error {
- return nil
- }
- // nonChildProcess represents a process where the calling process is not
- // the parent process. This process is created when a factory loads a container from
- // a persisted state.
- type nonChildProcess struct {
- processPid int
- processStartTime uint64
- fds []string
- }
- func (p *nonChildProcess) start() error {
- return errors.New("restored process cannot be started")
- }
- func (p *nonChildProcess) pid() int {
- return p.processPid
- }
- func (p *nonChildProcess) terminate() error {
- return errors.New("restored process cannot be terminated")
- }
- func (p *nonChildProcess) wait() (*os.ProcessState, error) {
- return nil, errors.New("restored process cannot be waited on")
- }
- func (p *nonChildProcess) startTime() (uint64, error) {
- return p.processStartTime, nil
- }
- func (p *nonChildProcess) signal(s os.Signal) error {
- proc, err := os.FindProcess(p.processPid)
- if err != nil {
- return err
- }
- return proc.Signal(s)
- }
- func (p *nonChildProcess) externalDescriptors() []string {
- return p.fds
- }
- func (p *nonChildProcess) setExternalDescriptors(newFds []string) {
- p.fds = newFds
- }
- func (p *nonChildProcess) forwardChildLogs() chan error {
- return nil
- }
|