mirror of
https://github.com/python/cpython.git
synced 2025-10-02 13:22:19 +00:00
Merge 3.4 (asyncio)
This commit is contained in:
commit
123759502e
3 changed files with 9 additions and 2 deletions
|
@ -153,7 +153,7 @@ class BaseSubprocessTransport(transports.SubprocessTransport):
|
||||||
if all(p is not None and p.disconnected
|
if all(p is not None and p.disconnected
|
||||||
for p in self._pipes.values()):
|
for p in self._pipes.values()):
|
||||||
self._finished = True
|
self._finished = True
|
||||||
self._loop.call_soon(self._call_connection_lost, None)
|
self._call(self._call_connection_lost, None)
|
||||||
|
|
||||||
def _call_connection_lost(self, exc):
|
def _call_connection_lost(self, exc):
|
||||||
try:
|
try:
|
||||||
|
|
|
@ -402,7 +402,7 @@ class IocpProactor:
|
||||||
ov.getresult()
|
ov.getresult()
|
||||||
return pipe
|
return pipe
|
||||||
|
|
||||||
# FIXME: Tulip issue 196: why to we neeed register=False?
|
# FIXME: Tulip issue 196: why do we need register=False?
|
||||||
# See also the comment in the _register() method
|
# See also the comment in the _register() method
|
||||||
return self._register(ov, pipe, finish_accept_pipe,
|
return self._register(ov, pipe, finish_accept_pipe,
|
||||||
register=False)
|
register=False)
|
||||||
|
|
|
@ -134,6 +134,13 @@ class PipeHandle:
|
||||||
def __init__(self, handle):
|
def __init__(self, handle):
|
||||||
self._handle = handle
|
self._handle = handle
|
||||||
|
|
||||||
|
def __repr__(self):
|
||||||
|
if self._handle != -1:
|
||||||
|
handle = 'handle=%r' % self._handle
|
||||||
|
else:
|
||||||
|
handle = 'closed'
|
||||||
|
return '<%s %s>' % (self.__class__.__name__, handle)
|
||||||
|
|
||||||
@property
|
@property
|
||||||
def handle(self):
|
def handle(self):
|
||||||
return self._handle
|
return self._handle
|
||||||
|
|
Loading…
Add table
Add a link
Reference in a new issue