Skip to content
This repository has been archived by the owner on Nov 6, 2020. It is now read-only.

Commit

Permalink
Typo and logging
Browse files Browse the repository at this point in the history
  • Loading branch information
arkpar committed Oct 31, 2016
1 parent af2f00a commit bca041a
Showing 1 changed file with 4 additions and 2 deletions.
6 changes: 4 additions & 2 deletions util/io/src/service.rs
Original file line number Diff line number Diff line change
Expand Up @@ -399,7 +399,7 @@ impl<Message> IoService<Message> where Message: Send + Sync + Clone + 'static {
let thread = thread::spawn(move || {
let p = panic.clone();
panic.catch_panic(move || {
IoManager::<Message>::start(p, &mut event_loop, h).expect("Error startting IO service");
IoManager::<Message>::start(p, &mut event_loop, h).expect("Error starting IO service");
}).expect("Error starting panic handler")
});
Ok(IoService {
Expand Down Expand Up @@ -435,7 +435,9 @@ impl<Message> Drop for IoService<Message> where Message: Send + Sync + Clone {
trace!(target: "shutdown", "[IoService] Closing...");
self.host_channel.lock().send(IoMessage::Shutdown).unwrap_or_else(|e| warn!("Error on IO service shutdown: {:?}", e));
if let Some(thread) = self.thread.take() {
thread.join().ok();
thread.join().unwrap_or_else(|e| {
debug!(target: "shutdown", "Error joining IO service event loop thread: {:?}", e);
});
}
trace!(target: "shutdown", "[IoService] Closed.");
}
Expand Down

0 comments on commit bca041a

Please sign in to comment.