asyncio: Sync with upstream (compat module)

This commit is contained in:
Yury Selivanov 2015-08-04 15:56:33 -04:00
parent 996083d6e6
commit 2a8911c0b7
7 changed files with 14 additions and 16 deletions

View file

@ -28,6 +28,7 @@
import sys
import warnings
from . import compat
from . import coroutines
from . import events
from . import futures
@ -378,7 +379,7 @@ def is_closed(self):
# On Python 3.3 and older, objects with a destructor part of a reference
# cycle are never destroyed. It's not more the case on Python 3.4 thanks
# to the PEP 442.
if sys.version_info >= (3, 4):
if compat.PY34:
def __del__(self):
if not self.is_closed():
warnings.warn("unclosed event loop %r" % self, ResourceWarning)

View file

@ -1,8 +1,8 @@
import collections
import subprocess
import sys
import warnings
from . import compat
from . import futures
from . import protocols
from . import transports
@ -116,7 +116,7 @@ def close(self):
# On Python 3.3 and older, objects with a destructor part of a reference
# cycle are never destroyed. It's not more the case on Python 3.4 thanks
# to the PEP 442.
if sys.version_info >= (3, 4):
if compat.PY34:
def __del__(self):
if not self._closed:
warnings.warn("unclosed transport %r" % self, ResourceWarning)

View file

@ -7,10 +7,10 @@
__all__ = ['BaseProactorEventLoop']
import socket
import sys
import warnings
from . import base_events
from . import compat
from . import constants
from . import futures
from . import sslproto
@ -79,7 +79,7 @@ def close(self):
# On Python 3.3 and older, objects with a destructor part of a reference
# cycle are never destroyed. It's not more the case on Python 3.4 thanks
# to the PEP 442.
if sys.version_info >= (3, 4):
if compat.PY34:
def __del__(self):
if self._sock is not None:
warnings.warn("unclosed transport %r" % self, ResourceWarning)

View file

@ -10,7 +10,6 @@
import errno
import functools
import socket
import sys
import warnings
try:
import ssl
@ -18,6 +17,7 @@
ssl = None
from . import base_events
from . import compat
from . import constants
from . import events
from . import futures
@ -568,7 +568,7 @@ def close(self):
# On Python 3.3 and older, objects with a destructor part of a reference
# cycle are never destroyed. It's not more the case on Python 3.4 thanks
# to the PEP 442.
if sys.version_info >= (3, 4):
if compat.PY34:
def __del__(self):
if self._sock is not None:
warnings.warn("unclosed transport %r" % self, ResourceWarning)

View file

@ -1,11 +1,11 @@
import collections
import sys
import warnings
try:
import ssl
except ImportError: # pragma: no cover
ssl = None
from . import compat
from . import protocols
from . import transports
from .log import logger
@ -317,7 +317,7 @@ def close(self):
# On Python 3.3 and older, objects with a destructor part of a reference
# cycle are never destroyed. It's not more the case on Python 3.4 thanks
# to the PEP 442.
if sys.version_info >= (3, 4):
if compat.PY34:
def __del__(self):
if not self._closed:
warnings.warn("unclosed transport %r" % self, ResourceWarning)

View file

@ -13,6 +13,7 @@
from . import base_events
from . import base_subprocess
from . import compat
from . import constants
from . import coroutines
from . import events
@ -370,7 +371,7 @@ def close(self):
# On Python 3.3 and older, objects with a destructor part of a reference
# cycle are never destroyed. It's not more the case on Python 3.4 thanks
# to the PEP 442.
if sys.version_info >= (3, 4):
if compat.PY34:
def __del__(self):
if self._pipe is not None:
warnings.warn("unclosed transport %r" % self, ResourceWarning)
@ -555,7 +556,7 @@ def close(self):
# On Python 3.3 and older, objects with a destructor part of a reference
# cycle are never destroyed. It's not more the case on Python 3.4 thanks
# to the PEP 442.
if sys.version_info >= (3, 4):
if compat.PY34:
def __del__(self):
if self._pipe is not None:
warnings.warn("unclosed transport %r" % self, ResourceWarning)

View file

@ -417,11 +417,7 @@ def kill_running():
def test_popen_error(self):
# Issue #24763: check that the subprocess transport is closed
# when BaseSubprocessTransport fails
if sys.platform == 'win32':
target = 'asyncio.windows_utils.Popen'
else:
target = 'subprocess.Popen'
with mock.patch(target) as popen:
with mock.patch('subprocess.Popen') as popen:
exc = ZeroDivisionError
popen.side_effect = exc