Fixed IO service shutdown (#3286)

openethereum · Nov 8, 2016 · 2da4368 · 2da4368
1 parent b3e0897
commit 2da4368
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/util/io/src/service.rs b/util/io/src/service.rs
@@ -433,6 +433,9 @@ impl<Message> IoService<Message> where Message: Send + Sync + Clone + 'static {
 impl<Message> Drop for IoService<Message> where Message: Send + Sync + Clone {
 	fn drop(&mut self) {
 		trace!(target: "shutdown", "[IoService] Closing...");
+		// Clear handlers so that shared pointers are not stuck on stack
+		// in Channel::send_sync
+		self.handlers.write().clear();
 		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().unwrap_or_else(|e| {