tomcat-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ma...@apache.org
Subject svn commit: r979872 - /tomcat/trunk/java/org/apache/tomcat/util/net/AprEndpoint.java
Date Tue, 27 Jul 2010 21:05:16 GMT
Author: markt
Date: Tue Jul 27 21:05:16 2010
New Revision: 979872

URL: http://svn.apache.org/viewvc?rev=979872&view=rev
Log:
Code clean-up
Remove deps on o.a.catalina
Fix a couple of Eclipse nags

Modified:
    tomcat/trunk/java/org/apache/tomcat/util/net/AprEndpoint.java

Modified: tomcat/trunk/java/org/apache/tomcat/util/net/AprEndpoint.java
URL: http://svn.apache.org/viewvc/tomcat/trunk/java/org/apache/tomcat/util/net/AprEndpoint.java?rev=979872&r1=979871&r2=979872&view=diff
==============================================================================
--- tomcat/trunk/java/org/apache/tomcat/util/net/AprEndpoint.java (original)
+++ tomcat/trunk/java/org/apache/tomcat/util/net/AprEndpoint.java Tue Jul 27 21:05:16 2010
@@ -25,7 +25,6 @@ import java.util.ArrayList;
 import java.util.HashMap;
 import java.util.concurrent.RejectedExecutionException;
 
-import org.apache.catalina.Globals;
 import org.apache.juli.logging.Log;
 import org.apache.juli.logging.LogFactory;
 import org.apache.tomcat.jni.Address;
@@ -40,7 +39,6 @@ import org.apache.tomcat.jni.SSLContext;
 import org.apache.tomcat.jni.SSLSocket;
 import org.apache.tomcat.jni.Socket;
 import org.apache.tomcat.jni.Status;
-import org.apache.catalina.core.AprLifecycleListener;
 
 
 /**
@@ -66,6 +64,8 @@ public class AprEndpoint extends Abstrac
 
     private static final Log log = LogFactory.getLog(AprEndpoint.class);
 
+    private static final boolean IS_SECURITY_ENABLED =
+        (System.getSecurityManager() != null);
 
     // ----------------------------------------------------------------- Fields
     /**
@@ -323,13 +323,13 @@ public class AprEndpoint extends Abstrac
     public int getKeepAliveCount() {
         if (pollers == null) {
             return 0;
-        } else {
-            int keepAliveCount = 0;
-            for (int i = 0; i < pollers.length; i++) {
-                keepAliveCount += pollers[i].getKeepAliveCount();
-            }
-            return keepAliveCount;
         }
+
+        int keepAliveCount = 0;
+        for (int i = 0; i < pollers.length; i++) {
+            keepAliveCount += pollers[i].getKeepAliveCount();
+        }
+        return keepAliveCount;
     }
 
 
@@ -339,13 +339,13 @@ public class AprEndpoint extends Abstrac
     public int getSendfileCount() {
         if (sendfiles == null) {
             return 0;
-        } else {
-            int sendfileCount = 0;
-            for (int i = 0; i < sendfiles.length; i++) {
-                sendfileCount += sendfiles[i].getSendfileCount();
-            }
-            return sendfileCount;
         }
+        
+        int sendfileCount = 0;
+        for (int i = 0; i < sendfiles.length; i++) {
+            sendfileCount += sendfiles[i].getSendfileCount();
+        }
+        return sendfileCount;
     }
 
 
@@ -361,12 +361,14 @@ public class AprEndpoint extends Abstrac
 
         if (initialized)
             return;
-        if (!AprLifecycleListener.isAprAvailable()) {
+
+        // Create the root APR memory pool
+        try {
+            rootPool = Pool.create(0);
+        } catch (UnsatisfiedLinkError e) {
             throw new Exception(sm.getString("endpoint.init.notavail"));
         }
-        
-        // Create the root APR memory pool
-        rootPool = Pool.create(0);
+
         // Create the pool for the server socket
         serverSockPool = Pool.create(rootPool);
         // Create the APR address that will be bound
@@ -840,7 +842,7 @@ public class AprEndpoint extends Abstrac
                     new SocketEventProcessor(socket, status);
                 ClassLoader loader = Thread.currentThread().getContextClassLoader();
                 try {
-                    if (Globals.IS_SECURITY_ENABLED) {
+                    if (IS_SECURITY_ENABLED) {
                         PrivilegedAction<Void> pa = new PrivilegedSetTccl(
                                 getClass().getClassLoader());
                         AccessController.doPrivileged(pa);
@@ -850,7 +852,7 @@ public class AprEndpoint extends Abstrac
                     }                
                     getExecutor().execute(proc);
                 } finally {
-                    if (Globals.IS_SECURITY_ENABLED) {
+                    if (IS_SECURITY_ENABLED) {
                         PrivilegedAction<Void> pa = new PrivilegedSetTccl(loader);
                         AccessController.doPrivileged(pa);
                     } else {
@@ -1280,15 +1282,15 @@ public class AprEndpoint extends Abstrac
                             // Break the loop and add the socket to poller.
                             break;
                         }
-                    } else {
-                        data.pos = data.pos + nw;
-                        if (data.pos >= data.end) {
-                            // Entire file has been sent
-                            Pool.destroy(data.fdpool);
-                            // Set back socket to blocking mode
-                            Socket.timeoutSet(data.socket, socketProperties.getSoTimeout()
* 1000);
-                            return true;
-                        }
+                    }
+
+                    data.pos = data.pos + nw;
+                    if (data.pos >= data.end) {
+                        // Entire file has been sent
+                        Pool.destroy(data.fdpool);
+                        // Set back socket to blocking mode
+                        Socket.timeoutSet(data.socket, socketProperties.getSoTimeout() *
1000);
+                        return true;
                     }
                 }
             } catch (Exception e) {



---------------------------------------------------------------------
To unsubscribe, e-mail: dev-unsubscribe@tomcat.apache.org
For additional commands, e-mail: dev-help@tomcat.apache.org


Mime
View raw message