Lines Matching refs:proc

113             proc = await asyncio.create_subprocess_exec(
120             proc.stdin.write(data)
121             await proc.stdin.drain()
122             proc.stdin.close()
125             data = await proc.stdout.read()
126             exitcode = await proc.wait()
139             proc = await asyncio.create_subprocess_exec(
144             stdout, stderr = await proc.communicate(data)
145             return proc.returncode, stdout
154         proc = self.loop.run_until_complete(
157         exitcode = self.loop.run_until_complete(proc.wait())
162         proc = self.loop.run_until_complete(
168         exitcode = self.loop.run_until_complete(proc.wait())
173         proc = self.loop.run_until_complete(
176         proc.kill()
177         returncode = self.loop.run_until_complete(proc.wait())
186         proc = self.loop.run_until_complete(
189         proc.terminate()
190         returncode = self.loop.run_until_complete(proc.wait())
206             proc = self.loop.run_until_complete(
213             async def send_signal(proc):  argument
215                 line = await proc.stdout.readline()
218                 proc.send_signal(signal.SIGHUP)
219                 returncode = await proc.wait()
222             returncode = self.loop.run_until_complete(send_signal(proc))
232         proc = self.loop.run_until_complete(
239         return (proc, large_data)
242         proc, large_data = self.prepare_broken_pipe_test()
244         async def write_stdin(proc, data):  argument
246             proc.stdin.write(data)
247             await proc.stdin.drain()
249         coro = write_stdin(proc, large_data)
254         self.loop.run_until_complete(proc.wait())
257         proc, large_data = self.prepare_broken_pipe_test()
261         self.loop.run_until_complete(proc.communicate(large_data))
262         self.loop.run_until_complete(proc.wait())
285             proc = await asyncio.create_subprocess_exec(
291             stdout_transport = proc._transport.get_pipe_transport(1)
293             stdout, stderr = await proc.communicate()
313             proc = await asyncio.create_subprocess_exec(
320             stdout, stderr = await proc.communicate(message)
321             exitcode = await proc.wait()
332             proc = await asyncio.create_subprocess_exec(
339             stdout, stderr = await proc.communicate(b'')
340             exitcode = await proc.wait()
351             proc = await asyncio.create_subprocess_exec(
358             stdout, stderr = await proc.communicate()
359             exitcode = await proc.wait()
370             proc = await asyncio.create_subprocess_exec(
377             stdout, stderr = await proc.communicate(b"abc")
378             exitcode = await proc.wait()
389             proc = await asyncio.create_subprocess_exec(
396             stdout, stderr = await proc.communicate(b"abc")
397             exitcode = await proc.wait()
408             proc = await asyncio.create_subprocess_exec(*PROGRAM_BLOCKED)
411             task = self.loop.create_task(proc.wait())
422             proc.kill()
423             await proc.wait()
476             proc = transport.get_extra_info('subprocess')
477             orig_kill = proc.kill
478             proc.kill = kill
506             proc = transport.get_extra_info('subprocess')
509             proc.kill()
510             proc.wait()
512             proc.kill = mock.Mock()
513             proc_returncode = proc.poll()
516             return (proc_returncode, transport_returncode, proc.kill.called)