Lines Matching full:metrics
16 assert_eq!(1, rt.metrics().num_workers()); in num_workers()
19 assert_eq!(2, rt.metrics().num_workers()); in num_workers()
25 assert_eq!(0, rt.metrics().num_blocking_threads()); in num_blocking_threads()
27 assert_eq!(1, rt.metrics().num_blocking_threads()); in num_blocking_threads()
33 assert_eq!(0, rt.metrics().num_idle_blocking_threads()); in num_idle_blocking_threads()
45 if 0 == rt.metrics().num_idle_blocking_threads() { in num_idle_blocking_threads()
51 assert_eq!(1, rt.metrics().num_idle_blocking_threads()); in num_idle_blocking_threads()
62 assert_eq!(0, rt.metrics().blocking_queue_depth()); in blocking_queue_depth()
74 assert!(rt.metrics().blocking_queue_depth() > 0); in blocking_queue_depth()
81 assert_eq!(0, rt.metrics().blocking_queue_depth()); in blocking_queue_depth()
87 let metrics = rt.metrics(); in active_tasks_count() localVariable
88 assert_eq!(0, metrics.active_tasks_count()); in active_tasks_count()
90 assert_eq!(1, metrics.active_tasks_count()); in active_tasks_count()
94 let metrics = rt.metrics(); in active_tasks_count() localVariable
95 assert_eq!(0, metrics.active_tasks_count()); in active_tasks_count()
97 assert_eq!(1, metrics.active_tasks_count()); in active_tasks_count()
117 assert_eq!(1, rt.metrics().remote_schedule_count()); in remote_schedule_count()
131 assert_eq!(1, rt.metrics().remote_schedule_count()); in remote_schedule_count()
137 let metrics = rt.metrics(); in worker_park_count() localVariable
142 assert!(1 <= metrics.worker_park_count(0)); in worker_park_count()
145 let metrics = rt.metrics(); in worker_park_count() localVariable
150 assert!(1 <= metrics.worker_park_count(0)); in worker_park_count()
151 assert!(1 <= metrics.worker_park_count(1)); in worker_park_count()
160 let metrics = rt.metrics(); in worker_noop_count() localVariable
165 assert!(0 < metrics.worker_noop_count(0)); in worker_noop_count()
168 let metrics = rt.metrics(); in worker_noop_count() localVariable
173 assert!(0 < metrics.worker_noop_count(0)); in worker_noop_count()
174 assert!(0 < metrics.worker_noop_count(1)); in worker_noop_count()
185 let metrics = rt.metrics(); in worker_steal_count() localVariable
210 let n: u64 = (0..metrics.num_workers()) in worker_steal_count()
211 .map(|i| metrics.worker_steal_count(i)) in worker_steal_count()
227 let metrics = rt.metrics(); in worker_poll_count_and_time() localVariable
234 assert_eq!(N, metrics.worker_poll_count(0)); in worker_poll_count_and_time()
236 assert_eq!(Duration::default(), metrics.worker_mean_poll_time(0)); in worker_poll_count_and_time()
239 assert!(!metrics.poll_count_histogram_enabled()); in worker_poll_count_and_time()
241 assert_eq!(0, metrics.poll_count_histogram_bucket_count(0, i)); in worker_poll_count_and_time()
245 let metrics = rt.metrics(); in worker_poll_count_and_time() localVariable
253 let n = (0..metrics.num_workers()) in worker_poll_count_and_time()
254 .map(|i| metrics.worker_poll_count(i)) in worker_poll_count_and_time()
259 let n: Duration = (0..metrics.num_workers()) in worker_poll_count_and_time()
260 .map(|i| metrics.worker_mean_poll_time(i)) in worker_poll_count_and_time()
266 assert!(!metrics.poll_count_histogram_enabled()); in worker_poll_count_and_time()
267 for n in 0..metrics.num_workers() { in worker_poll_count_and_time()
269 assert_eq!(0, metrics.poll_count_histogram_bucket_count(n, i)); in worker_poll_count_and_time()
299 let metrics = rt.metrics(); in worker_poll_count_histogram() localVariable
307 let num_workers = metrics.num_workers(); in worker_poll_count_histogram()
308 let num_buckets = metrics.poll_count_histogram_num_buckets(); in worker_poll_count_histogram()
310 assert!(metrics.poll_count_histogram_enabled()); in worker_poll_count_histogram()
315 .map(|(worker, bucket)| metrics.poll_count_histogram_bucket_count(worker, bucket)) in worker_poll_count_histogram()
333 let metrics = rt.metrics(); in worker_poll_count_histogram_range() localVariable
335 assert_eq!(metrics.poll_count_histogram_bucket_range(0), us(0)..us(50)); in worker_poll_count_histogram_range()
337 metrics.poll_count_histogram_bucket_range(1), in worker_poll_count_histogram_range()
340 assert_eq!(metrics.poll_count_histogram_bucket_range(2), us(100)..max); in worker_poll_count_histogram_range()
350 let metrics = rt.metrics(); in worker_poll_count_histogram_range() localVariable
355 assert_eq!(metrics.poll_count_histogram_bucket_range(0), us(0)..a); in worker_poll_count_histogram_range()
356 assert_eq!(metrics.poll_count_histogram_bucket_range(1), a..b); in worker_poll_count_histogram_range()
357 assert_eq!(metrics.poll_count_histogram_bucket_range(2), b..max); in worker_poll_count_histogram_range()
381 let metrics = rt.metrics(); in worker_poll_count_histogram_disabled_without_explicit_enable() localVariable
382 assert!(!metrics.poll_count_histogram_enabled()); in worker_poll_count_histogram_disabled_without_explicit_enable()
393 let metrics = rt.metrics(); in worker_total_busy_duration() localVariable
407 assert!(zero < metrics.worker_total_busy_duration(0)); in worker_total_busy_duration()
410 let metrics = rt.metrics(); in worker_total_busy_duration() localVariable
424 for i in 0..metrics.num_workers() { in worker_total_busy_duration()
425 assert!(zero < metrics.worker_total_busy_duration(i)); in worker_total_busy_duration()
432 let metrics = rt.metrics(); in worker_local_schedule_count() localVariable
438 assert_eq!(1, metrics.worker_local_schedule_count(0)); in worker_local_schedule_count()
439 assert_eq!(0, metrics.remote_schedule_count()); in worker_local_schedule_count()
442 let metrics = rt.metrics(); in worker_local_schedule_count() localVariable
453 let n: u64 = (0..metrics.num_workers()) in worker_local_schedule_count()
454 .map(|i| metrics.worker_local_schedule_count(i)) in worker_local_schedule_count()
458 assert_eq!(1, metrics.remote_schedule_count()); in worker_local_schedule_count()
465 let metrics = rt.metrics(); in worker_overflow_count() localVariable
496 let n: u64 = (0..metrics.num_workers()) in worker_overflow_count()
497 .map(|i| metrics.worker_overflow_count(i)) in worker_overflow_count()
509 let metrics = rt.metrics(); in injection_queue_depth() localVariable
517 assert_eq!(1, metrics.injection_queue_depth()); in injection_queue_depth()
521 let metrics = rt.metrics(); in injection_queue_depth() localVariable
546 let n = metrics.injection_queue_depth(); in injection_queue_depth()
563 let metrics = rt.metrics(); in worker_local_queue_depth() localVariable
569 assert_eq!(N, metrics.worker_local_queue_depth(0)); in worker_local_queue_depth()
573 let metrics = rt.metrics(); in worker_local_queue_depth() localVariable
597 let n: usize = (0..metrics.num_workers()) in worker_local_queue_depth()
598 .map(|i| metrics.worker_local_queue_depth(i)) in worker_local_queue_depth()
613 let metrics = rt.metrics(); in budget_exhaustion_yield() localVariable
615 assert_eq!(0, metrics.budget_forced_yield_count()); in budget_exhaustion_yield()
634 assert_eq!(1, rt.metrics().budget_forced_yield_count()); in budget_exhaustion_yield()
640 let metrics = rt.metrics(); in budget_exhaustion_yield_with_joins() localVariable
642 assert_eq!(0, metrics.budget_forced_yield_count()); in budget_exhaustion_yield_with_joins()
679 assert_eq!(1, rt.metrics().budget_forced_yield_count()); in budget_exhaustion_yield_with_joins()
686 let metrics = rt.metrics(); in io_driver_fd_count() localVariable
688 assert_eq!(metrics.io_driver_fd_registered_count(), 0); in io_driver_fd_count()
693 assert_eq!(metrics.io_driver_fd_registered_count(), 1); in io_driver_fd_count()
694 assert_eq!(metrics.io_driver_fd_deregistered_count(), 0); in io_driver_fd_count()
698 assert_eq!(metrics.io_driver_fd_deregistered_count(), 1); in io_driver_fd_count()
699 assert_eq!(metrics.io_driver_fd_registered_count(), 1); in io_driver_fd_count()
706 let metrics = rt.metrics(); in io_driver_ready_count() localVariable
711 assert_eq!(metrics.io_driver_ready_count(), 1); in io_driver_ready_count()