Intermediate changes

.mapping.json

@@ -412,6 +412,7 @@
   "contrib/libs/libunwind/CMakeLists.linux-aarch64.txt":"",
   "contrib/libs/libunwind/CMakeLists.linux-x86_64.txt":"",
   "contrib/libs/libunwind/CMakeLists.txt":"",
+  "contrib/libs/libunwind/CMakeLists.windows-x86_64.txt":"",
   "contrib/libs/liburing/CMakeLists.linux-aarch64.txt":"",
   "contrib/libs/liburing/CMakeLists.linux-x86_64.txt":"",
   "contrib/libs/liburing/CMakeLists.txt":"",
@@ -2625,6 +2626,16 @@
   "library/cpp/pop_count/CMakeLists.linux-x86_64.txt":"",
   "library/cpp/pop_count/CMakeLists.txt":"",
   "library/cpp/pop_count/CMakeLists.windows-x86_64.txt":"",
+  "library/cpp/porto/CMakeLists.darwin-x86_64.txt":"",
+  "library/cpp/porto/CMakeLists.linux-aarch64.txt":"",
+  "library/cpp/porto/CMakeLists.linux-x86_64.txt":"",
+  "library/cpp/porto/CMakeLists.txt":"",
+  "library/cpp/porto/CMakeLists.windows-x86_64.txt":"",
+  "library/cpp/porto/proto/CMakeLists.darwin-x86_64.txt":"",
+  "library/cpp/porto/proto/CMakeLists.linux-aarch64.txt":"",
+  "library/cpp/porto/proto/CMakeLists.linux-x86_64.txt":"",
+  "library/cpp/porto/proto/CMakeLists.txt":"",
+  "library/cpp/porto/proto/CMakeLists.windows-x86_64.txt":"",
   "library/cpp/presort/CMakeLists.darwin-x86_64.txt":"",
   "library/cpp/presort/CMakeLists.linux-aarch64.txt":"",
   "library/cpp/presort/CMakeLists.linux-x86_64.txt":"",
@@ -3076,10 +3087,21 @@
   "library/cpp/yt/backtrace/cursors/CMakeLists.windows-x86_64.txt":"",
   "library/cpp/yt/backtrace/cursors/dummy/CMakeLists.txt":"",
   "library/cpp/yt/backtrace/cursors/dummy/CMakeLists.windows-x86_64.txt":"",
+  "library/cpp/yt/backtrace/cursors/frame_pointer/CMakeLists.darwin-x86_64.txt":"",
+  "library/cpp/yt/backtrace/cursors/frame_pointer/CMakeLists.linux-aarch64.txt":"",
+  "library/cpp/yt/backtrace/cursors/frame_pointer/CMakeLists.linux-x86_64.txt":"",
+  "library/cpp/yt/backtrace/cursors/frame_pointer/CMakeLists.txt":"",
+  "library/cpp/yt/backtrace/cursors/frame_pointer/CMakeLists.windows-x86_64.txt":"",
+  "library/cpp/yt/backtrace/cursors/interop/CMakeLists.darwin-x86_64.txt":"",
+  "library/cpp/yt/backtrace/cursors/interop/CMakeLists.linux-aarch64.txt":"",
+  "library/cpp/yt/backtrace/cursors/interop/CMakeLists.linux-x86_64.txt":"",
+  "library/cpp/yt/backtrace/cursors/interop/CMakeLists.txt":"",
+  "library/cpp/yt/backtrace/cursors/interop/CMakeLists.windows-x86_64.txt":"",
   "library/cpp/yt/backtrace/cursors/libunwind/CMakeLists.darwin-x86_64.txt":"",
   "library/cpp/yt/backtrace/cursors/libunwind/CMakeLists.linux-aarch64.txt":"",
   "library/cpp/yt/backtrace/cursors/libunwind/CMakeLists.linux-x86_64.txt":"",
   "library/cpp/yt/backtrace/cursors/libunwind/CMakeLists.txt":"",
+  "library/cpp/yt/backtrace/cursors/libunwind/CMakeLists.windows-x86_64.txt":"",
   "library/cpp/yt/coding/CMakeLists.darwin-x86_64.txt":"",
   "library/cpp/yt/coding/CMakeLists.linux-aarch64.txt":"",
   "library/cpp/yt/coding/CMakeLists.linux-x86_64.txt":"",
