o
    1Élié  ã                   @   s®   d dl Z d dlZd dlZe  e¡Zi Zzejed< W n e	y1   ej
jr/ej
jdkr/ded< Y nw zejed< ejed< ejed< W n	 e	yL   Y nw dd	„ Zd
d„ ZdS )é    NÚTCP_USER_TIMEOUT)é   é   é%   é   ÚTCP_KEEPIDLEÚTCP_KEEPCNTÚTCP_KEEPINTVLc                 C   s   d| v pd| v pd| v S )Nr   r   r	   © )Útcp_optionsr
   r
   úd/var/www/html/tatsat2dev/dashboard-backend/venv/lib/python3.10/site-packages/pika/tcp_socket_opts.pyÚsocket_requires_keepalive   s
   ÿþr   c                 C   sh   | sd S t | ƒr| tjtjd¡ |  ¡ D ]\}}t |¡}|r*| tj	j
||¡ qt d||¡ qd S )Né   zUnsupported TCP option %s:%s)r   Ú
setsockoptÚsocketÚ
SOL_SOCKETÚSO_KEEPALIVEÚitemsÚ_SUPPORTED_TCP_OPTIONSÚgetÚpikaÚcompatÚSOL_TCPÚLOGGERÚwarning)r   ÚsockÚkeyÚvalueÚoptionr
   r
   r   Úset_sock_opts#   s   
ûr   )Úloggingr   Úpika.compatr   Ú	getLoggerÚ__name__r   r   r   ÚAttributeErrorr   ÚLINUX_VERSIONr   r   r	   r   r   r
   r
   r
   r   Ú<module>   s*   
€ú

ÿ