ó Á.Ž>c@sÈddd!ZddlmZddlmZddd„ƒYZdejfd „ƒYZd ejfd „ƒYZ d e fd „ƒYZ de fd„ƒYZ ddl m Z de fd„ƒYZdS(s$Revision: 1.3 $i iþÿÿÿiÿÿÿÿ(tunittest(thtbt DummyClockcBs eZdZd„Zd„ZRS(icCs ||_dS(N(ttime(tselftwhen((s9/usr/lib/python2.7/dist-packages/twisted/test/test_htb.pytset scCs|jS(N(R(R((s9/usr/lib/python2.7/dist-packages/twisted/test/test_htb.pyt__call__ s(t__name__t __module__RRR(((s9/usr/lib/python2.7/dist-packages/twisted/test/test_htb.pyRs t SomeBucketcBseZdZdZRS(idi(RR tmaxbursttrate(((s9/usr/lib/python2.7/dist-packages/twisted/test/test_htb.pyR stTestBucketBasecBseZd„Zd„ZRS(cCs(tj|_tƒ|_|jt_dS(N(RRt _realTimeFuncRtclock(R((s9/usr/lib/python2.7/dist-packages/twisted/test/test_htb.pytsetUps  cCs|jt_dS(N(RRR(R((s9/usr/lib/python2.7/dist-packages/twisted/test/test_htb.pyttearDowns(RR RR(((s9/usr/lib/python2.7/dist-packages/twisted/test/test_htb.pyR s t TestBucketcBseZd„Zd„ZRS(cCs,tƒ}|jdƒ}|jd|ƒdS(sTesting the size of the bucket.ièidN(R taddtfailUnlessEqual(Rtbtfit((s9/usr/lib/python2.7/dist-packages/twisted/test/test_htb.pyttestBucketSizes cCsKtƒ}|jdƒ}|jjdƒ|jdƒ}|jd|ƒdS(s Testing the bucket's drain rate.ièi iN(R RRRR(RRR((s9/usr/lib/python2.7/dist-packages/twisted/test/test_htb.pyttestBucketDrian$s  (RR RR(((s9/usr/lib/python2.7/dist-packages/twisted/test/test_htb.pyRs tTestBucketNestingcBs#eZd„Zd„Zd„ZRS(cCsAtj|ƒtƒ|_t|jƒ|_t|jƒ|_dS(N(R RR tparenttchild1tchild2(R((s9/usr/lib/python2.7/dist-packages/twisted/test/test_htb.pyR-s  cCs6|jjdƒ|jjdƒ}|jd|ƒdS(NiZi (RRRR(RR((s9/usr/lib/python2.7/dist-packages/twisted/test/test_htb.pyttestBucketParentSize3scCsRd|j_|jjdƒ|jjdƒ|jjdƒ}|jd|ƒdS(Niidi (RR RRRRR(RR((s9/usr/lib/python2.7/dist-packages/twisted/test/test_htb.pyttestBucketParentRate9s  (RR RRR(((s9/usr/lib/python2.7/dist-packages/twisted/test/test_htb.pyR,s  (t DummyConsumertConsumerShaperTestcBs#eZd„Zd„Zd„ZRS(cCsDtj|ƒtƒ|_tƒ|_tj|j|jƒ|_dS(N( R RRt underlyingR tbucketRtShapedConsumertshaped(R((s9/usr/lib/python2.7/dist-packages/twisted/test/test_htb.pyRLs   cCstd}|jjdƒ|jjddƒ|jj|ƒ|jjƒ|jt|j j ƒƒ||jj ƒdS(Ni idtx( R"RR$twriteRRtresumeProducingRtlenR!tgetvalueR (Rtdelta_t((s9/usr/lib/python2.7/dist-packages/twisted/test/test_htb.pyttestRateRs cCs=|j|jjdƒ|jjƒ|j|jjdƒdS(Nii(RR"t _refcountR$t stopProducing(R((s9/usr/lib/python2.7/dist-packages/twisted/test/test_htb.pyttestBucketRefs]s (RR RR+R.(((s9/usr/lib/python2.7/dist-packages/twisted/test/test_htb.pyR Ks  N((t __version__t twisted.trialRttwisted.protocolsRRtBucketR tTestCaseR RRttest_pcpRR (((s9/usr/lib/python2.7/dist-packages/twisted/test/test_htb.pyts