σ ΠH/\c@`sϊdZddlmZmZmZddlZddlmZddlm Z ddlm Z ddl mZddl mZdd lmZdd lmZdd lmZdd lmZejjd ƒrάd„ZneZy<ddlmZddlmZmZmZddgZWn e k r@dZdgZnXdgeZ"ddlZ#e#j$Z$ee#e%ƒde"ddƒZ&dZ'dZ(d„Z)de*fd„ƒYZ+dd„Zedk rσde*fd„ƒYZ,de*fd„ƒYZn[dS( s Waiting for I/O completion. i(tabsolute_importtdivisiontprint_functionN(tEvent(t_get_hub_noargs(tsleep(t integer_types(t iteritems(t copy_globals(t_NONE(tEINTR(tselecttwin32cC`s5| r"| r"| r"dddfSt||||ƒS(N((((t_real_original_select(trtwtxtt((s,lib/python2.7/site-packages/gevent/select.pyt_original_selects (tpoll(tPOLLINtPOLLOUTtPOLLNVALR Rterrortnames_to_ignoretdunder_names_to_keepiicC`sRy |j}Wn7tk rFt|tƒsBtd|fƒ‚n|SX|ƒSdS(Ns6argument must be an int, or have a fileno() method: %r(tfilenotAttributeErrort isinstanceRt TypeError(tobjtfileno_f((s,lib/python2.7/site-packages/gevent/select.pyt get_fileno3s  t SelectResultcB`s_eZd Zd„Zd„Zee_d„Zee_d„Z d„Z d„Z d „Z RS( treadtwriteteventcC`s"g|_g|_tƒ|_dS(N(R"R#RR$(tself((s,lib/python2.7/site-packages/gevent/select.pyt__init__As  cC`s!|jj|ƒ|jjƒdS(N(R"tappendR$tset(R%tsocket((s,lib/python2.7/site-packages/gevent/select.pytadd_readFscC`s!|jj|ƒ|jjƒdS(N(R#R'R$R((R%R)((s,lib/python2.7/site-packages/gevent/select.pyt add_writeLscC`sSxL|D]D}|t|ƒ|jƒ}||_|j|ƒ|j||ƒqWdS(N(R R$tpriorityR'tstart(R%twatcherstfdlisttcallbacktiotpritfdtwatcher((s,lib/python2.7/site-packages/gevent/select.pyt__add_watchersRs    cC`sƒtƒj}|j}|j}y<|j|||j||ƒ|j|||j||ƒWn"tk r~}t|j Œ‚nXdS(N( tget_hubtloopR1tMAXPRIt_SelectResult__add_watchersR*R+tIOErrorRtargs(R%R.trlisttwlistR7R1R8tex((s,lib/python2.7/site-packages/gevent/select.pyt_make_watchersYs    cC`s-x"|D]}|jƒ|jƒqW|2dS(N(tstoptclose(R%R.R4((s,lib/python2.7/site-packages/gevent/select.pyt _closeallds  cC`sXg}z=|j|||ƒ|jjd|ƒ|j|jgfSWd|j|ƒXdS(Nttimeout(R?R$twaitR"R#RB(R%R<R=RCR.((s,lib/python2.7/site-packages/gevent/select.pyR js (R"R#R$( t__name__t __module__t __slots__R&R*t_EV_READR$R+t _EV_WRITER9R?RBR (((s,lib/python2.7/site-packages/gevent/select.pyR!>s       cC`sσ|dk r'|dkr'tdƒ‚nddd f}yt|||dƒ}WnDtk r•}t|ddƒp}|jd}|tkr–‚q–nX|dsΜ|dsΜ|dsΜ|dk rΧ|dkrΧtƒ|Stƒ}|j |||ƒS( sΎAn implementation of :meth:`select.select` that blocks only the current greenlet. .. caution:: *xlist* is ignored. .. versionchanged:: 1.2a1 Raise a :exc:`ValueError` if timeout is negative. This matches Python 3's behaviour (Python 2 would raise a ``select.error``). Previously gevent had undefined behaviour. .. versionchanged:: 1.2a1 Raise an exception if any of the file descriptors are invalid. istimeout must be non-negativeterrnoiiN(((( tNonet ValueErrorRRtgetattrR;R t_g_sleepR!R (R<R=txlistRCt sel_resultstetenumbertresult((s,lib/python2.7/site-packages/gevent/select.pyR ts   6  t PollResultcB`s eZdZd„Zd„ZRS(teventsR$cC`stƒ|_tƒ|_dS(N(R(RURR$(R%((s,lib/python2.7/site-packages/gevent/select.pyR&°s cC`sl|dkrt}n0d}|t@r.t}n|t@rE|tO}n|jj||fƒ|jjƒdS(Ni( RRHRRIRRUtaddR$R((R%RUR3t result_flags((s,lib/python2.7/site-packages/gevent/select.pyt add_event΄s      (RUR$(RERFRGR&RX(((s,lib/python2.7/site-packages/gevent/select.pyRT­s cB`sAeZdZd„Zed„Zd„Zdd„Zd„Z RS(sΌ An implementation of :class:`select.poll` that blocks only the current greenlet. .. caution:: ``POLLPRI`` data is not supported. .. versionadded:: 1.1b1 cC`si|_tƒj|_dS(N(tfdsR6R7(R%((s,lib/python2.7/site-packages/gevent/select.pyR&Ιs cC`sf|tkrttB}n0d}|t@r2t}n|t@rI|tO}nt|ƒ}||j|sH         6 8 ]