HEX
Server: LiteSpeed
System: Linux php-prod-1.spaceapp.ru 5.15.0-157-generic #167-Ubuntu SMP Wed Sep 17 21:35:53 UTC 2025 x86_64
User: xnsbb3110 (1041)
PHP: 8.1.33
Disabled: NONE
Upload Files
File: //usr/local/CyberCP/lib64/python3.10/site-packages/websocket/__pycache__/_socket.cpython-310.pyc
o

�hN�@s�ddlZddlZddlZddlmZddlmZmZddlm	Z	m
Z
mZddlm
Z
mZ	ejejdfgZeed�rDe�ejejdf�eed�rSe�ejejd	f�eed
�rbe�ejejdf�eed�rqe�ejejd
f�dagd�ZGdd�d�Zdeeedfddfdd�Zdeeedffdd�Zdejdede fdd�Z!dejde fdd�Z"dejdee e#fdefdd�Z$dS) �N)�Union�)�"WebSocketConnectionClosedException�WebSocketTimeoutException)�SSLError�SSLWantReadError�SSLWantWriteError)�extract_error_code�extract_err_message�SO_KEEPALIVE�TCP_KEEPIDLE��
TCP_KEEPINTVL�
�TCP_KEEPCNT�)�DEFAULT_SOCKET_OPTION�sock_opt�setdefaulttimeout�getdefaulttimeout�recv�	recv_line�sendc@s"eZdZdededdfdd�ZdS)r�sockopt�sslopt�returnNcCs.|durg}|duri}||_||_d|_dS�N)rr�timeout)�selfrr�r�D/usr/local/CyberCP/lib/python3.10/site-packages/websocket/_socket.py�__init__8s
zsock_opt.__init__)�__name__�
__module__�__qualname__�list�dictr!rrrr r7srrrcCs|adS)z�
    Set the global timeout setting to connect.

    Parameters
    ----------
    timeout: int or float
        default socket timeout time (in seconds)
    N��_default_timeout)rrrr rBs
rcCstS)z�
    Get default timeout

    Returns
    ----------
    _default_timeout: int or float
        Return the global timeout setting (in seconds) to connect.
    r'rrrr rOs	r�sock�bufsizec
s��std����fdd�}z���dkr����}n|�}Wn<ty)td��tjy=}zt|�}t|��d}~wtyZ}zt|�}t	|t
�rUd|vrUt|���d}~ww|satd��|S)N�socket is already closed.c
s�z����WStyYn tjy.}zt|�}|tjtjfvr$�WYd}~nd}~wwt�	�}|�
�tj�|���
��}|��|rL����SdSr)rr�socket�errorr	�errno�EAGAIN�EWOULDBLOCK�	selectors�DefaultSelector�register�
EVENT_READ�select�
gettimeout�close)�exc�
error_code�sel�r�r*r)rr �_recv_s$���
�zrecv.<locals>._recvrzConnection timed out�	timed outz#Connection to remote host was lost.)rr6r�TimeoutErrorrr,rr
r�
isinstance�str)r)r*r=�bytes_�e�messagerr<r r[s0����rcCs0g}	t|d�}|�|�|dkrnqd�|�S)NTr�
�)r�append�join)r)�line�crrr r�s

�
r�datac
s�t�t�r
��d���std����fdd�}z���dkr$����WS|�WStjy<}zt|�}t	|��d}~wt
yY}zt|�}t|t�rTd|vrTt	|���d}~ww)Nzutf-8r+c
s�z����WStyYn%tjy3}zt|�}|dur �|tjtjfvr)�WYd}~nd}~wwt�	�}|�
�tj�|���
��}|��|rQ����SdSr)rrr,r-r	r.r/r0r1r2r3�EVENT_WRITEr5r6r7)r8r9r:�w�rKr)rr �_send�s(���
�zsend.<locals>._sendrr>)r@rA�encoderr6rr,rr
r�	Exception)r)rKrOrCrDrrNr r�s(

���r)%r.r1r,�typingr�_exceptionsrr�_ssl_compatrrr�_utilsr	r
�SOL_TCP�TCP_NODELAYr�hasattrrG�
SOL_SOCKETrrrrr(�__all__r�int�floatrr�bytesrrrArrrrr �<module>s2




.$