| Commit message (Collapse) | Author | Age | Files | Lines |
| |
|
|
|
|
| |
transport at subprocess exit.
Clear also its reference to the transport.
|
| |
|
|
|
|
| |
cancelled waiter.
Add unit test cancelling subprocess methods.
|
| |
|
|
|
| |
subprocess, kill the subprocess (close pipes, kill and read the return status).
Log an error in such case.
|
| |
|
|
| |
future before setting its result.
|
| |
|
|
|
| |
objects in the SubprocessStreamProtocol. It allows to pause the transport to
not buffer too much stdout or stderr data.
|
| | |
|
| |
|
|
|
|
|
|
| |
If you want to handle the BrokenPipeError, you can easily reimplement
communicate().
Add also a unit test to ensure that stdin.write() + stdin.drain() raises
BrokenPipeError.
|
| |
|
|
|
|
|
|
|
| |
- Log stdin, stdout and stderr transports and protocols
- Log process identifier (pid)
- Log connection of pipes
- Log process exit
- Log Process.communicate() tasks: feed stdin, read stdout and stderr
- Add __repr__() method to many classes related to subprocesses
|
| | |
|
| |
|
|
|
| |
Use self._loop instead of self._transport._loop, because transport._loop is set
to None at process exit.
|
| | |
|
| | |
|
| |
|
|
| |
and Popen objects
|
| | |
|
| |
|
|
| |
property
|
|
|
* Add a new asyncio.subprocess module
* Add new create_subprocess_exec() and create_subprocess_shell() functions
* The new asyncio.subprocess.SubprocessStreamProtocol creates stream readers
for stdout and stderr and a stream writer for stdin.
* The new asyncio.subprocess.Process class offers an API close to the
subprocess.Popen class:
- pid, returncode, stdin, stdout and stderr attributes
- communicate(), wait(), send_signal(), terminate() and kill() methods
* Remove STDIN (0), STDOUT (1) and STDERR (2) constants from base_subprocess
and unix_events, to not be confused with the symbols with the same name of
subprocess and asyncio.subprocess modules
* _ProactorBasePipeTransport.get_write_buffer_size() now counts also the size
of the pending write
* _ProactorBaseWritePipeTransport._loop_writing() may now pause the protocol if
the write buffer size is greater than the high water mark (64 KB by default)
* Add new subprocess examples: shell.py, subprocess_shell.py,
* subprocess_attach_read_pipe.py and subprocess_attach_write_pipe.py
|