зеркало из https://github.com/microsoft/docker.git
Update Container Wait Backend
This patch consolidates the two WaitStop and WaitWithContext methods on the container.State type. Now there is a single method, Wait, which takes a context and a bool specifying whether to wait for not just a container exit but also removal. The behavior has been changed slightly so that a wait call during a Created state will not return immediately but instead wait for the container to be started and then exited. The interface has been changed to no longer block, but instead returns a channel on which the caller can receive a *StateStatus value which indicates the ExitCode or an error if there was one (like a context timeout or state transition error). These changes have been propagated through the rest of the deamon to preserve all other existing behavior. Docker-DCO-1.1-Signed-off-by: Josh Hawn <josh.hawn@docker.com> (github: jlhawn)
This commit is contained in:
Родитель
1290ec2d4b
Коммит
cfdf84d5d0
|
@ -2,7 +2,6 @@ package container
|
|||
|
||||
import (
|
||||
"io"
|
||||
"time"
|
||||
|
||||
"golang.org/x/net/context"
|
||||
|
||||
|
@ -10,6 +9,7 @@ import (
|
|||
"github.com/docker/docker/api/types/backend"
|
||||
"github.com/docker/docker/api/types/container"
|
||||
"github.com/docker/docker/api/types/filters"
|
||||
containerpkg "github.com/docker/docker/container"
|
||||
"github.com/docker/docker/pkg/archive"
|
||||
)
|
||||
|
||||
|
@ -44,7 +44,7 @@ type stateBackend interface {
|
|||
ContainerStop(name string, seconds *int) error
|
||||
ContainerUnpause(name string) error
|
||||
ContainerUpdate(name string, hostConfig *container.HostConfig) (container.ContainerUpdateOKBody, error)
|
||||
ContainerWait(name string, timeout time.Duration) (int, error)
|
||||
ContainerWait(ctx context.Context, name string, untilRemoved bool) (<-chan *containerpkg.StateStatus, error)
|
||||
}
|
||||
|
||||
// monitorBackend includes functions to implement to provide containers monitoring functionality.
|
||||
|
|
|
@ -7,7 +7,6 @@ import (
|
|||
"net/http"
|
||||
"strconv"
|
||||
"syscall"
|
||||
"time"
|
||||
|
||||
"github.com/Sirupsen/logrus"
|
||||
"github.com/docker/docker/api"
|
||||
|
@ -284,13 +283,15 @@ func (s *containerRouter) postContainersUnpause(ctx context.Context, w http.Resp
|
|||
}
|
||||
|
||||
func (s *containerRouter) postContainersWait(ctx context.Context, w http.ResponseWriter, r *http.Request, vars map[string]string) error {
|
||||
status, err := s.backend.ContainerWait(vars["name"], -1*time.Second)
|
||||
waitC, err := s.backend.ContainerWait(ctx, vars["name"], false)
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
status := <-waitC
|
||||
|
||||
return httputils.WriteJSON(w, http.StatusOK, &container.ContainerWaitOKBody{
|
||||
StatusCode: int64(status),
|
||||
StatusCode: int64(status.ExitCode()),
|
||||
})
|
||||
}
|
||||
|
||||
|
|
|
@ -6,12 +6,13 @@ package builder
|
|||
|
||||
import (
|
||||
"io"
|
||||
"time"
|
||||
|
||||
"golang.org/x/net/context"
|
||||
|
||||
"github.com/docker/docker/api/types"
|
||||
"github.com/docker/docker/api/types/backend"
|
||||
"github.com/docker/docker/api/types/container"
|
||||
"golang.org/x/net/context"
|
||||
containerpkg "github.com/docker/docker/container"
|
||||
)
|
||||
|
||||
const (
|
||||
|
@ -49,7 +50,7 @@ type Backend interface {
|
|||
// ContainerStart starts a new container
|
||||
ContainerStart(containerID string, hostConfig *container.HostConfig, checkpoint string, checkpointDir string) error
|
||||
// ContainerWait stops processing until the given container is stopped.
|
||||
ContainerWait(containerID string, timeout time.Duration) (int, error)
|
||||
ContainerWait(ctx context.Context, name string, untilRemoved bool) (<-chan *containerpkg.StateStatus, error)
|
||||
// ContainerCreateWorkdir creates the workdir
|
||||
ContainerCreateWorkdir(containerID string) error
|
||||
|
||||
|
|
|
@ -4,6 +4,7 @@ package dockerfile
|
|||
// non-contiguous functionality. Please read the comments.
|
||||
|
||||
import (
|
||||
"context"
|
||||
"crypto/sha256"
|
||||
"encoding/hex"
|
||||
"fmt"
|
||||
|
@ -596,16 +597,25 @@ func (b *Builder) run(cID string, cmd []string) (err error) {
|
|||
return err
|
||||
}
|
||||
|
||||
if ret, _ := b.docker.ContainerWait(cID, -1); ret != 0 {
|
||||
waitC, err := b.docker.ContainerWait(context.Background(), cID, false)
|
||||
if err != nil {
|
||||
// Unable to begin waiting for container.
|
||||
close(finished)
|
||||
if cancelErr := <-cancelErrCh; cancelErr != nil {
|
||||
logrus.Debugf("Build cancelled (%v) and got a non-zero code from ContainerWait: %d",
|
||||
cancelErr, ret)
|
||||
logrus.Debugf("Build cancelled (%v) and unable to begin ContainerWait: %d", cancelErr, err)
|
||||
}
|
||||
return err
|
||||
}
|
||||
|
||||
if status := <-waitC; status.ExitCode() != 0 {
|
||||
close(finished)
|
||||
if cancelErr := <-cancelErrCh; cancelErr != nil {
|
||||
logrus.Debugf("Build cancelled (%v) and got a non-zero code from ContainerWait: %d", cancelErr, status.ExitCode())
|
||||
}
|
||||
// TODO: change error type, because jsonmessage.JSONError assumes HTTP
|
||||
return &jsonmessage.JSONError{
|
||||
Message: fmt.Sprintf("The command '%s' returned a non-zero code: %d", strings.Join(cmd, " "), ret),
|
||||
Code: ret,
|
||||
Message: fmt.Sprintf("The command '%s' returned a non-zero code: %d", strings.Join(cmd, " "), status.ExitCode()),
|
||||
Code: status.ExitCode(),
|
||||
}
|
||||
}
|
||||
close(finished)
|
||||
|
|
|
@ -1,6 +1,7 @@
|
|||
package container
|
||||
|
||||
import (
|
||||
"errors"
|
||||
"fmt"
|
||||
"sync"
|
||||
"time"
|
||||
|
@ -29,23 +30,25 @@ type State struct {
|
|||
ErrorMsg string `json:"Error"` // contains last known error when starting the container
|
||||
StartedAt time.Time
|
||||
FinishedAt time.Time
|
||||
waitChan chan struct{}
|
||||
Health *Health
|
||||
|
||||
waitStop chan struct{}
|
||||
waitRemove chan struct{}
|
||||
}
|
||||
|
||||
// StateStatus is used to return an error type implementing both
|
||||
// exec.ExitCode and error.
|
||||
// StateStatus is used to return container wait results.
|
||||
// Implements exec.ExitCode interface.
|
||||
// This type is needed as State include a sync.Mutex field which make
|
||||
// copying it unsafe.
|
||||
type StateStatus struct {
|
||||
exitCode int
|
||||
error string
|
||||
err error
|
||||
}
|
||||
|
||||
func newStateStatus(ec int, err string) *StateStatus {
|
||||
func newStateStatus(ec int, err error) *StateStatus {
|
||||
return &StateStatus{
|
||||
exitCode: ec,
|
||||
error: err,
|
||||
err: err,
|
||||
}
|
||||
}
|
||||
|
||||
|
@ -54,15 +57,17 @@ func (ss *StateStatus) ExitCode() int {
|
|||
return ss.exitCode
|
||||
}
|
||||
|
||||
// Error returns current error for the state.
|
||||
func (ss *StateStatus) Error() string {
|
||||
return ss.error
|
||||
// Err returns current error for the state. Returns nil if the container had
|
||||
// exited on its own.
|
||||
func (ss *StateStatus) Err() error {
|
||||
return ss.err
|
||||
}
|
||||
|
||||
// NewState creates a default state object with a fresh channel for state changes.
|
||||
func NewState() *State {
|
||||
return &State{
|
||||
waitChan: make(chan struct{}),
|
||||
waitStop: make(chan struct{}),
|
||||
waitRemove: make(chan struct{}),
|
||||
}
|
||||
}
|
||||
|
||||
|
@ -160,64 +165,73 @@ func IsValidStateString(s string) bool {
|
|||
return true
|
||||
}
|
||||
|
||||
func wait(waitChan <-chan struct{}, timeout time.Duration) error {
|
||||
if timeout < 0 {
|
||||
<-waitChan
|
||||
return nil
|
||||
}
|
||||
select {
|
||||
case <-time.After(timeout):
|
||||
return fmt.Errorf("Timed out: %v", timeout)
|
||||
case <-waitChan:
|
||||
return nil
|
||||
func (s *State) isStopped() bool {
|
||||
// The state is not considered "stopped" if it is either "created",
|
||||
// "running", or "paused".
|
||||
switch s.StateString() {
|
||||
case "created", "running", "paused":
|
||||
return false
|
||||
default:
|
||||
return true
|
||||
}
|
||||
}
|
||||
|
||||
// WaitStop waits until state is stopped. If state already stopped it returns
|
||||
// immediately. If you want wait forever you must supply negative timeout.
|
||||
// Returns exit code, that was passed to SetStopped
|
||||
func (s *State) WaitStop(timeout time.Duration) (int, error) {
|
||||
ctx := context.Background()
|
||||
if timeout >= 0 {
|
||||
var cancel func()
|
||||
ctx, cancel = context.WithTimeout(ctx, timeout)
|
||||
defer cancel()
|
||||
}
|
||||
if err := s.WaitWithContext(ctx); err != nil {
|
||||
if status, ok := err.(*StateStatus); ok {
|
||||
return status.ExitCode(), nil
|
||||
}
|
||||
return -1, err
|
||||
}
|
||||
return 0, nil
|
||||
}
|
||||
|
||||
// WaitWithContext waits for the container to stop. Optional context can be
|
||||
// passed for canceling the request.
|
||||
func (s *State) WaitWithContext(ctx context.Context) error {
|
||||
// Wait waits until the continer is in a "stopped" state. A context can be used
|
||||
// for cancelling the request or controlling timeouts. If untilRemoved is true,
|
||||
// Wait will block until the SetRemoved() method has been called. Wait must be
|
||||
// called without holding the state lock. Returns a channel which can be used
|
||||
// to receive the result. If the container exited on its own, the result's Err() method wil be nil and
|
||||
// its ExitCode() method will return the conatiners exit code, otherwise, the
|
||||
// results Err() method will return an error indicating why the wait operation
|
||||
// failed.
|
||||
func (s *State) Wait(ctx context.Context, untilRemoved bool) <-chan *StateStatus {
|
||||
s.Lock()
|
||||
if !s.Running {
|
||||
state := newStateStatus(s.ExitCode(), s.Error())
|
||||
defer s.Unlock()
|
||||
if state.ExitCode() == 0 {
|
||||
return nil
|
||||
|
||||
if !untilRemoved && s.isStopped() {
|
||||
// We are not waiting for removal and the container is already
|
||||
// in a stopped state so just return the current state.
|
||||
result := newStateStatus(s.ExitCode(), s.Err())
|
||||
|
||||
// Buffer so we don't block putting it in the channel.
|
||||
resultC := make(chan *StateStatus, 1)
|
||||
resultC <- result
|
||||
|
||||
return resultC
|
||||
}
|
||||
return state
|
||||
|
||||
// The waitStop chan will remain nil if we are waiting for removal, in
|
||||
// which case it would block forever.
|
||||
var waitStop chan struct{}
|
||||
if !untilRemoved {
|
||||
waitStop = s.waitStop
|
||||
}
|
||||
waitChan := s.waitChan
|
||||
s.Unlock()
|
||||
|
||||
// Always wait for removal, just in case the container gets removed
|
||||
// while it is still in a "created" state, in which case it is never
|
||||
// actually stopped.
|
||||
waitRemove := s.waitRemove
|
||||
|
||||
resultC := make(chan *StateStatus)
|
||||
|
||||
go func() {
|
||||
select {
|
||||
case <-waitChan:
|
||||
s.Lock()
|
||||
state := newStateStatus(s.ExitCode(), s.Error())
|
||||
s.Unlock()
|
||||
if state.ExitCode() == 0 {
|
||||
return nil
|
||||
}
|
||||
return state
|
||||
case <-ctx.Done():
|
||||
return ctx.Err()
|
||||
// Context timeout or cancellation.
|
||||
resultC <- newStateStatus(-1, ctx.Err())
|
||||
return
|
||||
case <-waitStop:
|
||||
case <-waitRemove:
|
||||
}
|
||||
|
||||
s.Lock()
|
||||
result := newStateStatus(s.ExitCode(), s.Err())
|
||||
s.Unlock()
|
||||
|
||||
resultC <- result
|
||||
}()
|
||||
|
||||
return resultC
|
||||
}
|
||||
|
||||
// IsRunning returns whether the running flag is set. Used by Container to check whether a container is running.
|
||||
|
@ -268,8 +282,8 @@ func (s *State) SetStopped(exitStatus *ExitStatus) {
|
|||
s.Pid = 0
|
||||
s.FinishedAt = time.Now().UTC()
|
||||
s.setFromExitStatus(exitStatus)
|
||||
close(s.waitChan) // fire waiters for stop
|
||||
s.waitChan = make(chan struct{})
|
||||
close(s.waitStop) // Fire waiters for stop
|
||||
s.waitStop = make(chan struct{})
|
||||
}
|
||||
|
||||
// SetRestarting sets the container state to "restarting" without locking.
|
||||
|
@ -282,8 +296,8 @@ func (s *State) SetRestarting(exitStatus *ExitStatus) {
|
|||
s.Pid = 0
|
||||
s.FinishedAt = time.Now().UTC()
|
||||
s.setFromExitStatus(exitStatus)
|
||||
close(s.waitChan) // fire waiters for stop
|
||||
s.waitChan = make(chan struct{})
|
||||
close(s.waitStop) // Fire waiters for stop
|
||||
s.waitStop = make(chan struct{})
|
||||
}
|
||||
|
||||
// SetError sets the container's error state. This is useful when we want to
|
||||
|
@ -335,6 +349,23 @@ func (s *State) SetDead() {
|
|||
s.Unlock()
|
||||
}
|
||||
|
||||
// SetRemoved assumes this container is already in the "dead" state and
|
||||
// closes the internal waitRemove channel to unblock callers waiting for a
|
||||
// container to be removed.
|
||||
func (s *State) SetRemoved() {
|
||||
s.Lock()
|
||||
close(s.waitRemove) // Unblock those waiting on remove.
|
||||
s.Unlock()
|
||||
}
|
||||
|
||||
// Err returns an error if there is one.
|
||||
func (s *State) Err() error {
|
||||
if s.ErrorMsg != "" {
|
||||
return errors.New(s.ErrorMsg)
|
||||
}
|
||||
return nil
|
||||
}
|
||||
|
||||
// Error returns current error for the state.
|
||||
func (s *State) Error() string {
|
||||
return s.ErrorMsg
|
||||
|
|
|
@ -1,7 +1,7 @@
|
|||
package container
|
||||
|
||||
import (
|
||||
"sync/atomic"
|
||||
"context"
|
||||
"testing"
|
||||
"time"
|
||||
|
||||
|
@ -30,31 +30,49 @@ func TestIsValidHealthString(t *testing.T) {
|
|||
|
||||
func TestStateRunStop(t *testing.T) {
|
||||
s := NewState()
|
||||
for i := 1; i < 3; i++ { // full lifecycle two times
|
||||
|
||||
// An initial wait (in "created" state) should block until the
|
||||
// container has started and exited. It shouldn't take more than 100
|
||||
// milliseconds.
|
||||
ctx, cancel := context.WithTimeout(context.Background(), 100*time.Millisecond)
|
||||
defer cancel()
|
||||
initialWait := s.Wait(ctx, false)
|
||||
|
||||
// Begin another wait for the final removed state. It should complete
|
||||
// within 200 milliseconds.
|
||||
ctx, cancel = context.WithTimeout(context.Background(), 200*time.Millisecond)
|
||||
defer cancel()
|
||||
removalWait := s.Wait(ctx, true)
|
||||
|
||||
// Full lifecycle two times.
|
||||
for i := 1; i <= 2; i++ {
|
||||
// Set the state to "Running".
|
||||
s.Lock()
|
||||
s.SetRunning(i+100, false)
|
||||
s.SetRunning(i, true)
|
||||
s.Unlock()
|
||||
|
||||
// Assert desired state.
|
||||
if !s.IsRunning() {
|
||||
t.Fatal("State not running")
|
||||
}
|
||||
if s.Pid != i+100 {
|
||||
t.Fatalf("Pid %v, expected %v", s.Pid, i+100)
|
||||
if s.Pid != i {
|
||||
t.Fatalf("Pid %v, expected %v", s.Pid, i)
|
||||
}
|
||||
if s.ExitCode() != 0 {
|
||||
t.Fatalf("ExitCode %v, expected 0", s.ExitCode())
|
||||
}
|
||||
|
||||
stopped := make(chan struct{})
|
||||
var exit int64
|
||||
go func() {
|
||||
exitCode, _ := s.WaitStop(-1 * time.Second)
|
||||
atomic.StoreInt64(&exit, int64(exitCode))
|
||||
close(stopped)
|
||||
}()
|
||||
// Async wait up to 50 milliseconds for the exit status.
|
||||
ctx, cancel := context.WithTimeout(context.Background(), 100*time.Millisecond)
|
||||
defer cancel()
|
||||
exitWait := s.Wait(ctx, false)
|
||||
|
||||
// Set the state to "Exited".
|
||||
s.Lock()
|
||||
s.SetStopped(&ExitStatus{ExitCode: i})
|
||||
s.Unlock()
|
||||
|
||||
// Assert desired state.
|
||||
if s.IsRunning() {
|
||||
t.Fatal("State is running")
|
||||
}
|
||||
|
@ -64,50 +82,86 @@ func TestStateRunStop(t *testing.T) {
|
|||
if s.Pid != 0 {
|
||||
t.Fatalf("Pid %v, expected 0", s.Pid)
|
||||
}
|
||||
select {
|
||||
case <-time.After(100 * time.Millisecond):
|
||||
t.Fatal("Stop callback doesn't fire in 100 milliseconds")
|
||||
case <-stopped:
|
||||
t.Log("Stop callback fired")
|
||||
|
||||
// Receive the exitWait result.
|
||||
status := <-exitWait
|
||||
if status.ExitCode() != i {
|
||||
t.Fatalf("ExitCode %v, expected %v, err %q", status.ExitCode(), i, status.Err())
|
||||
}
|
||||
exitCode := int(atomic.LoadInt64(&exit))
|
||||
if exitCode != i {
|
||||
t.Fatalf("ExitCode %v, expected %v", exitCode, i)
|
||||
|
||||
// A repeated call to Wait() should not block at this point.
|
||||
ctx, cancel = context.WithTimeout(context.Background(), 10*time.Millisecond)
|
||||
defer cancel()
|
||||
exitWait = s.Wait(ctx, false)
|
||||
|
||||
status = <-exitWait
|
||||
if status.ExitCode() != i {
|
||||
t.Fatalf("ExitCode %v, expected %v, err %q", status.ExitCode(), i, status.Err())
|
||||
}
|
||||
if exitCode, err := s.WaitStop(-1 * time.Second); err != nil || exitCode != i {
|
||||
t.Fatalf("WaitStop returned exitCode: %v, err: %v, expected exitCode: %v, err: %v", exitCode, err, i, nil)
|
||||
|
||||
if i == 1 {
|
||||
// Make sure our initial wait also succeeds.
|
||||
status = <-initialWait
|
||||
if status.ExitCode() != i {
|
||||
// Should have the exit code from this first loop.
|
||||
t.Fatalf("Initial wait exitCode %v, expected %v, err %q", status.ExitCode(), i, status.Err())
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
// Set the state to dead and removed.
|
||||
s.SetDead()
|
||||
s.SetRemoved()
|
||||
|
||||
// Wait for removed status or timeout.
|
||||
status := <-removalWait
|
||||
if status.ExitCode() != 2 {
|
||||
// Should have the final exit code from the loop.
|
||||
t.Fatalf("Removal wait exitCode %v, expected %v, err %q", status.ExitCode(), 2, status.Err())
|
||||
}
|
||||
}
|
||||
|
||||
func TestStateTimeoutWait(t *testing.T) {
|
||||
s := NewState()
|
||||
stopped := make(chan struct{})
|
||||
go func() {
|
||||
s.WaitStop(100 * time.Millisecond)
|
||||
close(stopped)
|
||||
}()
|
||||
|
||||
// Start a wait with a timeout.
|
||||
ctx, cancel := context.WithTimeout(context.Background(), 100*time.Millisecond)
|
||||
defer cancel()
|
||||
waitC := s.Wait(ctx, false)
|
||||
|
||||
// It should timeout *before* this 200ms timer does.
|
||||
select {
|
||||
case <-time.After(200 * time.Millisecond):
|
||||
t.Fatal("Stop callback doesn't fire in 200 milliseconds")
|
||||
case <-stopped:
|
||||
case status := <-waitC:
|
||||
t.Log("Stop callback fired")
|
||||
// Should be a timeout error.
|
||||
if status.Err() == nil {
|
||||
t.Fatal("expected timeout error, got nil")
|
||||
}
|
||||
if status.ExitCode() != -1 {
|
||||
t.Fatalf("expected exit code %v, got %v", -1, status.ExitCode())
|
||||
}
|
||||
}
|
||||
|
||||
s.Lock()
|
||||
s.SetStopped(&ExitStatus{ExitCode: 1})
|
||||
s.SetRunning(0, true)
|
||||
s.SetStopped(&ExitStatus{ExitCode: 0})
|
||||
s.Unlock()
|
||||
|
||||
stopped = make(chan struct{})
|
||||
go func() {
|
||||
s.WaitStop(100 * time.Millisecond)
|
||||
close(stopped)
|
||||
}()
|
||||
// Start another wait with a timeout. This one should return
|
||||
// immediately.
|
||||
ctx, cancel = context.WithTimeout(context.Background(), 100*time.Millisecond)
|
||||
defer cancel()
|
||||
waitC = s.Wait(ctx, false)
|
||||
|
||||
select {
|
||||
case <-time.After(200 * time.Millisecond):
|
||||
t.Fatal("Stop callback doesn't fire in 200 milliseconds")
|
||||
case <-stopped:
|
||||
case status := <-waitC:
|
||||
t.Log("Stop callback fired")
|
||||
if status.ExitCode() != 0 {
|
||||
t.Fatalf("expected exit code %v, got %v, err %q", 0, status.ExitCode(), status.Err())
|
||||
}
|
||||
}
|
||||
|
||||
}
|
||||
|
|
|
@ -1,9 +1,9 @@
|
|||
package daemon
|
||||
|
||||
import (
|
||||
"context"
|
||||
"fmt"
|
||||
"io"
|
||||
"time"
|
||||
|
||||
"github.com/Sirupsen/logrus"
|
||||
"github.com/docker/docker/api/errors"
|
||||
|
@ -160,14 +160,11 @@ func (daemon *Daemon) containerAttach(c *container.Container, cfg *stream.Attach
|
|||
cfg.Stdin = nil
|
||||
}
|
||||
|
||||
waitChan := make(chan struct{})
|
||||
if c.Config.StdinOnce && !c.Config.Tty {
|
||||
// Wait for the container to stop before returning.
|
||||
waitChan := c.Wait(context.Background(), false)
|
||||
defer func() {
|
||||
<-waitChan
|
||||
}()
|
||||
go func() {
|
||||
c.WaitStop(-1 * time.Second)
|
||||
close(waitChan)
|
||||
_ = <-waitChan // Ignore returned exit code.
|
||||
}()
|
||||
}
|
||||
|
||||
|
|
|
@ -13,6 +13,7 @@ import (
|
|||
"github.com/docker/docker/api/types/filters"
|
||||
"github.com/docker/docker/api/types/network"
|
||||
swarmtypes "github.com/docker/docker/api/types/swarm"
|
||||
containerpkg "github.com/docker/docker/container"
|
||||
clustertypes "github.com/docker/docker/daemon/cluster/provider"
|
||||
"github.com/docker/docker/plugin"
|
||||
"github.com/docker/libnetwork"
|
||||
|
@ -39,7 +40,7 @@ type Backend interface {
|
|||
DeactivateContainerServiceBinding(containerName string) error
|
||||
UpdateContainerServiceConfig(containerName string, serviceConfig *clustertypes.ServiceConfig) error
|
||||
ContainerInspectCurrent(name string, size bool) (*types.ContainerJSON, error)
|
||||
ContainerWaitWithContext(ctx context.Context, name string) error
|
||||
ContainerWait(ctx context.Context, name string, untilRemoved bool) (<-chan *containerpkg.StateStatus, error)
|
||||
ContainerRm(name string, config *types.ContainerRmConfig) error
|
||||
ContainerKill(name string, sig uint64) error
|
||||
SetContainerDependencyStore(name string, store exec.DependencyGetter) error
|
||||
|
|
|
@ -17,6 +17,7 @@ import (
|
|||
"github.com/docker/docker/api/types/backend"
|
||||
containertypes "github.com/docker/docker/api/types/container"
|
||||
"github.com/docker/docker/api/types/events"
|
||||
containerpkg "github.com/docker/docker/container"
|
||||
"github.com/docker/docker/daemon/cluster/convert"
|
||||
executorpkg "github.com/docker/docker/daemon/cluster/executor"
|
||||
"github.com/docker/libnetwork"
|
||||
|
@ -337,8 +338,8 @@ func (c *containerAdapter) events(ctx context.Context) <-chan events.Message {
|
|||
return eventsq
|
||||
}
|
||||
|
||||
func (c *containerAdapter) wait(ctx context.Context) error {
|
||||
return c.backend.ContainerWaitWithContext(ctx, c.container.nameOrID())
|
||||
func (c *containerAdapter) wait(ctx context.Context) (<-chan *containerpkg.StateStatus, error) {
|
||||
return c.backend.ContainerWait(ctx, c.container.nameOrID(), false)
|
||||
}
|
||||
|
||||
func (c *containerAdapter) shutdown(ctx context.Context) error {
|
||||
|
|
|
@ -279,25 +279,27 @@ func (r *controller) Wait(pctx context.Context) error {
|
|||
}
|
||||
}()
|
||||
|
||||
err := r.adapter.wait(ctx)
|
||||
if ctx.Err() != nil {
|
||||
return ctx.Err()
|
||||
waitC, err := r.adapter.wait(ctx)
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
if err != nil {
|
||||
ee := &exitError{}
|
||||
if ec, ok := err.(exec.ExitCoder); ok {
|
||||
ee.code = ec.ExitCode()
|
||||
if status := <-waitC; status.ExitCode() != 0 {
|
||||
exitErr := &exitError{
|
||||
code: status.ExitCode(),
|
||||
}
|
||||
|
||||
// Set the cause if it is knowable.
|
||||
select {
|
||||
case e := <-healthErr:
|
||||
ee.cause = e
|
||||
exitErr.cause = e
|
||||
default:
|
||||
if err.Error() != "" {
|
||||
ee.cause = err
|
||||
if status.Err() != nil {
|
||||
exitErr.cause = status.Err()
|
||||
}
|
||||
}
|
||||
return ee
|
||||
|
||||
return exitErr
|
||||
}
|
||||
|
||||
return nil
|
||||
|
|
|
@ -3,6 +3,7 @@
|
|||
package daemon
|
||||
|
||||
import (
|
||||
"context"
|
||||
"fmt"
|
||||
"io/ioutil"
|
||||
"os"
|
||||
|
@ -291,7 +292,12 @@ func (daemon *Daemon) setupConfigDir(c *container.Container) (setupErr error) {
|
|||
}
|
||||
|
||||
func killProcessDirectly(container *container.Container) error {
|
||||
if _, err := container.WaitStop(10 * time.Second); err != nil {
|
||||
ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
|
||||
defer cancel()
|
||||
|
||||
// Block until the container to stops or timeout.
|
||||
status := <-container.Wait(ctx, false)
|
||||
if status.Err() != nil {
|
||||
// Ensure that we don't kill ourselves
|
||||
if pid := container.GetPID(); pid != 0 {
|
||||
logrus.Infof("Container %s failed to exit within 10 seconds of kill - trying direct SIGKILL", stringid.TruncateID(container.ID))
|
||||
|
|
|
@ -6,6 +6,7 @@
|
|||
package daemon
|
||||
|
||||
import (
|
||||
"context"
|
||||
"fmt"
|
||||
"io/ioutil"
|
||||
"net"
|
||||
|
@ -773,7 +774,12 @@ func (daemon *Daemon) shutdownContainer(c *container.Container) error {
|
|||
if err := daemon.containerUnpause(c); err != nil {
|
||||
return fmt.Errorf("Failed to unpause container %s with error: %v", c.ID, err)
|
||||
}
|
||||
if _, err := c.WaitStop(time.Duration(stopTimeout) * time.Second); err != nil {
|
||||
|
||||
ctx, cancel := context.WithTimeout(context.Background(), time.Duration(stopTimeout)*time.Second)
|
||||
defer cancel()
|
||||
|
||||
// Wait with timeout for container to exit.
|
||||
if status := <-c.Wait(ctx, false); status.Err() != nil {
|
||||
logrus.Debugf("container %s failed to exit in %d second of SIGTERM, sending SIGKILL to force", c.ID, stopTimeout)
|
||||
sig, ok := signal.SignalMap["KILL"]
|
||||
if !ok {
|
||||
|
@ -782,8 +788,10 @@ func (daemon *Daemon) shutdownContainer(c *container.Container) error {
|
|||
if err := daemon.kill(c, int(sig)); err != nil {
|
||||
logrus.Errorf("Failed to SIGKILL container %s", c.ID)
|
||||
}
|
||||
c.WaitStop(-1 * time.Second)
|
||||
return err
|
||||
// Wait for exit again without a timeout.
|
||||
// Explicitly ignore the result.
|
||||
_ = <-c.Wait(context.Background(), false)
|
||||
return status.Err()
|
||||
}
|
||||
}
|
||||
// If container failed to exit in stopTimeout seconds of SIGTERM, then using the force
|
||||
|
@ -791,7 +799,9 @@ func (daemon *Daemon) shutdownContainer(c *container.Container) error {
|
|||
return fmt.Errorf("Failed to stop container %s with error: %v", c.ID, err)
|
||||
}
|
||||
|
||||
c.WaitStop(-1 * time.Second)
|
||||
// Wait without timeout for the container to exit.
|
||||
// Ignore the result.
|
||||
_ = <-c.Wait(context.Background(), false)
|
||||
return nil
|
||||
}
|
||||
|
||||
|
|
|
@ -134,6 +134,7 @@ func (daemon *Daemon) cleanupContainer(container *container.Container, forceRemo
|
|||
if e := daemon.removeMountPoints(container, removeVolume); e != nil {
|
||||
logrus.Error(e)
|
||||
}
|
||||
container.SetRemoved()
|
||||
stateCtr.del(container.ID)
|
||||
daemon.LogContainerEvent(container, "destroy")
|
||||
return nil
|
||||
|
|
|
@ -1,6 +1,7 @@
|
|||
package daemon
|
||||
|
||||
import (
|
||||
"context"
|
||||
"fmt"
|
||||
"runtime"
|
||||
"strings"
|
||||
|
@ -131,7 +132,10 @@ func (daemon *Daemon) Kill(container *container.Container) error {
|
|||
return nil
|
||||
}
|
||||
|
||||
if _, err2 := container.WaitStop(2 * time.Second); err2 != nil {
|
||||
ctx, cancel := context.WithTimeout(context.Background(), 2*time.Second)
|
||||
defer cancel()
|
||||
|
||||
if status := <-container.Wait(ctx, false); status.Err() != nil {
|
||||
return err
|
||||
}
|
||||
}
|
||||
|
@ -144,7 +148,10 @@ func (daemon *Daemon) Kill(container *container.Container) error {
|
|||
return err
|
||||
}
|
||||
|
||||
container.WaitStop(-1 * time.Second)
|
||||
// Wait for exit with no timeout.
|
||||
// Ignore returned status.
|
||||
_ = <-container.Wait(context.Background(), false)
|
||||
|
||||
return nil
|
||||
}
|
||||
|
||||
|
|
|
@ -1,6 +1,7 @@
|
|||
package daemon
|
||||
|
||||
import (
|
||||
"context"
|
||||
"fmt"
|
||||
"net/http"
|
||||
"time"
|
||||
|
@ -60,7 +61,10 @@ func (daemon *Daemon) containerStop(container *container.Container, seconds int)
|
|||
// So, instead we'll give it up to 2 more seconds to complete and if
|
||||
// by that time the container is still running, then the error
|
||||
// we got is probably valid and so we force kill it.
|
||||
if _, err := container.WaitStop(2 * time.Second); err != nil {
|
||||
ctx, cancel := context.WithTimeout(context.Background(), 2*time.Second)
|
||||
defer cancel()
|
||||
|
||||
if status := <-container.Wait(ctx, false); status.Err() != nil {
|
||||
logrus.Infof("Container failed to stop after sending signal %d to the process, force killing", stopSignal)
|
||||
if err := daemon.killPossiblyDeadProcess(container, 9); err != nil {
|
||||
return err
|
||||
|
@ -69,11 +73,15 @@ func (daemon *Daemon) containerStop(container *container.Container, seconds int)
|
|||
}
|
||||
|
||||
// 2. Wait for the process to exit on its own
|
||||
if _, err := container.WaitStop(time.Duration(seconds) * time.Second); err != nil {
|
||||
ctx, cancel := context.WithTimeout(context.Background(), time.Duration(seconds)*time.Second)
|
||||
defer cancel()
|
||||
|
||||
if status := <-container.Wait(ctx, false); status.Err() != nil {
|
||||
logrus.Infof("Container %v failed to exit within %d seconds of signal %d - using the force", container.ID, seconds, stopSignal)
|
||||
// 3. If it doesn't, then send SIGKILL
|
||||
if err := daemon.Kill(container); err != nil {
|
||||
container.WaitStop(-1 * time.Second)
|
||||
// Wait without a timeout, ignore result.
|
||||
_ = <-container.Wait(context.Background(), false)
|
||||
logrus.Warn(err) // Don't return error because we only care that container is stopped, not what function stopped it
|
||||
}
|
||||
}
|
||||
|
|
|
@ -1,32 +1,22 @@
|
|||
package daemon
|
||||
|
||||
import (
|
||||
"time"
|
||||
|
||||
"github.com/docker/docker/container"
|
||||
"golang.org/x/net/context"
|
||||
)
|
||||
|
||||
// ContainerWait stops processing until the given container is
|
||||
// stopped. If the container is not found, an error is returned. On a
|
||||
// successful stop, the exit code of the container is returned. On a
|
||||
// timeout, an error is returned. If you want to wait forever, supply
|
||||
// a negative duration for the timeout.
|
||||
func (daemon *Daemon) ContainerWait(name string, timeout time.Duration) (int, error) {
|
||||
// ContainerWait stops processing until the given container is stopped or
|
||||
// removed (if untilRemoved is true). If the container is not found, a nil
|
||||
// channel and non-nil error is returned immediately. If the container is
|
||||
// found, a status result will be sent on the returned channel once the wait
|
||||
// condition is met or if an error occurs waiting for the container (such as a
|
||||
// context timeout or cancellation). On a successful stop, the exit code of the
|
||||
// container is returned in the status with a non-nil Err() value.
|
||||
func (daemon *Daemon) ContainerWait(ctx context.Context, name string, untilRemoved bool) (<-chan *container.StateStatus, error) {
|
||||
container, err := daemon.GetContainer(name)
|
||||
if err != nil {
|
||||
return -1, err
|
||||
return nil, err
|
||||
}
|
||||
|
||||
return container.WaitStop(timeout)
|
||||
}
|
||||
|
||||
// ContainerWaitWithContext returns a channel where exit code is sent
|
||||
// when container stops. Channel can be cancelled with a context.
|
||||
func (daemon *Daemon) ContainerWaitWithContext(ctx context.Context, name string) error {
|
||||
container, err := daemon.GetContainer(name)
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
return container.WaitWithContext(ctx)
|
||||
return container.Wait(ctx, untilRemoved), nil
|
||||
}
|
||||
|
|
Загрузка…
Ссылка в новой задаче