• Home
  • Raw
  • Download

Lines Matching full:metrics

12     assert_eq!(1, rt.metrics().num_workers());  in num_workers()
15 assert_eq!(2, rt.metrics().num_workers()); in num_workers()
21 assert_eq!(0, rt.metrics().num_blocking_threads()); in num_blocking_threads()
23 assert_eq!(1, rt.metrics().num_blocking_threads()); in num_blocking_threads()
29 assert_eq!(0, rt.metrics().num_idle_blocking_threads()); in num_idle_blocking_threads()
41 if 0 == rt.metrics().num_idle_blocking_threads() { in num_idle_blocking_threads()
47 assert_eq!(1, rt.metrics().num_idle_blocking_threads()); in num_idle_blocking_threads()
58 assert_eq!(0, rt.metrics().blocking_queue_depth()); in blocking_queue_depth()
70 assert!(rt.metrics().blocking_queue_depth() > 0); in blocking_queue_depth()
77 assert_eq!(0, rt.metrics().blocking_queue_depth()); in blocking_queue_depth()
96 assert_eq!(1, rt.metrics().remote_schedule_count()); in remote_schedule_count()
110 assert_eq!(1, rt.metrics().remote_schedule_count()); in remote_schedule_count()
116 let metrics = rt.metrics(); in worker_park_count() localVariable
121 assert!(1 <= metrics.worker_park_count(0)); in worker_park_count()
124 let metrics = rt.metrics(); in worker_park_count() localVariable
129 assert!(1 <= metrics.worker_park_count(0)); in worker_park_count()
130 assert!(1 <= metrics.worker_park_count(1)); in worker_park_count()
139 let metrics = rt.metrics(); in worker_noop_count() localVariable
144 assert!(0 < metrics.worker_noop_count(0)); in worker_noop_count()
147 let metrics = rt.metrics(); in worker_noop_count() localVariable
152 assert!(0 < metrics.worker_noop_count(0)); in worker_noop_count()
153 assert!(0 < metrics.worker_noop_count(1)); in worker_noop_count()
164 let metrics = rt.metrics(); in worker_steal_count() localVariable
189 let n: u64 = (0..metrics.num_workers()) in worker_steal_count()
190 .map(|i| metrics.worker_steal_count(i)) in worker_steal_count()
201 let metrics = rt.metrics(); in worker_poll_count() localVariable
208 assert_eq!(N, metrics.worker_poll_count(0)); in worker_poll_count()
211 let metrics = rt.metrics(); in worker_poll_count() localVariable
219 let n = (0..metrics.num_workers()) in worker_poll_count()
220 .map(|i| metrics.worker_poll_count(i)) in worker_poll_count()
233 let metrics = rt.metrics(); in worker_total_busy_duration() localVariable
247 assert!(zero < metrics.worker_total_busy_duration(0)); in worker_total_busy_duration()
250 let metrics = rt.metrics(); in worker_total_busy_duration() localVariable
264 for i in 0..metrics.num_workers() { in worker_total_busy_duration()
265 assert!(zero < metrics.worker_total_busy_duration(i)); in worker_total_busy_duration()
272 let metrics = rt.metrics(); in worker_local_schedule_count() localVariable
278 assert_eq!(1, metrics.worker_local_schedule_count(0)); in worker_local_schedule_count()
279 assert_eq!(0, metrics.remote_schedule_count()); in worker_local_schedule_count()
282 let metrics = rt.metrics(); in worker_local_schedule_count() localVariable
293 let n: u64 = (0..metrics.num_workers()) in worker_local_schedule_count()
294 .map(|i| metrics.worker_local_schedule_count(i)) in worker_local_schedule_count()
298 assert_eq!(1, metrics.remote_schedule_count()); in worker_local_schedule_count()
305 let metrics = rt.metrics(); in worker_overflow_count() localVariable
336 let n: u64 = (0..metrics.num_workers()) in worker_overflow_count()
337 .map(|i| metrics.worker_overflow_count(i)) in worker_overflow_count()
349 let metrics = rt.metrics(); in injection_queue_depth() localVariable
357 assert_eq!(1, metrics.injection_queue_depth()); in injection_queue_depth()
361 let metrics = rt.metrics(); in injection_queue_depth() localVariable
376 let n = metrics.injection_queue_depth(); in injection_queue_depth()
389 let metrics = rt.metrics(); in worker_local_queue_depth() localVariable
395 assert_eq!(N, metrics.worker_local_queue_depth(0)); in worker_local_queue_depth()
399 let metrics = rt.metrics(); in worker_local_queue_depth() localVariable
423 let n: usize = (0..metrics.num_workers()) in worker_local_queue_depth()
424 .map(|i| metrics.worker_local_queue_depth(i)) in worker_local_queue_depth()
440 let metrics = rt.metrics(); in io_driver_fd_count() localVariable
442 assert_eq!(metrics.io_driver_fd_registered_count(), 0); in io_driver_fd_count()
447 assert_eq!(metrics.io_driver_fd_registered_count(), 1); in io_driver_fd_count()
448 assert_eq!(metrics.io_driver_fd_deregistered_count(), 0); in io_driver_fd_count()
452 assert_eq!(metrics.io_driver_fd_deregistered_count(), 1); in io_driver_fd_count()
453 assert_eq!(metrics.io_driver_fd_registered_count(), 1); in io_driver_fd_count()
460 let metrics = rt.metrics(); in io_driver_ready_count() localVariable
465 assert_eq!(metrics.io_driver_ready_count(), 1); in io_driver_ready_count()