σ O'—^c@@sΗdZddlmZddlZddlmZddlmZddlm Z m Z ddl m Z dd l mZdd lmZd d d dddddgZdgZegZgZeƒZejjdƒZd efd„ƒYZd efd„ƒYZd„Zdefd„ƒYZeedeƒƒZdefd„ƒYZ ee deƒƒZ!d„Z"d„Z#eed„Z$d „Z%y!dd!l&m'Z'e'ee%ƒWne(k rΒnXdS("s2 kombu.pools =========== Public resource pools. i(tabsolute_importN(tchaini(tResource(trangetvalues(tProducer(t EqualityDict(tlazyt ProducerPoolt PoolGrouptregister_groupt connectionst producerst get_limitt set_limittresetiΘtKOMBU_DISABLE_LIMIT_PROTECTIONcB@sVeZeZd„Zd„Zd„Zd„Zd„Zd„Zd„Z d„Z RS(cO@sD||_|jddƒp!|j|_tt|ƒj||ŽdS(NR(R tpoptNoneRtsuperRt__init__(tselfR targstkwargs((s-/tmp/pip-unpacked-wheel-UAnTfW/kombu/pools.pyR s cC@s|jjdtƒS(Ntblock(R tacquiretTrue(R((s-/tmp/pip-unpacked-wheel-UAnTfW/kombu/pools.pyt_acquire_connection%scC@sB|jƒ}y|j|ƒSWntk r=|jƒ‚nXdS(N(RRt BaseExceptiontrelease(Rtconn((s-/tmp/pip-unpacked-wheel-UAnTfW/kombu/pools.pytcreate_producer(s    cC@s t|jƒS(N(RR(R((s-/tmp/pip-unpacked-wheel-UAnTfW/kombu/pools.pytnew0scC@s@|jr<x0t|jƒD]}|jj|jƒƒqWndS(N(tlimitRt _resourcet put_nowaitR (Rt_((s-/tmp/pip-unpacked-wheel-UAnTfW/kombu/pools.pytsetup3s cC@sdS(N((Rtresource((s-/tmp/pip-unpacked-wheel-UAnTfW/kombu/pools.pytclose_resource8scC@slt|ƒr|ƒ}n|jdkrh|jƒ}y|j|ƒWqhtk rd|jƒ‚qhXn|S(N(tcallablet_channelRRtreviveRR(RtpR((s-/tmp/pip-unpacked-wheel-UAnTfW/kombu/pools.pytprepare;s      cC@s<|jr|jjƒnd|_tt|ƒj|ƒdS(N(t__connection__RRtchannelRR(RR&((s-/tmp/pip-unpacked-wheel-UAnTfW/kombu/pools.pyRGs  ( t__name__t __module__RRRRR R%R'R,R(((s-/tmp/pip-unpacked-wheel-UAnTfW/kombu/pools.pyRs       cB@s&eZdd„Zd„Zd„ZRS(cC@s ||_dS(N(R!(RR!((s-/tmp/pip-unpacked-wheel-UAnTfW/kombu/pools.pyRPscC@stdƒ‚dS(Ns!PoolGroups must define ``create``(tNotImplementedError(RR&R!((s-/tmp/pip-unpacked-wheel-UAnTfW/kombu/pools.pytcreateSscC@sV|j}|tkr!tƒ}ntds8ttds>     1