o

%we��@s�dZd
dl
Z
d
dl
mZ
d
dlmZ
d
dlmZ
zd
dlZWney)


dZYn
wdd�Z	dd	�Z
d
d�Zdd
�Zdd�Z
dS)zCompatibility utilities.�N)
�NullHandler)
�promise�
�wrapscCsdtd
urd
Sztj
}Wnty


td�
�
wt�|tj�}|
r%||O}n||M}t�|tj|�S)z Set flag to close fd after exec.Nz1close-on-exec flag not supported on this platform)�fcntl�
FD_CLOEXEC�AttributeError�NotImplementedError�F_GETFD�F_SETFD)�fd�cloexecr�flags�r�C/home/arjun/projects/env/lib/python3.10/site-packages/amqp/utils.py�set_cloexecs






��




rc
st��
�f
d
d��
}
|
S)z,Decorator to mark generator as a co-routine.cs�|i|
�
�
}t|�

|S)
N)
�next)�args�kwargs�co�
�genrr�_boot#s

zcoro.<locals>._bootr)rrrrr�coro!s
rc

C�t|t
�r|�d
d�S|S)zConvert str to bytes.�utf-8�
surrogatepass)�
isinstance�str�encode�
�
srrr�str_to_bytes,�


r"c

Cr)zConvert bytes to str.rr)r�bytes�decoder rrr�bytes_to_str3r#r&c

Cs*t|t
�r
t�|�
}|js|�t��

|S)
zGet logger by name.)rr�logging�	getLogger�handlers�
addHandlerr)
�loggerrrr�
get_logger:s






r,)�__doc__r'r�viner�
vine.utilsrr�ImportErrorrrr"r&r,rrrr�<module>
s





