vbatts/containerd
1
0
Fork 0
Code Pull requests Releases Activity

Fix io closer

Browse source 
Signed-off-by: Qiang Huang <h.huangqiang@huawei.com>
This commit is contained in:
Qiang Huang 2017-01-17 19:04:20 +08:00
parent e6f6261bae
commit 9a5b17009c
1 changed files with 6 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
cmd/ctr/utils.go
View file

@ -36,9 +36,9 @@ func prepareStdio(stdin, stdout, stderr string, console bool) (*sync.WaitGroup,
c.Close()
}
}(f)
go func(w io.Writer) {
go func(w io.WriteCloser) {
io.Copy(w, os.Stdin)
f.Close()
w.Close()
}(f)
f, err = fifo.OpenFifo(ctx, stdout, syscall.O_RDONLY|syscall.O_CREAT|syscall.O_NONBLOCK, 0700)
@ -51,9 +51,9 @@ func prepareStdio(stdin, stdout, stderr string, console bool) (*sync.WaitGroup,
}
}(f)
wg.Add(1)
go func(r io.Reader) {
go func(r io.ReadCloser) {
io.Copy(os.Stdout, r)
f.Close()
r.Close()
wg.Done()
}(f)
@ -68,9 +68,9 @@ func prepareStdio(stdin, stdout, stderr string, console bool) (*sync.WaitGroup,
}(f)
if !console {
wg.Add(1)
go func(r io.Reader) {
go func(r io.ReadCloser) {
io.Copy(os.Stderr, r)
f.Close()
r.Close()
wg.Done()
}(f)
}