void function ( long arg0 ) { synchronized ( this ) { if ( isStaleNow ( arg0 ) ) { value . set ( 0 ) ; updateTime . set ( arg0 ) ; } } }
safely reset the bucket state considering concurrent updates inc and resets . concode_field_sep AtomicLong updateTime concode_elem_sep AtomicLong value concode_elem_sep int windowLenMs concode_elem_sep Bucket[] buckets concode_elem_sep Logger LOG concode_elem_sep int bucketSize concode_field_sep int computeBucketIndex concode_elem_sep void incAt concode_elem_sep long getSum concode_elem_sep boolean isStaleNow concode_elem_sep void inc