diff options
author | Koushik Dutta <koushd@gmail.com> | 2014-09-09 00:37:11 -0700 |
---|---|---|
committer | Koushik Dutta <koushd@gmail.com> | 2014-09-09 00:37:11 -0700 |
commit | ddae2e320ff07584fcf21d65872639fdc24bae9b (patch) | |
tree | 7d37b4e1ce3df6651d19669b419dce32de66a984 /AndroidAsync | |
parent | 5b8aaf7ac110d11572a7212fd70d0bcd8e6f6db9 (diff) | |
download | AndroidAsync-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.java | 4 |
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) { |