Searched refs:waitMetricsMap (Results 1 – 2 of 2) sorted by relevance
185 KeyRangeMap< vector< PromiseStream< StorageMetrics > > > waitMetricsMap; member219 auto& v = waitMetricsMap[key]; in notify()245 notifyBytes(waitMetricsMap.rangeContaining(key), bytes); in notifyBytes()251 auto rs = waitMetricsMap.intersectingRanges(keys); in notifyNotReadable()264 …ER_KNOBS->STORAGE_METRICS_AVERAGE_INTERVAL_PER_KSECONDS; bandwidthSample.poll(waitMetricsMap, m); } in poll()265 … SERVER_KNOBS->STORAGE_METRICS_AVERAGE_INTERVAL_PER_KSECONDS; iopsSample.poll(waitMetricsMap, m); } in poll()
3170 auto r = metrics.waitMetricsMap.intersectingRanges(searchRange); in byteSampleApplyClear()3214 auto rs = self->waitMetricsMap.modify( req.keys ); in waitMetrics()3256 auto rs = self->waitMetricsMap.modify( req.keys ); in waitMetrics()3266 self->waitMetricsMap.coalesce( req.keys ); in waitMetrics()