Operation   : Linux premium131.web-hosting.com 4.18.0-553.44.1.lve.el8.x86_64 #1 SMP Thu Mar 13 14:29:12 UTC 2025 x86_64
Software     : Apache
Server IP    : 162.0.232.56 | Your IP: 216.73.216.111
Domains      : 1034 Domain(s)
Permission   : [ 0755 ]

a

XC?hPL�@s�
dd
lm
Z
mZ
ddlmZ
ddlmZ
ddlZddlZddl	Z	dZ
dZdd�Zed	gd
�
�Z
de
_e	jdkr�d
e
j_de
j_de
j_de
j_Gdd�de�ZGdd�de
d�ZGdd�de�ZGdd�de�ZGdd�de�Zeed�r�Gdd�de�Zeed��
rGd d!�d!e�Zeed"��
r2Gd#d$�d$e�Zeed%��
rNGd&d'�d'e�Zd(d)�Zed%�
�
rfeZn4ed�
�
rveZn$ed"�
�
r�eZned�
�
r�eZneZdS)*�)�ABCMeta�abstractmethod)
�
namedtuple)
�MappingN�
�c

Csdt|t
�r|}
n:zt
|���
}
Wn(tttfyH


td
�|�
�
d�Yn0|
dkr`td�|
�
�
�
|
S)NzInvalid file object: {!r}r
zInvalid file descriptor: {})�
isinstance�int�fileno�AttributeError�	TypeError�
ValueError�format)�fileobj�fd�r�./opt/alt/python39/lib64/python3.9/selectors.py�_fileobj_to_fds





�
�

r�SelectorKey)rr�events�dataz�SelectorKey(fileobj, fd, events, data)

    Object used to associate a file object to its backing
    file descriptor, selected event mask, and attached data.
)��zFile object registered.zUnderlying file descriptor.z3Events that must be waited for on this file object.zzOptional opaque data associated to this file object.
    For example, this could be used to store a per-client session ID.c@s,eZ
dZd
d�Zdd�Zdd�Zdd�Zd	S)
�_SelectorMappingcCs
|
|_dS�
N)
�	_selector)�self�selectorrrr�__init__@s
z_SelectorMapping.__init__c

Cst|j
j�
Sr)�lenr�
_fd_to_key�
rrrr�__len__Cs
z_SelectorMapping.__len__cCsBz|j�
|
�
}|jj|WSty<


td
�|
�
�
d�Yn0dS�N�{!r} is not registered)r�_fileobj_lookupr �KeyErrorr)rrrrrr�__getitem__Fs





z_SelectorMapping.__getitem__c

Cst|j
j�
Sr)�iterrr r!rrr�__iter__Ms
z_SelectorMapping.__iter__N)�__name__�
__module__�__qualname__rr"r'r)rrrrr=src@sjeZ
dZeddd�
�
Zedd��
Zddd�
Zeddd	�
�
Zd
d�Zdd
�Z	edd��
Z
dd�Zdd�Zd
S)�BaseSelectorNc
Cst�
dSr�
�NotImplementedError�rrrrrrr�register`szBaseSelector.registerc
Cst�
dSrr.)rrrrr�
unregisterwszBaseSelector.unregistercCs|�|
�

|�
|
||�Sr)r2r1r0rrr�modify�s

zBaseSelector.modifyc
Cst�
dSrr.)r�timeoutrrr�select�szBaseSelector.selectc


CsdSrrr!rrr�close�szBaseSelector.closecCsJ|��}|durt
d
�
�
z
||
WStyD


td�|
�
�
d�Yn0dS)NzSelector is closedr$)�get_map�RuntimeErrorr&r)rr�mappingrrr�get_key�s






zBaseSelector.get_keyc


Cst�
dSrr.r!rrrr7�szBaseSelector.get_mapc


Cs|Srrr!rrr�	__enter__�s
zBaseSelector.__enter__c
Gs|��
dSr)
r6)r�argsrrr�__exit__�s
zBaseSelector.__exit__)
N)
N)
N)
r*r+r,rr1r2r3r5r6r:r7r;r=rrrrr-Qs






r-)
�	metaclassc@sPeZ
dZd
d�Zdd�Zddd�
Zdd	�Zdd
d�
Zdd
�Zdd�Z	dd�Z
dS)�_BaseSelectorImplc

Csi|_t
|�
|_dSr)r r�_mapr!rrrr�sz_BaseSelectorImpl.__init__cCsLz
t|
�
WSt
yF


