σ O'—^c@@s…dZddlmZddlZddlZddlmZmZddlmZddl m Z ddl m Z ddl m Z d d lmZmZmZmZd d lmZd d lmZmZd d lmZd dlmZd dlmZd dlmZm Z m!Z!m"Z"dZ#dZ$ddgZ%ee&ƒZ'e'j(e'j)Z(Z)de*fd„ƒYZ+de*fd„ƒYZ,dS(s9 kombu.pidbox =============== Generic process mailbox. i(tabsolute_importN(t defaultdicttdeque(tcopy(tcount(tlocal(ttimei(tExchangetQueuetConsumertProducer(t LamportClock(t maybe_declaretoid_from(tInconsistencyError(trange(t get_logger(tcached_propertytkwdicttuuidtreprcalli sύA node named {node.hostname} is already using this process mailbox! Maybe you forgot to shutdown the other node or did not do so properly? Or if you meant to start multiple nodes on the same host please make sure you give each node a unique node name! tNodetMailboxcB@sΉeZd Zd Zd Zd Zd Zd d d d d„Zd e d d„Z d„Z d„Z d d d„Z d d d d„Zid„Zd„Zd„Zd d „ZeZd „ZRS( cC@sX||_||_||_||_|jjj|_|dkrKi}n||_dS(N( tchanneltmailboxthostnametstatetclocktadjustt adjust_clocktNonethandlers(tselfRRRRR((s./tmp/pip-unpacked-wheel-UAnTfW/kombu/pidbox.pyt__init__;s      c @smˆjjˆjƒ}‡fd†}||_t|p<ˆj|gd|d|dkrcˆjjn||S(Nc@s&|r"tjtjdˆƒƒndS(Ntnode(twarningstwarntW_PIDBOX_IN_USEtformat(tnametmessagest consumers(R (s./tmp/pip-unpacked-wheel-UAnTfW/kombu/pidbox.pytverify_exclusiveIstno_acktaccept(Rt get_queueRt on_declaredR RRR,(R RR+R,toptionstqueueR*((R s./tmp/pip-unpacked-wheel-UAnTfW/kombu/pidbox.pyR Fs cC@s||j|j<|S(N(Rt__name__(R tfun((s./tmp/pip-unpacked-wheel-UAnTfW/kombu/pidbox.pythandlerTscC@std|ddƒdS(NsCannot decode message: %rtexc_infoi(terror(R tmessagetexc((s./tmp/pip-unpacked-wheel-UAnTfW/kombu/pidbox.pyton_decode_errorXscC@s;|jd|d|p|jgd|jƒ}|jƒ|S(NRt callbacksR8(R thandle_messageR8tconsume(R Rtcallbacktconsumer((s./tmp/pip-unpacked-wheel-UAnTfW/kombu/pidbox.pytlisten[s   c K@sμ|p i}tdt|d d|ƒ||ƒ|r=|jpC|j}y||t|ƒƒ}WnLtk ru‚n9tk r­}td|ddƒit|ƒd6}nX|rθ|j i||j 6d|dd|dd |ƒn|S( Ns1pidbox received method %s [reply_to:%s ticket:%s]tkwargsspidbox command error: %rR4iR5texchanget routing_keytticket(( tdebugRt handle_callt handle_castRt SystemExitt ExceptionR5treprtreplyR( R tmethodt argumentstreply_toRBR?thandleRIR7((s./tmp/pip-unpacked-wheel-UAnTfW/kombu/pidbox.pytdispatchbs"     cC@s|j||j|S(N(RR(R RJRK((s./tmp/pip-unpacked-wheel-UAnTfW/kombu/pidbox.pyRMwscC@s|j||ƒS(N(RM(R RJRK((s./tmp/pip-unpacked-wheel-UAnTfW/kombu/pidbox.pyRDzscC@s|j||ƒS(N(RM(R RJRK((s./tmp/pip-unpacked-wheel-UAnTfW/kombu/pidbox.pyRE}scC@sd|jdƒ}|r7|j|jjdƒp0dƒn| sM|j|kr`|jt|ƒSdS(Nt destinationRi(tgetRtheadersRRNR(R tbodyR6RO((s./tmp/pip-unpacked-wheel-UAnTfW/kombu/pidbox.pyR:€s "c K@s2|jj||||d|jd|jjƒdS(NRt serializer(Rt_publish_replyRRS(R tdataR@RARBR?((s./tmp/pip-unpacked-wheel-UAnTfW/kombu/pidbox.pyRIˆs N(R1t __module__RRRRRRR!tTrueR R3R8R>RNRMRDRER:tdispatch_from_messageRI(((s./tmp/pip-unpacked-wheel-UAnTfW/kombu/pidbox.pyR*s&       c B@saeZeZdZdZdZdZdZ dZ dZ dgZ dZ dddddd„Zd„Zddddd„Zidddd„Zid„Zid „Zid dddd „Zd „Zed „ƒZd„Zdd„Zdddddd„Zdded ddddd„Zdd dddd„Zd„Zd„Zed„ƒZRS(s %s.pidboxsreply.%s.pidboxtdirecttjsoncC@sΔ||_||_||_|dkr0tƒn||_|j|j|jƒ|_|j|jƒ|_ t ƒ|_ t t ƒ|_|dkr™|jn||_|dkr·|jn||_dS(N(t namespacet connectionttypeRR Rt _get_exchangeR@t_get_reply_exchangetreply_exchangeRt_tlsRRt unclaimedR,RS(R R[R]R\RR,RS((s./tmp/pip-unpacked-wheel-UAnTfW/kombu/pidbox.pyR!¨s    cC@st|ƒ}||_|S(N(RR\(R R\tbound((s./tmp/pip-unpacked-wheel-UAnTfW/kombu/pidbox.pyt__call__Άs  cC@s.|ptjƒ}|j||||d|ƒS(NR(tsockett gethostnametnode_cls(R RRRR((s./tmp/pip-unpacked-wheel-UAnTfW/kombu/pidbox.pyR»sc C@s+|j|||dtd|d|d|ƒS(NRIttimeoutR<R(t _broadcastRW(R ROtcommandR?RhR<R((s./tmp/pip-unpacked-wheel-UAnTfW/kombu/pidbox.pytcallΏs cC@s|j|||dtƒS(NRI(RitFalse(R RORjR?((s./tmp/pip-unpacked-wheel-UAnTfW/kombu/pidbox.pytcastΖscC@s|j||dtƒS(NRI(RiRl(R RjR?((s./tmp/pip-unpacked-wheel-UAnTfW/kombu/pidbox.pytabcastΙsic C@s.|j||dtd|d|d|d|ƒS(NRIRhtlimitR<R(RiRW(R RjR?RhRoR<R((s./tmp/pip-unpacked-wheel-UAnTfW/kombu/pidbox.pyt multi_callΜs cC@sU|j}td||jjfd|jd|dtdtdittdƒd6ƒS( Ns%s.%sR@RAtdurablet auto_deletetqueue_argumentsiθs x-expires(toidRR`R'RlRWtinttREPLY_QUEUE_EXPIRES(R Rt((s./tmp/pip-unpacked-wheel-UAnTfW/kombu/pidbox.pytget_reply_queueΣs  cC@s |jƒS(N(Rw(R ((s./tmp/pip-unpacked-wheel-UAnTfW/kombu/pidbox.pyt reply_queueήscC@s,td||jfd|jdtdtƒS(Ns %s.%s.pidboxR@RqRr(RR[R@RlRW(R R((s./tmp/pip-unpacked-wheel-UAnTfW/kombu/pidbox.pyR-βs c K@s |p|jj}t|dddddtƒ}t|dtƒ}yF|j|d|d|d |gd i|d 6|jjƒd 6|Wntk r›nXdS( Nt exchange_typeRYt delivery_modet transientRqt auto_declareR@RAtdeclareRQRBR( R\tdefault_channelRRlR tpublishRtforwardR( R RIR@RARBRtoptstchantproducer((s./tmp/pip-unpacked-wheel-UAnTfW/kombu/pidbox.pyRTθs    c C@sωi|d6|d6|d6}|p*|jj} |j} |rt|j|ƒƒ|jd|di|jjd6|jd6ƒn|p‹|j }t | dt ƒ} | j |d| jd | gd i|j jƒd 6|rδtƒ|nd d 6d|ƒdS(NRJRKRORBRLR@RAR|R}RQRitexpiresRS(R\R~R@R RxtupdateR`R'RtRSR RlRRR€R( R R]RKROt reply_ticketRRhRSR6R‚R@Rƒ((s./tmp/pip-unpacked-wheel-UAnTfW/kombu/pidbox.pyt_publishϊs"   c C@s |dk r@t|ttfƒ r@tdjt|ƒƒƒ‚n|pIi}|r[tƒp^d} |pp|jj } |dkr |r |r—t |ƒpšd}n| p¬|j } |j ||d|d| d| d|d| ƒ| r|j | d|d|d|d| ƒSdS( Ns(destination must be a list/tuple not {0}ROR†RRhRSRoR<(Rt isinstancetlistttuplet ValueErrorR&R]RR\R~tlenRSR‡t_collect( R RjRKRORIRhRoR<RRSR†R‚((s./tmp/pip-unpacked-wheel-UAnTfW/kombu/pidbox.pyRis*  c @s;|dkr|j}n|p'|jj}|j}t||gd|dtƒ} g‰|j‰|jj ‰yˆj ˆƒSWnt k rnX‡‡‡‡‡fd†} | j | ƒzj| ^xR|rΨt |ƒpήtƒD]5} y|jjd|ƒWqίtjk rPqίXqίWˆSWdQXWd|j|jƒXdS(NR,R+c@sš|jj}ˆ|dƒpdƒ|dƒ}|rGtƒ|krGdS|dˆƒ}|ˆkr…ˆruˆ|ƒnˆj|ƒnˆ|j|ƒdS(NRiR„RB(RQRPRtappend(RRR6theaderR„tthis_id(RR<t responsesRBRb(s./tmp/pip-unpacked-wheel-UAnTfW/kombu/pidbox.pyt on_message?s    Rh(RR,R\R~RxR RWRbRRtpoptKeyErrortregister_callbackRRt drain_eventsReRhtafter_reply_message_receivedR'( R RBRoRhR<RR,R‚R0R=R’ti((RR<R‘RBRbs./tmp/pip-unpacked-wheel-UAnTfW/kombu/pidbox.pyR.s.       " cC@s#t|j|d|dtddƒS(NR]RqRzR{(Rt exchange_fmtRl(R R[R]((s./tmp/pip-unpacked-wheel-UAnTfW/kombu/pidbox.pyR^ZscC@s#t|j|dddtddƒS(NR]RYRqRzR{(Rtreply_exchange_fmtRl(R R[((s./tmp/pip-unpacked-wheel-UAnTfW/kombu/pidbox.pyR_`scC@s=y|jjSWn(tk r8t|ƒ}|j_|SXdS(N(RatOIDtAttributeErrorR (R Rt((s./tmp/pip-unpacked-wheel-UAnTfW/kombu/pidbox.pyRtfs  N( R1RVRRgR™RšRR[R\R]R@R`R,RSR!RdRkRmRnRpRwRRxR-RTR‡RlRiRR^R_Rt(((s./tmp/pip-unpacked-wheel-UAnTfW/kombu/pidbox.pyRŽsF            *  (-t__doc__t __future__RReR#t collectionsRRRt itertoolsRt threadingRRtRRR R tclocksR tcommonR R t exceptionsRtfiveRtlogRtutilsRRRRRvR%t__all__R1tloggerRCR5tobjectRR(((s./tmp/pip-unpacked-wheel-UAnTfW/kombu/pidbox.pyts,  ""  d