Added basic stats.
parent
0fc4f16e62
commit
0b01d7a550
15
src/main.rs
15
src/main.rs
|
@ -21,8 +21,19 @@ impl DumbQueue {
|
|||
#[macro_use] extern crate rocket;
|
||||
|
||||
#[get("/")]
|
||||
fn index() -> &'static str {
|
||||
"Hello, world!"
|
||||
fn index(dumb_queue: &State<DumbQueue>) -> String {
|
||||
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());
|
||||
drop(reader);
|
||||
}
|
||||
|
||||
format!("Total queues: {}\n {:?}", queue_count, stats)
|
||||
}
|
||||
|
||||
|
||||
|
|
Loading…
Reference in New Issue