Server : LiteSpeed System : Linux barito.iixcp.rumahweb.net 5.14.0-611.49.1.el9_7.x86_64 #1 SMP PREEMPT_DYNAMIC Tue Apr 21 16:39:08 EDT 2026 x86_64 User : elvh3918 ( 1528) PHP Version : 8.2.31 Disable Function : mail Directory : /usr/local/lib/python3.9/site-packages/kombu/utils/__pycache__/ |
a
��Sht
� @ s� d Z ddlmZ ddlZddlZddlmZ ddlmZ ddl m
Z ddl m
Z
ddlmZ eee
fZzdd lmZ W n: ey� zdd lmZ W n ey� dZY n0 Y n0 dad
d � Zd d
� Zdd� Zdd� Zdd� Z dd� Z edd� �Z dS )z Python Compatibility Utilities.� )� annotationsN)�contextmanager��wraps)�metadata)�UnsupportedOperation)�reraise)�register_after_forkc s t � �� fdd��}|S )z*Decorator to mark generator as co-routine.c s � | i |��}t |� |S �N)�next)�args�kwargs�it��gen� �</usr/local/lib/python3.9/site-packages/kombu/utils/compat.py�wind_up s zcoro.<locals>.wind_upr )r r r r r �coro s r c C s� dt jv rDz&dd l} ddlm} || �r.W dS W n tyB Y n0 dt jv r�z*dd l} ddlm} | j|ju rvW dS W n ty� Y n0 dS )NZeventletr )�is_monkey_patched�gevent)�socket�default)�sys�modulesr Zeventlet.patcherr � ImportErrorr )r Z is_eventletZ_gsocketr r r �_detect_environment& s"
r c C s t du rt� a t S )z=Detect the current environment: default, eventlet, or gevent.N)� _environmentr r r r r �detect_environmentB s r c C s^ t jdkrtj| d�}n8t�� }z|�| g �}W n tyN |j| d�}Y n0 dd� |D �S )z,Return setuptools entrypoints for namespace.)� �
)�groupc s s | ]}||� � fV qd S r
)�load)�.0�epr r r � <genexpr>U s �z entrypoints.<locals>.<genexpr>)r � version_info�importlib_metadata� entry_points�get�AttributeError�select)� namespacer( r r r � entrypointsJ s
�r- c C s t | tj�r| S | �� S )z!Get fileno from file-like object.)�
isinstance�numbers�Integral�fileno��fr r r r1 [ s r1 c C s" z
t | �W S ty Y n0 dS )z3Get object fileno, or :const:`None` if not defined.N)r1 �
FILENO_ERRORSr2 r r r � maybe_filenob s
r5 c g s g }g }d}�zz�z6| D ]&}|j }|j}|�|� � |�|� q|V W n t�� }Y n0 W |r�|�� }z||� rzd}W q` t�� }Y q`0 q`|dkr�t|d |d |d � nX|r�|�� }z||� r�d}W q� t�� }Y q�0 q�|dk�r t|d |d |d � 0 W ~n~0 dS )zNest context managers.)NNNr � � N)�__exit__� __enter__�appendr �exc_info�popr )ZmanagersZexits�vars�excZmgr�exitZenterr r r �nestedj s@
�
r@ ) �__doc__�
__future__r r/ r �
contextlibr � functoolsr � importlibr r' �ior Zkombu.exceptionsr r* �
ValueErrorr4 Z
billiard.utilr r Zmultiprocessing.utilr r r r r- r1 r5 r@ r r r r �<module> s2