i$bdZddlZddlZddlmZejeZGddeZ dS)zc This module contains utilities for generating timestamps for client-side timestamp specification. N)Lockc>eZdZdZdZ dZ dZ d dZdZdZ dZ dS) MonotonicTimestampGeneratoras An object that, when called, returns ``int(time.time() * 1e6)`` when possible, but, if the value returned by ``time.time`` doesn't increase, drifts into the future and logs warnings. Exposed configuration attributes can be configured with arguments to ``__init__`` or by changing attributes on an initialized object. .. versionadded:: 3.8.0 Tct|_|j5d|_d|_dddn #1swxYwY||_||_||_dS)Nr)rlocklast _last_warn warn_on_driftwarning_thresholdwarning_interval)selfr r r s f/Users/user/workspace/sujinbaek/cqa-test-app/venv/lib/python3.11/site-packages/cassandra/timestamps.py__init__z$MonotonicTimestampGenerator.__init__:sFF Y  DIDO               +!2 0s 6::cn||kr ||_|S|||dz|_|jS)a4 Returns the timestamp that should be used if ``now`` is the current time and ``last`` is the last timestamp returned by this object. Intended for internal and testing use only; to generate timestamps, call an instantiated ``MonotonicTimestampGenerator`` object. :param int now: an integer to be used as the current time, typically representing the current time in microseconds since the UNIX epoch :param int last: an integer representing the last timestamp returned by this object )nowr)r _maybe_warn)rrr s r_next_timestampz+MonotonicTimestampGenerator._next_timestampCsC ::DIJ     % % %qDI9 c|j5|ttjdz|jcdddS#1swxYwYdS)zw Makes ``MonotonicTimestampGenerator`` objects callable; defers internally to _next_timestamp. .A)rr N)rrinttimer )rs r__call__z$MonotonicTimestampGenerator.__call__Ws Y 8 8''C c0A,B,B-1Y(88 8 8 8 8 8 8 8 8 8 8 8 8 8 8 8 8 8 8s=AAAc|j|z }||jz }|jo||jdzko ||jdzk}|r>t d|||j||_dSdS)NrzClock skew detected: current tick ({now}) was {diff} microseconds behind the last generated timestamp ({last}), returned timestamps will be artificially incremented to guarantee monotonicity.)rdiffr )r r r r r logwarningformat)rrrsince_last_warnwarns rrz'MonotonicTimestampGenerator._maybe_warn`sy3/"A/#55A D$9C$??   " KK9:@$TY:@:8:8  9 9 9 "DOOO " "rN)Trr) __name__ __module__ __qualname____doc__r r r rrrrrrrrsM   1111(888"""""rr) r%loggingr threadingr getLoggerr"robjectrr&rrr+s"  g!!S"S"S"S"S"&S"S"S"S"S"r