From: Victor Stinner <victor.stinner@gmail.com>
Date: Mon, 7 Jul 2014 15:26:54 +0000 (+0200)
Subject: asyncio: sync with Tulip
X-Git-Tag: v3.4.2rc1~260
X-Git-Url: https://granicus.if.org/sourcecode?a=commitdiff_plain;h=1a870c913238e6e2178283b1d69e9be9203473f2;p=python

asyncio: sync with Tulip

- Tulip issue #181: Faster create_connection(). Call directly
  waiter.set_result() in the constructor of _ProactorBasePipeTransport and
  _SelectorSocketTransport, instead of using of delaying the call with
  call_soon().
- Cleanup iscoroutine()
---

diff --git a/Lib/asyncio/coroutines.py b/Lib/asyncio/coroutines.py
index 7654a0b9e0..48730c225a 100644
--- a/Lib/asyncio/coroutines.py
+++ b/Lib/asyncio/coroutines.py
@@ -166,11 +166,11 @@ def iscoroutinefunction(func):
     return getattr(func, '_is_coroutine', False)
 
 
-_COROUTINE_TYPES = (CoroWrapper, types.GeneratorType)
+_COROUTINE_TYPES = (types.GeneratorType, CoroWrapper)
 
 def iscoroutine(obj):
     """Return True if obj is a coroutine object."""
-    return isinstance(obj,  _COROUTINE_TYPES)
+    return isinstance(obj, _COROUTINE_TYPES)
 
 
 def _format_coroutine(coro):
diff --git a/Lib/asyncio/proactor_events.py b/Lib/asyncio/proactor_events.py
index a80876f366..23545c9ee9 100644
--- a/Lib/asyncio/proactor_events.py
+++ b/Lib/asyncio/proactor_events.py
@@ -38,7 +38,7 @@ class _ProactorBasePipeTransport(transports._FlowControlMixin,
             self._server.attach(self)
         self._loop.call_soon(self._protocol.connection_made, self)
         if waiter is not None:
-            self._loop.call_soon(waiter._set_result_unless_cancelled, None)
+            waiter.set_result(None)
 
     def _set_extra(self, sock):
         self._extra['pipe'] = sock
diff --git a/Lib/asyncio/selector_events.py b/Lib/asyncio/selector_events.py
index 2a170340b9..628efb750c 100644
--- a/Lib/asyncio/selector_events.py
+++ b/Lib/asyncio/selector_events.py
@@ -481,7 +481,7 @@ class _SelectorSocketTransport(_SelectorTransport):
         self._loop.add_reader(self._sock_fd, self._read_ready)
         self._loop.call_soon(self._protocol.connection_made, self)
         if waiter is not None:
-            self._loop.call_soon(waiter._set_result_unless_cancelled, None)
+            waiter.set_result(None)
 
     def pause_reading(self):
         if self._closing: