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:11 -0700
commitddae2e320ff07584fcf21d65872639fdc24bae9b (patch)
tree7d37b4e1ce3df6651d19669b419dce32de66a984 /AndroidAsync
parent5b8aaf7ac110d11572a7212fd70d0bcd8e6f6db9 (diff)
downloadAndroidAsync-ddae2e320ff07584fcf21d65872639fdc24bae9b.tar.gz
AndroidAsync-ddae2e320ff07584fcf21d65872639fdc24bae9b.tar.bz2
AndroidAsync-ddae2e320ff07584fcf21d65872639fdc24bae9b.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 d6f95e0..d7b9f84 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) {