blob: 745cb6466b3010cb7d77a5217ba71c177f76ce91 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
|
"""Example writing to and reading from a subprocess at the same time using
tasks."""
import asyncio
import os
from asyncio.subprocess import PIPE
@asyncio.coroutine
def send_input(writer, input):
try:
for line in input:
print('sending', len(line), 'bytes')
writer.write(line)
d = writer.drain()
if d:
print('pause writing')
yield from d
print('resume writing')
writer.close()
except BrokenPipeError:
print('stdin: broken pipe error')
except ConnectionResetError:
print('stdin: connection reset error')
@asyncio.coroutine
def log_errors(reader):
while True:
line = yield from reader.readline()
if not line:
break
print('ERROR', repr(line))
@asyncio.coroutine
def read_stdout(stdout):
while True:
line = yield from stdout.readline()
print('received', repr(line))
if not line:
break
@asyncio.coroutine
def start(cmd, input=None, **kwds):
kwds['stdout'] = PIPE
kwds['stderr'] = PIPE
if input is None and 'stdin' not in kwds:
kwds['stdin'] = None
else:
kwds['stdin'] = PIPE
proc = yield from asyncio.create_subprocess_shell(cmd, **kwds)
tasks = []
if input is not None:
tasks.append(send_input(proc.stdin, input))
else:
print('No stdin')
if proc.stderr is not None:
tasks.append(log_errors(proc.stderr))
else:
print('No stderr')
if proc.stdout is not None:
tasks.append(read_stdout(proc.stdout))
else:
print('No stdout')
if tasks:
# feed stdin while consuming stdout to avoid hang
# when stdin pipe is full
yield from asyncio.wait(tasks)
exitcode = yield from proc.wait()
print("exit code: %s" % exitcode)
def main():
if os.name == 'nt':
loop = asyncio.ProactorEventLoop()
asyncio.set_event_loop(loop)
else:
loop = asyncio.get_event_loop()
loop.run_until_complete(start(
'sleep 2; wc', input=[b'foo bar baz\n'*300 for i in range(100)]))
loop.close()
if __name__ == '__main__':
main()
|
