Commitef62e67

authored and

committed

gh-90522: add test

Subprocess opening /dev/stdin fails if it is a socketpair.

1 parent3afa104 commitef62e67Copy full SHA for ef62e67

File tree

+20

-0

lines changed

+20

-0

lines changed

Lines changed: 20 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -401,6 +401,26 @@ async def empty_error():`
`401`	`401`	`self.assertEqual(output,None)`
`402`	`402`	`self.assertEqual(exitcode,0)`
`403`	`403`
	`404`	`+@unittest.skipIf(sys.platform!='linux',"Don't have /dev/stdin")`
	`405`	`+deftest_devstdin_input(self):`
	`406`	`+`
	`407`	`+asyncdefdevstdin_input(message):`
	`408`	`+code='file = open("/dev/stdin"); data = file.read(); print(len(data))'`
	`409`	`+proc=awaitasyncio.create_subprocess_exec(`
	`410`	`+sys.executable,'-c',code,`
	`411`	`+stdin=asyncio.subprocess.PIPE,`
	`412`	`+stdout=asyncio.subprocess.PIPE,`
	`413`	`+stderr=asyncio.subprocess.PIPE,`
	`414`	`+close_fds=False,`
	`415`	`+ )`
	`416`	`+stdout,stderr=awaitproc.communicate(message)`
	`417`	`+exitcode=awaitproc.wait()`
	`418`	`+return (stdout,exitcode)`
	`419`	`+`
	`420`	`+output,exitcode=self.loop.run_until_complete(devstdin_input(b'abc'))`
	`421`	`+self.assertEqual(output.rstrip(),b'3')`
	`422`	`+self.assertEqual(exitcode,0)`
	`423`	`+`
`404`	`424`	`deftest_cancel_process_wait(self):`
`405`	`425`	`# Issue #23140: cancel Process.wait()`
`406`	`426`

Comments

(0)