directory-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From trus...@apache.org
Subject svn commit: r220233 - /directory/network/trunk/src/java/org/apache/mina/filter/ThreadPoolFilter.java
Date Fri, 22 Jul 2005 03:38:33 GMT
Author: trustin
Date: Thu Jul 21 20:38:32 2005
New Revision: 220233

URL: http://svn.apache.org/viewcvs?rev=220233&view=rev
Log:
Removed debugging printlns.

Modified:
    directory/network/trunk/src/java/org/apache/mina/filter/ThreadPoolFilter.java

Modified: directory/network/trunk/src/java/org/apache/mina/filter/ThreadPoolFilter.java
URL: http://svn.apache.org/viewcvs/directory/network/trunk/src/java/org/apache/mina/filter/ThreadPoolFilter.java?rev=220233&r1=220232&r2=220233&view=diff
==============================================================================
--- directory/network/trunk/src/java/org/apache/mina/filter/ThreadPoolFilter.java (original)
+++ directory/network/trunk/src/java/org/apache/mina/filter/ThreadPoolFilter.java Thu Jul
21 20:38:32 2005
@@ -165,8 +165,7 @@
                 if( buf == null )
                 {
                     buf = new SessionBuffer( session );
-                    Object old = buffers.put( session, buf );
-                    //System.out.println( "new " + System.identityHashCode( session ) + "
(" + ( old == null ) + ')' );
+                    buffers.put( session, buf );
                 }
             }
         }
@@ -179,8 +178,7 @@
         final IoSession session = buf.session;
         synchronized( buffers )
         {
-            Object old = buffers.remove( session );
-            //System.out.println( Thread.currentThread().getName() + " del " + System.identityHashCode(
session ) + " (" + ( old != null ) + ')' );
+            buffers.remove( session );
         }
     }
 
@@ -218,15 +216,12 @@
 
         public void run()
         {
-            String name = Thread.currentThread().getName();
             for( ;; )
             {
                 if( !waitForPromotion() )
                     break;
                 
-                //System.out.println( name + " promoted" );
                 SessionBuffer buf = fetchBuffer();
-                //System.out.println( name + " fetched: " + (buf != null? System.identityHashCode(buf)
: 0 ) );
                 giveUpLead();
 
                 if( buf == null )
@@ -326,8 +321,7 @@
             {
                 if( eventQueue.isEmpty() )
                 {
-                    boolean removed = busySessionBuffers.remove( buf );
-                    //System.out.println( Thread.currentThread().getName() + " busyDel: "
+ System.identityHashCode( buf.session ) + " (" + removed + ')' );
+                    busySessionBuffers.remove( buf );
                     removeSessionBuffer( buf );
                 }
                 else



Mime
View raw message