third_party/deftserver/ioloop-reset.diff - Issue 9314025: Remove fling, deftserver (used only by fling), and commons-codec

Side by Side Diff

Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.

Keyboard Shortcuts

	File
u :	up to issue
j / k :	jump to file after / before current file
J / K :	jump to next file with a comment after / before current file
	Side-by-side diff
i :	toggle intra-line diffs
e :	expand all comments
c :	collapse all comments
s :	toggle showing all comments
n / p :	next / previous diff chunk or comment
N / P :	next / previous comment
<Up> / <Down> :	next / previous line

	Issue
u :	up to list of issues
j / k :	jump to patch after / before current patch
o / <Enter> :	open current patch in side-by-side view
i :	open current patch in unified diff view

	Issue List
j / k :	jump to issue after / before current issue
o / <Enter> :	open current issue

Side by Side Diff: third_party/deftserver/ioloop-reset.diff

Issue 9314025: Remove fling, deftserver (used only by fling), and commons-codec (Closed) Base URL: http://dart.googlecode.com/svn/branches/bleeding_edge/dart/

Patch Set: '' Created 8 years, 10 months ago

Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.

Jump to:

View unified diff | Download patch | Annotate | Revision Log

OLD	NEW
	(Empty)
1 diff --git a/src/main/java/org/deftserver/io/IOLoop.java b/src/main/java/org/def tserver/io/IOLoop.java

2 index f64d3d8..20db7dd 100644

3 --- a/src/main/java/org/deftserver/io/IOLoop.java

4 +++ b/src/main/java/org/deftserver/io/IOLoop.java

5 @@ -7,6 +7,7 @@ import java.nio.channels.ClosedChannelException;

6 import java.nio.channels.SelectableChannel;

7 import java.nio.channels.SelectionKey;

8 import java.nio.channels.Selector;

9 +import java.util.ArrayList;

10 import java.util.Collection;

11 import java.util.HashMap;

12 import java.util.Iterator;

13 @@ -19,6 +20,7 @@ import org.deftserver.io.callback.JMXDebuggableCallbackManager ;

14 import org.deftserver.io.timeout.JMXDebuggableTimeoutManager;

15 import org.deftserver.io.timeout.Timeout;

16 import org.deftserver.io.timeout.TimeoutManager;

17 +import org.deftserver.util.Closeables;

18 import org.deftserver.util.MXBeanUtil;

19 import org.deftserver.web.AsyncCallback;

20 import org.slf4j.Logger;

21 @@ -112,6 +114,12 @@ public class IOLoop implements IOLoopMXBean {

22 running = false;

23 logger.debug("Stopping IOLoop...");

24 }

25 +

26 + public void reset() {

27 + for (SelectableChannel channel : new ArrayList<SelectableChannel>(handlers. keySet())) {

28 + Closeables.closeQuietly(this, channel);

29 + }

30 + }

31

32 /**

33 * Registers a new {@code IOHandler} with this {@code IOLoop}.

OLD	NEW

« no previous file with comments | « third_party/deftserver/README ('k') | no next file » | no next file with comments »