+ ,i<cs^RIt^RIt!RR]4t!RR4t!RR4t!RR 4t!R R 4t!R R 4t!RR4t !RR4t R#)Ncs2aa]tRt^toV3RltRtVtV;t#)RequestExceededExceptionc sN<WnW nRV RV 2p\SV` V4R#)a`Error when requested amount exceeds what is allowed The request that raised this error should be retried after waiting the time specified by ``retry_time``. :type requested_amt: int :param requested_amt: The originally requested byte amount :type retry_time: float :param retry_time: The length in time to wait to retry for the requested amount zRequest amount z) exceeded the amount available. Retry in N) requested_amt retry_timeZsuper__init__)selfrrZmsg __class__s&&& 9/usr/lib/python3.14/site-packages/s3transfer/bandwidth.pyrZ!RequestExceededException.__init__s2+$ .WXbWcd rr)__name__ __module__ __qualname____firstlineno__r__static_attributes____classdictcell__Z __classcell__)r __classdict__s@@rrrsrrcs]tRt^%tRtRtR#) RequestTokenzDA token to pass as an identifier when consuming from the LeakyBucketN)r r r r Z__doc__rrrrrr%sNrrcs,a]tRt^+toRtRtRtVtR#) TimeUtilsc s,\P!4#)zOGet the current time back :rtype: float :returns: The current time in seconds )timer&rrZTimeUtils.time,s yy{rc s.\P!V4#)z_Sleep for a designated time :type value: float :param value: The time to sleep for in seconds )rsleep)rZvalue&&rrZTimeUtils.sleep4s zz%  rrN)r r r r rrrrr@rrr+s!!rrcs4a]tRt^=toRRltRRltRtVtR#)BandwidthLimiterNc sHWnW nVf\4VnR#R#)zLimits bandwidth for shared S3 transfers :type leaky_bucket: LeakyBucket :param leaky_bucket: The leaky bucket to use limit bandwidth :type time_utils: TimeUtils :param time_utils: Time utility to use for interacting with time. N) _leaky_bucket _time_utilsr)r leaky_bucket time_utils&&&rrZBandwidthLimiter.__init__>s%*%  ({D  rc sv\WPW P4pV'gVP4V#)aWraps a fileobj in a bandwidth limited stream wrapper :type fileobj: file-like obj :param fileobj: The file-like obj to wrap :type transfer_coordinator: s3transfer.futures.TransferCoordinator param transfer_coordinator: The coordinator for the general transfer that the wrapped stream is a part of :type enabled: boolean :param enabled: Whether bandwidth limiting should be enabled to start )BandwidthLimitedStreamrrdisable_bandwidth_limiting)rfileobjtransfer_coordinatorZenabledZstreams&&&& rget_bandwith_limited_streamZ,BandwidthLimiter.get_bandwith_limited_streamLs6( '')=?O?O   - - / r)rrN)T)r r r r rr%rrrrrrr=s +rrcspa]tRt^ctoRRltRtRtRtRtRt Rt RR lt R t R t R tR tRtVtR#)r!Nc sWnW nW0nW@nVf\ 4VnRVn\ 4Vn^VnWPn R#)aLimits bandwidth for reads on a wrapped stream :type fileobj: file-like object :param fileobj: The file like object to wrap :type leaky_bucket: LeakyBucket :param leaky_bucket: The leaky bucket to use to throttle reads on the stream :type transfer_coordinator: s3transfer.futures.TransferCoordinator param transfer_coordinator: The coordinator for the general transfer that the wrapped stream is a part of :type time_utils: TimeUtils :param time_utils: The time utility to use for interacting with time NT) _fileobjr_transfer_coordinatorrr_bandwidth_limiting_enabledr_request_token _bytes_seen_bytes_threshold)rr#rr$rZbytes_thresholds&&&&&&rrZBandwidthLimitedStream.__init__dsK0 )%9"%  ({D +/(*n /rc RVnR#)z0Enable bandwidth limiting on reads to the streamTNr)rrrenable_bandwidth_limitingZ0BandwidthLimitedStream.enable_bandwidth_limitings +/(rc r-)z1Disable bandwidth limiting on reads to the streamFNr.rrrr"Z1BandwidthLimitedStream.disable_bandwidth_limitings +0(rc sPVP'gVPPV4#V;PV, unVPVP8dVPPV4#VP 4VPPV4#)zXRead a specified amount Reads will only be throttled if bandwidth limiting is enabled. )r)r'readr+r,_consume_through_leaky_bucket)rZamountrrr0ZBandwidthLimitedStream.reads ///==%%f- - F"   d33 3==%%f- - **,}}!!&))rcsVVPP'g;VPPVPVP 4^VnR#VPPh \ d1pTPPTP4Rp?KRp?ii;i)rN) r(Z exceptionrconsumer+r*rrrr)rZes& rr1Z4BandwidthLimitedStream._consume_through_leaky_buckets ,,666 5""**$$d&9&9$% ,,66 6, 5  &&q||44 5s7A-- B(8%B##B(c &VP4R#)z6Signal that data being read is being transferred to S3N)r/rrrsignal_transferringZ*BandwidthLimitedStream.signal_transferrings &&(rc r3)z:Signal that data being read is not being transferred to S3N)r"rrrsignal_not_transferringZ.BandwidthLimitedStream.signal_not_transferrings '')rcs<VPPW4R#r&)r'seek)rZwhereZwhencer rr6ZBandwidthLimitedStream.seeks 5)rcs6VPP4#r&)r'tellrrrr7ZBandwidthLimitedStream.tells}}!!##rcsVP'd#VP'dVP4VPP 4R#r&)r)r+r1r'closerrrr8ZBandwidthLimitedStream.closes7  + + +0@0@0@  . . 0 rcsV#r&rrrr __enter__Z BandwidthLimitedStream.__enter__s rcs&VP4R#r&)r8)rZargsZkwargss&*,r__exit__ZBandwidthLimitedStream.__exit__s  r)r)r+r,r'rr*rr()Ni)r)r r r r rr/r"r0r1r4r5r6r7r8r9r:rrrrrr!r!csG!0F01*(7$)**$rr!csHa]tRt^toR RltRtRtRtRtRt Rt Vt R#) LeakyBucketNc s\V4VnW nVf\4Vn\P !4VnW0nVf\4VnW@n Vf\4Vn R#R#)aA leaky bucket abstraction to limit bandwidth consumption :type rate: int :type rate: The maximum rate to allow. This rate is in terms of bytes per second. :type time_utils: TimeUtils :param time_utils: The time utility to use for interacting with time :type rate_tracker: BandwidthRateTracker :param rate_tracker: Tracks bandwidth consumption :type consumption_scheduler: ConsumptionScheduler :param consumption_scheduler: Schedules consumption retries when necessary N) float _max_raterr threadingZLock_lock _rate_trackerBandwidthRateTracker_consumption_schedulerConsumptionScheduler)rZmax_raterZ rate_trackerZconsumption_schedulers&&&&&rrZLeakyBucket.__init__sf.x%  ({D ^^% )  !5!7D &;# (*>*@D ' )rc sVP;_uu_4VPP4pVPP V4'dVP WV4uuRRR4#VP W4'dVPWV4MVPW4uuRRR4#RRR4R# +'giR#;i)aConsume an a requested amount :type amt: int :param amt: The amount of bytes to request to consume :type request_token: RequestToken :param request_token: The token associated to the consumption request that is used to identify the request. So if a RequestExceededException is raised the token should be used in subsequent retry consume() request. :raises RequestExceededException: If the consumption amount would exceed the maximum allocated bandwidth :rtype: int :returns: The amount consumed N) r?rrrB is_scheduled,_release_requested_amt_for_scheduled_request_projected_to_exceed_max_rate!_raise_request_exceeded_exception_release_requested_amtramt request_tokentime_now&&& rr2ZLeakyBucket.consumes$ZZZ'',,.H**77 FFHHZ 33CBB66223AZZZZsA B=-:B== C csTVPPW4pW0P8#r&)r@get_projected_rater=)rrJrLZprojected_raterMrrFZ)LeakyBucket._projected_to_exceed_max_rates%++>>sM..rcsZVPPV4VPW4#r&)rBprocess_scheduled_consumptionrHrI&&&&rrEZ8LeakyBucket._release_requested_amt_for_scheduled_requests. ##AA  **399rcsV\VP4, pVPPWV4p\ WR7h)r )r<r=rBschedule_consumptionr)rrJrKrLZallocated_timers&&&& rrGZ-LeakyBucket._raise_request_exceeded_exception#sBuT^^4400EE  '  rcs<VPPW4V#r&)r@record_consumption_rate)rrJrLr rrHZ"LeakyBucket._release_requested_amt,s 223A r)rBr?r=r@r)NNN) r r r r rr2rFrErGrHrrrrrr;r;s+!AFB>/: rr;cs8a]tRtRtoRtRtRtRtRtVt R#)rCi1c s"/Vn^VnR#)z*Schedules when to consume a desired amountN _tokens_to_scheduled_consumption _total_waitrrrrZConsumptionScheduler.__init__2s02-rc sWP9#)zIndicates if a consumption request has been scheduled :type token: RequestToken :param token: The token associated to the consumption request that is used to identify the request. )rT)rtokenrrrDZ!ConsumptionScheduler.is_scheduled7s====rc sV;PV, unRVPRV/VPV&VP#)aLSchedules a wait time to be able to consume an amount :type amt: int :param amt: The amount of bytes scheduled to be consumed :type token: RequestToken :param token: The token associated to the consumption request that is used to identify the request. :type time_to_consume: float :param time_to_consume: The desired time it should take for that specific request amount to be consumed in regardless of previously scheduled consumption requests :rtype: float :returns: The amount of time to wait for the specific request before actually consuming the specified amount. Z wait_durationtime_to_consume)rUrT)rrJrVrWrPrrQZ)ConsumptionScheduler.schedule_consumption@sE& O+ T-- 8 --e4rc sVPPV4p\VPVR,, ^4VnR#)zProcesses a scheduled consumption request that has completed :type token: RequestToken :param token: The token associated to the consumption request that is used to identify the request. rWN)rTZpopZmaxrU)rrVZscheduled_retrys&& rrOZ2ConsumptionScheduler.process_scheduled_consumptionZs=??CCEJ   /@A A1 rrSN) r r r r rrDrQrOrrrrrrCrC1s > 4   rrCcsRa]tRtRtoR Rlt]R4tRtRtRt Rt Rt Vt R #) rAigc s.WnRVnRVnR#)aZTracks the rate of bandwidth consumption :type a: float :param a: The constant to use in calculating the exponentional moving average of the bandwidth rate. Specifically it is used in the following calculation: current_rate = alpha * new_rate + (1 - alpha) * current_rate This value of this constant should be between 0 and 1. N)_alpha _last_time _current_rate)rZalpharrrZBandwidthRateTracker.__init__hs !rc s:VPfR#VP#)zUThe current transfer rate :rtype: float :returns: The current tracked transfer rate )rYrZrrr current_rateZ!BandwidthRateTracker.current_ratexs ?? "!!!rc sDVPfR#VPW4#)a"Get the projected rate using a provided amount and time :type amt: int :param amt: The proposed amount to consume :type time_at_consumption: float :param time_at_consumption: The proposed time to consume at :rtype: float :returns: The consumption rate if that amt and time were consumed r[)rY*_calculate_exponential_moving_average_raterrJtime_at_consumptionr rrNZ'BandwidthRateTracker.get_projected_rates' ?? ">>   rc sxVPfW nRVnR#VPW4VnW nR#)zRecord the consumption rate based off amount and time point :type amt: int :param amt: The amount that got consumed :type time_at_consumption: float :param time_at_consumption: The time at which the amount was consumed Nr[)rYrZr]r^r rrRZ,BandwidthRateTracker.record_consumption_rates; ?? "1O!$D  !LL  .rcsZW P, pV^8:d \R4#W, #)rZinf)rYr<)rrJr_Z time_deltarMr_calculate_rateZ$BandwidthRateTracker._calculate_rates*(??: ? < !!rcsVPW4pVPV,^VP, VP,,#)i)r`rXrZ)rrJr_Znew_raterMrr]Z?BandwidthRateTracker._calculate_exponential_moving_average_rates;''A{{X%T[[DrZ Exceptionrrrrr!r;rCrArrrrask y(  !!$##LnnbZZz3 3 lNONOr