@@ -4,7 +4,6 @@ use os_pipe::PipeReader;
44use std:: io:: { BufRead , BufReader , Error , ErrorKind , Read , Result } ;
55use std:: process:: { Child , ExitStatus } ;
66use std:: thread:: JoinHandle ;
7- use CmdChild :: { ProcChild , SyncChild , ThreadChild } ;
87
98/// Representation of running or exited children processes, connected with pipes
109/// optionally.
@@ -79,7 +78,7 @@ impl CmdChildren {
7978 let handle = self . 0 . pop ( ) . unwrap ( ) ;
8079 let mut ret = Ok ( ( ) ) ;
8180 match handle {
82- ProcChild {
81+ CmdChild :: Proc {
8382 mut child, stderr, ..
8483 } => {
8584 if let Some ( stdout) = child. stdout . take ( ) {
@@ -88,10 +87,10 @@ impl CmdChildren {
8887 }
8988 CmdChild :: log_stderr_output ( stderr) ;
9089 }
91- ThreadChild { .. } => {
90+ CmdChild :: ThreadFn { .. } => {
9291 panic ! ( "should not wait pipe on thread" ) ;
9392 }
94- SyncChild { stderr, stdout, .. } => {
93+ CmdChild :: SyncFn { stderr, stdout, .. } => {
9594 CmdChild :: log_stderr_output ( stderr) ;
9695 if let Some ( stdout) = stdout {
9796 ret = f ( Box :: new ( stdout) ) ;
@@ -105,18 +104,18 @@ impl CmdChildren {
105104
106105#[ derive( Debug ) ]
107106pub ( crate ) enum CmdChild {
108- ProcChild {
107+ Proc {
109108 child : Child ,
110109 cmd : String ,
111110 stderr : Option < PipeReader > ,
112111 } ,
113- ThreadChild {
112+ ThreadFn {
114113 child : JoinHandle < CmdResult > ,
115114 cmd : String ,
116115 stdout : Option < PipeReader > ,
117116 stderr : Option < PipeReader > ,
118117 } ,
119- SyncChild {
118+ SyncFn {
120119 cmd : String ,
121120 stdout : Option < PipeReader > ,
122121 stderr : Option < PipeReader > ,
@@ -135,7 +134,7 @@ impl CmdChild {
135134 Ok ( ( ) )
136135 } ;
137136 match self {
138- ProcChild {
137+ CmdChild :: Proc {
139138 mut child,
140139 stderr,
141140 cmd,
@@ -151,7 +150,7 @@ impl CmdChild {
151150 ) ) ;
152151 }
153152 }
154- ThreadChild {
153+ CmdChild :: ThreadFn {
155154 child, cmd, stderr, ..
156155 } => {
157156 let status = child. join ( ) ;
@@ -170,7 +169,7 @@ impl CmdChild {
170169 }
171170 }
172171 }
173- SyncChild { stdout, stderr, .. } => {
172+ CmdChild :: SyncFn { stdout, stderr, .. } => {
174173 Self :: log_stderr_output ( stderr) ;
175174 Self :: print_stdout_output ( stdout) ;
176175 }
@@ -180,7 +179,7 @@ impl CmdChild {
180179
181180 fn wait_with_output ( self ) -> Result < Vec < u8 > > {
182181 match self {
183- ProcChild { child, cmd, stderr } => {
182+ CmdChild :: Proc { child, cmd, stderr } => {
184183 Self :: log_stderr_output ( stderr) ;
185184 let output = child. wait_with_output ( ) ?;
186185 if !output. status . success ( ) {
@@ -192,10 +191,10 @@ impl CmdChild {
192191 Ok ( output. stdout )
193192 }
194193 }
195- ThreadChild { cmd, .. } => {
194+ CmdChild :: ThreadFn { cmd, .. } => {
196195 panic ! ( "{} thread should not be waited for output" , cmd) ;
197196 }
198- SyncChild { stdout, stderr, .. } => {
197+ CmdChild :: SyncFn { stdout, stderr, .. } => {
199198 Self :: log_stderr_output ( stderr) ;
200199 if let Some ( mut out) = stdout {
201200 let mut buf = vec ! [ ] ;
@@ -243,9 +242,9 @@ impl CmdChild {
243242 children
244243 . iter ( )
245244 . map ( |child| match child {
246- ProcChild { cmd, .. } => cmd. to_owned ( ) ,
247- ThreadChild { cmd, .. } => cmd. to_owned ( ) ,
248- SyncChild { cmd, .. } => cmd. to_owned ( ) ,
245+ CmdChild :: Proc { cmd, .. } => cmd. to_owned ( ) ,
246+ CmdChild :: ThreadFn { cmd, .. } => cmd. to_owned ( ) ,
247+ CmdChild :: SyncFn { cmd, .. } => cmd. to_owned ( ) ,
249248 } )
250249 . collect :: < Vec < _ > > ( )
251250 . join ( " | " )
0 commit comments