aboutsummaryrefslogtreecommitdiffstats
path: root/AndroidAsync
diff options
context:
space:
mode:
authorKoushik Dutta <koushd@gmail.com>2014-09-09 00:37:11 -0700
committerKoushik Dutta <koushd@gmail.com>2014-09-09 00:37:23 -0700
commit0b99866b2b74a37a419183e1ff4b1c59974cfa8d (patch)
tree17bb3bd8546e82494585226c9ac5dfc8a2a2fc37 /AndroidAsync
parentaee01843b7e8d3245a34e876be718370ba95c74f (diff)
downloadAndroidAsync-0b99866b2b74a37a419183e1ff4b1c59974cfa8d.tar.gz
AndroidAsync-0b99866b2b74a37a419183e1ff4b1c59974cfa8d.tar.bz2
AndroidAsync-0b99866b2b74a37a419183e1ff4b1c59974cfa8d.zip
watch for selector exceptions.
Diffstat (limited to 'AndroidAsync')
-rw-r--r--AndroidAsync/src/com/koushikdutta/async/AsyncServer.java4
1 files changed, 4 insertions, 0 deletions
diff --git a/AndroidAsync/src/com/koushikdutta/async/AsyncServer.java b/AndroidAsync/src/com/koushikdutta/async/AsyncServer.java
index 450dc5b..be4a363 100644
--- a/AndroidAsync/src/com/koushikdutta/async/AsyncServer.java
+++ b/AndroidAsync/src/com/koushikdutta/async/AsyncServer.java
@@ -608,6 +608,10 @@ public class AsyncServer {
runLoop(server, selector, queue);
}
catch (ClosedSelectorException e) {
+ StreamUtility.closeQuietly(selector.getSelector());
+ }
+ catch (AsyncSelectorException e) {
+ StreamUtility.closeQuietly(selector.getSelector());
}
// see if we keep looping, this must be in a synchronized block since the queue is accessed.
synchronized (server) {