| Commit message (Collapse) | Author | Age | Files | Lines |
| |
|
|
|
|
|
| |
Override the connect_read_pipe() method of the loop to mock immediatly
pause_reading() and resume_reading() methods.
The test failed randomly on FreeBSD 9 buildbot and on Windows using trollius.
|
| |
|
|
|
|
|
|
|
| |
* Use test_utils.run_briefly() to execute pending calls to really close
transports
* sslproto: mock also _SSLPipe.shutdown(), it's need to close the transport
* pipe test: the test doesn't close explicitly the PipeHandle, so ignore
the warning instead
* test_popen: use the context manager ("with p:") to explicitly close pipes
|
| |
|
|
|
|
| |
cancelled waiter.
Add unit test cancelling subprocess methods.
|
| | |
|
| | |
|
| |
|
|
| |
future before setting its result.
|
| | |
|
| |
|
|
|
|
|
|
|
|
| |
methods of BaseEventLoop now use the identifier of the current thread to ensure
that they are called from the thread running the event loop.
Before, the get_event_loop() method was used to check the thread, and no
exception was raised when the thread had no event loop. Now the methods always
raise an exception in debug mode when called from the wrong thread. It should
help to notice misusage of the API.
|
| | |
|
| |
|
|
| |
module to run the asyncio test suite. The test module is rarely installed.
|
| |
|
|
| |
Mark the write end of the stdin pipe as non-inheritable.
|
| |
|
|
|
| |
* mock also resume_reading()
* ensure that resume_reading() is called
|
| |
|
|
|
| |
objects in the SubprocessStreamProtocol. It allows to pause the transport to
not buffer too much stdout or stderr data.
|
| | |
|
| | |
|
| | |
|
| |
|
|
|
| |
Add a basic synchronization mechanism to wait until the child process is ready
before sending it a signal.
|
| | |
|
| |
|
|
|
|
|
|
| |
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.
|
| |
|
|
| |
variable is set
|
| | |
|
| | |
|
| |
|
|
| |
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
|