@@ -3125,11 +3147,21 @@
   "library/cpp/yt/misc/CMakeLists.linux-x86_64.txt":"",
   "library/cpp/yt/misc/CMakeLists.txt":"",
   "library/cpp/yt/misc/CMakeLists.windows-x86_64.txt":"",
+  "library/cpp/yt/mlock/CMakeLists.darwin-x86_64.txt":"",
+  "library/cpp/yt/mlock/CMakeLists.linux-aarch64.txt":"",
+  "library/cpp/yt/mlock/CMakeLists.linux-x86_64.txt":"",
+  "library/cpp/yt/mlock/CMakeLists.txt":"",
+  "library/cpp/yt/mlock/CMakeLists.windows-x86_64.txt":"",
   "library/cpp/yt/small_containers/CMakeLists.darwin-x86_64.txt":"",
   "library/cpp/yt/small_containers/CMakeLists.linux-aarch64.txt":"",
   "library/cpp/yt/small_containers/CMakeLists.linux-x86_64.txt":"",
   "library/cpp/yt/small_containers/CMakeLists.txt":"",
   "library/cpp/yt/small_containers/CMakeLists.windows-x86_64.txt":"",
+  "library/cpp/yt/stockpile/CMakeLists.darwin-x86_64.txt":"",
+  "library/cpp/yt/stockpile/CMakeLists.linux-aarch64.txt":"",
+  "library/cpp/yt/stockpile/CMakeLists.linux-x86_64.txt":"",
+  "library/cpp/yt/stockpile/CMakeLists.txt":"",
+  "library/cpp/yt/stockpile/CMakeLists.windows-x86_64.txt":"",
   "library/cpp/yt/string/CMakeLists.darwin-x86_64.txt":"",
   "library/cpp/yt/string/CMakeLists.linux-aarch64.txt":"",
   "library/cpp/yt/string/CMakeLists.linux-x86_64.txt":"",
@@ -9953,6 +9985,18 @@
   "yt/yt/core/misc/isa_crc64/CMakeLists.linux-x86_64.txt":"",
   "yt/yt/core/misc/isa_crc64/CMakeLists.txt":"",
   "yt/yt/core/misc/isa_crc64/CMakeLists.windows-x86_64.txt":"",
+  "yt/yt/core/rpc/CMakeLists.txt":"",
+  "yt/yt/core/rpc/grpc/CMakeLists.darwin-x86_64.txt":"",
+  "yt/yt/core/rpc/grpc/CMakeLists.linux-aarch64.txt":"",
+  "yt/yt/core/rpc/grpc/CMakeLists.linux-x86_64.txt":"",
+  "yt/yt/core/rpc/grpc/CMakeLists.txt":"",
+  "yt/yt/core/rpc/grpc/CMakeLists.windows-x86_64.txt":"",
+  "yt/yt/core/service_discovery/CMakeLists.txt":"",
+  "yt/yt/core/service_discovery/yp/CMakeLists.darwin-x86_64.txt":"",
+  "yt/yt/core/service_discovery/yp/CMakeLists.linux-aarch64.txt":"",
+  "yt/yt/core/service_discovery/yp/CMakeLists.linux-x86_64.txt":"",
+  "yt/yt/core/service_discovery/yp/CMakeLists.txt":"",
+  "yt/yt/core/service_discovery/yp/CMakeLists.windows-x86_64.txt":"",
   "yt/yt/library/CMakeLists.darwin-x86_64.txt":"",
   "yt/yt/library/CMakeLists.linux-aarch64.txt":"",
   "yt/yt/library/CMakeLists.linux-x86_64.txt":"",
@@ -9962,6 +10006,17 @@
   "yt/yt/library/auth/CMakeLists.linux-aarch64.txt":"",
   "yt/yt/library/auth/CMakeLists.linux-x86_64.txt":"",
   "yt/yt/library/auth/CMakeLists.txt":"",
