File: //usr/local/CyberCP/lib64/python3.10/site-packages/websocket/__pycache__/_socket.cpython-310.pyc
o
�hN � @ s� d dl Z d dlZd dlZd dlmZ ddlmZmZ ddlm Z m
Z
m Z ddl m
Z
mZ ejejdfgZeed�rDe�ejejdf� eed�rSe�ejejd f� eed
�rbe�ejejd f� eed �rqe�ejejd
f� dag d�ZG dd� d�Zdee e df ddfdd�Z dee e df fdd�Z dejde de fdd�Z!dejde fdd �Z"dejd ee e#f de fd d �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" e Zd Zdededdfdd�ZdS )r �sockopt�sslopt�returnNc C s. |d u rg }|d u r i }|| _ || _d | _d S �N)r r �timeout)�selfr r � r �D/usr/local/CyberCP/lib/python3.10/site-packages/websocket/_socket.py�__init__8 s
zsock_opt.__init__)�__name__�
__module__� __qualname__�list�dictr! r r r r r 7 s r r r c C s | a dS )z�
Set the global timeout setting to connect.
Parameters
----------
timeout: int or float
default socket timeout time (in seconds)
N��_default_timeout)r r r r r B s
r c C s t S )z�
Get default timeout
Returns
----------
_default_timeout: int or float
Return the global timeout setting (in seconds) to connect.
r' r r r r r O s r �sock�bufsizec
s� �st d��� �fdd�}z��� dkr��� �}n|� }W n< ty) td�� tjy= } zt|�}t|��d }~w tyZ } zt|�}t |t
�rUd|v rUt|��� d }~ww |sat d��|S )N�socket is already closed.c
s� z�� � �W S ty Y n tjy. } zt| �}|tjtjfvr$� W Y d } ~ nd } ~ ww t� � }|�
�tj � |� ��
� �}|�� |rL�� � �S d S r )r r �socket�errorr �errno�EAGAIN� EWOULDBLOCK� selectors�DefaultSelector�register�
EVENT_READ�select�
gettimeout�close)�exc�
error_code�sel�r�r* r) r r �_recv_ s$ ���
�zrecv.<locals>._recvr zConnection timed out� timed outz#Connection to remote host was lost.) r r6 r � TimeoutErrorr r, r r
r �
isinstance�str)r) r* r= �bytes_�e�messager r< r r [ s0 � ���r c C s0 g } t | d�}|�|� |dkrnqd�|�S )NTr �
� )r �append�join)r) �line�cr r r r � s
�
r �datac
s� t � t�r
� �d�� �std��� �fdd�}z��� dkr$��� �W S |� W S tjy< } zt|�}t |��d }~w t
yY } zt|�}t |t�rTd|v rTt |��� d }~ww )Nzutf-8r+ c
s� z�� � �W S ty Y n% tjy3 } zt| �}|d u r � |tjtjfvr)� W Y d } ~ nd } ~ ww t� � }|�
�tj � |� ��
� �}|�� |rQ�� � �S d S r )r r r, r- r r. r/ r0 r1 r2 r3 � EVENT_WRITEr5 r6 r7 )r8 r9 r: �w�rK r) r r �_send� s( ���
�zsend.<locals>._sendr r> ) r@ rA �encoder r6 r r, r r
r � Exception)r) rK rO rC rD r rN r r � s(
���r )%r. r1 r, �typingr � _exceptionsr r � _ssl_compatr r r �_utilsr r
�SOL_TCP� TCP_NODELAYr �hasattrrG �
SOL_SOCKETr r r r r( �__all__r �int�floatr r �bytesr r rA r r r r r �<module> s2
.$