�
z fc @ s d Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l m Z m Z m
Z
m Z m Z m
Z
m Z m Z m Z m Z m Z m Z m Z m Z e e e
e e e e f � Z y e Wn e k
r� i Z n Xd � Z d e f d � � YZ e e e f Z d � Z d � Z! d � Z" d
� Z# d e$ d � Z% d e$ d
� Z& e& Z' d e( e$ e$ d � Z) d f d � � YZ* d e* f d � � YZ+ d � Z, e$ e( d � Z- e j. d k r�d d l/ Z/ d f d � � YZ0 d e* f d � � YZ1 n d S( s� 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.
i����N( t EALREADYt EINPROGRESSt EWOULDBLOCKt
ECONNRESETt EINVALt ENOTCONNt ESHUTDOWNt EINTRt EISCONNt EBADFt ECONNABORTEDt EPIPEt EAGAINt errorcodec C sK y t j | � SWn3 t t t f k
rF | t k r> t | Sd | SXd S( Ns Unknown error %s( t ost strerrort
ValueErrort
OverflowErrort NameErrorR
( t err( ( s /usr/lib64/python2.7/asyncore.pyt _strerrorD s t ExitNowc B s e Z RS( ( t __name__t
__module__( ( ( s /usr/lib64/python2.7/asyncore.pyR L s c C s9 y | j � Wn$ t k
r$ � n | j � n Xd S( N( t handle_read_eventt _reraised_exceptionst handle_error( t obj( ( s /usr/lib64/python2.7/asyncore.pyt readQ s
c C s9 y | j � Wn$ t k
r$ � n | j � n Xd S( N( t handle_write_eventR R ( R ( ( s /usr/lib64/python2.7/asyncore.pyt writeY s
c C s9 y | j � Wn$ t k
r$ � n | j � n Xd S( N( t handle_expt_eventR R ( R ( ( s /usr/lib64/python2.7/asyncore.pyt
_exceptiona s
c C s� yz | t j @r | j � n | t j @r7 | j � n | t j @rQ | j � n | t j t j Bt j B@ry | j
� n Wnc t j k
r� } | j
d t k r� | j � q� | j
� n$ t k
r� � n | j � n Xd S( Ni ( t selectt POLLINR t POLLOUTR t POLLPRIR t POLLHUPt POLLERRt POLLNVALt handle_closet sockett errort argst
_DISCONNECTEDR R ( R t flagst e( ( s /usr/lib64/python2.7/asyncore.pyt readwritei s"
g c
C s | d k r t } n | r�g } g } g } x� | j � D]v \ } } | j � } | j � } | rt | j | � n | r� | j r� | j | � n | s� | r: | j | � q: q: Wg | k o� | k o� | k n r� t j | � d Sy% t j | | | | � \ } } } Wn3 t j
k
rF} | j d t k r?� qGd Sn Xx9 | D]1 } | j
| � } | d k ruqNn t | � qNWx9 | D]1 } | j
| � } | d k r�q�n t | � q�Wx< | D]1 } | j
| � } | d k r�q�n t | � q�Wn d S( Ni ( t Nonet
socket_mapt itemst readablet writablet appendt acceptingt timet sleepR! R* R+ R t getR R R (
t timeoutt mapt rt wR. t fdR t is_rt is_wR ( ( s /usr/lib64/python2.7/asyncore.pyt poll} sN '
%
c C s} | d k r t } n | d k r4 t | d � } n t j � } | ryx� | j � D]� \ } } d } | j � r� | t j t j BO} n | j � r� | j
r� | t j O} n | rS | t j t j
Bt j BO} | j | | � qS qS Wy | j | � } Wn5 t j k
r0} | j d t k r'� n g } n XxE | D]: \ } } | j | � } | d k req8n t | | � q8Wn d S( Ni� i ( R0 R1 t intR! RA R2 R3 R" R$ R4 R6 R# R& R% R' t registerR* R+ R R9 R/ ( R: R; t pollsterR> R R- R< R ( ( s /usr/lib64/python2.7/asyncore.pyt poll2� s4
g >@c C s� | d k r t } n | r3 t t d � r3 t } n t } | d k rb xJ | r^ | | | � qH Wn0 x- | r� | d k r� | | | � | d } qe Wd S( NRA i i ( R0 R1 t hasattrR! RE RA ( R: t use_pollR; t countt poll_fun( ( s /usr/lib64/python2.7/asyncore.pyt loop� s
t
dispatcherc B sa e Z e Z e Z e Z e Z e Z d Z e
d g � Z d d d � Z d � Z
e
Z d d � Z d d � Z d � Z d d � Z d � Z d � Z d � Z d
� Z d � Z d � Z d
� Z d � Z d � Z d � Z d � Z d � Z d d � Z d � Z d � Z! d � Z" d � Z# d � Z$ d � Z% d � Z& d � Z' d � Z( d � Z) d � Z* RS(! t warningc C s� | d k r t | _ n | | _ d | _ | r� | j d � | j | | � t | _ y | j � | _ Wq� t
j k
r� } | j d t
t f k r� t | _ q� | j | � � q� Xn d | _
d S( Ni ( R0 R1 t _mapt _filenot setblockingt
set_sockett Truet connectedt getpeernamet addrR) R* R+ R R t Falset del_channel( t selft sockR; R ( ( s /usr/lib64/python2.7/asyncore.pyt __init__� s
c C s� | j j d | j j g } | j r? | j r? | j d � n | j rX | j d � n | j d k r� y | j d | j � Wq� t k
r� | j t | j � � q� Xn d d j
| � t | � f S( Nt .t listeningRR s %s:%ds <%s at %#x>t ( t __class__R R R6 RT R5 RR R0 t TypeErrort reprt joint id( RW t status( ( s /usr/lib64/python2.7/asyncore.pyt __repr__ s
c C s) | d k r | j } n | | | j ( ( s /usr/lib64/python2.7/asyncore.pyRV s
c C s? | | f | _ t j | | � } | j d � | j | � d S( Ni ( t family_and_typeR) RO RP ( RW t familyt typeRX ( ( s /usr/lib64/python2.7/asyncore.pyt
create_socket' s
c C s) | | _ | j � | _ | j | � d S( N( R) t filenoRN Rd ( RW RX R; ( ( s /usr/lib64/python2.7/asyncore.pyRP - s c C sT y9 | j j t j t j | j j t j t j � d B� Wn t j k
rO n Xd S( Ni ( R) t
setsockoptt
SOL_SOCKETt SO_REUSEADDRt
getsockoptR* ( RW ( ( s /usr/lib64/python2.7/asyncore.pyt set_reuse_addr3 s c C s t S( N( RQ ( RW ( ( s /usr/lib64/python2.7/asyncore.pyR3 D s c C s t S( N( RQ ( RW ( ( s /usr/lib64/python2.7/asyncore.pyR4 G s c C s= t | _ t j d k r- | d k r- d } n | j j | � S( Nt nti ( RQ R6 R t nameR) t listen( RW t num( ( s /usr/lib64/python2.7/asyncore.pyRq N s c C s | | _ | j j | � S( N( RT R) t bind( RW RT ( ( s /usr/lib64/python2.7/asyncore.pyRs T s c C s� t | _ t | _ | j j | � } | t t t f k sT | t k ra t
j d k ra | | _ d S| d t
f k r� | | _ | j � n t j | t | � � d S( NRo t cei ( Ro Rt ( RU RR RQ t
connectingR) t
connect_exR R R R R Rp RT R t handle_connect_eventR* R
( RW t addressR ( ( s /usr/lib64/python2.7/asyncore.pyt connectX s
c C st y | j j � \ } } WnJ t k
r- d St j k
re } | j d t t t f k r_ d S� n X| | f Sd S( Ni ( R) t acceptR^ R0 R* R+ R R
R ( RW t connRT t why( ( s /usr/lib64/python2.7/asyncore.pyRz f s
c C sr y | j j | � } | SWnQ t j k
rm } | j d t k rF d S| j d t k rg | j � d S� n Xd S( Ni ( R) t sendR* R+ R R, R( ( RW t datat resultR| ( ( s /usr/lib64/python2.7/asyncore.pyR} t s
c C so y. | j j | � } | s) | j � d S| SWn: t j k
rj } | j d t k rd | j � d S� n Xd S( Nt i ( R) t recvR( R* R+ R, ( RW t buffer_sizeR~ R| ( ( s /usr/lib64/python2.7/asyncore.pyR� � s
c C sr t | _ t | _ t | _ | j � y | j j � Wn5 t j k
rm } | j d t t
f k rn � qn n Xd S( Ni ( RU RR R6 Ru RV R) t closeR* R+ R R ( RW R| ( ( s /usr/lib64/python2.7/asyncore.pyR� � s
c C s� y t | j | � } Wn- t k
rE t d | j j | f � � n9 Xd i | j j d 6| d 6} t j | t d d �| Sd S( Ns! %s instance has no attribute '%s'sB %(me)s.%(attr)s is deprecated. Use %(me)s.socket.%(attr)s instead.t met attrt
stackleveli ( t getattrR) t AttributeErrorR] R t warningst warnt DeprecationWarning( RW R� t retattrt msg( ( s /usr/lib64/python2.7/asyncore.pyt __getattr__� s
c C s t j j d t | � � d S( Ns log: %s
( t syst stderrR t str( RW t message( ( s /usr/lib64/python2.7/asyncore.pyt log� s t infoc C s% | | j k r! d | | f GHn d S( Ns %s: %s( t ignore_log_types( RW R� Rg ( ( s /usr/lib64/python2.7/asyncore.pyt log_info� s c C sP | j r | j � n6 | j sB | j r5 | j � n | j � n
| j � d S( N( R6 t
handle_acceptRR Ru Rw t handle_read( RW ( ( s /usr/lib64/python2.7/asyncore.pyR � s
c C sb | j j t j t j � } | d k rB t j | t | � � � n | j � t | _ t | _
d S( Ni ( R) Rm Rk t SO_ERRORR* R t handle_connectRQ RR RU Ru ( RW R ( ( s /usr/lib64/python2.7/asyncore.pyRw � s
c C s= | j r
d S| j s/ | j r/ | j � q/ n | j � d S( N( R6 RR Ru Rw t handle_write( RW ( ( s /usr/lib64/python2.7/asyncore.pyR � s c C sB | j j t j t j � } | d k r4 | j � n
| j � d S( Ni ( R) Rm Rk R� R( t handle_expt( RW R ( ( s /usr/lib64/python2.7/asyncore.pyR � s
c C sm t � \ } } } } y t | � } Wn d t | � } n X| j d | | | | f d � | j � d S( Ns) <__repr__(self) failed for object at %0x>s: uncaptured python exception, closing channel %s (%s:%s %s)R* ( t compact_tracebackR_ Ra R� R( ( RW t nilt tt vt tbinfot self_repr( ( s /usr/lib64/python2.7/asyncore.pyR � s c C s | j d d � d S( Ns! unhandled incoming priority eventRL ( R� ( RW ( ( s /usr/lib64/python2.7/asyncore.pyR� � s c C s | j d d � d S( Ns unhandled read eventRL ( R� ( RW ( ( s /usr/lib64/python2.7/asyncore.pyR� � s c C s | j d d � d S( Ns unhandled write eventRL ( R� ( RW ( ( s /usr/lib64/python2.7/asyncore.pyR� � s c C s | j d d � d S( Ns unhandled connect eventRL ( R� ( RW ( ( s /usr/lib64/python2.7/asyncore.pyR� s c C s | j d d � d S( Ns unhandled accept eventRL ( R� ( RW ( ( s /usr/lib64/python2.7/asyncore.pyR� s c C s | j d d � | j � d S( Ns unhandled close eventRL ( R� R� ( RW ( ( s /usr/lib64/python2.7/asyncore.pyR( s N(+ R R RU t debugRR R6 Ru t closingR0 RT t frozensetR� RY Rc t __str__Rd RV Rh RP Rn R3 R4 Rq Rs Ry Rz R} R� R� R� R� R� R Rw R R R R� R� R� R� R� R( ( ( ( s /usr/lib64/python2.7/asyncore.pyRK � sL
t dispatcher_with_sendc B s; e Z d d d � Z d � Z d � Z d � Z d � Z RS( c C s t j | | | � d | _ d S( NR� ( RK RY t
out_buffer( RW RX R; ( ( s /usr/lib64/python2.7/asyncore.pyRY s c C s3 d } t j | | j d � } | j | | _ d S( Ni i ( RK R} R� ( RW t num_sent( ( s /usr/lib64/python2.7/asyncore.pyt
initiate_send s c C s | j � d S( N( R� ( RW ( ( s /usr/lib64/python2.7/asyncore.pyR� s c C s | j p t | j � S( N( RR t lenR� ( RW ( ( s /usr/lib64/python2.7/asyncore.pyR4 s c C sA | j r# | j d t | � � n | j | | _ | j � d S( Ns
sending %s( R� R� R_ R� R� ( RW R~ ( ( s /usr/lib64/python2.7/asyncore.pyR} " s N( R R R0 RY R� R� R4 R} ( ( ( s /usr/lib64/python2.7/asyncore.pyR� s
c C s� t j � \ } } } g } | s0 t d � � n xD | rv | j | j j j | j j j t | j � f � | j
} q3 W~ | d \ } } } d j g | D] } d | ^ q� � } | | | f | | | f S( Ns traceback does not existi����R\ s
[%s|%s|%s]( R� t exc_infot AssertionErrorR5 t tb_framet f_codet co_filenamet co_nameR� t tb_linenot tb_nextR` ( R� R� t tbR� t filet functiont linet xR� ( ( s /usr/lib64/python2.7/asyncore.pyR� , s
&c C s� | d k r t } n x | j � D]q } y | j � Wq" t k
rm } | j d t k r^ q� | s� � q� q" t k
r� � q" | s� � q� q" Xq" W| j � d S( Ni ( R0 R1 t valuesR� t OSErrorR+ R R t clear( R; t
ignore_allR� ( ( s /usr/lib64/python2.7/asyncore.pyt close_all@ s
t posixt file_wrapperc B sM e Z d � Z d � Z d � Z d d � Z e Z e Z d � Z d � Z
RS( c C s t j | � | _ d S( N( R t dupR> ( RW R> ( ( s /usr/lib64/python2.7/asyncore.pyRY g s c G s t j | j | � S( N( R R R> ( RW R+ ( ( s /usr/lib64/python2.7/asyncore.pyR� j s c G s t j | j | � S( N( R R R> ( RW R+ ( ( s /usr/lib64/python2.7/asyncore.pyR} m s c C s9 | t j k r) | t j k r) | r) d St d � � d S( Ni s- Only asyncore specific behaviour implemented.( R) Rk R� t NotImplementedError( RW t levelt optnamet buflen( ( s /usr/lib64/python2.7/asyncore.pyRm p s
c C s6 | j d k r d S| j } d | _ t j | � d S( Ni i����( R> R R� ( RW R> ( ( s /usr/lib64/python2.7/asyncore.pyR� { s
c C s | j S( N( R> ( RW ( ( s /usr/lib64/python2.7/asyncore.pyRi � s N( R R RY R� R} R0 Rm R R R� Ri ( ( ( s /usr/lib64/python2.7/asyncore.pyR� b s t file_dispatcherc B s e Z d d � Z d � Z RS( c C s� t j | d | � t | _ y | j � } Wn t k
r? n X| j | � t j | t j d � } | t
j B} t j | t j | � d S( Ni (
RK RY R0 RQ RR Ri R� t set_filet fcntlt F_GETFLR t
O_NONBLOCKt F_SETFL( RW R> R; R- ( ( s /usr/lib64/python2.7/asyncore.pyRY � s
c C s/ t | � | _ | j j � | _ | j � d S( N( R� R) Ri RN Rd ( RW R> ( ( s /usr/lib64/python2.7/asyncore.pyR� � s N( R R R0 RY R� ( ( ( s /usr/lib64/python2.7/asyncore.pyR� � s
(2 t __doc__R! R) R� R7 R� R t errnoR R R R R R R R R R R
R R R
R� R, R1 R R t ExceptionR t KeyboardInterruptt
SystemExitR R R R R/ R0 RA RE t poll3RU RJ RK R� R� R� Rp R� R� R� ( ( ( s /usr/lib64/python2.7/asyncore.pyt / sB ^
-!� 3 #