| Server IP : 192.250.235.158 / Your IP : 216.73.216.143 Web Server : LiteSpeed System : Linux s4099.sgp1.stableserver.net 5.14.0-503.21.1.el9_5.x86_64 #1 SMP PREEMPT_DYNAMIC Sun Jan 12 09:45:05 EST 2025 x86_64 User : vmxfzbqj ( 1905) PHP Version : 8.3.31 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : OFF | Sudo : OFF | Pkexec : OFF Directory : /lib/python3.9/site-packages/supervisor/__pycache__/ |
Upload File : |
a
0�g/ � @ s~ d dl Z d dlZG dd� d�ZG dd� de�ZG dd� de�ZG dd � d e�Zd
d � Zd d
� Ze� rjeZne� rveZneZdS )� Nc @ s\ e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zd d � Zd
d� Z dd� Z
dd� Z dd� Z dS )�
BasePollerc C s || _ | �� d S �N)�options�
initialize)�selfr � r �5/usr/lib/python3.9/site-packages/supervisor/poller.py�__init__ s zBasePoller.__init__c C s d S r r �r r r r r
s zBasePoller.initializec C s t �d S r ��NotImplementedError�r �fdr r r �register_readable
s z BasePoller.register_readablec C s t �d S r r r
r r r �register_writable s z BasePoller.register_writablec C s t �d S r r r
r r r �unregister_readable s z BasePoller.unregister_readablec C s t �d S r r r
r r r �unregister_writable s z BasePoller.unregister_writablec C s t �d S r r )r �timeoutr r r �poll s zBasePoller.pollc C s d S r r r
r r r �before_daemonize s zBasePoller.before_daemonizec C s d S r r r
r r r �after_daemonize s zBasePoller.after_daemonizec C s d S r r r
r r r �close" s zBasePoller.closeN)
�__name__�
__module__� __qualname__r r r r r r r r r r r r r r r s r c @ sL e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zd d � Zd
d� Z dd� Z
dS )� SelectPollerc C s t | _| �� d S r )�select�_select� _init_fdsetsr
r r r r ( s zSelectPoller.initializec C s | j �|� d S r )� readables�addr
r r r r , s z SelectPoller.register_readablec C s | j �|� d S r )� writablesr r
r r r r / s z SelectPoller.register_writablec C s | j �|� d S r )r �discardr
r r r r 2 s z SelectPoller.unregister_readablec C s | j �|� d S r )r! r" r
r r r r 5 s z SelectPoller.unregister_writablec C s | � � d S r )r r
r r r �unregister_all8 s zSelectPoller.unregister_allc
C s� z | j �| j| jg |�\}}}W n� tjy� } zz|jd tjkrd| jj �
d� g g fW Y d }~S |jd tj kr�| jj �
d� | � � g g fW Y d }~S � W Y d }~n
d }~0 0 ||fS )Nr �EINTR encountered in pollzEBADF encountered in poll)
r r r r! �error�args�errno�EINTRr �logger�blather�EBADFr# )r r �r�w�x�errr r r r ; s �zSelectPoller.pollc C s t � | _t � | _d S r )�setr r! r
r r r r M s zSelectPoller._init_fdsetsN) r r r r r r r r r# r r r r r r r & s r c @ sL e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zd d � Zd
d� Z dd� Z
dS )�
PollPollerc C s: t �� | _t jt jB t jB | _t j| _t � | _
t � | _ d S r ) r r �_pollerZPOLLINZPOLLPRIZPOLLHUP�READZPOLLOUT�WRITEr0 r r! r
r r r r S s
zPollPoller.initializec C s | j �|| j� | j�|� d S r )r2 �registerr3 r r r
r r r r Z s z PollPoller.register_readablec C s | j �|| j� | j�|� d S r )r2 r5 r4 r! r r
r r r r ^ s z PollPoller.register_writablec C s6 | j �|� | j�|� || jv r2| j�|| j� d S r )r r" r2 �
unregisterr! r5 r4 r
r r r r b s
z PollPoller.unregister_readablec C s6 | j �|� | j�|� || jv r2| j�|| j� d S r )r! r" r2 r6 r r5 r3 r
r r r r h s
z PollPoller.unregister_writablec C s` | � |�}g g }}|D ]>\}}| �||�r.q|| j@ rB|�|� || j@ r|�|� q||fS r )� _poll_fds�_ignore_invalidr3 �appendr4 )r r Zfdsr r! r � eventmaskr r r r n s
zPollPoller.pollc
C sn z| j �|d �W S tjyh } z<|jd tjkrR| jj� d� g W Y d }~S � W Y d }~n
d }~0 0 d S )N�� r r$ )
r2 r r r% r& r' r( r r) r* )r r r/ r r r r7 z s zPollPoller._poll_fdsc C s6 |t j@ r2| j�|� | j�|� | j�|� dS dS )NTF)r ZPOLLNVALr2 r6 r r" r! )r r r: r r r r8 � s
zPollPoller._ignore_invalidN) r r r r r r r r r r7 r8 r r r r r1 Q s r1 c @ sd e Zd ZdZdZdd� Zdd� Zdd� Zd d
� Zd d � Z d
d� Z
dd� Z dd� Z dd� Z
dd� ZdS )� KQueuePollerz.
Wrapper for select.kqueue()/kevent()
r; c C s t �� | _t� | _t� | _d S r )r �kqueue�_kqueuer0 r r! r
r r r r � s
zKQueuePoller.initializec C s0 | j �|� tj|tjtjd�}| �||� d S �N)�filter�flags)r r r �kevent�KQ_FILTER_READ� KQ_EV_ADD�_kqueue_control�r r rB r r r r � s
�z KQueuePoller.register_readablec C s0 | j �|� tj|tjtjd�}| �||� d S r? )r! r r rB �KQ_FILTER_WRITErD rE rF r r r r � s
�z KQueuePoller.register_writablec C s0 t j|t jt jd�}| j�|� | �||� d S r? )r rB rC � KQ_EV_DELETEr r" rE rF r r r r � s
� z KQueuePoller.unregister_readablec C s0 t j|t jt jd�}| j�|� | �||� d S r? )r rB rG rH r! r" rE rF r r r r � s
� z KQueuePoller.unregister_writablec
C s` z| j �|gd� W nF tyZ } z.|jtjkrD| jj�d| � n� W Y d }~n
d }~0 0 d S )Nr z7EBADF encountered in kqueue. Invalid file descriptor %s)r> �control�OSErrorr' r+ r r) r* )r r rB r% r r r rE � s
�z KQueuePoller._kqueue_controlc
C s� g g }}z| j �d | j|�}W nT tyt } z<|jtjkr^| jj�d� ||fW Y d }~S � W Y d }~n
d }~0 0 |D ]4}|j t
j kr�|� |j
� |j t
jkrz|� |j
� qz||fS )Nr$ )r> rI �
max_eventsrJ r' r( r r) r* r@ r rC r9 �identrG )r r r r! Zkeventsr% rB r r r r � s
zKQueuePoller.pollc C s | � � d S r )r r
r r r r � s z KQueuePoller.before_daemonizec C s: t �� | _| jD ]}| �|� q| jD ]}| �|� q&d S r )r r= r> r r r! r r
r r r r � s
z KQueuePoller.after_daemonizec C s | j �� d | _ d S r )r> r r
r r r r � s
zKQueuePoller.closeN)r r r �__doc__rK r r r r r rE r r r r r r r r r< � s
r< c C s
t td�S )Nr ��hasattrr r r r r �implements_poll� s rP c C s
t td�S )Nr= rN r r r r �implements_kqueue� s rQ ) r r' r r r1 r< rP rQ ZPollerr r r r �<module> s "+>O