Commite316575

committed

pumps: FIX don't pump when proc has no streams

1 parentc3c170c commite316575Copy full SHA for e316575

File tree

-4

lines changed

-4

lines changed

Lines changed: 9 additions & 4 deletions

Original file line number	Diff line number	Diff line change
`@@ -92,11 +92,16 @@ def pump_stream(cmdline, name, stream, is_decode, handler):`
`92`	`92`	`cmdline=getattr(process,'args','')# PY3+ only`
`93`	`93`	`ifnotisinstance(cmdline, (tuple,list)):`
`94`	`94`	`cmdline=cmdline.split()`
	`95`	`+`
	`96`	`+pumps= []`
	`97`	`+ifprocess.stdout:`
	`98`	`+pumps.append(('stdout',process.stdout,stdout_handler))`
	`99`	`+ifprocess.stderr:`
	`100`	`+pumps.append(('stderr',process.stderr,stderr_handler))`
	`101`	`+`
`95`	`102`	`threads= []`
`96`		`-forname,stream,handlerin (`
`97`		`- ('stdout',process.stdout,stdout_handler),`
`98`		`- ('stderr',process.stderr,stderr_handler),`
`99`		`- ):`
	`103`	`+`
	`104`	`+forname,stream,handlerinpumps:`
`100`	`105`	`t=threading.Thread(target=pump_stream,`
`101`	`106`	`args=(cmdline,name,stream,decode_streams,handler))`
`102`	`107`	`t.setDaemon(True)`

Comments

(0)