|j��D]}|j|
ur"|j
YSq"�Yn0dSr)rr
r �valuesrr�rr�keyrrrr%�s	





z!_BaseSelectorImpl._fileobj_lookupNcCsb|r|tt
B@r td
�|�
�
�
t|
|�|
�
||�}|j|jvrRtd�|
|j��
�
||j|j<|S)NzInvalid events: {!r}z"{!r} (FD {}) is already registered)	�
EVENT_READ�EVENT_WRITEr
rrr%rr r&�rrrrrCrrrr1�s



�
z_BaseSelectorImpl.registercCs>z|j�
|�|
�
�
}Wn"ty8


td
�|
�
�
d�Yn0|Sr#)r �popr%r&rrBrrrr2�s





z_BaseSelectorImpl.unregistercCs�z|j|�
|
�
}Wn"ty6


td
�|
�
�
d�Yn0||jkr\|�|
�

|�|
||�}n"||jkr~|j|d�
}||j|j	<|S)Nr$)
r)
r r%r&rrr2r1r�_replacerrFrrrr3�s












z_BaseSelectorImpl.modifyc

Cs|j�
�
d|_dSr)r �clearr@r!rrrr6

s


z_BaseSelectorImpl.closec


Cs|jSr)
r@r!rrrr7
s
z_BaseSelectorImpl.get_mapcCs&z|j|
WSt
y 


YdS0dSr)r r&)rrrrr�_key_from_fd
s	


z_BaseSelectorImpl._key_from_fd)
N)
N)r*r+r,rr%r1r2r3r6r7rJrrrrr?�s


r?cs\eZ
dZ�f
d
d�Zd
�f
dd�	Z�f
dd�ZejdkrDdd	d
�
Zne	j	Zddd�
Z	�Z
S)�SelectSelectorc

st��
�
t�|_t�|_dSr)�superr�set�_readers�_writersr!�
�	__class__rrr&
s



zSelectSelector.__init__Ncs@t��
|
||�}|t@r&|j�|j�

|t@r<|j�|j�

|Sr)rLr1rDrN�addrrErOrFrPrrr1+
s





zSelectSelector.registercs,t��
|
�
}|j�|j�

|j�|j�

|Sr)rLr2rN�discardrrOrBrPrrr23
s



zSelectSelector.unregisterZwin32cCs$t�|
|||�\}
}}|
||gfSr)
r5)r�
r�
w�
_r4�
xrrr�_select:
s

zSelectSelector._selectc	Cs�|
durdnt|
d
�}
g}z|�
|j|jg|
�\}}}WntyN


|YS0t|�
}t|�
}||BD]J}d
}||vr�|tO}||vr�|tO}|�|�
}|rh|�	|||j
@f�

qh|S�Nr
)�maxrXrNrO�InterruptedErrorrMrDrErJ�appendr)	rr4�readyrTrUrVrrrCrrrr5@
s$


















zSelectSelector.select)
N)
N)
N)r*r+r,rr1r2�sys�platformrXr5�
__classcell__rrrPrrK#
s

rKcsZeZ
dZd
Zd
Zd
Z�f
dd�Zd�f
dd�	Z�f
dd�Zd
�f
dd	�	Z	dd
d�
Z
�ZS)�_PollLikeSelectorNc

st��
�
|��|_dSr)rLr�
_selector_clsrr!rPrrr\
s


z_PollLikeSelector.__init__cslt��
|
||�}d
}|t@r&||jO}|t@r8||jO}z|j�
|j|�
Wn


t��|
�

�Yn0|SrY)	rLr1rD�_EVENT_READrE�_EVENT_WRITErrr2)rrrrrCZ
poller_eventsrPrrr1`
s













z_PollLikeSelector.registercs6t��
|
�
}z|j�
|j�

Wnty0


Yn0|Sr)rLr2rr�OSErrorrBrPrrr2n
s




z_PollLikeSelector.unregistercs�z|j|�
|
�
}Wn"ty6


t|
�d
��
d�Yn0d}||jkr�d}|t@r\||jO}|t@rn||jO}z|j�	|j
|�
Wn


t��|
�

�Yn0d}||j
kr�d}|r�|j||d�}||j|j
<|S)Nz is not registeredFr
T)rr)r r%r&rrDrcrErdrr3rrLr2rrH)rrrrrCZchangedZselector_eventsrPrrr3x
s.
























z_PollLikeSelector.modifycCs�|
durd}
n|
d
k
rd
}
nt�
|
d�
}
g}z|j�|
�
}WntyT


|YS0|D]V\}}d
}||j@rz|tO}||j@r�|tO}|�	|�
}|rZ|�
|||j@f�

qZ|S)Nr
�@�@)�math�ceilr�pollr[rcrErdrDrJr\r)rr4r]�
fd_event_listr�eventrrCrrrr5�
s(


















z_PollLikeSelector.select)
N)
N)
N)r*r+r,rbrcrdrr1r2r3r5r`rrrPrraV
s


