σ O'—^c@@s²ddlmZddlmZmZddlmZddlmZddlm Z ddl m Z m Z de fd „ƒYZ d e fd „ƒYZd e fd „ƒYZdS(i(tabsolute_import(t ConnectiontProducer(tpools(tConnectionPool(teqhashi(tCasetMockttest_ProducerPoolcB@s±eZejZdejfd„ƒYZd„Zd„Zd„Zd„Z d„Z d„Z d„Z d „Z d „Zd „Zd „Zd „Zd„Zd„Zd„ZRS(tMyPoolcB@seZd„Zd„ZRS(cO@s&tƒ|_tjj|||ŽdS(N(RtinstanceRt ProducerPoolt__init__(tselftargstkwargs((s8/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_pools.pyR s cC@s|jS(N(R (R t connection((s8/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_pools.pyRs(t__name__t __module__R R(((s8/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_pools.pyR s cC@s+tƒ|_|j|jddƒ|_dS(Ntlimiti (Rt connectionstPooltpool(R ((s8/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_pools.pytsetUps cC@s|jjtddƒƒdS(Ntnametresource(Rtclose_resourceR(R ((s8/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_pools.pyttest_close_resourcescC@sxtƒ|j_tƒ|jj_tƒ}|j_tƒ}|_|jtƒ|jjƒWdQX|j j ƒdS(N( RRRtIOErrort side_effectt_acquire_connectiont return_valuet assertRaisestcreate_producertreleasetassert_called_with(R tacqtconn((s8/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_pools.pyt-test_releases_connection_when_Producer_raisesscC@s‹tƒ}tƒ}|_tƒ|j_tƒ}|j_tƒ}|_d|_|j tƒ|jj |ƒWdQX|j j ƒdS(N( RRRtreviveRRRtNonet_channelR tprepareR"R#(R tpptpR$R%((s8/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_pools.pyt(test_prepare_release_connection_on_error's  cC@sRtƒ}tƒ|_|jj|ƒ|jjjƒd|_|jj|ƒdS(N(Rt__connection__RR"R#R((R R,((s8/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_pools.pyt test_release_releases_connection2s    cC@s|j|jj|jƒdS(N(tassertIsRR(R ((s8/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_pools.pyt test_init:scC@s#|j|jjtƒƒtƒdS(N(tassertIsInstanceRRR(R ((s8/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_pools.pyt test_Producer=scC@s'|jjƒ|jjjdtƒdS(Ntblock(RRRtacquireR#tTrue(R ((s8/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_pools.pyttest_acquire_connection@s cC@sB|jjƒ}|ƒ}|j|tƒ|jjjdtƒdS(NR4(RtnewR2RRR5R#R6(R tpromisetproducer((s8/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_pools.pyttest_newDs cC@s9|j|jddƒ}|jƒ|j|jjƒdS(NR(RRR(tsetupt assertFalset _resourcetqueue(R R((s8/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_pools.pyttest_setup_unlimitedJs cC@sT|jt|jjjƒ|jjƒ|jjjƒ}|ƒ}|j|tƒdS(N( t assertEqualtlenRR>R?Rt get_nowaitR2R(R tfirstR:((s8/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_pools.pyt test_setupOs% cC@s‚tƒ}|jj_|j|jddƒ}d|j_|jj ƒ}|j |ƒ}|j |jjj ƒ|j j|ƒdS(NRi (RRR5RR R(R R)R>RCR*t assertTruetcalledR'R#(R RRRDR:((s8/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_pools.pyt test_prepareVs cC@s~tƒ|jj_|j|jddƒ}tƒ|j_|jjƒ}|jjj ƒ|j |ƒ}|j |j j ƒdS(NRi (RRR5RR R R)R>RCtresetR*R=R'RG(R RRDR:((s8/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_pools.pyt$test_prepare_channel_already_created_scC@s ttƒ}|jj|ƒdS(N(RRRR*(R tx((s8/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_pools.pyttest_prepare_not_callablehs cC@sUtƒ}tƒ|_tƒ|_|jj|ƒ|jjjƒ|j|jƒdS(N(RtchannelR.RR"R#t assertIsNone(R R,((s8/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_pools.pyt test_releasels    (RRRR RR RRR&R-R/R1R3R7R;R@RERHRJRLRO(((s8/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_pools.pyR s"           ttest_PoolGroupcB@s{eZejZdejfd„ƒYZd„Zd„Zd„Zd„Z d„Z d„Z d„Z d „Z d „ZRS( tMyGroupcB@seZd„ZRS(cC@s ||fS(N((R RR((s8/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_pools.pytcreatezs(RRRR(((s8/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_pools.pyRQxscC@s9|jƒ}|jtƒ|jtƒdƒWdQXdS(Ni (tGroupR tNotImplementedErrorRRR(R tg((s8/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_pools.pyttest_interface_create}s cC@s`ttjd<|jdtjƒ}|d}|j|dtjƒfƒ|jtjdƒdS(NiRtfoo(tFalseRt_usedRQtuse_global_limittassertTupleEqualt get_limitRF(R RUtres((s8/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_pools.pyttest_getitem_using_global_limit‚s   cC@s=ttjd<|jddƒ}|d}|j|dƒdS(NiRi8RW(RWi8(R6RRYRQR[(R RUR]((s8/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_pools.pyttest_getitem_using_custom_limit‰s  cC@s/|jƒ}|d|d=|jd|ƒdS(NRW(RQt assertNotIn(R RU((s8/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_pools.pyt test_delitems cC@sftdƒ}tj|}|j|ƒ|j|tƒ|j|j|ƒ|j|j tj ƒƒdS(Ns memory://( RRRRFR2RR0RRARR\(R R%R,((s8/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_pools.pyttest_Connections•s    cC@s‰tdƒ}tj|}|j|ƒ|j|tjƒ|j|jtj|ƒ|j|j |jj ƒ|j|j tj ƒƒdS(Ns memory://( RRt producersRFR2R R0RRARR\(R R%R,((s8/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_pools.pyttest_Producerss   cC@s4tdƒ}tj||jttjƒƒƒdS(Ns memory://(RRRRFtlistt _all_pools(R R%((s8/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_pools.pyttest_all_groups¦s  cC@s₯tjƒdtfd„ƒY}tƒ}tjd<|ƒ}tjj|ƒtjƒ|jjƒ|j |j ƒtƒ}tjdsj^