Fixed #218.
This commit is contained in:
+2
-1
@@ -92,7 +92,8 @@ impl Network {
|
|||||||
last_events_time = Instant::now();
|
last_events_time = Instant::now();
|
||||||
}
|
}
|
||||||
// Poll Mio for events, blocking until we get an event.
|
// Poll Mio for events, blocking until we get an event.
|
||||||
poll.poll(&mut events, POLL_TIMEOUT).expect("Error polling sockets");
|
poll.poll(&mut events, POLL_TIMEOUT)
|
||||||
|
.unwrap_or_else(|e| warn!("Error polling sockets: {}", e));
|
||||||
if !running.load(Ordering::SeqCst) {
|
if !running.load(Ordering::SeqCst) {
|
||||||
break;
|
break;
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user