()
| 9 | use crate::storage::{device, multicast}; |
| 10 | |
| 11 | pub async fn class_b_c_scheduler_loop() { |
| 12 | let conf = config::get(); |
| 13 | |
| 14 | loop { |
| 15 | trace!("Starting class_b_c_scheduler_loop run"); |
| 16 | |
| 17 | if let Err(err) = schedule_device_queue_batch(conf.network.scheduler.batch_size).await { |
| 18 | error!(error = %err, "Scheduling device-queue batch failed"); |
| 19 | } else { |
| 20 | trace!("class_b_c_scheduler_loop completed successfully"); |
| 21 | } |
| 22 | |
| 23 | sleep(conf.network.scheduler.interval).await; |
| 24 | } |
| 25 | } |
| 26 | |
| 27 | pub async fn multicast_group_queue_scheduler_loop() { |
| 28 | let conf = config::get(); |
no test coverage detected