diff options
Diffstat (limited to 'libpod')
-rw-r--r-- | libpod/container.go | 18 | ||||
-rw-r--r-- | libpod/container_internal.go | 7 |
2 files changed, 25 insertions, 0 deletions
diff --git a/libpod/container.go b/libpod/container.go index 4bf9a1ba9..570110ca1 100644 --- a/libpod/container.go +++ b/libpod/container.go @@ -179,6 +179,9 @@ type ContainerState struct { // This maps the path the file will be mounted to in the container to // the path of the file on disk outside the container BindMounts map[string]string `json:"bindMounts,omitempty"` + // StoppedByUser indicates whether the container was stopped by an + // explicit call to the Stop() API. + StoppedByUser bool // ExtensionStageHooks holds hooks which will be executed by libpod // and not delegated to the OCI runtime. @@ -1003,6 +1006,21 @@ func (c *Container) BindMounts() (map[string]string, error) { return newMap, nil } +// StoppedByUser returns whether the container was last stopped by an explicit +// call to the Stop() API, or whether it exited naturally. +func (c *Container) StoppedByUser() (bool, error) { + if !c.batched { + c.lock.Lock() + defer c.lock.Unlock() + + if err := c.syncContainer(); err != nil { + return false, err + } + } + + return c.state.StoppedByUser, nil +} + // Misc Accessors // Most will require locking diff --git a/libpod/container_internal.go b/libpod/container_internal.go index a791df491..0b9c5a96a 100644 --- a/libpod/container_internal.go +++ b/libpod/container_internal.go @@ -376,6 +376,7 @@ func resetState(state *ContainerState) error { state.ExecSessions = make(map[string]*ExecSession) state.NetworkStatus = nil state.BindMounts = make(map[string]string) + state.StoppedByUser = false return nil } @@ -789,6 +790,7 @@ func (c *Container) init(ctx context.Context) error { c.state.ExitCode = 0 c.state.Exited = false c.state.State = ContainerStateCreated + c.state.StoppedByUser = false if err := c.save(); err != nil { return err @@ -950,6 +952,11 @@ func (c *Container) stop(timeout uint) error { return err } + c.state.StoppedByUser = true + if err := c.save(); err != nil { + return errors.Wrapf(err, "error saving container %s state after stopping", c.ID()) + } + // Wait until we have an exit file, and sync once we do return c.waitForExitFileAndSync() } |