summaryrefslogtreecommitdiff
path: root/libkpod/wait.go
diff options
context:
space:
mode:
Diffstat (limited to 'libkpod/wait.go')
-rw-r--r--libkpod/wait.go42
1 files changed, 0 insertions, 42 deletions
diff --git a/libkpod/wait.go b/libkpod/wait.go
deleted file mode 100644
index e972a0ba0..000000000
--- a/libkpod/wait.go
+++ /dev/null
@@ -1,42 +0,0 @@
-package libkpod
-
-import (
- "github.com/pkg/errors"
- "github.com/projectatomic/libpod/oci"
- "k8s.io/apimachinery/pkg/util/wait"
-)
-
-func isStopped(c *ContainerServer, ctr *oci.Container) bool {
- c.runtime.UpdateStatus(ctr)
- cStatus := c.runtime.ContainerStatus(ctr)
- if cStatus.Status == oci.ContainerStateStopped {
- return true
- }
- return false
-}
-
-// ContainerWait stops a running container with a grace period (i.e., timeout).
-func (c *ContainerServer) ContainerWait(container string) (int32, error) {
- ctr, err := c.LookupContainer(container)
- if err != nil {
- return 0, errors.Wrapf(err, "failed to find container %s", container)
- }
-
- err = wait.PollImmediateInfinite(1,
- func() (bool, error) {
- if !isStopped(c, ctr) {
- return false, nil
- } else { // nolint
- return true, nil // nolint
- } // nolint
-
- },
- )
-
- if err != nil {
- return 0, err
- }
- exitCode := ctr.State().ExitCode
- c.ContainerStateToDisk(ctr)
- return exitCode, nil
-}