fR @ 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 e e e
e e e e f Z y e Wn e k
r i Z Yn Xd d Z Gd d d e Z e e e f Z d d Z d
d Z d d
Z! d d Z" d d d d Z# d d d d Z$ e$ Z% d d d d d d Z& Gd d d Z' Gd d d e' Z( d d Z) d d d d Z* e j+ d! k rd d l, Z, Gd" d# d# Z- Gd$ d% d% e' Z. n d S)&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
ECONNRESETEINVALENOTCONN ESHUTDOWNEISCONNEBADF ECONNABORTEDEPIPEEAGAIN errorcodec
C sO y t j | SWn7 t t t f k
rJ | t k r> t | Sd | SYn Xd S)NzUnknown error %s)osstrerror
ValueError
OverflowError NameErrorr )err r -/opt/alt/python34/lib64/python3.4/asyncore.py _strerrorD s r c @ s e Z d Z d S)ExitNowN)__name__
__module__ __qualname__r r r r r L s r c C s; y | j Wn& t k
r% Yn | j Yn Xd S)N)handle_read_event_reraised_exceptions handle_error)objr r r readQ s
r c C s; y | j Wn& t k
r% Yn | j Yn Xd S)N)handle_write_eventr r )r r r r writeY s
r" c C s; y | j Wn& t k
r% Yn | j Yn Xd S)N)handle_expt_eventr r )r r r r
_exceptiona s
r$ 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 Wnt t k
r } z/ | j d t
k r | j n
| j
WYd d } ~ Xn& t k
r Yn | j Yn Xd S)Nr )selectPOLLINr POLLOUTr! POLLPRIr# ZPOLLHUPZPOLLERRZPOLLNVAL handle_closeOSErrorargs
_DISCONNECTEDr r )r flagser r r readwritei s"
r/ g c C s | d k r t } n | rg } g } g } x t | j D]v \ } } | j } | j } | rz | 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 | | | | \ } } } Wn t
k
r/d SYn Xx9 | D]1 } | j | } | d k r^q7n t | q7Wx9 | D]1 } | j | } | d k rqsn t
| qsWx< | D]1 } | j | } | d k rqn t | qWn d S)N)
socket_maplistitemsreadablewritableappend acceptingtimeZsleepr% InterruptedErrorgetr r" r$ ) timeoutmaprwr. fdr Zis_rZis_wr r r poll} sJ '
%
r? c C sK | d k r t } n | d k r4 t | d } n t j } | rGx t | j D]t \ } } d } | j r | t j t j BO} n | j r | j
r | t j O} n | rY | j | | qY qY Wy | j | } Wn t
k
r g } Yn XxE | D]: \ } } | j | } | d k r3qn t | | qWn d S)Ni r )r0 intr% r? r1 r2 r3 r& r( r4 r6 r' registerr8 r9 r/ )r: r; Zpollsterr> r r- r< r r r poll2 s.
rB g >@Fc 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)Nr? r )r0 hasattrr% rB r? )r: Zuse_pollr; countZpoll_funr r r loop s
rF c @ s e Z d Z d Z d Z d Z d Z d Z d Z e d g Z
d d d d Z d d Z e Z
d d d Z d d
d Z e j e j d d
Z d d d Z d d Z d d Z d d Z d d Z d d Z d d Z d d Z d d Z d d! Z d" d# Z d$ d% Z d& d' Z d( d) d* Z! d+ d, Z" d- d. Z# d/ d0 Z$ d1 d2 Z% d3 d4 Z& d5 d6 Z' d7 d8 Z( d9 d: Z) d; d< Z* d= d> Z+ d? d@ Z, dA dB Z- d S)C
dispatcherFNwarningc C s | d k r t | _ n | | _ d | _ | r | j d | j | | d | _ y | j | _ Wq t k
r } z: | j d t
t f k r d | _ n | j | WYd d } ~ Xq Xn d | _
d S)Nr TF)r0 _map_fileno setblocking
set_socket connectedZ getpeernameaddrr* r+ r r del_channelsocket)selfsockr; r r r r __init__ s
zdispatcher.__init__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 Yq Xn d d j | t
| f S)N.Z listeningrM z%s:%dz <%s at %#x> ) __class__r r r6 rN r5 rM TypeErrorreprjoinid)rQ Zstatusr r r __repr__ s
zdispatcher.__repr__c C s) | d k r | j } n | | | j