From 9d72d03c2da260a3349717c1d28a007bbfd60fd2 Mon Sep 17 00:00:00 2001 From: fhanik Date: Fri, 13 Apr 2007 19:16:08 +0000 Subject: [PATCH] remove redundant calls, easier to track usage git-svn-id: https://svn.apache.org/repos/asf/tomcat/tc6.0.x/trunk@528605 13f79535-47bb-0310-9956-ffa450edef68 --- java/org/apache/tomcat/util/net/NioEndpoint.java | 15 ++++++--------- 1 file changed, 6 insertions(+), 9 deletions(-) diff --git a/java/org/apache/tomcat/util/net/NioEndpoint.java b/java/org/apache/tomcat/util/net/NioEndpoint.java index 122f704df..8b0c7f35c 100644 --- a/java/org/apache/tomcat/util/net/NioEndpoint.java +++ b/java/org/apache/tomcat/util/net/NioEndpoint.java @@ -1381,9 +1381,6 @@ public class NioEndpoint { else r.reset(socket,ka,OP_REGISTER); addEvent(r); } - public void cancelledKey(SelectionKey key, SocketStatus status) { - cancelledKey(key, status, true); - } public void cancelledKey(SelectionKey key, SocketStatus status, boolean dispatch) { try { if ( key == null ) return;//nothing to do @@ -1533,10 +1530,10 @@ public class NioEndpoint { } } else { //invalid key - cancelledKey(sk, SocketStatus.ERROR); + cancelledKey(sk, SocketStatus.ERROR,false); } } catch ( CancelledKeyException ckx ) { - cancelledKey(sk, SocketStatus.ERROR); + cancelledKey(sk, SocketStatus.ERROR,false); } catch (Throwable t) { log.error("",t); } @@ -1607,9 +1604,9 @@ public class NioEndpoint { try { KeyAttachment ka = (KeyAttachment) key.attachment(); if ( ka == null ) { - cancelledKey(key, SocketStatus.ERROR); //we don't support any keys without attachments + cancelledKey(key, SocketStatus.ERROR,false); //we don't support any keys without attachments } else if ( ka.getError() ) { - cancelledKey(key, SocketStatus.ERROR); + cancelledKey(key, SocketStatus.ERROR,true); }else if ((ka.interestOps()&SelectionKey.OP_READ) == SelectionKey.OP_READ) { //only timeout sockets that we are waiting for a read from long delta = now - ka.getLastAccess(); @@ -1622,14 +1619,14 @@ public class NioEndpoint { } else if (isTimedout) { key.interestOps(0); ka.interestOps(0); //avoid duplicate timeout calls - cancelledKey(key, SocketStatus.TIMEOUT); + cancelledKey(key, SocketStatus.TIMEOUT,true); } else { long nextTime = now+(timeout-delta); nextExpiration = (nextTime < nextExpiration)?nextTime:nextExpiration; } }//end if }catch ( CancelledKeyException ckx ) { - cancelledKey(key, SocketStatus.ERROR); + cancelledKey(key, SocketStatus.ERROR,false); } }//for if ( log.isDebugEnabled() ) log.debug("Poller processed "+keycount+" keys through timeout"); -- 2.11.0