๓ O'—^c@@sqdZddlmZddlZddlmZddlmZddlm Z ddl m Z ddl mZdd lmZmZdd lmZdd lmZmZdd lmZdd lmZmZmZmZddlmZdddgZ ee!ƒZ"da$dZ%de&fd„ƒYZ'd„Z(ed„ƒZ)d„Z*d„Z+de,fd„ƒYZ-dS(s> kombu.async.hub =============== Event loop implementation. i(tabsolute_importN(tdeque(tcontextmanager(tsleep(t GeneratorType(tpromise(tEmptytrange(t get_logger(tcached_propertytfileno(t get_errno(tREADtWRITEtERRtpolli(tTimertHubtget_event_looptset_event_loops<Received unknown event %r for fd %r, please contact support!tStopcB@seZdZRS(sStops the event loop.(t__name__t __module__t__doc__(((s1/tmp/pip-unpacked-wheel-UAnTfW/kombu/async/hub.pyR&scC@s tƒ‚dS(N(R(((s1/tmp/pip-unpacked-wheel-UAnTfW/kombu/async/hub.pyt_raise_stop_error*sco@s dVdS(N((targstkwargs((s1/tmp/pip-unpacked-wheel-UAnTfW/kombu/async/hub.pyt_dummy_context.scC@stS(N(t _current_loop(((s1/tmp/pip-unpacked-wheel-UAnTfW/kombu/async/hub.pyR3scC@s |a|S(N(R(tloop((s1/tmp/pip-unpacked-wheel-UAnTfW/kombu/async/hub.pyR7sc B@saeZdZeZeZeZdZdd„Zd„Z d„Z d„Z d„Z d„Z dddd d „Zd „Zd!ed „Zd „Zd „Zd„Zd„Zd„Zd„Zd„Zd„Zd„Zd„Zd„Zd„Zd„Zd„Ze e!e"e#e$e%e&eeed„ Z'd„Z(d„Z)e*d„ƒZ+e,d„ƒZ-RS("sCEvent loop object. :keyword timer: Specify timer object. cC@s’|dk r|ntƒ|_i|_i|_tƒ|_tƒ|_tƒ|_ t |_ d|_ tƒ|_ d|_d|_|jƒdS(N((tNoneRttimertreaderstwriterstsetton_tickton_closeRt_readytFalset_runningt_loopt consolidatetconsolidate_callbacktpropagate_errorst_create_poller(tselfR((s1/tmp/pip-unpacked-wheel-UAnTfW/kombu/async/hub.pyt__init__Ps         cC@s|jƒ|jƒdS(N(tcloseR,(R-((s1/tmp/pip-unpacked-wheel-UAnTfW/kombu/async/hub.pytresetjs cC@s.tƒ|_|jj|_|jj|_dS(N(Rtpollertregistert _register_fdt unregistert_unregister_fd(R-((s1/tmp/pip-unpacked-wheel-UAnTfW/kombu/async/hub.pyR,ns cC@s>|jdk r:|jjƒd|_d|_d|_ndS(N(R1RR/R3R5(R-((s1/tmp/pip-unpacked-wheel-UAnTfW/kombu/async/hub.pyt _close_pollerss    cC@s|jtƒdS(N(t call_soonR(R-((s1/tmp/pip-unpacked-wheel-UAnTfW/kombu/async/hub.pytstopzscC@s+djt|ƒt|jƒt|jƒƒS(Ns(tformattidtlenR R!(R-((s1/tmp/pip-unpacked-wheel-UAnTfW/kombu/async/hub.pyt__repr__}sii c C@s|j}d}|r|jrxโt|ƒD]ั}t|jƒ\}}|dkrVPny |ƒWq+|k rw‚q+ttfk r‚q+tk rำ} t | ƒt j krบ‚nt j d| ddƒq+tk r๛} t j d| ddƒq+Xq+Wnt|p||ƒS(NsError in timer: %rtexc_infoi(RRt_queueRtnextt schedulert MemoryErrortAssertionErrortOSErrorR terrnotENOMEMtloggerterrort Exceptiontmin( R-t min_delayt max_delayt max_timerst propagateRtdelaytitentrytexc((s1/tmp/pip-unpacked-wheel-UAnTfW/kombu/async/hub.pyt fire_timers‚s(    !cC@s&z|j|ƒWd|j|ƒXdS(N(t _unregistert_discard(R-tfd((s1/tmp/pip-unpacked-wheel-UAnTfW/kombu/async/hub.pyt_remove_from_loop™scC@sšt|ƒ}y|jj||ƒWn!tk rF|j|ƒ‚nPX|t@rZ|jn|j}|r†|jj |ƒd||R)R*R#R%R+tpopleftRWR&RkRRaRoRrR]RFtinfotW_UNKNOWN_EVENTt TypeErrort isinstanceRCR RDtEBADFRH(!R-t generatorRRIR?RR`RtR R RR R!RRRt hub_removet scheduledR)R*R#ttodoRMt tick_callbacktitemt poll_timeouttto_consolidateteventsRUteventt general_errorRntcbargsRQ((s1/tmp/pip-unpacked-wheel-UAnTfW/kombu/async/hub.pyt create_loops˜                                      cC@sddlm}||ƒS(Ni(t repr_active(tdebugR‹(R-R‹((s1/tmp/pip-unpacked-wheel-UAnTfW/kombu/async/hub.pyR‹^scC@sddlm}|||ƒS(Ni(t repr_events(RŒR(R-R†R((s1/tmp/pip-unpacked-wheel-UAnTfW/kombu/async/hub.pyRbscC@s t|jƒS(N(titerR(R-((s1/tmp/pip-unpacked-wheel-UAnTfW/kombu/async/hub.pyR@fscC@s(|jdkr!|jƒ|_n|jS(N(R(RRŠ(R-((s1/tmp/pip-unpacked-wheel-UAnTfW/kombu/async/hub.pyRjsN(((.RRRR R RRR$R.R0R,R6R8R<RRRVR&RXR\R_R^R7RdReRgRiRjRoRrRSR/RTR~RRIR?RR`RtRŠR‹RR R@tpropertyR(((s1/tmp/pip-unpacked-wheel-UAnTfW/kombu/async/hub.pyR=sH                    Z  (.Rt __future__RRDt collectionsRt contextlibRttimeRttypesRR~tamqpRt kombu.fiveRRt kombu.logRt kombu.utilsR R tkombu.utils.compatR tkombu.utils.eventioR R RRRRt__all__RRFRRRzt BaseExceptionRRRRRtobjectR(((s1/tmp/pip-unpacked-wheel-UAnTfW/kombu/async/hub.pyts. "