From c8eebd00709a9695576e6f38796de333e96a85b3 Mon Sep 17 00:00:00 2001 From: Gyu-Ho Lee Date: Wed, 27 Jan 2016 00:54:40 -0800 Subject: [PATCH] etcdctl: use os.Stdout, os.Stderr directly for cmd --- etcdctl/command/exec_watch_command.go | 15 ++------------- 1 file changed, 2 insertions(+), 13 deletions(-) diff --git a/etcdctl/command/exec_watch_command.go b/etcdctl/command/exec_watch_command.go index f6f8a2227..75aa35333 100644 --- a/etcdctl/command/exec_watch_command.go +++ b/etcdctl/command/exec_watch_command.go @@ -17,7 +17,6 @@ package command import ( "errors" "fmt" - "io" "os" "os/exec" "os/signal" @@ -105,16 +104,8 @@ func execWatchCommandFunc(c *cli.Context, ki client.KeysAPI) { cmd := exec.Command(cmdArgs[0], cmdArgs[1:]...) cmd.Env = environResponse(resp, os.Environ()) - stdout, err := cmd.StdoutPipe() - if err != nil { - fmt.Fprintf(os.Stderr, err.Error()) - os.Exit(1) - } - stderr, err := cmd.StderrPipe() - if err != nil { - fmt.Fprintf(os.Stderr, err.Error()) - os.Exit(1) - } + cmd.Stdout = os.Stdout + cmd.Stderr = os.Stderr go func() { err := cmd.Start() @@ -122,8 +113,6 @@ func execWatchCommandFunc(c *cli.Context, ki client.KeysAPI) { fmt.Fprintf(os.Stderr, err.Error()) os.Exit(1) } - go io.Copy(os.Stdout, stdout) - go io.Copy(os.Stderr, stderr) cmd.Wait() }() }