ó âžYc@sddlZddlZddlZddlmZmZddlZy ejZWn ee fk ruejZnXdZ d Z e Z eƒZdefd„ƒYZd„Zd„Zed d d d d gƒZdefd„ƒYZdefd„ƒYZeedƒr(defd„ƒYZneedƒrPdefd„ƒYZneedƒrxdefd„ƒYZneedƒr defd„ƒYZndeƒkr¸eZn]deƒkrÐeZnEdeƒkrèeZn-deƒkreZnd„ZeZeZ dS(!iÿÿÿÿN(t namedtupletMappingiit SelectorErrorcBs#eZd„Zd„Zd„ZRS(cCs tt|ƒjƒ||_dS(N(tsuperRt__init__terrno(tselfterrcode((sa/data/av2000/soap/soapenv/lib/python2.7/site-packages/requests/packages/urllib3/util/selectors.pyRscCsdj|jƒS(Ns(tformatR(R((sa/data/av2000/soap/soapenv/lib/python2.7/site-packages/requests/packages/urllib3/util/selectors.pyt__repr__scCs |jƒS(N(R (R((sa/data/av2000/soap/soapenv/lib/python2.7/site-packages/requests/packages/urllib3/util/selectors.pyt__str__"s(t__name__t __module__RR R (((sa/data/av2000/soap/soapenv/lib/python2.7/site-packages/requests/packages/urllib3/util/selectors.pyRs  cCsˆt|tƒr|}nHyt|jƒƒ}Wn/tttfk r_tdj|ƒƒ‚nX|dkr„tdj|ƒƒ‚n|S(sl Return a file descriptor from a file object. If given an integer will simply return that integer back. sInvalid file object: {0!r}isInvalid file descriptor: {0}(t isinstancetinttfilenotAttributeErrort TypeErrort ValueErrorR(tfileobjtfd((sa/data/av2000/soap/soapenv/lib/python2.7/site-packages/requests/packages/urllib3/util/selectors.pyt_fileobj_to_fd&s  c OsÊ|jddƒ}|dkr-d}t}n.t|ƒ}|dkrNd}n tƒ|}t|ƒ}|rˆd|krˆtdƒ‚nt}x5|tkrÅy|||Ž}Wq‘tt t j fk rÁ}d}t |dƒrï|j }nt |dƒr|jd}n|t jkp8t t dƒo8|t jk} | r¦|dk r‘tƒ} | |krwtdt jƒ‚n|r d|kr|| |dRR9RRERGRIR"RLRPRMRQRRRS(((sa/data/av2000/soap/soapenv/lib/python2.7/site-packages/requests/packages/urllib3/util/selectors.pyR?„s          R"tSelectSelectorcBsDeZdZd„Zdd„Zd„Zdd„Zdd„ZRS(s Select-based selector. cCs/tt|ƒjƒtƒ|_tƒ|_dS(N(RRTRtsett_readerst_writers(R((sa/data/av2000/soap/soapenv/lib/python2.7/site-packages/requests/packages/urllib3/util/selectors.pyRs cCsbtt|ƒj|||ƒ}|t@r>|jj|jƒn|t@r^|jj|jƒn|S(N( RRTRERCRVtaddRRDRW(RRR1R2RB((sa/data/av2000/soap/soapenv/lib/python2.7/site-packages/requests/packages/urllib3/util/selectors.pyREs   cCsBtt|ƒj|ƒ}|jj|jƒ|jj|jƒ|S(N(RRTRGRVtdiscardRRW(RRRB((sa/data/av2000/soap/soapenv/lib/python2.7/site-packages/requests/packages/urllib3/util/selectors.pyRGscCstj||g|ƒS(s? Wrapper for select.select because timeout is a positional arg (R"(RtrtwR((sa/data/av2000/soap/soapenv/lib/python2.7/site-packages/requests/packages/urllib3/util/selectors.pyt_selectsc Cst|jƒ r$t|jƒ r$gS|dkr6dn t|dƒ}g}t|jt|j|j|ƒ\}}}t|ƒ}t|ƒ}x|||BD]p}d}||kr½|t O}n||krÖ|t O}n|j |ƒ}|r˜|j |||j @fƒq˜q˜W|S(Ngi(R6RVRWRtmaxR/R\tTrueRURCRDRQtappendR1( RRtreadyRZR[t_RR1RB((sa/data/av2000/soap/soapenv/lib/python2.7/site-packages/requests/packages/urllib3/util/selectors.pyR"s$ !      !N( R R R>RRRERGR\R"(((sa/data/av2000/soap/soapenv/lib/python2.7/site-packages/requests/packages/urllib3/util/selectors.pyRTs     tpollt PollSelectorcBsDeZdZd„Zdd„Zd„Zdd„Zdd„ZRS(s Poll-based selector cCs&tt|ƒjƒtjƒ|_dS(N(RRcRR"Rbt_poll(R((sa/data/av2000/soap/soapenv/lib/python2.7/site-packages/requests/packages/urllib3/util/selectors.pyR5scCsrtt|ƒj|||ƒ}d}|t@r>|tjO}n|t@rX|tjO}n|jj|j |ƒ|S(Ni( RRcRERCR"tPOLLINRDtPOLLOUTRdR(RRR1R2RBt event_mask((sa/data/av2000/soap/soapenv/lib/python2.7/site-packages/requests/packages/urllib3/util/selectors.pyRE9s  cCs/tt|ƒj|ƒ}|jj|jƒ|S(N(RRcRGRdR(RRRB((sa/data/av2000/soap/soapenv/lib/python2.7/site-packages/requests/packages/urllib3/util/selectors.pyRGCscCsM|dk r7|dkr!d}q7tj|dƒ}n|jj|ƒ}|S(sj Wrapper function for select.poll.poll() so that _syscall_wrapper can work with only seconds. ig@@N(RtmathtceilRdRb(RRR+((sa/data/av2000/soap/soapenv/lib/python2.7/site-packages/requests/packages/urllib3/util/selectors.pyt _wrap_pollHs    cCs§g}t|jtd|ƒ}x‚|D]z\}}d}|tj@rR|tO}n|tj@rm|tO}n|j|ƒ}|r%|j |||j @fƒq%q%W|S(NRi( R/RjR^R"ReRDRfRCRQR_R1(RRR`t fd_eventsRRgR1RB((sa/data/av2000/soap/soapenv/lib/python2.7/site-packages/requests/packages/urllib3/util/selectors.pyR"Vs  !N( R R R>RRRERGRjR"(((sa/data/av2000/soap/soapenv/lib/python2.7/site-packages/requests/packages/urllib3/util/selectors.pyRc3s    tepollt EpollSelectorcBsJeZdZd„Zd„Zdd„Zd„Zdd„Zd„Z RS(s Epoll-based selector cCs&tt|ƒjƒtjƒ|_dS(N(RRmRR"Rlt_epoll(R((sa/data/av2000/soap/soapenv/lib/python2.7/site-packages/requests/packages/urllib3/util/selectors.pyRjscCs |jjƒS(N(RnR(R((sa/data/av2000/soap/soapenv/lib/python2.7/site-packages/requests/packages/urllib3/util/selectors.pyRnscCsxtt|ƒj|||ƒ}d}|t@r>|tjO}n|t@rX|tjO}nt|j jt |j |ƒ|S(Ni( RRmRERCR"tEPOLLINRDtEPOLLOUTR/RnRR(RRR1R2RBt events_mask((sa/data/av2000/soap/soapenv/lib/python2.7/site-packages/requests/packages/urllib3/util/selectors.pyREqs  cCsMtt|ƒj|ƒ}yt|jjt|jƒWntk rHnX|S(N(RRmRGR/RnRRR(RRRB((sa/data/av2000/soap/soapenv/lib/python2.7/site-packages/requests/packages/urllib3/util/selectors.pyRG{s  c Cs|dk rG|dkr!d}ntj|dƒd}t|ƒ}nd}tt|jƒdƒ}g}t|jj t d|d|ƒ}x‚|D]z\}}d}|t j @rÀ|t O}n|t j@rÛ|tO}n|j|ƒ}|r“|j|||j@fƒq“q“W|S( Nigg@@gü©ñÒMbP?gð¿iRt maxevents(RRhRiRR]R6R7R/RnRbR^R"RoRDRpRCRQR_R1( RRt max_eventsR`RkRRgR1RB((sa/data/av2000/soap/soapenv/lib/python2.7/site-packages/requests/packages/urllib3/util/selectors.pyR"„s*      !cCs$|jjƒtt|ƒjƒdS(N(RnRLRRm(R((sa/data/av2000/soap/soapenv/lib/python2.7/site-packages/requests/packages/urllib3/util/selectors.pyRL¥s N( R R R>RRRRERGR"RL(((sa/data/av2000/soap/soapenv/lib/python2.7/site-packages/requests/packages/urllib3/util/selectors.pyRmhs   !tkqueuetKqueueSelectorcBsJeZdZd„Zd„Zdd„Zd„Zdd„Zd„Z RS(s Kqueue / Kevent-based selector cCs&tt|ƒjƒtjƒ|_dS(N(RRuRR"Rtt_kqueue(R((sa/data/av2000/soap/soapenv/lib/python2.7/site-packages/requests/packages/urllib3/util/selectors.pyR­scCs |jjƒS(N(RvR(R((sa/data/av2000/soap/soapenv/lib/python2.7/site-packages/requests/packages/urllib3/util/selectors.pyR±scCs¶tt|ƒj|||ƒ}|t@rhtj|jtjtjƒ}t |j j t |gddƒn|t @r²tj|jtjtjƒ}t |j j t |gddƒn|S(Ni(RRuRERCR"tkeventRtKQ_FILTER_READt KQ_EV_ADDR/RvtcontrolRRDtKQ_FILTER_WRITE(RRR1R2RBRw((sa/data/av2000/soap/soapenv/lib/python2.7/site-packages/requests/packages/urllib3/util/selectors.pyRE´s   "   "cCsætt|ƒj|ƒ}|jt@r}tj|jtjtj ƒ}y#t |j j t |gddƒWq}tk ryq}Xn|jt@râtj|jtjtj ƒ}y#t |j j t |gddƒWqâtk rÞqâXn|S(Ni(RRuRGR1RCR"RwRRxt KQ_EV_DELETER/RvRzRRRDR{(RRRBRw((sa/data/av2000/soap/soapenv/lib/python2.7/site-packages/requests/packages/urllib3/util/selectors.pyRGÆs$   #    # c Cs9|dk rt|dƒ}nt|jƒd}i}t|jjtd||ƒ}xÑ|D]É}|j}|j }d}|t j kr–|t O}n|t j kr²|tO}n|j|ƒ} | r\| j|kró| || j@f|| jRRRRERGR"RL(((sa/data/av2000/soap/soapenv/lib/python2.7/site-packages/requests/packages/urllib3/util/selectors.pyRu«s     cCstdƒ‚dS(Ns!Platform does not have a selector(R(Ra((sa/data/av2000/soap/soapenv/lib/python2.7/site-packages/requests/packages/urllib3/util/selectors.pyt no_selector sii( RRhR"t collectionsRRttimeRRt ImportErrorRCRDR^t HAS_SELECTtobjectRt ExceptionRRR/R0R3R?R$RTRcRmRutglobalstDefaultSelectorR‚R(((sa/data/av2000/soap/soapenv/lib/python2.7/site-packages/requests/packages/urllib3/util/selectors.pytsJ         8|14BU