raric
@seZ
dZejZejZejZ	d
S)�PollSelectorN)
r*r+r,r5rirb�POLLINrc�POLLOUTrdrrrrrl�
s

rl�epollcs@eZ
dZejZejZejZ	d
d�Z
ddd�
Z�f
dd�Z�ZS)	�
EpollSelectorc

Cs
|j�
�Sr�rr
r!rrrr
�
s
zEpollSelector.filenoNc	Cs�|
durd
}
n |
dk
rd}
nt�
|
d�
d}
tt|j�
d�}g}z|j�|
|�}Wntyj


|YS0|D]V\}}d}|tj	@r�|t
O}|tj@r�|tO}|�
|�
}|rp|�|||j@f�

qp|S)N���r
rfg����MbP?r)rgrhrZrr rrir[r5�EPOLLINrE�EPOLLOUTrDrJr\r)	rr4�max_evr]rjrrkrrCrrrr5�
s*


















zEpollSelector.selectc

s|j�
�
t��
�
dSr�rr6rLr!rPrrr6�
s


zEpollSelector.close)
N)
r*r+r,r5rorbrsrcrtrdr
r6r`rrrPrrp�
s


 rp�devpollcs6eZ
dZejZejZejZ	d
d�Z
�f
dd�Z�ZS)�DevpollSelectorc

Cs
|j�
�Srrqr!rrrr
�
s
zDevpollSelector.filenoc

s|j�
�
t��
�
dSrrvr!rPrrr6�
s


zDevpollSelector.close)
r*r+r,r5rwrbrmrcrnrdr
r6r`rrrPrrx�
s


rx�kqueuecsTeZ
dZ�f
d
d�Zdd�Zd�f
dd�	Z�f
dd	�Zdd
d�
Z�f
dd
�Z�Z	S)�KqueueSelectorc

st��
�
t��|_dSr)rLrr5ryrr!rPrrr�
s


zKqueueSelector.__init__c

Cs
|j�
�Srrqr!rrrr
s
zKqueueSelector.filenoNcs�t��
|
||�}z`|t@r@t�|jtjtj�}|j�	|g
d
d
�
|t
@rnt�|jtjtj�}|j�	|g
d
d
�
Wn


t��|
�

�Yn0|SrY)
rLr1rDr5�keventr�KQ_FILTER_READZ	KQ_EV_ADDr�controlrE�KQ_FILTER_WRITEr2)rrrrrC�kevrPrrr1s 




�


�



zKqueueSelector.registercs�t��
|
�
}|jt@rTt�|jtjtj�}z|j	�
|g
d
d
�
WntyR


Yn0|jt@r�t�|jtj
tj�}z|j	�
|g
d
d
�
Wnty�


Yn0|SrY)rLr2rrDr5r{rr|ZKQ_EV_DELETErr}rerEr~)rrrCrrPrrr2s$




�





�


zKqueueSelector.unregisterc
Cs�|
durdnt|
d
�}
tt
|j�
d�}g}z|j�d||
�}WntyT


|YS0|D]Z}|j}|j}d
}|tj	kr�|t
O}|tjkr�|tO}|�
|�
}	|	rZ|�|	||	j@f�

qZ|S)Nr
r)rZrr rr}r[Zident�filterr5r|rDr~rErJr\r)
rr4rur]Zkev_listrr�flagrrCrrrr5*s&




















zKqueueSelector.selectc

s|j�
�
t��
�
dSrrvr!rPrrr6Cs


zKqueueSelector.close)
N)
N)
r*r+r,rr
r1r2r5r6r`rrrPrrz�
s
rzc
CsZtt
|d�}
|
durd
Sz(|
�}|dkr4|�d�

n|��
WdStyT


Yd
S0dS)NFrir
T)�getattrr5rir6re)�methodrZselector_objrrr�_can_useHs





r�) �abcrr�collectionsr�collections.abcrrgr5r^rDrErr�__doc__�version_inforrrrrr-r?rKra�hasattrrlrprxrzr�ZDefaultSelectorrrrr�<module>sL










~T3Z
.M