mirror of
https://github.com/python/cpython.git
synced 2025-09-26 18:29:57 +00:00
Merge latest Tulip into asyncio
This commit is contained in:
parent
b62deac9a3
commit
0742cae335
3 changed files with 0 additions and 7 deletions
|
@ -114,7 +114,6 @@ class BaseSubprocessTransport(transports.SubprocessTransport):
|
||||||
assert returncode is not None, returncode
|
assert returncode is not None, returncode
|
||||||
assert self._returncode is None, self._returncode
|
assert self._returncode is None, self._returncode
|
||||||
self._returncode = returncode
|
self._returncode = returncode
|
||||||
self._loop._subprocess_closed(self)
|
|
||||||
self._call(self._protocol.process_exited)
|
self._call(self._protocol.process_exited)
|
||||||
self._try_finish()
|
self._try_finish()
|
||||||
|
|
||||||
|
|
|
@ -169,9 +169,6 @@ class _UnixSelectorEventLoop(selector_events.BaseSelectorEventLoop):
|
||||||
def _child_watcher_callback(self, pid, returncode, transp):
|
def _child_watcher_callback(self, pid, returncode, transp):
|
||||||
self.call_soon_threadsafe(transp._process_exited, returncode)
|
self.call_soon_threadsafe(transp._process_exited, returncode)
|
||||||
|
|
||||||
def _subprocess_closed(self, transp):
|
|
||||||
pass
|
|
||||||
|
|
||||||
|
|
||||||
def _set_nonblocking(fd):
|
def _set_nonblocking(fd):
|
||||||
flags = fcntl.fcntl(fd, fcntl.F_GETFL)
|
flags = fcntl.fcntl(fd, fcntl.F_GETFL)
|
||||||
|
|
|
@ -178,9 +178,6 @@ class ProactorEventLoop(proactor_events.BaseProactorEventLoop):
|
||||||
yield from transp._post_init()
|
yield from transp._post_init()
|
||||||
return transp
|
return transp
|
||||||
|
|
||||||
def _subprocess_closed(self, transport):
|
|
||||||
pass
|
|
||||||
|
|
||||||
|
|
||||||
class IocpProactor:
|
class IocpProactor:
|
||||||
"""Proactor implementation using IOCP."""
|
"""Proactor implementation using IOCP."""
|
||||||
|
|
Loading…
Add table
Add a link
Reference in a new issue