+  "yt/yt/library/backtrace_introspector/CMakeLists.linux-aarch64.txt":"",
+  "yt/yt/library/backtrace_introspector/CMakeLists.linux-x86_64.txt":"",
+  "yt/yt/library/backtrace_introspector/CMakeLists.txt":"",
+  "yt/yt/library/backtrace_introspector/http/CMakeLists.linux-aarch64.txt":"",
+  "yt/yt/library/backtrace_introspector/http/CMakeLists.linux-x86_64.txt":"",
+  "yt/yt/library/backtrace_introspector/http/CMakeLists.txt":"",
+  "yt/yt/library/containers/CMakeLists.darwin-x86_64.txt":"",
+  "yt/yt/library/containers/CMakeLists.linux-aarch64.txt":"",
+  "yt/yt/library/containers/CMakeLists.linux-x86_64.txt":"",
+  "yt/yt/library/containers/CMakeLists.txt":"",
+  "yt/yt/library/containers/CMakeLists.windows-x86_64.txt":"",
   "yt/yt/library/decimal/CMakeLists.darwin-x86_64.txt":"",
   "yt/yt/library/decimal/CMakeLists.linux-aarch64.txt":"",
   "yt/yt/library/decimal/CMakeLists.linux-x86_64.txt":"",
@@ -9970,20 +10025,50 @@
   "yt/yt/library/erasure/CMakeLists.linux-aarch64.txt":"",
   "yt/yt/library/erasure/CMakeLists.linux-x86_64.txt":"",
   "yt/yt/library/erasure/CMakeLists.txt":"",
+  "yt/yt/library/monitoring/CMakeLists.darwin-x86_64.txt":"",
+  "yt/yt/library/monitoring/CMakeLists.linux-aarch64.txt":"",
+  "yt/yt/library/monitoring/CMakeLists.linux-x86_64.txt":"",
+  "yt/yt/library/monitoring/CMakeLists.txt":"",
+  "yt/yt/library/monitoring/CMakeLists.windows-x86_64.txt":"",
   "yt/yt/library/numeric/CMakeLists.darwin-x86_64.txt":"",
   "yt/yt/library/numeric/CMakeLists.linux-aarch64.txt":"",
   "yt/yt/library/numeric/CMakeLists.linux-x86_64.txt":"",
   "yt/yt/library/numeric/CMakeLists.txt":"",
+  "yt/yt/library/process/CMakeLists.darwin-x86_64.txt":"",
+  "yt/yt/library/process/CMakeLists.linux-aarch64.txt":"",
+  "yt/yt/library/process/CMakeLists.linux-x86_64.txt":"",
+  "yt/yt/library/process/CMakeLists.txt":"",
+  "yt/yt/library/process/CMakeLists.windows-x86_64.txt":"",
   "yt/yt/library/profiling/CMakeLists.darwin-x86_64.txt":"",
   "yt/yt/library/profiling/CMakeLists.linux-aarch64.txt":"",
   "yt/yt/library/profiling/CMakeLists.linux-x86_64.txt":"",
   "yt/yt/library/profiling/CMakeLists.txt":"",
   "yt/yt/library/profiling/CMakeLists.windows-x86_64.txt":"",
+  "yt/yt/library/profiling/perf/CMakeLists.darwin-x86_64.txt":"",
+  "yt/yt/library/profiling/perf/CMakeLists.linux-aarch64.txt":"",
+  "yt/yt/library/profiling/perf/CMakeLists.linux-x86_64.txt":"",
+  "yt/yt/library/profiling/perf/CMakeLists.txt":"",
+  "yt/yt/library/profiling/perf/CMakeLists.windows-x86_64.txt":"",
   "yt/yt/library/profiling/resource_tracker/CMakeLists.darwin-x86_64.txt":"",
   "yt/yt/library/profiling/resource_tracker/CMakeLists.linux-aarch64.txt":"",
   "yt/yt/library/profiling/resource_tracker/CMakeLists.linux-x86_64.txt":"",
   "yt/yt/library/profiling/resource_tracker/CMakeLists.txt":"",
   "yt/yt/library/profiling/resource_tracker/CMakeLists.windows-x86_64.txt":"",
