LSrSSKrSSKrSSKJr "SS5r"SS5rg)zEThis module implements token buckets used for client side throttling.N)CapacityNotAvailableErrorc&\rSrSrSrSrSrSrg)ClockcgNselfs *lib/third_party/botocore/retries/bucket.py__init__Clock.__init__ s c0[R"U5 gr)timesleepr amounts r r Clock.sleep s 6rc,[R"5$r)rr s r current_timeClock.current_timesyy{rr N)__name__ __module__ __qualname____firstlineno__r rr__static_attributes__r rr rrs rrc\rSrSrSr\4Sjr\S5r\RS5r\S5r \S5r SSjr S r S r S rS rg ) TokenBucketg?cSUlSUlSUlX lSUlX0l[ R"5Ul[ R"UR5Ul Xl g)Nr) _fill_rate _max_capacity_current_capacity_clock_last_timestamp _min_rate threadingLock_lock Condition_new_fill_rate_conditionmax_rate)r r-clockmin_rates r r TokenBucket.__init__sU!!" #!^^% (1(;(;DJJ(G% rcUR$r)r"r s r r-TokenBucket.max_rate!s rcJUR UR5 [XR5UlUS:aXlOSUl[ URUR 5UlURR5 SSS5 g!,(df  g=f)N) r,_refillmaxr'r"r#minr$notify)r values r r-r2%s{  * * LLN!%8DOz%*"%&"&)&&(:(:&D "  ) ) 0 0 2#+ * *s A>B B"cUR$r)r#r s r max_capacityTokenBucket.max_capacity:s!!!rcUR$r)r$r s r available_capacityTokenBucket.available_capacity>s%%%rcnUR URXS9sSSS5 $!,(df  g=f)a"Acquire token or return amount of time until next token available. If block is True, then this method will block until there's sufficient capacity to acquire the desired amount. If block is False, then this method will return True is capacity was successfully acquired, False otherwise. )rblockN)r,_acquire)r rrAs r acquireTokenBucket.acquireBs' * *===<+ * *s& 4cpUR5 XR::aU=RU-slgU(d [5eURU5nUS:aDURR U5 UR5 URU5nUS:aMDU=RU-slg)NTr)r5r$r _sleep_amountr,wait)r rrA sleep_amounts r rBTokenBucket._acquireOs  ++ +  " "f , "/11--f5L"--22<@ #11&9 "  " "f , "rc8XR- UR- $r)r$r"rs r rFTokenBucket._sleep_amountfs///4??BBrcURR5nURcXlgURnXR- UR-n[ UR X#-5nX@lXlgr)r%rr&r$r"r7r#)r timestampcurrent_capacity fill_amount new_capacitys r r5TokenBucket._refillisnKK,,.    '#, 11 #7#774??J 4--/?/MN !-(r) r%r$r"r&r*r#r'r,r-N)r4T)rrrr _MIN_RATEr propertyr-setterr;r>rCrBrFr5rr rr rrsxI1: !__33(""&& =.C )rr)__doc__r(rbotocore.exceptionsrrrr rr rWs'K 9_)_)r