fix pipe in broken may cause shim lock forever for runtime v1

lifubang · thaJeztah · commit 538c6661e7e7 · 2018-11-20T16:04:09.000+01:00
Signed-off-by: Lifubang <lifubang@acmcoder.com> (cherry picked from commit e76a887) Signed-off-by: Sebastiaan van Stijn <github@gone.nl>
diff --git a/linux/shim/service_linux.go b/linux/shim/service_linux.go
@@ -49,9 +49,11 @@ func (p *linuxPlatform) CopyConsole(ctx context.Context, console console.Console
 		cwg.Add(1)
 		go func() {
 			cwg.Done()
-			p := bufPool.Get().(*[]byte)
-			defer bufPool.Put(p)
-			io.CopyBuffer(epollConsole, in, *p)
+			bp := bufPool.Get().(*[]byte)
+			defer bufPool.Put(bp)
+			io.CopyBuffer(epollConsole, in, *bp)
+			// we need to shutdown epollConsole when pipe broken
+			epollConsole.Shutdown(p.epoller.CloseConsole)
 		}()
 	}
 