+  "yt/yt/library/profiling/solomon/CMakeLists.darwin-x86_64.txt":"",
+  "yt/yt/library/profiling/solomon/CMakeLists.linux-aarch64.txt":"",
+  "yt/yt/library/profiling/solomon/CMakeLists.linux-x86_64.txt":"",
+  "yt/yt/library/profiling/solomon/CMakeLists.txt":"",
+  "yt/yt/library/profiling/solomon/CMakeLists.windows-x86_64.txt":"",
+  "yt/yt/library/profiling/tcmalloc/CMakeLists.darwin-x86_64.txt":"",
+  "yt/yt/library/profiling/tcmalloc/CMakeLists.linux-aarch64.txt":"",
+  "yt/yt/library/profiling/tcmalloc/CMakeLists.linux-x86_64.txt":"",
+  "yt/yt/library/profiling/tcmalloc/CMakeLists.txt":"",
+  "yt/yt/library/profiling/tcmalloc/CMakeLists.windows-x86_64.txt":"",
+  "yt/yt/library/program/CMakeLists.darwin-x86_64.txt":"",
+  "yt/yt/library/program/CMakeLists.linux-aarch64.txt":"",
+  "yt/yt/library/program/CMakeLists.linux-x86_64.txt":"",
+  "yt/yt/library/program/CMakeLists.txt":"",
+  "yt/yt/library/program/CMakeLists.windows-x86_64.txt":"",
   "yt/yt/library/quantile_digest/CMakeLists.darwin-x86_64.txt":"",
   "yt/yt/library/quantile_digest/CMakeLists.linux-aarch64.txt":"",
   "yt/yt/library/quantile_digest/CMakeLists.linux-x86_64.txt":"",
@@ -10002,6 +10087,11 @@
   "yt/yt/library/tracing/CMakeLists.linux-x86_64.txt":"",
   "yt/yt/library/tracing/CMakeLists.txt":"",
   "yt/yt/library/tracing/CMakeLists.windows-x86_64.txt":"",
+  "yt/yt/library/tracing/jaeger/CMakeLists.darwin-x86_64.txt":"",
+  "yt/yt/library/tracing/jaeger/CMakeLists.linux-aarch64.txt":"",
+  "yt/yt/library/tracing/jaeger/CMakeLists.linux-x86_64.txt":"",
+  "yt/yt/library/tracing/jaeger/CMakeLists.txt":"",
+  "yt/yt/library/tracing/jaeger/CMakeLists.windows-x86_64.txt":"",
   "yt/yt/library/tvm/CMakeLists.darwin-x86_64.txt":"",
   "yt/yt/library/tvm/CMakeLists.linux-aarch64.txt":"",
   "yt/yt/library/tvm/CMakeLists.linux-x86_64.txt":"",
@@ -10012,12 +10102,24 @@
   "yt/yt/library/undumpable/CMakeLists.linux-x86_64.txt":"",
   "yt/yt/library/undumpable/CMakeLists.txt":"",
   "yt/yt/library/undumpable/CMakeLists.windows-x86_64.txt":"",
+  "yt/yt/library/ytprof/CMakeLists.darwin-x86_64.txt":"",
+  "yt/yt/library/ytprof/CMakeLists.linux-aarch64.txt":"",
+  "yt/yt/library/ytprof/CMakeLists.linux-x86_64.txt":"",
   "yt/yt/library/ytprof/CMakeLists.txt":"",
+  "yt/yt/library/ytprof/CMakeLists.windows-x86_64.txt":"",
   "yt/yt/library/ytprof/api/CMakeLists.darwin-x86_64.txt":"",
   "yt/yt/library/ytprof/api/CMakeLists.linux-aarch64.txt":"",
   "yt/yt/library/ytprof/api/CMakeLists.linux-x86_64.txt":"",
   "yt/yt/library/ytprof/api/CMakeLists.txt":"",
   "yt/yt/library/ytprof/api/CMakeLists.windows-x86_64.txt":"",
+  "yt/yt/library/ytprof/http/CMakeLists.linux-aarch64.txt":"",
+  "yt/yt/library/ytprof/http/CMakeLists.linux-x86_64.txt":"",
+  "yt/yt/library/ytprof/http/CMakeLists.txt":"",
+  "yt/yt/library/ytprof/proto/CMakeLists.darwin-x86_64.txt":"",
+  "yt/yt/library/ytprof/proto/CMakeLists.linux-aarch64.txt":"",
+  "yt/yt/library/ytprof/proto/CMakeLists.linux-x86_64.txt":"",
+  "yt/yt/library/ytprof/proto/CMakeLists.txt":"",
+  "yt/yt/library/ytprof/proto/CMakeLists.windows-x86_64.txt":"",
   "yt/yt_proto/CMakeLists.txt":"",
   "yt/yt_proto/yt/CMakeLists.darwin-x86_64.txt":"",
   "yt/yt_proto/yt/CMakeLists.linux-aarch64.txt":"",

contrib/libs/CMakeLists.windows-x86_64.txt

@@ -33,6 +33,7 @@ add_subdirectory(libbz2)
 add_subdirectory(libc_compat)
 add_subdirectory(libevent)
 add_subdirectory(libfyaml)
