more perf logging

This commit is contained in:
Aleksey Kladov 2019-05-29 14:34:21 +03:00
parent 9eef546ca2
commit 6a1e3e59cb

View file

@ -170,7 +170,9 @@ fn main_loop_inner(
let (libdata_sender, libdata_receiver) = unbounded(); let (libdata_sender, libdata_receiver) = unbounded();
loop { loop {
let _p = profile("loop_turn");
state.maybe_collect_garbage(); state.maybe_collect_garbage();
log::trace!("selecting"); log::trace!("selecting");
let event = select! { let event = select! {
recv(msg_receiver) -> msg => match msg { recv(msg_receiver) -> msg => match msg {
@ -184,8 +186,11 @@ fn main_loop_inner(
}, },
recv(libdata_receiver) -> data => Event::Lib(data.unwrap()) recv(libdata_receiver) -> data => Event::Lib(data.unwrap())
}; };
log::info!("loop_turn = {:?}", event); log::info!("loop turn = {:?}", event);
let _p = profile("loop_turn"); let queue_count = pool.queued_count();
if queue_count > 0 {
log::info!("queued count = {}", queue_count);
}
let mut state_changed = false; let mut state_changed = false;
match event { match event {
Event::Task(task) => on_task(task, msg_sender, pending_requests), Event::Task(task) => on_task(task, msg_sender, pending_requests),
@ -468,7 +473,7 @@ impl<'a> PoolDispatcher<'a> {
Ok(self) Ok(self)
} }
fn finish(&mut self) -> ::std::result::Result<u64, RawRequest> { fn finish(&mut self) -> std::result::Result<u64, RawRequest> {
match (self.res.take(), self.req.take()) { match (self.res.take(), self.req.take()) {
(Some(res), None) => Ok(res), (Some(res), None) => Ok(res),
(None, Some(req)) => Err(req), (None, Some(req)) => Err(req),