Mercurial Hosting > luan
changeset 942:c157a786ed0b
remove Timeout.Task
author | Franklin Schmidt <fschmidt@gmail.com> |
---|---|
date | Tue, 11 Oct 2016 00:41:39 -0600 |
parents | c948f674a2d5 |
children | 96f60ce98949 |
files | src/org/eclipse/jetty/io/nio/SelectorManager.java src/org/eclipse/jetty/util/thread/Timeout.java |
diffstat | 2 files changed, 0 insertions(+), 116 deletions(-) [+] |
line wrap: on
line diff
diff -r c948f674a2d5 -r c157a786ed0b src/org/eclipse/jetty/io/nio/SelectorManager.java --- a/src/org/eclipse/jetty/io/nio/SelectorManager.java Tue Oct 11 00:34:19 2016 -0600 +++ b/src/org/eclipse/jetty/io/nio/SelectorManager.java Tue Oct 11 00:41:39 2016 -0600 @@ -47,7 +47,6 @@ import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.eclipse.jetty.util.thread.Timeout; -import org.eclipse.jetty.util.thread.Timeout.Task; /* ------------------------------------------------------------ */ @@ -498,11 +497,8 @@ // workout how long to wait in select _timeout.setNow(now); - long to_next_timeout=_timeout.getTimeToNext(); long wait = _changes.size()==0?__IDLE_TICK:0L; - if (wait > 0 && to_next_timeout >= 0 && wait > to_next_timeout) - wait = to_next_timeout; // If we should wait with a select if (wait>0) @@ -631,13 +627,6 @@ now=System.currentTimeMillis(); _timeout.setNow(now); - Task task = _timeout.expired(); - while (task!=null) - { - if (task instanceof Runnable) - execute((Runnable)task); - task = _timeout.expired(); - } // Idle tick if (now-_idleTick>__IDLE_TICK) @@ -814,8 +803,6 @@ } } - - _timeout.cancelAll(); try { selector=_selector;
diff -r c948f674a2d5 -r c157a786ed0b src/org/eclipse/jetty/util/thread/Timeout.java --- a/src/org/eclipse/jetty/util/thread/Timeout.java Tue Oct 11 00:34:19 2016 -0600 +++ b/src/org/eclipse/jetty/util/thread/Timeout.java Tue Oct 11 00:41:39 2016 -0600 @@ -37,13 +37,11 @@ private Object _lock; private long _duration; private volatile long _now=System.currentTimeMillis(); - private Task _head=new Task(); /* ------------------------------------------------------------ */ public Timeout(Object lock) { _lock=lock; - _head._timeout=this; } /* ------------------------------------------------------------ */ @@ -70,114 +68,13 @@ return _now=System.currentTimeMillis(); } - /* ------------------------------------------------------------ */ public long getNow() { return _now; } - /* ------------------------------------------------------------ */ public void setNow(long now) { _now=now; } - - /* ------------------------------------------------------------ */ - /** Get an expired tasks. - * This is called instead of {@link #tick()} to obtain the next - * expired Task, but without calling it's {@link Task#expire()} or - * {@link Task#expired()} methods. - * - * @return the next expired task or null. - */ - - public Task expired() - { - synchronized (_lock) - { - long _expiry = _now-_duration; - if (_head._next!=_head) - { - Task task = _head._next; - if (task._timestamp>_expiry) - return null; - - task.unlink(); - task._expired=true; - return task; - } - return null; - } - } - - public void cancelAll() - { - synchronized (_lock) - { - _head._next=_head._prev=_head; - } - } - - public long getTimeToNext() - { - synchronized (_lock) - { - if (_head._next==_head) - return -1; - long to_next = _duration+_head._next._timestamp-_now; - return to_next<0?0:to_next; - } - } - - @Override - public String toString() - { - StringBuffer buf = new StringBuffer(); - buf.append(super.toString()); - - Task task = _head._next; - while (task!=_head) - { - buf.append("-->"); - buf.append(task); - task=task._next; - } - - return buf.toString(); - } - - /* ------------------------------------------------------------ */ - /* ------------------------------------------------------------ */ - /* ------------------------------------------------------------ */ - /* ------------------------------------------------------------ */ - /** Task. - * The base class for scheduled timeouts. This class should be - * extended to implement the expire() method, which is called if the - * timeout expires. - * - * - * - */ - public static class Task - { - Task _next; - Task _prev; - Timeout _timeout; - long _timestamp=0; - boolean _expired=false; - - protected Task() - { - _next=_prev=this; - } - - private void unlink() - { - _next._prev=_prev; - _prev._next=_next; - _next=_prev=this; - _expired=false; - } - } - }