You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@tomcat.apache.org by ma...@apache.org on 2012/03/04 11:18:25 UTC
svn commit: r1296775 -
/tomcat/tc7.0.x/trunk/java/org/apache/coyote/http11/Http11NioProtocol.java
Author: markt
Date: Sun Mar 4 10:18:25 2012
New Revision: 1296775
URL: http://svn.apache.org/viewvc?rev=1296775&view=rev
Log:
Remove unused imports
Modified:
tomcat/tc7.0.x/trunk/java/org/apache/coyote/http11/Http11NioProtocol.java
Modified: tomcat/tc7.0.x/trunk/java/org/apache/coyote/http11/Http11NioProtocol.java
URL: http://svn.apache.org/viewvc/tomcat/tc7.0.x/trunk/java/org/apache/coyote/http11/Http11NioProtocol.java?rev=1296775&r1=1296774&r2=1296775&view=diff
==============================================================================
--- tomcat/tc7.0.x/trunk/java/org/apache/coyote/http11/Http11NioProtocol.java (original)
+++ tomcat/tc7.0.x/trunk/java/org/apache/coyote/http11/Http11NioProtocol.java Sun Mar 4 10:18:25 2012
@@ -16,7 +16,6 @@
*/
package org.apache.coyote.http11;
-import java.nio.channels.SelectionKey;
import java.nio.channels.SocketChannel;
import java.util.Iterator;
@@ -27,7 +26,6 @@ import org.apache.tomcat.util.net.Abstra
import org.apache.tomcat.util.net.NioChannel;
import org.apache.tomcat.util.net.NioEndpoint;
import org.apache.tomcat.util.net.NioEndpoint.Handler;
-import org.apache.tomcat.util.net.NioEndpoint.KeyAttachment;
import org.apache.tomcat.util.net.SSLImplementation;
import org.apache.tomcat.util.net.SecureNioChannel;
import org.apache.tomcat.util.net.SocketWrapper;
@@ -43,13 +41,13 @@ import org.apache.tomcat.util.net.Socket
* @author Filip Hanik
*/
public class Http11NioProtocol extends AbstractHttp11JsseProtocol {
-
+
private static final Log log = LogFactory.getLog(Http11NioProtocol.class);
@Override
protected Log getLog() { return log; }
-
+
@Override
protected AbstractEndpoint.Handler getHandler() {
@@ -73,7 +71,7 @@ public class Http11NioProtocol extends A
// -------------------- Properties--------------------
-
+
private Http11ConnectionHandler cHandler;
// -------------------- Pool setup --------------------
@@ -81,19 +79,19 @@ public class Http11NioProtocol extends A
public void setPollerThreadCount(int count) {
((NioEndpoint)endpoint).setPollerThreadCount(count);
}
-
+
public int getPollerThreadCount() {
return ((NioEndpoint)endpoint).getPollerThreadCount();
}
-
+
public void setSelectorTimeout(long timeout) {
((NioEndpoint)endpoint).setSelectorTimeout(timeout);
}
-
+
public long getSelectorTimeout() {
return ((NioEndpoint)endpoint).getSelectorTimeout();
}
-
+
public void setAcceptorThreadPriority(int threadPriority) {
((NioEndpoint)endpoint).setAcceptorThreadPriority(threadPriority);
}
@@ -105,12 +103,12 @@ public class Http11NioProtocol extends A
public int getAcceptorThreadPriority() {
return ((NioEndpoint)endpoint).getAcceptorThreadPriority();
}
-
+
public int getPollerThreadPriority() {
return ((NioEndpoint)endpoint).getThreadPriority();
}
-
-
+
+
public boolean getUseSendfile() {
return ((NioEndpoint)endpoint).getUseSendfile();
}
@@ -118,7 +116,7 @@ public class Http11NioProtocol extends A
public void setUseSendfile(boolean useSendfile) {
((NioEndpoint)endpoint).setUseSendfile(useSendfile);
}
-
+
// -------------------- Tcp setup --------------------
public void setOomParachute(int oomParachute) {
((NioEndpoint)endpoint).setOomParachute(oomParachute);
@@ -143,7 +141,7 @@ public class Http11NioProtocol extends A
Http11ConnectionHandler(Http11NioProtocol proto) {
this.proto = proto;
}
-
+
@Override
protected AbstractProtocol getProtocol() {
return proto;
@@ -153,8 +151,8 @@ public class Http11NioProtocol extends A
protected Log getLog() {
return log;
}
-
-
+
+
@Override
public SSLImplementation getSslImplementation() {
return proto.sslImplementation;
@@ -166,7 +164,7 @@ public class Http11NioProtocol extends A
*/
@Override
public void release(SocketChannel socket) {
- if (log.isDebugEnabled())
+ if (log.isDebugEnabled())
log.debug("Iterating through our connections to release a socket channel:"+socket);
boolean released = false;
Iterator<java.util.Map.Entry<NioChannel, Http11NioProcessor>> it = connections.entrySet().iterator();
@@ -181,10 +179,10 @@ public class Http11NioProtocol extends A
break;
}
}
- if (log.isDebugEnabled())
+ if (log.isDebugEnabled())
log.debug("Done iterating through our connections to release a socket channel:"+socket +" released:"+released);
}
-
+
/**
* Expected to be used by the Poller to release resources on socket
* close, errors etc.
@@ -203,7 +201,7 @@ public class Http11NioProtocol extends A
/**
* Expected to be used by the handler once the processor is no longer
* required.
- *
+ *
* @param socket
* @param processor
* @param isSocketClosing Not used in HTTP
@@ -241,7 +239,7 @@ public class Http11NioProtocol extends A
protected void longPoll(SocketWrapper<NioChannel> socket,
Http11NioProcessor processor) {
connections.put(socket.getSocket(), processor);
-
+
if (processor.isAsync()) {
socket.setAsync(true);
} else {
---------------------------------------------------------------------
To unsubscribe, e-mail: dev-unsubscribe@tomcat.apache.org
For additional commands, e-mail: dev-help@tomcat.apache.org