ó O'—^c@@sdZddlmZddlZddlZddlZddlmZddl m Z ddl m Z ddl mZd gZdZZd ZZd;ZZejZejZeed dƒZeeddƒZeeddƒZeeddƒZeeddƒZeedd ƒZ eeddƒZ!eeddƒZ"eeddƒZ#eeddƒZ$eeddƒZ%eeddƒZ&eed d!ƒZ'eed"d#ƒZ(eed$d%ƒZ)eed&d'ƒZ*eed(dƒZ+eed)dƒZ,eed*dƒZ-eed+d ƒZ.eed,d ƒZ/eed-d ƒZ0eed.dƒZ1eed/d0ƒZ2ye3ej4ej5fƒZ6Wn#e7k r¤e3ej4fƒZ6nXd1e8fd2„ƒYZ9d3e9fd4„ƒYZ:d5e9fd6„ƒYZ;d7e9fd8„ƒYZ<d9„Z=d:„Z>dS(<sV kombu.utils.eventio =================== Evented IO support for multiple platforms. i(tabsolute_importN(tIntegral(tdetect_environmenti(tfileno(t get_errnotpolliiitepolltkqueuetkeventt KQ_EV_ADDt KQ_EV_DELETEit KQ_EV_ENABLEt KQ_EV_CLEARi t KQ_EV_ERRORi@t KQ_EV_EOFi€tKQ_FILTER_READiÿÿÿÿtKQ_FILTER_WRITEiþÿÿÿt KQ_FILTER_AIOiýÿÿÿtKQ_FILTER_VNODEiüÿÿÿtKQ_FILTER_PROCiûÿÿÿtKQ_FILTER_SIGNALiúÿÿÿtKQ_FILTER_TIMERiùÿÿÿt KQ_NOTE_LOWATtKQ_NOTE_DELETEt KQ_NOTE_WRITEtKQ_NOTE_EXTENDtKQ_NOTE_ATTRIBt KQ_NOTE_LINKtKQ_NOTE_RENAMEtkQ_NOTE_REVOKEi@tPollercB@seZd„ZRS(cC@sFy|j|ƒSWn.tk rA}t|ƒtjkrB‚qBnXdS(N(t_pollt ExceptionRterrnotEINTR(tselfttimeouttexc((s5/tmp/pip-unpacked-wheel-UAnTfW/kombu/utils/eventio.pyR>s (t__name__t __module__R(((s5/tmp/pip-unpacked-wheel-UAnTfW/kombu/utils/eventio.pyR<st_epollcB@s5eZd„Zd„Zd„Zd„Zd„ZRS(cC@stƒ|_dS(N(RR((R#((s5/tmp/pip-unpacked-wheel-UAnTfW/kombu/utils/eventio.pyt__init__HscC@sLy|jj||ƒWn.tk rG}t|ƒtjkrH‚qHnXdS(N(R(tregisterR RR!tEEXIST(R#tfdteventsR%((s5/tmp/pip-unpacked-wheel-UAnTfW/kombu/utils/eventio.pyR*Ks cC@swy|jj|ƒWn\tjtttfk r6n=ttfk rr}t |ƒt j t j fkrs‚qsnXdS(N( R(t unregistertsocketterrort ValueErrortKeyErrort TypeErrortIOErrortOSErrorRR!tENOENTtEPERM(R#R,R%((s5/tmp/pip-unpacked-wheel-UAnTfW/kombu/utils/eventio.pyR.RscC@s"|jj|dk r|ndƒS(Niÿÿÿÿ(R(RtNone(R#R$((s5/tmp/pip-unpacked-wheel-UAnTfW/kombu/utils/eventio.pyR[scC@s|jjƒdS(N(R(tclose(R#((s5/tmp/pip-unpacked-wheel-UAnTfW/kombu/utils/eventio.pyR9^s(R&R'R)R*R.RR9(((s5/tmp/pip-unpacked-wheel-UAnTfW/kombu/utils/eventio.pyR(Fs    t_kqueuecB@sbeZeeBeBeBZd„Zd„Zd„Z d„Z d„Z d„Z d„Z d„ZRS(cC@s1tƒ|_i|_d|_|jj|_dS(N(RR:t_activeR8ton_file_changetcontrolt _kcontrol(R#((s5/tmp/pip-unpacked-wheel-UAnTfW/kombu/utils/eventio.pyR)fs   cC@s$|j||tƒ||j|(R#R,tev((s5/tmp/pip-unpacked-wheel-UAnTfW/kombu/utils/eventio.pyt watch_filexs   cC@s8t|dtdtd|jƒ}|j|gdƒdS(NRARBRCi(RRR RDR>(R#R,RE((s5/tmp/pip-unpacked-wheel-UAnTfW/kombu/utils/eventio.pyt unwatch_files   cC@sµ|s dSg}|t@r<|jt|dtd|ƒƒn| sM|t@ro|jt|dtd|ƒƒn|j}x6|D].}y||gdƒWqtk r¬qXqWdS(NRARBi(tWRITEtappendRRtREADRR>R1(R#R,R-RBtkeventsR=te((s5/tmp/pip-unpacked-wheel-UAnTfW/kombu/utils/eventio.pyR?†s      cC@s<|jdd|ƒ}ig}}xñ|D]é}|j}|jtkrd|j|dƒtB||R8tidentRARtgetRJRRBRtERRRHR RRCRR.RIR<tlisttitems(R#R$RKR-t file_changestkR,((s5/tmp/pip-unpacked-wheel-UAnTfW/kombu/utils/eventio.pyR™s&      cC@s|jjƒdS(N(R:R9(R#((s5/tmp/pip-unpacked-wheel-UAnTfW/kombu/utils/eventio.pyR9¯s(R&R'RRRRRDR)R*R.RFRGR?RR9(((s5/tmp/pip-unpacked-wheel-UAnTfW/kombu/utils/eventio.pyR:bs       t_selectcB@s>eZd„Zd„Zd„Zd„Zd„Zd„ZRS(cC@s5tƒtƒtƒf|_\|_|_|_dS(N(tsett_allt_rfdt_wfdt_efd(R#((s5/tmp/pip-unpacked-wheel-UAnTfW/kombu/utils/eventio.pyR)µscC@sgt|ƒ}|t@r)|jj|ƒn|t@rF|jj|ƒn|t@rc|jj|ƒndS(N(RRORYtaddRHRXRJRW(R#R,R-((s5/tmp/pip-unpacked-wheel-UAnTfW/kombu/utils/eventio.pyR*ºs    cC@sxz|j|jB|jBD]a}yt|gggdƒWqttjfk rx}t|ƒtkry|j |ƒqyqXqWdS(Ni( RWRXRYt_selectft _selecterrR/R0Rt SELECT_BAD_FDR.(R#R,R%((s5/tmp/pip-unpacked-wheel-UAnTfW/kombu/utils/eventio.pyt _remove_badÃs cC@svyt|ƒ}Wn/tjk rA}t|ƒtkr;dS‚nX|jj|ƒ|jj|ƒ|jj|ƒdS(N( RR/R0RR]RWtdiscardRXRY(R#R,R%((s5/tmp/pip-unpacked-wheel-UAnTfW/kombu/utils/eventio.pyR.ËscC@ssy+t|j|j|j|ƒ\}}}WnTttjfk r}t|ƒtj kr_dSt|ƒt kr{|j ƒS‚nXi}xF|D]>}t |t ƒs³|jƒ}n|j|dƒtB||}t |t ƒsü|jƒ}n|j|dƒtB||}t |t ƒsE|jƒ}n|j|dƒtB||s`           QF