o i@s8ddlZddlmZGdddeZGdddeZdS)N) IBatchedTimerc@s(eZdZdZddZddZddZdS) _BatchedCallz Wraps IDelayedCall-implementing objects, implementing only the API which txaio promised in the first place: .cancel Do not create these yourself; use _BatchedTimer.call_later() cCs||_||_||_dSN)_timer_index_call)selftimerindexZthe_callr SC:\Users\psant\Downloads\PAF backend\school\venv\Lib\site-packages\txaio/_common.py__init__'s z_BatchedCall.__init__cCs|j|j|d|_dSr)r _remove_callrrr r r cancel-s z_BatchedCall.cancelcCs|Sr)rrr r r __call__1sz_BatchedCall.__call__N)__name__ __module__ __qualname____doc__r rrr r r r rs  rc@s4eZdZdZ d ddZddZddZd d ZdS) _BatchedTimera= Internal helper. Instances of this are returned from :meth:`txaio.make_batched_timer` and that is the only way they should be instantiated. You may depend on methods from the interface class only (:class:`txaio.IBatchedTimer`) **NOTE** that the times are in milliseconds in this class! NcCs>|dkrtdt||_||_||_||_t|_||_dS)Nz!bucket_milliseconds must be > 0.0) ValueErrorfloat_bucket_milliseconds _chunk_size _get_seconds_create_delayed_calldict_buckets_loop)rZbucket_milliseconds chunk_sizeZseconds_providerZdelayed_call_creatorloopr r r r As  z_BatchedTimer.__init__c s|}t||d}|t||j8}t||fdd}z |j|d|W|StyQ|d|}|td||j |} | |gf|j|<Y|Sw)z# IBatchedTimer API icsiSrr r argsfunckwargsr r Zsz*_BatchedTimer.call_later..@@rN) rintrrrappendKeyErrorrmax_notify_bucket) rdelayr%r$r&now real_timecalldiff delayed_callr r#r call_laterRs" z_BatchedTimer.call_latercs`j|\}}j|=gfddjttt|j}|jtd|dS)z Internal helper. This 'does' the callbacks in a particular bucket. :param real_time: the bucket to do callbacks on c s|d|D]}z|Wqty$}z |WYd}~qd}~ww||d}|r:|d|||dStrPd}D] }|d|7}qBt|dS)Nr)z'Error(s) processing call_later bucket: z{} ) Exceptionr+rlenformat RuntimeError)callsr!Zchunk_delay_msr2emsgerrorsnotify_one_chunkrr r r?us,   z6_BatchedTimer._notify_bucket..notify_one_chunkrN)rrmathceilrr7rr-)rr1r4r:Zdelay_msr r=r r.ksz_BatchedTimer._notify_bucketcCsNz |j|\}}Wn tyYdSw|||s%|j|=|dSdS)z Internal helper. Removes a (possibly still pending) call from a bucket. It is *not* an error of the bucket is gone (e.g. the call has already happened). N)rr,remover)rr1r2r4r:r r r rs   z_BatchedTimer._remove_callr)rrrrr r5r.rr r r r r5s  *r)r@Ztxaio.interfacesrobjectrrr r r r s