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:23 -0700 |
commit | 0b99866b2b74a37a419183e1ff4b1c59974cfa8d (patch) | |
tree | 17bb3bd8546e82494585226c9ac5dfc8a2a2fc37 /AndroidAsync | |
parent | aee01843b7e8d3245a34e876be718370ba95c74f (diff) | |
download | AndroidAsync-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.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 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) { |