Lines Matching refs:proc

115             proc = await asyncio.create_subprocess_exec(
122             proc.stdin.write(data)
123             await proc.stdin.drain()
124             proc.stdin.close()
127             data = await proc.stdout.read()
128             exitcode = await proc.wait()
141             proc = await asyncio.create_subprocess_exec(
146             stdout, stderr = await proc.communicate(data)
147             return proc.returncode, stdout
156         proc = self.loop.run_until_complete(
159         exitcode = self.loop.run_until_complete(proc.wait())
164         proc = self.loop.run_until_complete(
170         exitcode = self.loop.run_until_complete(proc.wait())
175         proc = self.loop.run_until_complete(
178         proc.kill()
179         returncode = self.loop.run_until_complete(proc.wait())
197         proc = self.loop.run_until_complete(
203             proc.send_signal(signal.CTRL_BREAK_EVENT)
205         proc.kill()
206         returncode = self.loop.run_until_complete(proc.wait())
215         proc = self.loop.run_until_complete(
218         proc.terminate()
219         returncode = self.loop.run_until_complete(proc.wait())
235             proc = self.loop.run_until_complete(
242             async def send_signal(proc):
244                 line = await proc.stdout.readline()
247                 proc.send_signal(signal.SIGHUP)
248                 returncode = await proc.wait()
251             returncode = self.loop.run_until_complete(send_signal(proc))
261         proc = self.loop.run_until_complete(
268         return (proc, large_data)
271         proc, large_data = self.prepare_broken_pipe_test()
273         async def write_stdin(proc, data):
275             proc.stdin.write(data)
276             await proc.stdin.drain()
278         coro = write_stdin(proc, large_data)
283         self.loop.run_until_complete(proc.wait())
286         proc, large_data = self.prepare_broken_pipe_test()
290         self.loop.run_until_complete(proc.communicate(large_data))
291         self.loop.run_until_complete(proc.wait())
314             proc = await asyncio.create_subprocess_exec(
320             stdout_transport = proc._transport.get_pipe_transport(1)
322             stdout, stderr = await proc.communicate()
342             proc = await asyncio.create_subprocess_exec(
349             stdout, stderr = await proc.communicate(message)
350             exitcode = await proc.wait()
361             proc = await asyncio.create_subprocess_exec(
368             stdout, stderr = await proc.communicate(b'')
369             exitcode = await proc.wait()
380             proc = await asyncio.create_subprocess_exec(
387             stdout, stderr = await proc.communicate()
388             exitcode = await proc.wait()
399             proc = await asyncio.create_subprocess_exec(
406             stdout, stderr = await proc.communicate(b"abc")
407             exitcode = await proc.wait()
418             proc = await asyncio.create_subprocess_exec(
425             stdout, stderr = await proc.communicate(b"abc")
426             exitcode = await proc.wait()
438             proc = await asyncio.create_subprocess_exec(
445             stdout, stderr = await proc.communicate(message)
446             exitcode = await proc.wait()
457             proc = await asyncio.create_subprocess_exec(*PROGRAM_BLOCKED)
460             task = self.loop.create_task(proc.wait())
471             proc.kill()
472             await proc.wait()
525             proc = transport.get_extra_info('subprocess')
526             orig_kill = proc.kill
527             proc.kill = kill
555             proc = transport.get_extra_info('subprocess')
558             proc.kill()
559             proc.wait()
561             proc.kill = mock.Mock()
562             proc_returncode = proc.poll()
565             return (proc_returncode, transport_returncode, proc.kill.called)
569         # proc.wait()
690             proc = await asyncio.create_subprocess_exec(
693             stdout, _ = await proc.communicate()