Nothing was reading this. Remove it. It can always be added back in later if we need...
authormarkt <markt@13f79535-47bb-0310-9956-ffa450edef68>
Fri, 17 Sep 2010 16:43:33 +0000 (16:43 +0000)
committermarkt <markt@13f79535-47bb-0310-9956-ffa450edef68>
Fri, 17 Sep 2010 16:43:33 +0000 (16:43 +0000)
git-svn-id: https://svn.apache.org/repos/asf/tomcat/trunk@998195 13f79535-47bb-0310-9956-ffa450edef68

java/org/apache/tomcat/util/net/NioEndpoint.java

index 4004c3d..6cb20ab 100644 (file)
@@ -120,11 +120,6 @@ public class NioEndpoint extends AbstractEndpoint {
     long lastParachuteCheck = System.currentTimeMillis();
     
     /**
-     * Keep track of how many threads are in use
-     */
-    protected AtomicInteger activeSocketProcessors = new AtomicInteger(0);
-    
-    /**
      * 
      */
     protected volatile CountDownLatch stopLatch = null;
@@ -1469,7 +1464,6 @@ public class NioEndpoint extends AbstractEndpoint {
         }
          
         public void run() {
-            NioEndpoint.this.activeSocketProcessors.addAndGet(1);
             SelectionKey key = null;
             try {
                 key = socket.getIOChannel().keyFor(socket.getPoller().getSelector());
@@ -1543,7 +1537,7 @@ public class NioEndpoint extends AbstractEndpoint {
                 status = null;
                 //return to cache
                 processorCache.offer(this);
-                NioEndpoint.this.activeSocketProcessors.addAndGet(-1);            }
+            }
         }
 
     }