File: //lib/python3/dist-packages/supervisor/__pycache__/poller.cpython-310.pyc
o
VƧ\/ � @ s� d dl Z d dlZG dd� d�ZG dd� de�ZG dd� de�ZG dd � d e�Zd
d � Zd d
� Ze� r6eZdS e� r=eZdS eZdS )� 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 �3/usr/lib/python3/dist-packages/supervisor/poller.py�__init__ � zBasePoller.__init__c C � d S r r �r r r r r
� zBasePoller.initializec C � t �r ��NotImplementedError�r �fdr r r �register_readable
r
z BasePoller.register_readablec C r r r r r r r �register_writable r
z BasePoller.register_writablec C r r r r r r r �unregister_readable r
z BasePoller.unregister_readablec C r r r r r r r �unregister_writable r
z BasePoller.unregister_writablec C r r r )r �timeoutr r r �poll r
zBasePoller.pollc C r r r r r r r �before_daemonize r
zBasePoller.before_daemonizec C r r r r r r r �after_daemonize r
zBasePoller.after_daemonizec C r r r r r r r �close" r
zBasePoller.closeN)
�__name__�
__module__� __qualname__r r r r r r r r r r r r r r r s r c @ �L 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 ( r
zSelectPoller.initializec C � | j �|� d S r )� readables�addr r r r r , � z SelectPoller.register_readablec C r$ r )� writablesr& r r r r r / r' z SelectPoller.register_writablec C r$ r )r% �discardr r r r r 2 r' z SelectPoller.unregister_readablec C r$ r )r( r) r r r r r 5 r' z SelectPoller.unregister_writablec C � | � � d S r )r# r r r r �unregister_all8 � zSelectPoller.unregister_allc
C s� z| j �| j| jg |�\}}}W ||fS tjyW } z7|jd tjkr5| jj �
d� g g fW Y d }~S |jd tj krR| jj �
d� | � � g g fW Y d }~S � d }~ww )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 @ r )�
PollPollerc C s: t �� | _t jt jB t jB | _t j| _t � | _
t � | _ d S r ) r! r �_poller�POLLIN�POLLPRI�POLLHUP�READ�POLLOUT�WRITEr9 r% r( r r r r r S s
zPollPoller.initializec C � | j �|| j� | j�|� d S r )r; �registerr? r% r& r r r r r Z � z PollPoller.register_readablec C rB r )r; rC rA r( r& r r r r r ^ rD z PollPoller.register_writablec C �: | j �|� | j�|� || jv r| j�|| j� d S d S r )r% r) r; �
unregisterr( rC rA r r r r r b �
�z PollPoller.unregister_readablec C rE r )r( r) r; rF r% rC r? r r r r r h rG z PollPoller.unregister_writablec C s` | � |�}g g }}|D ] \}}| �||�rq || j@ r!|�|� || j@ r+|�|� q ||fS r )� _poll_fds�_ignore_invalidr? �appendrA )r r �fdsr% r( r � eventmaskr r r r n s
�zPollPoller.pollc
C s^ z | j �|d �W S tjy. } z|jd tjkr)| jj� d� g W Y d }~S � d }~ww )N�� r r- )
r; r r! r. r/ r0 r1 r r2 r3 )r r r8 r r r rH z s ��zPollPoller._poll_fdsc C s6 |t j@ r| j�|� | j�|� | j�|� dS dS )NTF)r! �POLLNVALr; rF r% r) r( )r r rL r r r rI � s
zPollPoller._ignore_invalidN) r r r r r r r r r rH rI r r r r r: Q s r: 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()
rM c C s t �� | _t� | _t� | _d S r )r! �kqueue�_kqueuer9 r% r( r r r r r � s
zKQueuePoller.initializec C �0 | j �|� tj|tjtjd�}| �||� d S �N)�filter�flags)r% r& r! �kevent�KQ_FILTER_READ� KQ_EV_ADD�_kqueue_control�r r rV r r r r � �
�z KQueuePoller.register_readablec C rR rS )r( r& r! rV �KQ_FILTER_WRITErX rY rZ r r r r � r[ z KQueuePoller.register_writablec C �0 t j|t jt jd�}| j�|� | �||� d S rS )r! rV rW � KQ_EV_DELETEr% r) rY rZ r r r r � �
� z KQueuePoller.unregister_readablec C r] rS )r! rV r\ r^ r( r) rY rZ r r r r � r_ z KQueuePoller.unregister_writablec
C s` z | j �|gd� W d S ty/ } z|jtjkr#| jj�d| � n� W Y d }~d S d }~ww )Nr z7EBADF encountered in kqueue. Invalid file descriptor %s)rQ �control�OSErrorr0 r4 r r2 r3 )r r rV r. r r r rY � s
����z KQueuePoller._kqueue_controlc
C s� g g }}z | j �d | j|�}W n$ ty4 } z|jtjkr/| jj�d� ||fW Y d }~S � d }~ww |D ]}|j t
j krE|� |j
� |j t
jkrQ|� |j
� q7||fS )Nr- )rQ r` �
max_eventsra r0 r1 r r2 r3 rT r! rW rJ �identr\ )r r r% r( �keventsr. rV r r r r � s"
�� �zKQueuePoller.pollc C r* r )r r r r r r � r, z KQueuePoller.before_daemonizec C s: t �� | _| jD ]}| �|� q| jD ]}| �|� qd S r )r! rP rQ r% r r( r r r r r r � s
�z KQueuePoller.after_daemonizec C s | j �� d | _ d S r )rQ r r r r r r � s
zKQueuePoller.closeN)r r r �__doc__rb r r r r r rY r r r r r r r r rO � s
rO c C �
t td�S )Nr ��hasattrr! r r r r �implements_poll� �
ri c C rf )NrP rg r r r r �implements_kqueue� rj rk ) r! r0 r r r: rO ri rk �Pollerr r r r �<module> s "+>O