Modified Checkpoint/Restore flags to improve compatibility with Docker.

Added a number of unimplemented flags required for using runsc's
Checkpoint and Restore with Docker. Modified the "image-path" flag to
require a directory instead of a file.

PiperOrigin-RevId: 201697486
Change-Id: I55883df2f1bbc3ec3c395e0ca160ce189e5e7eba
This commit is contained in:
Brielle Broder
2018-06-22 09:41:26 -07:00
committed by Shentubot
parent 0e434b66a6
commit e1aee51d09
2 changed files with 30 additions and 4 deletions
+15 -2
View File
@@ -16,6 +16,7 @@ package cmd
import (
"os"
"path/filepath"
"context"
"flag"
@@ -24,6 +25,9 @@ import (
"gvisor.googlesource.com/gvisor/runsc/container"
)
// File containing the container's saved image/state within the given image-path's directory.
const checkpointFileName = "checkpoint.img"
// Checkpoint implements subcommands.Command for the "checkpoint" command.
type Checkpoint struct {
imagePath string
@@ -48,6 +52,13 @@ func (*Checkpoint) Usage() string {
// SetFlags implements subcommands.Command.SetFlags.
func (c *Checkpoint) SetFlags(f *flag.FlagSet) {
f.StringVar(&c.imagePath, "image-path", "", "path to saved container image")
// Unimplemented flags necessary for compatibility with docker.
var wp string
f.StringVar(&wp, "work-path", "", "ignored")
var lr bool
f.BoolVar(&lr, "leave-running", false, "ignored")
}
// Execute implements subcommands.Command.Execute.
@@ -70,10 +81,12 @@ func (c *Checkpoint) Execute(_ context.Context, f *flag.FlagSet, args ...interfa
Fatalf("image-path flag must be provided")
}
fullImagePath := filepath.Join(c.imagePath, checkpointFileName)
// Create the image file and open for writing.
file, err := os.OpenFile(c.imagePath, os.O_CREATE|os.O_EXCL|os.O_RDWR, 0644)
file, err := os.OpenFile(fullImagePath, os.O_CREATE|os.O_EXCL|os.O_RDWR, 0644)
if err != nil {
Fatalf("os.OpenFile(%q) failed: %v", c.imagePath, err)
Fatalf("os.OpenFile(%q) failed: %v", fullImagePath, err)
}
defer file.Close()
+15 -2
View File
@@ -15,6 +15,7 @@
package cmd
import (
"path/filepath"
"syscall"
"context"
@@ -53,7 +54,17 @@ func (*Restore) Usage() string {
// SetFlags implements subcommands.Command.SetFlags.
func (r *Restore) SetFlags(f *flag.FlagSet) {
r.Create.SetFlags(f)
f.StringVar(&r.imagePath, "image-path", "", "path to saved container image")
f.StringVar(&r.imagePath, "image-path", "", "directory path to saved container image")
// Unimplemented flags necessary for compatibility with docker.
var d bool
f.BoolVar(&d, "detach", false, "ignored")
var nsr bool
f.BoolVar(&nsr, "no-subreaper", false, "ignored")
var wp string
f.StringVar(&wp, "work-path", "", "ignored")
}
// Execute implements subcommands.Command.Execute.
@@ -81,7 +92,9 @@ func (r *Restore) Execute(_ context.Context, f *flag.FlagSet, args ...interface{
Fatalf("image-path flag must be provided")
}
cont, err := container.Create(id, spec, conf, bundleDir, r.consoleSocket, r.pidFile, r.imagePath)
restoreFile := filepath.Join(r.imagePath, checkpointFileName)
cont, err := container.Create(id, spec, conf, bundleDir, r.consoleSocket, r.pidFile, restoreFile)
if err != nil {
Fatalf("error restoring container: %v", err)
}