我正在尝试实现一些效果docker run并docker exec使用libcontainer.
我已经能够使用以下代码创建一个容器并在其中运行一个进程:
func Run(id string, s *specs.LinuxSpec, f *Factory) (int, error) {
...
container, err := f.CreateContainer(id, config)
if err != nil {
return -1, err
}
process := newProcess(s.Process)
tty, err := newTty(s.Process.Terminal, process, rootuid)
defer tty.Close()
if err != nil {
return -1, err
}
defer func() {
if derr := Destroy(container); derr != nil {
err = derr
}
}()
handler := NewSignalHandler(tty)
defer handler.Close()
if err := container.Start(process); err != nil {
return -1, err
}
return handler.forward(process)
}
这很好用(我相信),但是当我必须在同一个容器中运行另一个进程时,问题就来了。例如,一个容器已经在运行(主进程在前台模式下运行):我怎样才能实现 Docker 允许你做的事情docker exec?
我有以下代码:
func Exec(container libcontainer.Container, process *libcontainer.Process, onData func(data []byte), onErr func(err error)) (int, error) {
reader, writer := io.Pipe()
process.Stdin = os.Stdin
rootuid, err := container.Config().HostUID()
if err != nil {
return -1, err
}
tty, err := newTty(true, process, rootuid)
defer tty.Close()
if err != nil {
return -1, err
}
handler := NewSignalHandler(tty)
defer handler.Close()
// Redirect process output
process.Stdout = writer
process.Stderr = writer
// Todo: Fix this, it waits for the main process to exit before it starts
if err := container.Start(process); err != nil {
return -1, err
}
go func(reader io.Reader) {
scanner := bufio.NewScanner(reader)
for scanner.Scan() {
onData(scanner.Bytes())
}
if err := scanner.Err(); err != nil {
onErr(err)
}
}(reader)
return handler.forward(process)
}
这也有效,但问题是:它在运行之前等待主进程退出。有时它会运行,但是100%在运行一个简单的whoami命令5 到 7 次调用该函数后,我的记忆就会消失。
我很确定我做错了什么,我只是不知道是什么。还是我对容器的理解让我失望?
我用这个项目作为参考:https : //github.com/opencontainers/runc
繁星点点滴滴
相关分类