Merge branch 'master' into optimize_ssl_nonbuffered_read

Author: tarasko

examples/bench/echoclient.py

@@ -4,12 +4,15 @@
 
 import argparse
 import concurrent.futures
+import multiprocessing
 import socket
 import ssl
 import time
 
 
 if __name__ == '__main__':
+    multiprocessing.set_start_method("fork")
+
     parser = argparse.ArgumentParser()
     parser.add_argument('--msize', default=1000, type=int,
                         help='message size in bytes')

pyproject.toml

@@ -59,7 +59,6 @@ docs = [
 requires = [
     "packaging>=20",
     "setuptools>=60",
-    "wheel",
     "Cython~=3.1",
 ]
 build-backend = "setuptools.build_meta"

setup.py

@@ -12,6 +12,7 @@
 import pathlib
 import platform
 import re
+import shlex
 import shutil
 import subprocess
 import sys
@@ -23,7 +24,7 @@
 
 CYTHON_DEPENDENCY = 'Cython~=3.1'
 MACHINE = platform.machine()
-MODULES_CFLAGS = [os.getenv('UVLOOP_OPT_CFLAGS', '-O2')]
+MODULES_CFLAGS = shlex.split(os.getenv('UVLOOP_OPT_CFLAGS', '-O2'))
 _ROOT = pathlib.Path(__file__).parent
 LIBUV_DIR = str(_ROOT / 'vendor' / 'libuv')
 LIBUV_BUILD_DIR = str(_ROOT / 'build' / 'libuv-{}'.format(MACHINE))

tests/test_base.py

@@ -799,6 +799,26 @@ async def main():
         elif result.returncode != 0:
             self.fail(result.stdout.strip())
 
+    def test_thread_name_prefix_in_default_executor(self):
+        if self.implementation == "asyncio" and sys.version_info < (3, 9):
+            raise unittest.SkipTest(
+                "thread_name_prefix was added in CPython 3.9"
+            )
+
+        called = []
+
+        def cb():
+            called.append(threading.current_thread().name)
+
+        async def runner():
+            await self.loop.run_in_executor(None, cb)
+
+        self.loop.run_until_complete(runner())
+
+        self.assertEqual(len(called), 1)
+        self.assertTrue(called[0] is not None)
+        self.assertTrue(called[0].startswith(self.implementation))
+
 
 class TestBaseUV(_TestBase, UVTestCase):
 

uvloop/loop.pyx

@@ -2754,7 +2754,7 @@ cdef class Loop:
             # Only check when the default executor is being used
             self._check_default_executor()
             if executor is None:
-                executor = cc_ThreadPoolExecutor()
+                executor = cc_ThreadPoolExecutor(thread_name_prefix='uvloop')
                 self._default_executor = executor
 
         return aio_wrap_future(executor.submit(func, *args), loop=self)