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 : /opt/alt/python37/lib64/python3.7/__pycache__/ |
B
^����dO� @ sl d dl Z d dl T d dlZd dlZd dlZd dlZd dlmZmZ y d dlZW n e k
rd dZY nX e
edd�Z e
edd�Z e
edd�Z
d d
d d d
gZe�e�e �� e�d edd� � e�d
edd� � e�dedd� � e�dedd� � dZdZdd� ZeZej�� �d��r�i Zded< d ed < d ed < d ed!< d"ed#< d$ed%< d&ed'< d(ed)< d*ed+< d,ed-< d.ed/< d0ed1< d2ed3< d4ed5< d6ed7< e� d8� G d9d:� d:e �Z G d;d<� d<e j�ZdLd=d �Z e e jd>��r�d?d@� Z!e� d@� e e dA��rde"d fdBdA�Z#ne$e"d fdCdA�Z#e� dA� dDe#_%e e
hZ&G dEdF� dFej'�Z(dMdHd
�Z)e*� Z+e+dfdId �Z,dNdJdK�Z-dS )O� N)�*)�IntEnum�IntFlag�EBADF� �EAGAIN� � EWOULDBLOCK�fromfd�getfqdn�create_connection�
AddressFamily�
SocketKindc C s | � � o| �d�S )NZAF_)�isupper�
startswith)�C� r �+/opt/alt/python37/lib64/python3.7/socket.py�<lambda>L � r c C s | � � o| �d�S )NZSOCK_)r r )r r r r r Q r ZMsgFlagc C s | � � o| �d�S )NZMSG_)r r )r r r r r V r Z AddressInfoc C s | � � o| �d�S )NZAI_)r r )r r r r r [ r z 127.0.0.1z::1c C s" y|| �S t k
r | S X d S )N)�
ValueError)�valueZ
enum_klassr r r �_intenum_convertera s r �winz The operation was interrupted.i' z A bad file handle was passed.i' zPermission denied.i ' z!A fault occurred on the network??i ' z#An invalid operation was attempted.i&' z The socket operation would blocki3' z,A blocking operation is already in progress.i4' z The network address is in use.i@' z The connection has been reset.iF' z The network has been shut down.iJ' zThe operation timed out.iL' zConnection refused.iM' zThe name is too long.iO' zThe host is down.iP' zThe host is unreachable.iQ' �errorTabc @ s e Zd ZdS )�_GiveupOnSendfileN)�__name__�
__module__� __qualname__r r r r r � s r c s( e Zd ZdddgZd8dd�Zdd � Zd
d � Zd d
� Zdd� Zdd� Z dd� Z
d9dddd�dd�Z e e
d�rvd:dd�Zn
d;d d�Zd<d d �Zd d � Zd=d!d"�Zd#d$� Zejfd%d&�Zd'd(� Z� fd)d*�Ze� fd+d,��Ze� fd-d.��Ze
jd/k�rd0d1� Z d2d3� Z nd4d1� Z d5d3� Z d6e _ d7e _ � Z S )>�socket� __weakref__�_io_refs�_closed���Nc C sP |d kr,|dkrt }|dkr t}|dkr,d}tj�| ||||� d| _d| _d S )Nr# r F)�AF_INET� SOCK_STREAM�_socketr �__init__r! r" )�self�family�type�proto�filenor r r r' � s zsocket.__init__c C s | S )Nr )r( r r r � __enter__� s zsocket.__enter__c G s | j s| �� d S )N)r" �close)r( �argsr r r �__exit__� s zsocket.__exit__c C s� t | dd�}d| jj| jj|r"dnd| �� | j| j| jf }|s�y | �� }|r^|dt |� 7 }W n t
k
rt Y nX y | � � }|r�|dt |� 7 }W n t
k
r� Y nX |d7 }|S ) Nr" Fz,<%s.%s%s fd=%i, family=%s, type=%s, proto=%iz [closed]� z
, laddr=%sz
, raddr=%s�>) �getattr� __class__r r r, r) r* r+ � getsockname�str�errorZ getpeername)r( �closed�sZladdrZraddrr r r �__repr__� s0
zsocket.__repr__c C s t d��d S )Nz Cannot serialize socket object)� TypeError)r( r r r � __getstate__� s zsocket.__getstate__c C s6 t | �� �}| j| j| j| j|d�}|�| �� � |S )N)r, )�dupr, r4 r) r* r+ �
settimeout�
gettimeout)r( �fd�sockr r r r= � s z
socket.dupc C sF | � � \}}t| j| j| j|d�}t� d kr>| �� r>|�d� ||fS )N)r, T)Z_acceptr r) r* r+ Zgetdefaulttimeoutr? � setblocking)r( r@ �addrrA r r r �accept� s
z
socket.accept�r)�encoding�errors�newlinec
C s� t |�dddhks td|f ��d|k}d|kp4| }d|k}d} |rN| d7 } |rZ| d7 } t| | �}
| jd7 _|d kr~d}|dk r�tj}|dkr�|s�td ��|
S |r�|r�t�|
|
|�} n |r�t�|
|�} n t�|
|�} |r�| S t� | |||�} || _
| S )
NrE �w�bz&invalid mode %r (only r, w, b allowed)r1 � r# r z!unbuffered streams must be binary) �setr �SocketIOr! �io�DEFAULT_BUFFER_SIZE�BufferedRWPair�BufferedReader�BufferedWriter�
TextIOWrapper�mode)
r( rT � bufferingrF rG rH ZwritingZreadingZbinaryZrawmode�raw�buffer�textr r r �makefile� s<
zsocket.makefile�sendfiler c
C s� | � |||� | �� }y |�� }W n0 ttjfk
rR } z t|��W d d }~X Y nX yt�|�j}W n* t k
r� } z t|��W d d }~X Y nX |s�dS |s�|n|}| �
� } | dkr�t d��t t
d�r�t
�� }
nt
�� }
|
�|t
j� d} |
j} tj}
z�x�| �r| | ��st�d��|�r.|| }|dk�r.P y|
||||�}W n^ tk
�rd | �s^| � w�Y q� t k
�r� } z | dk�r�t|��|d �W d d }~X Y q�X |dk�r�P ||7 }| |7 } q�W | S | dk�r�t |d��r�|�|� X d S )Nr z&non-blocking sockets are not supported� PollSelectorz timed out�seek)�_check_sendfile_paramsr, �AttributeErrorrN �UnsupportedOperationr �os�fstat�st_size�OSErrorr? r �hasattr� selectorsr[ ZSelectSelector�registerZ EVENT_WRITEZselectrZ r& �timeout�BlockingIOErrorr\ )r( �file�offset�countZsocknor, �errZfsize� blocksizerg Zselector�
total_sentZselector_selectZ os_sendfile�sentr r r �_sendfile_use_sendfile s`
z socket._sendfile_use_sendfilec C s t d��d S )Nz,os.sendfile() not available on this platform)r )r( ri rj rk r r r rp J s c
C s | � |||� | �� dkr"td��|r0|�|� |r>t|d�nd}d}|j}| j}z�x�|rrt|| |�}|dkrrP t||��}|s�P xLy ||�} W n tk
r� w�Y q�X || 7 }| t |�k r�|| d � }q�P q�W qVW |S |dkr�t
|d�r�|�|| � X d S )Nr z&non-blocking sockets are not supportedi r\ ) r] r? r r\ �min�read�send�
memoryviewrh �lenrd )
r( ri rj rk rm rn Z file_readZ sock_send�dataro r r r �_sendfile_use_sendN s<
zsocket._sendfile_use_sendc C sd dt |dd�krtd��| jt@ s*td��|d k r`t|t�sJtd�|���|dkr`td�|���d S )NrJ rT z$file should be opened in binary modez+only SOCK_STREAM type sockets are supportedz+count must be a positive integer (got {!r})r )r3 r r* r% �
isinstance�intr; �format)r( ri rj rk r r r r] r s
z socket._check_sendfile_paramsc C s2 y| � |||�S tk
r, | �|||�S X d S )N)rp r rw )r( ri rj rk r r r rZ s zsocket.sendfilec C s* | j dkr| j d8 _ | jr&| �� d S )Nr rK )r! r" r. )r( r r r �_decref_socketios� s
zsocket._decref_socketiosc C s |� | � d S )N)r. )r( Z_ssr r r � _real_close� s zsocket._real_closec C s d| _ | jdkr| �� d S )NTr )r" r! r| )r( r r r r. � s
z socket.closec s d| _ t� �� S )NT)r" �super�detach)r( )r4 r r r~ � s z
socket.detachc s t t� jt�S )N)r r} r) r
)r( )r4 r r r) � s z
socket.familyc s t t� jt�S )N)r r} r* r )r( )r4 r r r* � s z socket.type�ntc C s t �| �� �S )N)r` Zget_handle_inheritabler, )r( r r r �get_inheritable� s zsocket.get_inheritablec C s t �| �� |� d S )N)r` Zset_handle_inheritabler, )r( � inheritabler r r �set_inheritable� s zsocket.set_inheritablec C s t �| �� �S )N)r` r� r, )r( r r r r� � s c C s t �| �� |� d S )N)r` r� r, )r( r� r r r r� � s z&Get the inheritable flag of the socketz&Set the inheritable flag of the socket)r# r# r# N)rE N)r N)r N)r N)r N) r r r � __slots__r' r- r0 r: r< r= rD rY rd r` rp rw r] rZ r{ r& r r| r. r~ �propertyr) r* �namer� r� �__doc__�
__classcell__r r )r4 r r � s:
)
A
$
r c C s t | �}t||||�S )N)r= r )r@ r) r* r+ Znfdr r r r
� s Zsharec C s t ddd| �S )Nr )r )�infor r r � fromshare� s r� �
socketpairc C sh | d kr*yt } W n tk
r( t} Y nX t�| ||�\}}t| |||�� �}t| |||�� �}||fS )N)ZAF_UNIX� NameErrorr$ r& r� r r~ )r) r* r+ �arJ r r r r� � s
c
C s | t krt}n| tkr t}ntd��|tkr4td��|dkrDtd��t| ||�}z�|�|df� |�� |� � d d� \}}t| ||�}yP|�
d� y|� ||f� W n t t
fk
r� Y nX |�
d� |�� \}} W n |�� � Y nX W d |�� X ||fS )Nz?Only AF_INET and AF_INET6 socket address families are supportedz)Only SOCK_STREAM socket type is supportedr z Only protocol zero is supported� FT)r$ �
_LOCALHOSTZAF_INET6�
_LOCALHOST_V6r r% r �bindZlistenr5 rB �connectrh �InterruptedErrorrD r. )
r) r* r+ �hostZlsockrC �portZcsockZssock�_r r r r� � s8
a8 socketpair([family[, type[, proto]]]) -> (socket object, socket object)
Create a pair of socket objects from the sockets returned by the platform
socketpair() function.
The arguments are the same as for socket() except the default family is AF_UNIX
if defined on the platform; otherwise, the default is AF_INET.
c sl e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Z� fd d �Zd
d� Z e
dd� �Z e
dd� �Z dd� Z
� ZS )rM c C sZ |dkrt d| ��tj�| � || _d|kr6|d7 }|| _d|k| _d|k| _d| _d S )N)rE rI �rw�rb�wbZrwbzinvalid mode: %rrJ rE rI F) r rN � RawIOBaser' �_sock�_mode�_reading�_writing�_timeout_occurred)r( rA rT r r r r' 3 s
zSocketIO.__init__c
C s� | � � | �� | jr td��xby | j�|�S tk
rH d| _� Y q tk
r| } z|jd t krjd S � W d d }~X Y q X q W d S )Nz!cannot read from timed out objectTr )
� _checkClosed�_checkReadabler� rc r� Z recv_intorg r7 r/ �_blocking_errnos)r( rJ �er r r �readinto? s zSocketIO.readintoc
C sX | � � | �� y | j�|�S tk
rR } z|jd tkr@d S � W d d }~X Y nX d S )Nr )r� �_checkWritabler� rs r7 r/ r� )r( rJ r� r r r �writeV s zSocketIO.writec C s | j rtd��| jS )Nz I/O operation on closed socket.)r8 r r� )r( r r r �readablef s zSocketIO.readablec C s | j rtd��| jS )Nz I/O operation on closed socket.)r8 r r� )r( r r r �writablem s zSocketIO.writablec s | j rtd��t� �� S )Nz I/O operation on closed socket.)r8 r r} �seekable)r( )r4 r r r� t s zSocketIO.seekablec C s | � � | j�� S )N)r� r� r, )r( r r r r, { s zSocketIO.filenoc C s | j s| �� S dS d S )Nr# )r8 r, )r( r r r r� � s z
SocketIO.namec C s | j S )N)r� )r( r r r rT � s z
SocketIO.modec C s* | j r
d S tj�| � | j�� d | _d S )N)r8 rN r� r. r� r{ )r( r r r r. � s
zSocketIO.close)r r r r' r� r� r� r� r� r, r� r� rT r. r� r r )r4 r rM " s rM r1 c C sn | � � } | r| dkrt� } yt| �\}}}W n tk
r@ Y n*X |�d|� x|D ]} d| krTP qTW |} | S )Nz0.0.0.0r �.)�stripZ gethostnameZ
gethostbyaddrr7 �insert)r� Zhostname�aliasesZipaddrsr r r r � s
c C s� | \}}d }x�t ||dt�D ]�}|\}}} }
} d } y>t||| �} |tk rR| �|� |r`| �|� | �| � d }| S tk
r� }
z|
}| d k r�| �� W d d }
~
X Y q X q W |d k r�z|�W d d }X ntd��d S )Nr z!getaddrinfo returns an empty list) � getaddrinfor% r �_GLOBAL_DEFAULT_TIMEOUTr> r� r� r7 r. )Zaddressrg Zsource_addressr� r� rl �res�af�socktyper+ � canonname�sarA r� r r r r � s.
c C sT g }xJt �| |||||�D ]2}|\}} }}
} |�t|t�t| t�||
| f� qW |S )N)r& r� �appendr r
r ) r� r� r) r* r+ �flagsZaddrlistr� r� r� r� r� r r r r� � s r� )r )r1 )r r r r ).r& r` �sysrN re �enumr r �errno� ImportErrorr3 r r r �__all__�extend�_get_exports_list�_convertr r� r� r r Z _realsocket�platform�lowerr r r� � Exceptionr r
rd r� r% r� r$ r� r� r� rM r �objectr� r r� r r r r �<module>1 s�
F
$
u
+