Edit File: poller.cpython-36.pyc
3 �k�`/ � @ 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 || _ | j� d S )N)�options� initialize)�selfr � r � /usr/lib/python3.6/poller.py�__init__ s zBasePoller.__init__c C s d S )Nr )r r r r r s zBasePoller.initializec C s t �d S )N)�NotImplementedError)r �fdr r r �register_readable s z BasePoller.register_readablec C s t �d S )N)r )r r r r r �register_writable s z BasePoller.register_writablec C s t �d S )N)r )r r r r r �unregister_readable s z BasePoller.unregister_readablec C s t �d S )N)r )r r r r r �unregister_writable s z BasePoller.unregister_writablec C s t �d S )N)r )r �timeoutr r r �poll s zBasePoller.pollc C s d S )Nr )r r r r �before_daemonize s zBasePoller.before_daemonizec C s d S )Nr )r r r r �after_daemonize s zBasePoller.after_daemonizec C s d S )Nr )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 | _| j� d S )N)�select�_select� _init_fdsets)r r r r r ( s zSelectPoller.initializec C s | j j|� d S )N)� readables�add)r r r r r r , s z SelectPoller.register_readablec C s | j j|� d S )N)� writablesr )r r r r r r / s z SelectPoller.register_writablec C s | j j|� d S )N)r �discard)r r r r r r 2 s z SelectPoller.unregister_readablec C s | j j|� d S )N)r r )r r r r r r 5 s z SelectPoller.unregister_writablec C s | j � d S )N)r )r r r r �unregister_all8 s zSelectPoller.unregister_allc C s� y | j j| j| jg |�\}}}W nz tjk r� } z\|jd tjkrZ| jj j d� g g fS |jd tj kr�| jj j d� | j � g g fS � W Y d d }~X nX ||fS )Nr zEINTR 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 )N)�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 j� | _t jt jB t jB | _t j| _t � | _ t � | _ d S )N) r r �_pollerZPOLLINZPOLLPRIZPOLLHUP�READZPOLLOUT�WRITEr+ r r )r r r r r S s zPollPoller.initializec C s | j j|| j� | jj|� d S )N)r- �registerr. r r )r r r r r r Z s z PollPoller.register_readablec C s | j j|| j� | jj|� d S )N)r- r0 r/ r r )r r r r r r ^ s z PollPoller.register_writablec C s6 | j j|� | jj|� || jkr2| jj|| j� d S )N)r r r- � unregisterr r0 r/ )r r r r r r b s z PollPoller.unregister_readablec C s6 | j j|� | jj|� || jkr2| jj|| j� d S )N)r r r- r1 r r0 r. )r r r r r r h s z PollPoller.unregister_writablec C sd | j |�}g g }}xF|D ]>\}}| j||�r0q|| j@ rD|j|� || j@ r|j|� qW ||fS )N)� _poll_fds�_ignore_invalidr. �appendr/ )r r Zfdsr r r � eventmaskr r r r n s zPollPoller.pollc C s^ y| j j|d �S tjk rX } z*|jd tjkrF| jjj d� g S � W Y d d }~X nX d S )Ni� r zEINTR encountered in poll) r- r r r r! r" r# r r$ r% )r r r* r r r r2 z s zPollPoller._poll_fdsc C s6 |t j@ r2| jj|� | jj|� | jj|� dS dS )NTF)r ZPOLLNVALr- r1 r r r )r r r5 r r r r3 � s zPollPoller._ignore_invalidN) r r r r r r r r r r2 r3 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() i� c C s t j� | _t� | _t� | _d S )N)r �kqueue�_kqueuer+ r r )r r r r r � s zKQueuePoller.initializec C s0 | j j|� tj|tjtjd�}| j||� d S )N)�filter�flags)r r r �kevent�KQ_FILTER_READ� KQ_EV_ADD�_kqueue_control)r r r; r r r r � s z KQueuePoller.register_readablec C s0 | j j|� tj|tjtjd�}| j||� d S )N)r9 r: )r r r r; �KQ_FILTER_WRITEr= r> )r r r; r r r r � s z KQueuePoller.register_writablec C s0 t j|t jt jd�}| jj|� | j||� d S )N)r9 r: )r r; r< � KQ_EV_DELETEr r r> )r r r; r r r r � s z KQueuePoller.unregister_readablec C s0 t j|t jt jd�}| jj|� | j||� d S )N)r9 r: )r r; r? r@ r r r> )r r r; r r r r � s z KQueuePoller.unregister_writablec C s^ y| j j|gd� W nD tk rX } z(|jtjkrF| jjjd| � n� W Y d d }~X nX d S )Nr z7EBADF encountered in kqueue. Invalid file descriptor %s)r8 �control�OSErrorr" r& r r$ r% )r r r; r r r r r> � s z KQueuePoller._kqueue_controlc C s� g g }}y| j jd | j|�}W nF tk rf } z*|jtjkrT| jjjd� ||fS � W Y d d }~X nX x<|D ]4}|j t j kr�|j |j � |j t jkrn|j |j � qnW ||fS )NzEINTR encountered in poll)r8 rA � max_eventsrB r" r# r r$ r% r9 r r< r4 Zidentr? )r r r r Zkeventsr r; r r r r � s zKQueuePoller.pollc C s | j � d S )N)r )r r r r r � s z KQueuePoller.before_daemonizec C sB t j� | _x| jD ]}| j|� qW x| jD ]}| j|� q,W d S )N)r r7 r8 r r r r )r r r r r r � s z KQueuePoller.after_daemonizec C s | j j� d | _ d S )N)r8 r )r r r r r � s zKQueuePoller.closeN)r r r �__doc__rC r r r r r r> r r r r r r r r r6 � s r6 c C s t td�S )Nr )�hasattrr r r r r �implements_poll� s rF c C s t td�S )Nr7 )rE r r r r r �implements_kqueue� s rG ) r r" r r r, r6 rF rG ZPollerr r r r �<module> s "+>O
Back to File Manager