+add_subdirectory(libunwind)
 add_subdirectory(libxml)
 add_subdirectory(linuxvdso)
 add_subdirectory(llvm12)

contrib/libs/libunwind/CMakeLists.txt

@@ -10,6 +10,8 @@ if (CMAKE_SYSTEM_NAME STREQUAL "Linux" AND CMAKE_SYSTEM_PROCESSOR STREQUAL "aarc
   include(CMakeLists.linux-aarch64.txt)
 elseif (CMAKE_SYSTEM_NAME STREQUAL "Darwin" AND CMAKE_SYSTEM_PROCESSOR STREQUAL "x86_64")
   include(CMakeLists.darwin-x86_64.txt)
+elseif (WIN32 AND CMAKE_SYSTEM_PROCESSOR STREQUAL "AMD64" AND NOT HAVE_CUDA)
+  include(CMakeLists.windows-x86_64.txt)
 elseif (CMAKE_SYSTEM_NAME STREQUAL "Linux" AND CMAKE_SYSTEM_PROCESSOR STREQUAL "x86_64" AND NOT HAVE_CUDA)
   include(CMakeLists.linux-x86_64.txt)
 endif()

contrib/libs/libunwind/CMakeLists.windows-x86_64.txt

@@ -0,0 +1,35 @@
+
+# This file was generated by the build system used internally in the Yandex monorepo.
+# Only simple modifications are allowed (adding source-files to targets, adding simple properties
+# like target_include_directories). These modifications will be ported to original
+# ya.make files by maintainers. Any complex modifications which can't be ported back to the
+# original buildsystem will not be accepted.
+
+
+
+add_library(contrib-libs-libunwind)
+target_compile_options(contrib-libs-libunwind PUBLIC
+  -D_libunwind_
+)
+target_compile_options(contrib-libs-libunwind PRIVATE
+  -D_LIBUNWIND_IS_NATIVE_ONLY
+  -fno-exceptions
+  -fno-rtti
+  -funwind-tables
+)
+target_include_directories(contrib-libs-libunwind PRIVATE
+  ${CMAKE_SOURCE_DIR}/contrib/libs/libunwind/include
+)
+target_link_libraries(contrib-libs-libunwind PUBLIC
+  cpp-sanitizer-include
+)
+target_sources(contrib-libs-libunwind PRIVATE
+  ${CMAKE_SOURCE_DIR}/contrib/libs/libunwind/src/Unwind-EHABI.cpp
+  ${CMAKE_SOURCE_DIR}/contrib/libs/libunwind/src/Unwind-seh.cpp
+  ${CMAKE_SOURCE_DIR}/contrib/libs/libunwind/src/Unwind-sjlj.c
+  ${CMAKE_SOURCE_DIR}/contrib/libs/libunwind/src/UnwindLevel1-gcc-ext.c
+  ${CMAKE_SOURCE_DIR}/contrib/libs/libunwind/src/UnwindLevel1.c
+  ${CMAKE_SOURCE_DIR}/contrib/libs/libunwind/src/UnwindRegistersRestore.S
+  ${CMAKE_SOURCE_DIR}/contrib/libs/libunwind/src/UnwindRegistersSave.S
+  ${CMAKE_SOURCE_DIR}/contrib/libs/libunwind/src/libunwind.cpp
+)

contrib/python/anyio/.dist-info/METADATA

@@ -0,0 +1,105 @@
+Metadata-Version: 2.1
+Name: anyio
+Version: 3.7.1
+Summary: High level compatibility layer for multiple asynchronous event loop implementations
+Author-email: Alex Grönholm <alex.gronholm@nextday.fi>
+License: MIT
+Project-URL: Documentation, https://anyio.readthedocs.io/en/latest/
+Project-URL: Changelog, https://anyio.readthedocs.io/en/stable/versionhistory.html
+Project-URL: Source code, https://github.com/agronholm/anyio
+Project-URL: Issue tracker, https://github.com/agronholm/anyio/issues
+Classifier: Development Status :: 5 - Production/Stable
+Classifier: Intended Audience :: Developers
+Classifier: License :: OSI Approved :: MIT License
+Classifier: Framework :: AnyIO
+Classifier: Typing :: Typed
+Classifier: Programming Language :: Python
+Classifier: Programming Language :: Python :: 3
+Classifier: Programming Language :: Python :: 3.7
+Classifier: Programming Language :: Python :: 3.8
+Classifier: Programming Language :: Python :: 3.9
+Classifier: Programming Language :: Python :: 3.10
+Classifier: Programming Language :: Python :: 3.11
+Requires-Python: >=3.7
+Description-Content-Type: text/x-rst
+License-File: LICENSE
+Requires-Dist: idna (>=2.8)
+Requires-Dist: sniffio (>=1.1)
+Requires-Dist: exceptiongroup ; python_version < "3.11"
+Requires-Dist: typing-extensions ; python_version < "3.8"
+Provides-Extra: doc
+Requires-Dist: packaging ; extra == 'doc'
+Requires-Dist: Sphinx ; extra == 'doc'
+Requires-Dist: sphinx-rtd-theme (>=1.2.2) ; extra == 'doc'
+Requires-Dist: sphinxcontrib-jquery ; extra == 'doc'
+Requires-Dist: sphinx-autodoc-typehints (>=1.2.0) ; extra == 'doc'
+Provides-Extra: test
+Requires-Dist: anyio[trio] ; extra == 'test'
+Requires-Dist: coverage[toml] (>=4.5) ; extra == 'test'
+Requires-Dist: hypothesis (>=4.0) ; extra == 'test'
+Requires-Dist: psutil (>=5.9) ; extra == 'test'
+Requires-Dist: pytest (>=7.0) ; extra == 'test'
+Requires-Dist: pytest-mock (>=3.6.1) ; extra == 'test'
+Requires-Dist: trustme ; extra == 'test'
+Requires-Dist: uvloop (>=0.17) ; (python_version < "3.12" and platform_python_implementation == "CPython" and platform_system != "Windows") and extra == 'test'
+Requires-Dist: mock (>=4) ; (python_version < "3.8") and extra == 'test'
+Provides-Extra: trio
+Requires-Dist: trio (<0.22) ; extra == 'trio'
+
+.. image:: https://github.com/agronholm/anyio/actions/workflows/test.yml/badge.svg
+  :target: https://github.com/agronholm/anyio/actions/workflows/test.yml
+  :alt: Build Status
+.. image:: https://coveralls.io/repos/github/agronholm/anyio/badge.svg?branch=master
+  :target: https://coveralls.io/github/agronholm/anyio?branch=master
+  :alt: Code Coverage
+.. image:: https://readthedocs.org/projects/anyio/badge/?version=latest
+  :target: https://anyio.readthedocs.io/en/latest/?badge=latest
+  :alt: Documentation
+.. image:: https://badges.gitter.im/gitterHQ/gitter.svg
+  :target: https://gitter.im/python-trio/AnyIO
+  :alt: Gitter chat
+
+AnyIO is an asynchronous networking and concurrency library that works on top of either asyncio_ or
+trio_. It implements trio-like `structured concurrency`_ (SC) on top of asyncio and works in harmony
+with the native SC of trio itself.
+
+Applications and libraries written against AnyIO's API will run unmodified on either asyncio_ or
+trio_. AnyIO can also be adopted into a library or application incrementally – bit by bit, no full
+refactoring necessary. It will blend in with the native libraries of your chosen backend.
+
+Documentation
+-------------
+
+View full documentation at: https://anyio.readthedocs.io/
+
+Features
+--------
+
+AnyIO offers the following functionality:
+
+* Task groups (nurseries_ in trio terminology)
+* High-level networking (TCP, UDP and UNIX sockets)
+
+  * `Happy eyeballs`_ algorithm for TCP connections (more robust than that of asyncio on Python
+    3.8)
+  * async/await style UDP sockets (unlike asyncio where you still have to use Transports and
+    Protocols)
+
+* A versatile API for byte streams and object streams
+* Inter-task synchronization and communication (locks, conditions, events, semaphores, object
+  streams)
+* Worker threads
+* Subprocesses
+* Asynchronous file I/O (using worker threads)
+* Signal handling
+
+AnyIO also comes with its own pytest_ plugin which also supports asynchronous fixtures.
+It even works with the popular Hypothesis_ library.
+
+.. _asyncio: https://docs.python.org/3/library/asyncio.html
+.. _trio: https://github.com/python-trio/trio
+.. _structured concurrency: https://en.wikipedia.org/wiki/Structured_concurrency
+.. _nurseries: https://trio.readthedocs.io/en/stable/reference-core.html#nurseries-and-spawning
+.. _Happy eyeballs: https://en.wikipedia.org/wiki/Happy_Eyeballs
+.. _pytest: https://docs.pytest.org/en/latest/
+.. _Hypothesis: https://hypothesis.works/

contrib/python/anyio/.dist-info/entry_points.txt

@@ -0,0 +1,2 @@
+[pytest11]
+anyio = anyio.pytest_plugin

contrib/python/anyio/.dist-info/top_level.txt

@@ -0,0 +1 @@
+anyio

contrib/python/anyio/LICENSE

@@ -0,0 +1,20 @@
+The MIT License (MIT)
+
+Copyright (c) 2018 Alex Grönholm
+
+Permission is hereby granted, free of charge, to any person obtaining a copy of
+this software and associated documentation files (the "Software"), to deal in
+the Software without restriction, including without limitation the rights to
+use, copy, modify, merge, publish, distribute, sublicense, and/or sell copies of
+the Software, and to permit persons to whom the Software is furnished to do so,
+subject to the following conditions:
+
+The above copyright notice and this permission notice shall be included in all
+copies or substantial portions of the Software.
+
+THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS
+FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR
+COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER
+IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN
+CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.

contrib/python/anyio/README.rst

@@ -0,0 +1,57 @@
+.. image:: https://github.com/agronholm/anyio/actions/workflows/test.yml/badge.svg
+  :target: https://github.com/agronholm/anyio/actions/workflows/test.yml
+  :alt: Build Status
+.. image:: https://coveralls.io/repos/github/agronholm/anyio/badge.svg?branch=master
+  :target: https://coveralls.io/github/agronholm/anyio?branch=master
+  :alt: Code Coverage
+.. image:: https://readthedocs.org/projects/anyio/badge/?version=latest
+  :target: https://anyio.readthedocs.io/en/latest/?badge=latest
+  :alt: Documentation
+.. image:: https://badges.gitter.im/gitterHQ/gitter.svg
+  :target: https://gitter.im/python-trio/AnyIO
+  :alt: Gitter chat
+
+AnyIO is an asynchronous networking and concurrency library that works on top of either asyncio_ or
+trio_. It implements trio-like `structured concurrency`_ (SC) on top of asyncio and works in harmony
+with the native SC of trio itself.
+
+Applications and libraries written against AnyIO's API will run unmodified on either asyncio_ or
+trio_. AnyIO can also be adopted into a library or application incrementally – bit by bit, no full
+refactoring necessary. It will blend in with the native libraries of your chosen backend.
+
+Documentation
+-------------
+
+View full documentation at: https://anyio.readthedocs.io/
+
+Features
+--------
+
+AnyIO offers the following functionality:
+
+* Task groups (nurseries_ in trio terminology)
+* High-level networking (TCP, UDP and UNIX sockets)
+
+  * `Happy eyeballs`_ algorithm for TCP connections (more robust than that of asyncio on Python
+    3.8)
+  * async/await style UDP sockets (unlike asyncio where you still have to use Transports and
+    Protocols)
+
+* A versatile API for byte streams and object streams
+* Inter-task synchronization and communication (locks, conditions, events, semaphores, object
+  streams)
+* Worker threads
+* Subprocesses
+* Asynchronous file I/O (using worker threads)
+* Signal handling
+
+AnyIO also comes with its own pytest_ plugin which also supports asynchronous fixtures.
+It even works with the popular Hypothesis_ library.
+
+.. _asyncio: https://docs.python.org/3/library/asyncio.html
+.. _trio: https://github.com/python-trio/trio
+.. _structured concurrency: https://en.wikipedia.org/wiki/Structured_concurrency
+.. _nurseries: https://trio.readthedocs.io/en/stable/reference-core.html#nurseries-and-spawning
+.. _Happy eyeballs: https://en.wikipedia.org/wiki/Happy_Eyeballs
+.. _pytest: https://docs.pytest.org/en/latest/
+.. _Hypothesis: https://hypothesis.works/

contrib/python/anyio/anyio/__init__.py

@@ -0,0 +1,169 @@
+from __future__ import annotations
+
+__all__ = (
+    "maybe_async",
+    "maybe_async_cm",
+    "run",
+    "sleep",
+    "sleep_forever",
+    "sleep_until",
+    "current_time",
+    "get_all_backends",
+    "get_cancelled_exc_class",
+    "BrokenResourceError",
+    "BrokenWorkerProcess",
+    "BusyResourceError",
+    "ClosedResourceError",
+    "DelimiterNotFound",
+    "EndOfStream",
+    "ExceptionGroup",
+    "IncompleteRead",
+    "TypedAttributeLookupError",
+    "WouldBlock",
+    "AsyncFile",
+    "Path",
+    "open_file",
+    "wrap_file",
+    "aclose_forcefully",
+    "open_signal_receiver",
+    "connect_tcp",
+    "connect_unix",
+    "create_tcp_listener",
+    "create_unix_listener",
+    "create_udp_socket",
+    "create_connected_udp_socket",
+    "getaddrinfo",
+    "getnameinfo",
+    "wait_socket_readable",
+    "wait_socket_writable",
+    "create_memory_object_stream",
+    "run_process",
+    "open_process",
+    "create_lock",
+    "CapacityLimiter",
+    "CapacityLimiterStatistics",
+    "Condition",
+    "ConditionStatistics",
+    "Event",
+    "EventStatistics",
+    "Lock",
+    "LockStatistics",
+    "Semaphore",
+    "SemaphoreStatistics",
+    "create_condition",
+    "create_event",
+    "create_semaphore",
+    "create_capacity_limiter",
+    "open_cancel_scope",
+    "fail_after",
+    "move_on_after",
+    "current_effective_deadline",
+    "TASK_STATUS_IGNORED",
+    "CancelScope",
+    "create_task_group",
+    "TaskInfo",
+    "get_current_task",
+    "get_running_tasks",
+    "wait_all_tasks_blocked",
+    "run_sync_in_worker_thread",
+    "run_async_from_thread",
+    "run_sync_from_thread",
+    "current_default_worker_thread_limiter",
+    "create_blocking_portal",
+    "start_blocking_portal",
+    "typed_attribute",
+    "TypedAttributeSet",
+    "TypedAttributeProvider",
+)
+
+from typing import Any
+
+from ._core._compat import maybe_async, maybe_async_cm
+from ._core._eventloop import (
+    current_time,
+    get_all_backends,
+    get_cancelled_exc_class,
+    run,
+    sleep,
+    sleep_forever,
+    sleep_until,
+)
+from ._core._exceptions import (
+    BrokenResourceError,
+    BrokenWorkerProcess,
+    BusyResourceError,
+    ClosedResourceError,
+    DelimiterNotFound,
+    EndOfStream,
+    ExceptionGroup,
+    IncompleteRead,
+    TypedAttributeLookupError,
+    WouldBlock,
+)
+from ._core._fileio import AsyncFile, Path, open_file, wrap_file
+from ._core._resources import aclose_forcefully
+from ._core._signals import open_signal_receiver
+from ._core._sockets import (
+    connect_tcp,
+    connect_unix,
+    create_connected_udp_socket,
+    create_tcp_listener,
+    create_udp_socket,
+    create_unix_listener,
+    getaddrinfo,
+    getnameinfo,
+    wait_socket_readable,
+    wait_socket_writable,
+)
+from ._core._streams import create_memory_object_stream
+from ._core._subprocesses import open_process, run_process
+from ._core._synchronization import (
+    CapacityLimiter,
+    CapacityLimiterStatistics,
+    Condition,
+    ConditionStatistics,
+    Event,
+    EventStatistics,
+    Lock,
+    LockStatistics,
+    Semaphore,
+    SemaphoreStatistics,
+    create_capacity_limiter,
+    create_condition,
+    create_event,
+    create_lock,
+    create_semaphore,
+)
+from ._core._tasks import (
+    TASK_STATUS_IGNORED,
+    CancelScope,
+    create_task_group,
+    current_effective_deadline,
+    fail_after,
+    move_on_after,
+    open_cancel_scope,
+)
+from ._core._testing import (
+    TaskInfo,
+    get_current_task,
+    get_running_tasks,
+    wait_all_tasks_blocked,
+)
+from ._core._typedattr import TypedAttributeProvider, TypedAttributeSet, typed_attribute
+
+# Re-exported here, for backwards compatibility
+# isort: off
+from .to_thread import current_default_worker_thread_limiter, run_sync_in_worker_thread
+from .from_thread import (
+    create_blocking_portal,
+    run_async_from_thread,
+    run_sync_from_thread,
+    start_blocking_portal,
+)
+
+# Re-export imports so they look like they live directly in this package
+key: str
+value: Any
+for key, value in list(locals().items()):
+    if getattr(value, "__module__", "").startswith("anyio."):
+        value.__module__ = __name__