(self)
| 2654 | |
| 2655 | impl QueueBuilder { |
| 2656 | fn build(self) -> (QueueParameters, RateLimiter) { |
| 2657 | let Queue { |
| 2658 | manager, |
| 2659 | backlog, |
| 2660 | max_workers_per_alloc, |
| 2661 | timelimit, |
| 2662 | max_worker_count, |
| 2663 | limiter_max_alloc_fails, |
| 2664 | limiter_max_submit_fails, |
| 2665 | limiter_delays, |
| 2666 | min_utilization, |
| 2667 | cli_resources, |
| 2668 | } = self.finish().unwrap(); |
| 2669 | let params = QueueParameters { |
| 2670 | manager, |
| 2671 | max_workers_per_alloc, |
| 2672 | backlog, |
| 2673 | timelimit, |
| 2674 | name: None, |
| 2675 | max_worker_count, |
| 2676 | min_utilization, |
| 2677 | additional_args: vec![], |
| 2678 | worker_start_cmd: None, |
| 2679 | worker_stop_cmd: None, |
| 2680 | worker_wrap_cmd: None, |
| 2681 | cli_resource_descriptor: cli_resources, |
| 2682 | worker_args: vec![], |
| 2683 | idle_timeout: None, |
| 2684 | }; |
| 2685 | |
| 2686 | ( |
| 2687 | params, |
| 2688 | RateLimiter::new( |
| 2689 | limiter_delays, |
| 2690 | limiter_max_submit_fails, |
| 2691 | limiter_max_alloc_fails, |
| 2692 | ), |
| 2693 | ) |
| 2694 | } |
| 2695 | } |
| 2696 | |
| 2697 | fn lost_worker_normal(reason: LostWorkerReason) -> LostWorkerDetails { |
no test coverage detected