File: //lib64/python3.9/__pycache__/asyncore.cpython-39.opt-1.pyc
a
�DOg�N � @ sf d Z ddlZddlZddlZddlZddlZddlZddlmZm Z m
Z
m Z m Z m
Z
mZmZmZmZmZmZmZ ee e
eeeeh�Zze W n ey� i ZY n0 dd� ZG dd� de�Zee e fZ dd � Z d
d � Z d d
� Z!dd� Z"d&dd�Z#d'dd�Z$e$Z%d(dd�Z&G dd� d�Z'G dd � d e'�Z(d d � Z)d)d d �Z*ej+d!k�rbG d"d#� d#�Z,G d$d%� d%e'�Z-dS )*a� Basic infrastructure for asynchronous socket service clients and servers.
There are only two ways to have a program on a single processor do "more
than one thing at a time". Multi-threaded programming is the simplest and
most popular way to do it, but there is another very different technique,
that lets you have nearly all the advantages of multi-threading, without
actually using multiple threads. it's really only practical if your program
is largely I/O bound. If your program is CPU bound, then pre-emptive
scheduled threads are probably what you really need. Network servers are
rarely CPU-bound, however.
If your operating system supports the select() system call in its I/O
library (and nearly all do), then you can use it to juggle multiple
communication channels at once; doing other work while your I/O is taking
place in the "background." Although this strategy can seem strange and
complex, especially at first, it is in many ways easier to understand and
control than multi-threaded programming. The module documented here solves
many of the difficult problems for you, making the task of building
sophisticated high-performance network servers and clients a snap.
� N)
�EALREADY� EINPROGRESS� EWOULDBLOCK�
ECONNRESET�EINVAL�ENOTCONN� ESHUTDOWN�EISCONN�EBADF� ECONNABORTED�EPIPE�EAGAIN� errorcodec
C sF z t �| �W S tttfy@ | tv r4t| Y S d| Y S 0 d S )NzUnknown error %s)�os�strerror�
ValueError�
OverflowError� NameErrorr )�err� r � /usr/lib64/python3.9/asyncore.py� _strerrorD s r c @ s e Zd ZdS )�ExitNowN)�__name__�
__module__� __qualname__r r r r r L s r c C s8 z | � � W n& ty � Y n | �� Y n0 d S �N)�handle_read_event�_reraised_exceptions� handle_error��objr r r �readQ s r" c C s8 z | � � W n& ty � Y n | �� Y n0 d S r )�handle_write_eventr r r r r r �writeY s r$ c C s8 z | � � W n& ty � Y n | �� Y n0 d S r )�handle_expt_eventr r r r r r �
_exceptiona s r& c
C s� zX|t j@ r| �� |t j@ r&| �� |t j@ r8| �� |t jt jB t j B @ rV| �
� W nh t y� } z,|j d t
vr�| �� n| �
� W Y d }~n.d }~0 ty� � Y n | �� Y n0 d S �Nr )�select�POLLINr �POLLOUTr# �POLLPRIr% �POLLHUP�POLLERR�POLLNVAL� handle_close�OSError�args�
_DISCONNECTEDr r )r! �flags�er r r � readwritei s"
r5 � c C s< |d u r t }|�r8g }g }g }t|�� �D ]L\}}|�� }|�� }|rP|�|� |rd|jsd|�|� |sl|r*|�|� q*g | kr�| kr�|kr�n nt�| � d S t � |||| �\}}}|D ] }|�
|�}|d u r�q�t |� q�|D ]"}|�
|�}|d u �rq�t |� q�|D ]&}|�
|�}|d u �r,�qt
|� �qd S r )�
socket_map�list�items�readable�writable�append� accepting�time�sleepr( �getr" r$ r& ) �timeout�map�r�wr4 �fdr! Zis_rZis_wr r r �poll} s@
"
rF c C s� |d u r t }| d ur t| d �} t�� }|r�t|�� �D ]L\}}d}|�� r\|tjtjB O }|� � rt|j
st|tj O }|r8|� ||� q8|�| �}|D ]&\}}|�
|�}|d u r�q�t||� q�d S )Ni� r )r7 �intr( rF r8 r9 r: r) r+ r; r= r* �registerr@ r5 )rA rB ZpollsterrE r! r3 rC r r r �poll2� s(
rI � >@Fc C sb |d u r t }|r ttd�r t}nt}|d u r>|r^|| |� q,n |r^|dkr^|| |� |d }q>d S )NrF r � )r7 �hasattrr( rI rF )rA Zuse_pollrB �countZpoll_funr r r �loop� s
rN c @ s2 e Zd ZdZdZdZdZdZdZe dh�Z
dAdd�Z dd� Z dBdd �Z
dCd
d �Zejejfd d
�ZdDdd�Zdd� Zdd� Zdd� Zdd� Zdd� Zdd� Zd d � Zd d � Zd d!� Z d"d#� Z d$d%� Z dEd'd(�Z d)d*� Z d+d,� Z!d-d.� Z"d/d0� Z#d1d2� Z$d3d4� Z%d5d6� Z&d7d8� Z'd9d:� Z(d;d<� Z)d=d>� Z*d?d@� Z+dS )F�
dispatcherFN�warningc
C s� |d u rt | _n|| _d | _|r�|�d� | �||� d| _z|�� | _W q� ty� } z2|j d t
t fv rtd| _n | � |� � W Y d }~q�d }~0 0 nd | _
d S )NFTr )r7 �_map�_fileno� setblocking�
set_socket� connected� getpeername�addrr0 r1 r r � del_channel�socket)�self�sockrB r r r r �__init__� s
zdispatcher.__init__c C s� | j jd | j j g}| jr.| jr.|�d� n| jr>|�d� | jd ur�z|�d| j � W n" ty~ |�t| j�� Y n0 dd� |�t
| �f S )N�.Z listeningrU z%s:%dz <%s at %#x>� ) � __class__r r r= rW r< rU � TypeError�repr�join�id)rZ �statusr r r �__repr__� s
zdispatcher.__repr__c C s |d u r| j }| || j< d S r )rQ rR )rZ rB r r r � add_channel s zdispatcher.add_channelc C s, | j }|d u r| j}||v r"||= d | _ d S r )rR rQ )rZ rB rE r r r rX s zdispatcher.del_channelc C s. ||f| _ t�||�}|�d� | �|� d S )NF)Zfamily_and_typerY rS rT )rZ �family�typer[ r r r �
create_socket s
zdispatcher.create_socketc C s || _ |�� | _| �|� d S r )rY �filenorR rf �rZ r[ rB r r r rT s
zdispatcher.set_socketc C sB z*| j �t jt j| j �t jt j�dB � W n ty< Y n0 d S )NrK )rY �
setsockopt�
SOL_SOCKET� SO_REUSEADDR�
getsockoptr0 �rZ r r r �set_reuse_addr# s
��� zdispatcher.set_reuse_addrc C s dS �NTr rp r r r r: 4 s zdispatcher.readablec C s dS rr r rp r r r r; 7 s zdispatcher.writablec C s( d| _ tjdkr |dkr d}| j�|�S )NT�nt� )r= r �namerY �listen)rZ �numr r r rv > s zdispatcher.listenc C s || _ | j�|�S r )rW rY �bind)rZ rW r r r rx D s zdispatcher.bindc C sp d| _ d| _| j�|�}|tttfv s8|tkrBtj dkrB|| _
d S |dt fv r^|| _
| � � nt
|t| ��d S )NFTrs r )rU �
connectingrY �
connect_exr r r r r ru rW r �handle_connect_eventr0 r )rZ �addressr r r r �connectH s ��
zdispatcher.connectc
C sz z| j �� \}}W nZ ty& Y d S tyl } z0|jd tttfv rVW Y d }~d S � W Y d }~nd }~0 0 ||fS d S r' )rY �acceptr` r0 r1 r r r
)rZ �connrW �whyr r r r~ V s zdispatcher.acceptc
C s~ z| j �|�}|W S tyx } zN|jd tkr>W Y d }~dS |jd tv rb| �� W Y d }~dS � W Y d }~n
d }~0 0 d S r' )rY �sendr0 r1 r r2 r/ )rZ �data�resultr� r r r r� d s zdispatcher.sendc
C sx z(| j �|�}|s | �� W dS |W S W nJ tyr } z2|jd tv r\| �� W Y d }~dS � W Y d }~n
d }~0 0 d S )N� r )rY �recvr/ r0 r1 r2 )rZ Z buffer_sizer� r� r r r r� q s
zdispatcher.recvc
C sp d| _ d| _d| _| �� | jd urlz| j�� W n8 tyj } z |jd tt fvrV� W Y d }~n
d }~0 0 d S )NFr )
rU r= ry rX rY �closer0 r1 r r
)rZ r� r r r r� � s
zdispatcher.closec C s t j�dt|� � d S )Nzlog: %s
)�sys�stderrr$ �str)rZ �messager r r �log� s zdispatcher.log�infoc C s || j vrtd||f � d S )Nz%s: %s)�ignore_log_types�print)rZ r� rh r r r �log_info� s
zdispatcher.log_infoc C s: | j r| �� n&| js.| jr$| �� | �� n| �� d S r )r= �
handle_acceptrU ry r{ � handle_readrp r r r r � s
z dispatcher.handle_read_eventc C s@ | j �t jt j�}|dkr(t|t|���| �� d| _d| _d S )Nr TF) rY ro rm �SO_ERRORr0 r �handle_connectrU ry �rZ r r r r r{ � s z dispatcher.handle_connect_eventc C s* | j r
d S | js | jr | �� | �� d S r )r= rU ry r{ � handle_writerp r r r r# � s z dispatcher.handle_write_eventc C s0 | j �t jt j�}|dkr$| �� n| �� d S r' )rY ro rm r� r/ � handle_exptr� r r r r% � s
z dispatcher.handle_expt_eventc C sX t � \}}}}z t| �}W n dt| � }Y n0 | �d||||f d� | �� d S )Nz)<__repr__(self) failed for object at %0x>z:uncaptured python exception, closing channel %s (%s:%s %s)�error)�compact_tracebackra rc r� r/ )rZ �nil�t�v�tbinfoZ self_reprr r r r � s �� zdispatcher.handle_errorc C s | � dd� d S )Nz!unhandled incoming priority eventrP �r� rp r r r r� � s zdispatcher.handle_exptc C s | � dd� d S )Nzunhandled read eventrP r� rp r r r r� � s zdispatcher.handle_readc C s | � dd� d S )Nzunhandled write eventrP r� rp r r r r� � s zdispatcher.handle_writec C s | � dd� d S )Nzunhandled connect eventrP r� rp r r r r� � s zdispatcher.handle_connectc C s | � � }|d ur| j|� d S r )r~ �handle_accepted)rZ Zpairr r r r� � s zdispatcher.handle_acceptc C s |� � | �dd� d S )Nzunhandled accepted eventrP )r� r� )rZ r[ rW r r r r� � s zdispatcher.handle_acceptedc C s | � dd� | �� d S )Nzunhandled close eventrP )r� r� rp r r r r/ � s zdispatcher.handle_close)NN)N)N)N)r� ),r r r �debugrU r= ry �closingrW � frozensetr� r\ re rf rX rY �AF_INET� SOCK_STREAMri rT rq r: r; rv rx r} r~ r� r� r� r� r� r r{ r# r% r r� r� r� r� r� r� r/ r r r r rO � sJ
rO c @ s6 e Zd Zd dd�Zdd� Zdd� Zdd � Zd
d � ZdS )
�dispatcher_with_sendNc C s t �| ||� d| _d S )Nr� )rO r\ �
out_bufferrk r r r r\ � s z dispatcher_with_send.__init__c C s. d}t �| | jd d� �}| j|d � | _d S )Nr i )rO r� r� )rZ Znum_sentr r r �
initiate_send s z"dispatcher_with_send.initiate_sendc C s | � � d S r )r� rp r r r r� s z!dispatcher_with_send.handle_writec C s | j pt| j�S r )rU �lenr� rp r r r r; s z dispatcher_with_send.writablec C s0 | j r| �dt|� � | j| | _| �� d S )Nz
sending %s)r� r� ra r� r� )rZ r� r r r r� s zdispatcher_with_send.send)NN)r r r r\ r� r� r; r� r r r r r� � s
r� c C s� t �� \} }}g }|s td��|rL|�|jjj|jjjt|j �f� |j
}q ~|d \}}}d� dd� |D ��}|||f| ||fS )Nztraceback does not exist���r^ c S s g | ] }d | �qS )z
[%s|%s|%s]r )�.0�xr r r �
<listcomp>& r� z%compact_traceback.<locals>.<listcomp>) r� �exc_info�AssertionErrorr< �tb_frame�f_code� co_filename�co_namer� � tb_lineno�tb_nextrb )r� r� �tbr� �file�function�liner� r r r r� s �r� c C s� | d u r t } t| �� �D ]n}z |�� W q tyb } z"|jd tkrHn|sN� W Y d }~qd }~0 tyt � Y q |s�� Y q0 q| �� d S r' ) r7 r8 �valuesr� r0 r1 r
r �clear)rB Z
ignore_allr� r r r � close_all) s
r� �posixc @ sN e Zd Zdd� Zdd� Zdd� Zdd� Zdd
d �ZeZeZ d d
� Z
dd� Z d S )� file_wrapperc C s t �|�| _d S r )r �duprE �rZ rE r r r r\ N s zfile_wrapper.__init__c C s* | j dkr tjd| t| d� | �� d S )Nr zunclosed file %r)�source)rE �warnings�warn�ResourceWarningr� rp r r r �__del__Q s
�zfile_wrapper.__del__c G s t j| jg|�R � S r )r r" rE �rZ r1 r r r r� W s zfile_wrapper.recvc G s t j| jg|�R � S r )r r$ rE r� r r r r� Z s zfile_wrapper.sendNc C s( |t jkr |t jkr |s dS td��d S )Nr z-Only asyncore specific behaviour implemented.)rY rm r� �NotImplementedError)rZ �levelZoptname�buflenr r r ro ] s
��zfile_wrapper.getsockoptc C s( | j dk rd S | j }d| _ t�|� d S )Nr r� )rE r r� r� r r r r� h s
zfile_wrapper.closec C s | j S r )rE rp r r r rj o s zfile_wrapper.fileno)N) r r r r\ r� r� r� ro r" r$ r� rj r r r r r� I s
r� c @ s e Zd Zddd�Zdd� ZdS )�file_dispatcherNc C sN t �| d |� d| _z |�� }W n ty2 Y n0 | �|� t�|d� d S )NTF)rO r\ rU rj �AttributeError�set_filer � set_blocking)rZ rE rB r r r r\ t s
zfile_dispatcher.__init__c C s" t |�| _| j�� | _| �� d S r )r� rY rj rR rf r� r r r r� s
zfile_dispatcher.set_file)N)r r r r\ r� r r r r r� r s
r� )r6 N)r6 N)rJ FNN)NF).�__doc__r( rY r� r> r� r �errnor r r r r r r r r
r r r
r r� r2 r7 r r � Exceptionr �KeyboardInterrupt�
SystemExitr r" r$ r& r5 rF rI Zpoll3rN rO r� r� r� ru r� r� r r r r �<module> sD < �
'
*
)