From f1dda4395eb52eaeca8f9a1c76c2e2c3e6532490 Mon Sep 17 00:00:00 2001 From: Zhang Wei Date: Mon, 12 Sep 2016 17:21:08 +0800 Subject: [PATCH] Add parallel operation support for pause/unpause Support parallel pause/unpause Signed-off-by: Zhang Wei --- cli/command/container/pause.go | 3 ++- cli/command/container/unpause.go | 3 ++- 2 files changed, 4 insertions(+), 2 deletions(-) diff --git a/cli/command/container/pause.go b/cli/command/container/pause.go index 0cc5b351ba..6817cf60eb 100644 --- a/cli/command/container/pause.go +++ b/cli/command/container/pause.go @@ -34,8 +34,9 @@ func runPause(dockerCli *command.DockerCli, opts *pauseOptions) error { ctx := context.Background() var errs []string + errChan := parallelOperation(ctx, opts.containers, dockerCli.Client().ContainerPause) for _, container := range opts.containers { - if err := dockerCli.Client().ContainerPause(ctx, container); err != nil { + if err := <-errChan; err != nil { errs = append(errs, err.Error()) } else { fmt.Fprintf(dockerCli.Out(), "%s\n", container) diff --git a/cli/command/container/unpause.go b/cli/command/container/unpause.go index c3635db555..c4d8d4841e 100644 --- a/cli/command/container/unpause.go +++ b/cli/command/container/unpause.go @@ -35,8 +35,9 @@ func runUnpause(dockerCli *command.DockerCli, opts *unpauseOptions) error { ctx := context.Background() var errs []string + errChan := parallelOperation(ctx, opts.containers, dockerCli.Client().ContainerUnpause) for _, container := range opts.containers { - if err := dockerCli.Client().ContainerUnpause(ctx, container); err != nil { + if err := <-errChan; err != nil { errs = append(errs, err.Error()) } else { fmt.Fprintf(dockerCli.Out(), "%s\n", container)