Edit File: asyncore_25.cpython-36.pyc
3 �k�`�A � @ sB d Z ddlZddlZddlZddlZddlZddlmZmZm Z m Z m Z m Z m Z mZmZ ddlmZmZ ye W n ek r� i ZY nX G dd� de�Zdd� Zd d � Zd d � Zd d� Zd%dd�Zd&dd�Z e Z d'dd�Z G dd� d�Z G dd� de �Z d d � Z!d(d d �Z"ej#d k�r>ddl$Z$G 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 preemptive 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�ENOTCONN� ESHUTDOWN�EINTR�EISCONN� errorcode)� as_string�as_bytesc @ s e Zd ZdS )�ExitNowN)�__name__� __module__� __qualname__� r r �!/usr/lib/python3.6/asyncore_25.pyr A s r c C s: y | j � W n( tk r" � Y n | j� Y nX d S )N)�handle_read_eventr � handle_error)�objr r r �readD s r c C s: y | j � W n( tk r" � Y n | j� Y nX d S )N)�handle_write_eventr r )r r r r �writeL s r c C s: y | j � W n( tk r" � Y n | j� Y nX d S )N)�handle_expt_eventr r )r r r r � _exceptionT s r c C sz yL|t jt jB @ r| j� |t j@ r,| j� |t jt jB t jB @ rJ| j � W n( t k rb � Y n | j � Y nX d S )N) �select�POLLIN�POLLPRIr �POLLOUTr �POLLERR�POLLHUP�POLLNVALr r r )r �flagsr r r � readwrite\ s r# � c C s� |d kr t }|�r�g }g }g }xR|j� D ]F\}}|j� }|j� }|rN|j|� |r\|j|� |sd|r(|j|� q(W g | ko�| ko�|kn r�tj| � nVytj|||| �\}}}W n: tjk r� } z | j d t kr� nd S W Y d d } ~ X nX x*|D ]"}|j |�}|d k�rq�t |� q�W x.|D ]&}|j |�}|d k�rD�q(t |� �q(W x.|D ]&}|j |�}|d k�rt�qXt|� �qXW d S )Nr )� socket_map�items�readable�writable�append�timeZsleepr �error�argsr �getr r r ) �timeout�map�r�w�e�fdr Zis_rZis_w�errr r r �polli sL " r5 c C s |d kr t }| d k r t| d �} tj� }|�rxh|j� D ]\\}}d}|j� r\|tjtjB O }|j� rn|tj O }|r8|tj tj B tj B O }|j ||� q8W y|j| �}W n8 tjk r� } z|jd tkrʂ g }W Y d d }~X nX x0|D ](\}}|j|�}|d k�rq�t||� q�W d S )Ni� r )r% �intr r5 r& r' r r r( r r r r! �registerr+ r, r r- r# )r. r/ Zpollsterr3 r r" r0 r4 r r r �poll2� s4 r8 � >@Fc C sj |d kr t }|r ttd�r t}nt}|d krBx8|r>|| |� q.W n$x"|rd|dkrd|| |� |d8 }qDW d S )Nr5 r � )r% �hasattrr r8 r5 )r. Zuse_pollr/ �countZpoll_funr r r �loop� s r= c @ s e Zd ZdZdZdZdZdZd>dd�Zdd� Z d?dd�Z d@d d �Z d d � Z dAd d�Z dd� Zdd� Zdd� Zdd� Zdd� Zdd� Zdd � Zd d � Zd d � Zd!d"� Zd#d$� Zd%d&� ZdBd(d)�Zd*d+� Zd,d-� Z d.d/� Z d0d1� Z d2d3� Z d4d5� Z d6d7� Z!d8d9� Z"d:d;� Z#d<d=� Z$dS )C� dispatcherFNc C sj |d krt | _n|| _|r`| j||� | jjd� d| _y|j� | _W qf tjk r\ Y qfX nd | _d S )Nr T) r% �_map� set_socket�socket� setblocking� connectedZ getpeername�addrr+ )�self�sockr/ r r r �__init__� s zdispatcher.__init__c C s� | j jd | j j g}| jr.| jr.|jd� n| jr>|jd� | jd k r�y|jd| j � W n$ tk r� |jt| j�� Y nX ddj |�t | �f S )N�.Z listeningrC z%s:%dz <%s at %#x>� ) � __class__r r � acceptingrD r) rC � TypeError�repr�join�id)rE Zstatusr r r �__repr__� s zdispatcher.__repr__c C s |d kr| j }| || j< d S )N)r? �_fileno)rE r/ r r r � add_channel� s zdispatcher.add_channelc C s, | j }|d kr| j}||kr"||= d | _ d S )N)rQ r? )rE r/ r3 r r r � del_channel� s zdispatcher.del_channelc C s< ||f| _ tj||�| _| jjd� | jj� | _| j� d S )Nr )Zfamily_and_typerA rB �filenorQ rR )rE Zfamily�typer r r � create_socket s zdispatcher.create_socketc C s || _ |j� | _| j|� d S )N)rA rT rQ rR )rE rF r/ r r r r@ s zdispatcher.set_socketc C sF y*| j jt jt j| j jt jt j�dB � W n t jk r@ Y nX d S )Nr: )rA Z setsockoptZ SOL_SOCKETZ SO_REUSEADDRZ getsockoptr+ )rE r r r �set_reuse_addr s zdispatcher.set_reuse_addrc C s dS )NTr )rE r r r r' s zdispatcher.readablec C s dS )NTr )rE r r r r( " s zdispatcher.writablec C s( d| _ tjdkr |dkr d}| jj|�S )NT�nt� r: )rK �os�namerA �listen)rE Znumr r r r\ ) s zdispatcher.listenc C s || _ | jj|�S )N)rD rA �bind)rE rD r r r r] / s zdispatcher.bindc C sZ d| _ | jj|�}|tttfkr$d S |dtfkrF|| _d| _ | j� ntj |t | ��d S )NFr T) rC rA Z connect_exr r r r rD �handle_connectr+ r )rE Zaddressr4 r r r �connect3 s zdispatcher.connectc C sR y| j j� \}}||fS t jk rL } z|jd tkr:n� W Y d d }~X nX d S )Nr )rA �acceptr+ r, r )rE ZconnrD �whyr r r r` @ s zdispatcher.acceptc C sN y| j j|�}|S t jk rH } z|jd tkr6dS � W Y d d }~X nX d S )Nr )rA �sendr+ r, r )rE �data�resultra r r r rb K s zdispatcher.sendc C sp y$| j j|�}|s | j� dS |S W nF t jk rj } z(|jd tttgkrX| j� dS � W Y d d }~X nX d S )N� r )rA �recv� handle_closer+ r, r r r )rE � buffer_sizerc ra r r r rf U s zdispatcher.recvc C s | j � | jj� d S )N)rS rA �close)rE r r r ri g s zdispatcher.closec C s t | j|�S )N)�getattrrA )rE �attrr r r � __getattr__m s zdispatcher.__getattr__c C s t jjdt|� � d S )Nzlog: %s )�sys�stderrr �str)rE �messager r r �logt s zdispatcher.log�infoc C s ds |dkr t d||f � d S )NTrr z%s: %s)�print)rE rp rU r r r �log_infow s zdispatcher.log_infoc C sF | j r | jsd| _| j� n&| js:| j� d| _| j� n| j� d S )NT)rK rC � handle_acceptr^ � handle_read)rE r r r r { s z dispatcher.handle_read_eventc C s | j s| j� d| _ | j� d S )NT)rC r^ � handle_write)rE r r r r � s z dispatcher.handle_write_eventc C s | j � d S )N)� handle_expt)rE r r r r � s z dispatcher.handle_expt_eventc C sX t � \}}}}y t| �}W n dt| � }Y nX | jd||||f d� | j� d S )Nz)<__repr__(self) failed for object at %0x>z:uncaptured python exception, closing channel %s (%s:%s %s)r+ )�compact_tracebackrM rO rt ri )rE Znil�t�v�tbinfoZ self_reprr r r r � s zdispatcher.handle_errorc C s | j dd� d S )Nzunhandled exception�warning)rt )rE r r r rx � s zdispatcher.handle_exptc C s | j dd� d S )Nzunhandled read eventr} )rt )rE r r r rv � s zdispatcher.handle_readc C s | j dd� d S )Nzunhandled write eventr} )rt )rE r r r rw � s zdispatcher.handle_writec C s | j dd� d S )Nzunhandled connect eventr} )rt )rE r r r r^ � s zdispatcher.handle_connectc C s | j dd� d S )Nzunhandled accept eventr} )rt )rE r r r ru � s zdispatcher.handle_acceptc C s | j dd� | j� d S )Nzunhandled close eventr} )rt ri )rE r r r rg � s zdispatcher.handle_close)NN)N)N)N)rr )%r r r �debugrC rK �closingrD rG rP rR rS rV r@ rW r' r( r\ r] r_ r` rb rf ri rl rq rt r r r r rx rv rw r^ ru rg r r r r r> � sD r> c @ s6 e Zd Zd dd�Zdd� Zdd� Zdd � Zd d � ZdS ) �dispatcher_with_sendNc C s t j| ||� d| _d S )Nre )r> rG � out_buffer)rE rF r/ r r r rG � s z dispatcher_with_send.__init__c C s* t j| | jd d� �}| j|d � | _d S )Ni )r> rb r� )rE Znum_sentr r r � initiate_send� s z"dispatcher_with_send.initiate_sendc C s | j � d S )N)r� )rE r r r rw � s z!dispatcher_with_send.handle_writec C s | j pt| j�S )N)rC �lenr� )rE r r r r( � s z dispatcher_with_send.writablec C s0 | j r| jdt|� � | j| | _| j� d S )Nz sending %s)r~ rt rM r� r� )rE rc r r r rb � s zdispatcher_with_send.send)NN)r r r rG r� rw r( rb r r r r r� � s r� c C s� t j� \} }}g }|st�x0|rJ|j|jjj|jjjt|j �f� |j }q W ~|d \}}}dj dd� |D ��}|||f| ||fS )Nr: rI c S s g | ] }d | �qS )z [%s|%s|%s]r )�.0�xr r r � <listcomp>� s z%compact_traceback.<locals>.<listcomp>���) rm �exc_info�AssertionErrorr) �tb_frame�f_code� co_filename�co_namero � tb_lineno�tb_nextrN )rz r{ �tbr| �fileZfunction�linerr r r r ry � s ry c C s4 | d kr t } x| j� D ]}|jj� qW | j� d S )N)r% �valuesrA ri �clear)r/ r� r r r � close_all� s r� �posixc @ s< e Zd Zdd� Zdd� Zdd� ZeZeZdd� Zd d � Z d S ) � file_wrapperc C s || _ d S )N)r3 )rE r3 r r r rG s zfile_wrapper.__init__c C s t tj| j|��S )N)r rZ r r3 )rE Z buffersizer r r rf s zfile_wrapper.recvc C s t j| jt|��S )N)rZ r r3 r )rE �sr r r rb s zfile_wrapper.sendc C s t j| j� d S )N)rZ ri r3 )rE r r r ri s zfile_wrapper.closec C s | j S )N)r3 )rE r r r rT s zfile_wrapper.filenoN) r r r rG rf rb r r ri rT r r r r r� s r� c @ s e Zd Zddd�Zdd� ZdS )�file_dispatcherNc C sL t j| d |� d| _| j|� tj|tjd�}|tjO }tj|tj|� d S )NTr ) r> rG rC �set_file�fcntlZF_GETFLrZ � O_NONBLOCKZF_SETFL)rE r3 r/ r" r r r rG s zfile_dispatcher.__init__c C s || _ t|�| _| j� d S )N)rQ r� rA rR )rE r3 r r r r� $ s zfile_dispatcher.set_file)N)r r r rG r� r r r r r� s r� )r$ N)r$ N)r9 FNN)N)'�__doc__r rA rm r* rZ �errnor r r r r r r r r Zsupervisor.compatr r r% � NameError� Exceptionr r r r r# r5 r8 Zpoll3r= r> r� ry r� r[ r� r� r� r r r r �<module>/ s: , + x
Back to File Manager