Add a deadlock detection thread

Cargo.toml

@@ -106,6 +106,7 @@ evm-debug-tests = ["ethcore/evm-debug-tests"]
 slow-blocks = ["ethcore/slow-blocks"]
 secretstore = ["ethcore-secretstore"]
 final = ["parity-version/final"]
+deadlock_detection = ["parking_lot/deadlock_detection"]
 
 [lib]
 path = "parity/lib.rs"

parity/lib.rs

@@ -141,6 +141,37 @@ fn print_hash_of(maybe_file: Option<String>) -> Result<String, String> {
 	}
 }
 
+fn run_deadlock_detection_thread() {
+	#[cfg(feature = "deadlock_detection")]
+	{ // only for #[cfg]
+		use std::thread;
+		use std::time::Duration;
+		use parking_lot::deadlock;
+
+		info!("Starting deadlock detection thread.");
+		// Create a background thread which checks for deadlocks every 10s
+		thread::spawn(move || {
+			loop {
+				thread::sleep(Duration::from_secs(10));
+				let deadlocks = deadlock::check_deadlock();
+				if deadlocks.is_empty() {
+					continue;
+				}
+
+				warn!("{} {} detected", deadlocks.len(), Style::new().bold().paint("deadlock(s)"));
+				for (i, threads) in deadlocks.iter().enumerate() {
+					warn!("{} #{}", Style::new().bold().paint("Deadlock"), i);
+					for t in threads {
+						warn!("Thread Id {:#?}", t.thread_id());
+						warn!("{:#?}", t.backtrace());
+					}
+				}
+			}
+		});
+	}
+}
+
+
 /// Action that Parity performed when running `start`.
 pub enum ExecutionAction {
 	/// The execution didn't require starting a node, and thus has finished.
@@ -161,6 +192,8 @@ fn execute<Cr, Rr>(command: Execute, on_client_rq: Cr, on_updater_rq: Rr) -> Res
 	// 		they want
 	let logger = setup_log(&command.logger).expect("Logger is initialized only once; qed");
 
+	run_deadlock_detection_thread();
+
 	match command.cmd {
 		Cmd::Run(run_cmd) => {
 			if run_cmd.ui_conf.enabled && !run_cmd.ui_conf.info_page_only {