Now get queue names from stats.
parent
e265ad2877
commit
927c0fbe3b
15
src/main.rs
15
src/main.rs
|
@ -22,18 +22,19 @@ impl DumbQueue {
|
|||
|
||||
#[get("/")]
|
||||
fn index(dumb_queue: &State<DumbQueue>) -> String {
|
||||
let map_reader = &dumb_queue.queue_map.read().unwrap();
|
||||
let queue_reader = &dumb_queue.queues.read().unwrap();
|
||||
let queue_count = queue_reader.len();
|
||||
let mut stats : Vec<usize> = vec!();
|
||||
|
||||
for q in 0..queue_count {
|
||||
let queue = &queue_reader[q];
|
||||
let reader = queue.read().unwrap();
|
||||
stats.push(reader.len());
|
||||
let queue_count = queue_reader.len();
|
||||
let mut stats : HashMap<String, usize> = HashMap::new();
|
||||
|
||||
for (key,val) in map_reader.iter() {
|
||||
let reader = queue_reader[*val].read().unwrap();
|
||||
stats.insert(key.to_string(), reader.len());
|
||||
drop(reader);
|
||||
}
|
||||
|
||||
format!("Total queues: {}\n {:?}", queue_count, stats)
|
||||
format!("Total queues: {}\nCounts: {:?}", queue_count, stats)
|
||||
}
|
||||
|
||||
|
||||
|
|
Loading…
Reference in New Issue