Keep stream and logs in sync for detecting closed pipe

hashicorp · May 9, 2018 · 51440e2 · 51440e2
1 parent 2640ef3
commit 51440e2
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/client/fs_endpoint.go b/client/fs_endpoint.go
@@ -253,7 +253,8 @@ func (f *FileSystem) stream(conn io.ReadWriteCloser) {
 	go func() {
 		for {
 			if _, err := conn.Read(nil); err != nil {
-				if err == io.EOF {
+				if err == io.EOF || err == io.ErrClosedPipe {
+					// One end of the pipe was explicitly closed, exit cleanly
 					cancel()
 					return
 				}