gddlZddlZddlZddlZddlZddlZddlZGddZ GddZ Gdde Z Gdd ejjZy) Nc@eZdZdZdZdZdZdZdZdZ dZ d Z y ) Stopwatcha A simple stopwatch that starts automatically. >>> w = Stopwatch() >>> _1_sec = datetime.timedelta(seconds=1) >>> w.split() < _1_sec True >>> time.sleep(1.0) >>> w.split() >= _1_sec True >>> w.stop() >= _1_sec True >>> w.reset() >>> w.start() >>> w.split() < _1_sec True Launch the Stopwatch in a context: >>> with Stopwatch() as watch: ... assert isinstance(watch.split(), datetime.timedelta) After exiting the context, the watch is stopped; read the elapsed time directly: >>> watch.elapsed datetime.timedelta(...) >>> watch.elapsed.seconds 0 cD|j|jyN)resetstartselfs #/opt/Tautulli/lib/tempora/timing.py__init__zStopwatch.__init__+s  ctjd|_tjt 5|`dddy#1swYyxYwNr)datetime timedeltaelapsed contextlibsuppressAttributeError_startr s r rzStopwatch.reset/s<))!,   0     s AA cltjtj|jz SN)seconds)rrtime monotonicrr s r _diffzStopwatch._diff4s#!!$..*:T[[*HIIr c6tj|_yr)rrrr s r rzStopwatch.start7snn& r cd|xj|jz c_|`|jSr)rrrr s r stopzStopwatch.stop:s%  $ K||r c<|j|jzSr)rrr s r splitzStopwatch.split?s||djjl**r c&|j|Sr)rr s r __enter__zStopwatch.__enter__Cs  r c$|jyr)r)r exc_type exc_value tracebacks r __exit__zStopwatch.__exit__Gs  r N) __name__ __module__ __qualname____doc__r rrrrr!r#r(r r rr s0> J' +r rc eZdZdZdZdZeZy)IntervalGovernorz Decorate a function to only allow it to be called once per min_interval. Otherwise, it returns None. >>> gov = IntervalGovernor(30) >>> gov.min_interval.total_seconds() 30.0 ct|tjrtj|}||_d|_yr) isinstancenumbersNumberrr min_interval last_call)r r4s r r zIntervalGovernor.__init__Us/ lGNN 3#--lCL(r cFtjfd}|S)Ncj xs'jjjkD}|rt_|i|Syr)r5r!r4r)argskwargsallowfuncr s r wrapperz*IntervalGovernor.decorate..wrapper\sM&T$..*>*>*@4CTCT*TE!*T,V,,r ) functoolswraps)r r;r<s`` r decoratezIntervalGovernor.decorate[s%   -  - r N)r)r*r+r,r r?__call__r-r r r/r/Ks Hr r/cHeZdZdZedffd ZedZdZxZ S)Timerz Watch for a target elapsed time. >>> t = Timer(0.1) >>> t.expired() False >>> __import__('time').sleep(0.15) >>> t.expired() True InfcN|j||_t| yr)_accepttargetsuperr )r rF __class__s r r zTimer.__init__tsll6*  r ctt|tjr|j}| t d}|S)u Accept None or ∞ or datetime or numeric for target >>> Timer._accept(datetime.timedelta(seconds=30)) 30.0 >>> Timer._accept(None) inf rC)r1rr total_secondsfloat)rFs r rEz Timer._acceptxs5 fh00 1))+F >5\F r cX|jj|jkDSr)r!rJrFr s r expiredz Timer.expireds zz|))+dkk99r ) r)r*r+r,rKr staticmethodrErM __classcell__)rHs@r rBrBhs/ $El$:r rBceZdZdZdZdZ dZ ejjdde ddfdZ dZ dZ dZd Zd Zy ) BackoffDelaya Exponential backoff delay. Useful for defining delays between retries. Consider for use with ``jaraco.functools.retry_call`` as the cleanup. Default behavior has no effect; a delay or jitter must be supplied for the call to be non-degenerate. >>> bd = BackoffDelay() >>> bd() >>> bd() The following instance will delay 10ms for the first call, 20ms for the second, etc. >>> bd = BackoffDelay(delay=0.01, factor=2) >>> bd() >>> bd() Inspect and adjust the state of the delay anytime. >>> bd.delay 0.04 >>> bd.delay = 0.01 Set limit to prevent the delay from exceeding bounds. >>> bd = BackoffDelay(delay=0.01, factor=2, limit=0.015) >>> bd() >>> bd.delay 0.015 To reset the backoff, simply call ``.reset()``: >>> bd.reset() >>> bd.delay 0.01 Iterate on the object to retrieve/advance the delay values. >>> next(bd) 0.01 >>> next(bd) 0.015 >>> import itertools >>> tuple(itertools.islice(bd, 3)) (0.015, 0.015, 0.015) Limit may be a callable taking a number and returning the limited number. >>> at_least_one = lambda n: max(n, 1) >>> bd = BackoffDelay(delay=0.01, factor=2, limit=at_least_one) >>> next(bd) 0.01 >>> next(bd) 1 Pass a jitter to add or subtract seconds to the delay. >>> bd = BackoffDelay(jitter=0.01) >>> next(bd) 0 >>> next(bd) 0.01 Jitter may be a callable. To supply a non-deterministic jitter between -0.5 and 0.5, consider: >>> import random >>> jitter=functools.partial(random.uniform, -0.5, 0.5) >>> bd = BackoffDelay(jitter=jitter) >>> next(bd) 0 >>> 0 <= next(bd) <= 0.5 True rinfc||_||_t|tjr|fd}||_t|tjr|fd}||_y)Nc0tdt|Sr)maxmin)nlimit_s r limitz$BackoffDelay.__init__..limits1c&!n--r cSrr-)jitter_sr jitterz%BackoffDelay.__init__..jittersr )delayfactorr1r2r3rZr])r r^r_rZr]r\rYs @@r r zBackoffDelay.__init__sS  eW^^ ,F . fgnn -G  r c@tjt|yr)rsleepnextr s r r@zBackoffDelay.__call__s 4:r c>|j}|j|Sr)r^bump)r r^s r __next__zBackoffDelay.__next__s   r c|Srr-r s r __iter__zBackoffDelay.__iter__s r c|j|j|jz|jz|_yr)rZr^r_r]r s r rdzBackoffDelay.bumps*ZZ T[[ 84;;= HI r ch|j}|j|ji|jyr)_saved___init__r r8r9)r saveds r rzBackoffDelay.resets($$ uzz2U\\2r N)r)r*r+r,r^r_r]jaracor=save_method_argsrKr r@rergrdrr-r r rQrQseM^ E F! F@ &&qe Q'$ J3r rQ)collections.abc collectionsrrr=r2rjaraco.functoolsrlrr/rBabcIteratorrQr-r r rssT ==@:$:I$:N{3;??++{3r