summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorVictor Stinner <victor.stinner@gmail.com>2015-02-04 14:50:59 +0100
committerVictor Stinner <victor.stinner@gmail.com>2015-02-04 14:50:59 +0100
commit1a8dbfe47116143c4c69c0d8fd9b11477d7fc554 (patch)
tree9caf8f66bee3d5a66ef615f9e99ff70178d5bb4b
parent061d5c5cc08d0c815eb04780e8037054cee4fb90 (diff)
downloadcpython-1a8dbfe47116143c4c69c0d8fd9b11477d7fc554.tar.gz
asyncio: BaseSelectorEventLoop uses directly the private _debug attribute
Just try to be consistent: _debug was already used in some places, and always used in BaseProactorEventLoop.
-rw-r--r--Lib/asyncio/selector_events.py10
1 files changed, 5 insertions, 5 deletions
diff --git a/Lib/asyncio/selector_events.py b/Lib/asyncio/selector_events.py
index 4bd6dc8d1c..7cbd4fd108 100644
--- a/Lib/asyncio/selector_events.py
+++ b/Lib/asyncio/selector_events.py
@@ -214,7 +214,7 @@ class BaseSelectorEventLoop(base_events.BaseEventLoop):
# It's now up to the protocol to handle the connection.
except Exception as exc:
- if self.get_debug():
+ if self._debug:
context = {
'message': ('Error on transport creation '
'for incoming connection'),
@@ -312,7 +312,7 @@ class BaseSelectorEventLoop(base_events.BaseEventLoop):
This method is a coroutine.
"""
- if self.get_debug() and sock.gettimeout() != 0:
+ if self._debug and sock.gettimeout() != 0:
raise ValueError("the socket must be non-blocking")
fut = futures.Future(loop=self)
self._sock_recv(fut, False, sock, n)
@@ -350,7 +350,7 @@ class BaseSelectorEventLoop(base_events.BaseEventLoop):
This method is a coroutine.
"""
- if self.get_debug() and sock.gettimeout() != 0:
+ if self._debug and sock.gettimeout() != 0:
raise ValueError("the socket must be non-blocking")
fut = futures.Future(loop=self)
if data:
@@ -393,7 +393,7 @@ class BaseSelectorEventLoop(base_events.BaseEventLoop):
This method is a coroutine.
"""
- if self.get_debug() and sock.gettimeout() != 0:
+ if self._debug and sock.gettimeout() != 0:
raise ValueError("the socket must be non-blocking")
fut = futures.Future(loop=self)
try:
@@ -453,7 +453,7 @@ class BaseSelectorEventLoop(base_events.BaseEventLoop):
This method is a coroutine.
"""
- if self.get_debug() and sock.gettimeout() != 0:
+ if self._debug and sock.gettimeout() != 0:
raise ValueError("the socket must be non-blocking")
fut = futures.Future(loop=self)
self._sock_accept(fut, False, sock)