Stackless issue #199: stackless call "asyncio._CTask"

Remove an unused static function, add test cases and change-log.

Author: Anselm Kruis

Modules/_asynciomodule.c

@@ -2542,21 +2542,17 @@ static PyStacklessFunctionDeclarationObject task_step_impl_declaration = {
         task_step_impl_stackless,
         "task_step_impl_stackless"
 };
-#endif
 
 static PyObject *
-task_step_impl(TaskObj *task, PyObject *exc)
+task_step_impl_part1(TaskObj *task, PyObject *exc, int *failed)
 {
-#ifdef STACKLESS
-    return PyStackless_CallFunction(&task_step_impl_declaration, Py_None,
-        (PyObject *)task, exc, NULL, 0, NULL);
-}
+    STACKLESS_GETARG();
+#else  /* #ifdef STACKLESS */
 
 static PyObject *
-task_step_impl_part1(TaskObj *task, PyObject *exc, int *failed)
+task_step_impl(TaskObj *task, PyObject *exc)
 {
-#endif
-    STACKLESS_GETARG();
+#endif  /* #ifdef STACKLESS */
     int res;
     int clear_exc = 0;
     PyObject *result = NULL;

Stackless/changelog.txt

@@ -9,6 +9,10 @@ What's New in Stackless 3.X.X?
 
 *Release date: 20XX-XX-XX*
 
+- https://github.com/stackless-dev/stackless/issues/199
+  Enable stackless calls of coroutines wrapped in "asyncio._CTask", if
+  soft-switching is enabled. Now asyncio runs coroutines stackless.
+
 - https://github.com/stackless-dev/stackless/issues/197
   Enable stackless calls of method "contextvars.Context.run", if soft-switching
   is enabled.

Stackless/unittests/test_generator.py

@@ -366,8 +366,7 @@ async def test():
     def test_context_run(self):
         contextvars.Context().run(self.assertLevel)
 
-    #  needs Stackless pull request #188
-    def xx_test_asyncio(self):
+    def _test_asyncio(self, task_class):
         async def test():
             try:
                 await self.coro()
@@ -377,13 +376,19 @@ async def test():
         asyncio.set_event_loop(asyncio.new_event_loop())
         self.addCleanup(asyncio.set_event_loop, None)
         loop = asyncio.get_event_loop()
-        task = asyncio.tasks._PyTask(test())
+        task = task_class(test())
         asyncio.ensure_future(task)
         try:
             loop.run_forever()
         finally:
             loop.close()
 
+    def test_asyncio_PyTask(self):
+        self._test_asyncio(asyncio.tasks._PyTask)
+
+    def test_asyncio_CTask(self):
+        self._test_asyncio(asyncio.tasks._CTask)
+
 
 if __name__ == '__main__':
     unittest.main()