Browse Source

Add parallel operation support for pause/unpause

Support parallel pause/unpause

Signed-off-by: Zhang Wei <zhangwei555@huawei.com>
Zhang Wei 8 years ago
parent
commit
f1dda4395e
2 changed files with 4 additions and 2 deletions
  1. 2 1
      cli/command/container/pause.go
  2. 2 1
      cli/command/container/unpause.go

+ 2 - 1
cli/command/container/pause.go

@@ -34,8 +34,9 @@ func runPause(dockerCli *command.DockerCli, opts *pauseOptions) error {
 	ctx := context.Background()
 	ctx := context.Background()
 
 
 	var errs []string
 	var errs []string
+	errChan := parallelOperation(ctx, opts.containers, dockerCli.Client().ContainerPause)
 	for _, container := range opts.containers {
 	for _, container := range opts.containers {
-		if err := dockerCli.Client().ContainerPause(ctx, container); err != nil {
+		if err := <-errChan; err != nil {
 			errs = append(errs, err.Error())
 			errs = append(errs, err.Error())
 		} else {
 		} else {
 			fmt.Fprintf(dockerCli.Out(), "%s\n", container)
 			fmt.Fprintf(dockerCli.Out(), "%s\n", container)

+ 2 - 1
cli/command/container/unpause.go

@@ -35,8 +35,9 @@ func runUnpause(dockerCli *command.DockerCli, opts *unpauseOptions) error {
 	ctx := context.Background()
 	ctx := context.Background()
 
 
 	var errs []string
 	var errs []string
+	errChan := parallelOperation(ctx, opts.containers, dockerCli.Client().ContainerUnpause)
 	for _, container := range opts.containers {
 	for _, container := range opts.containers {
-		if err := dockerCli.Client().ContainerUnpause(ctx, container); err != nil {
+		if err := <-errChan; err != nil {
 			errs = append(errs, err.Error())
 			errs = append(errs, err.Error())
 		} else {
 		} else {
 			fmt.Fprintf(dockerCli.Out(), "%s\n", container)
 			fmt.Fprintf(dockerCli.Out(), "%s\n", container)