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 2011/06/29 02:06:21 UTC

svn commit: r1140915 - in /tomcat/trunk/java/org/apache/catalina/tribes/transport: ReceiverBase.java bio/util/SingleRemoveSynchronizedAddLock.java

Author: markt
Date: Wed Jun 29 00:06:20 2011
New Revision: 1140915

URL: http://svn.apache.org/viewvc?rev=1140915&view=rev
Log:
Fix what were originally typos
Similar to https://issues.apache.org/bugzilla/show_bug.cgi?id=50648

Modified:
    tomcat/trunk/java/org/apache/catalina/tribes/transport/ReceiverBase.java
    tomcat/trunk/java/org/apache/catalina/tribes/transport/bio/util/SingleRemoveSynchronizedAddLock.java

Modified: tomcat/trunk/java/org/apache/catalina/tribes/transport/ReceiverBase.java
URL: http://svn.apache.org/viewvc/tomcat/trunk/java/org/apache/catalina/tribes/transport/ReceiverBase.java?rev=1140915&r1=1140914&r2=1140915&view=diff
==============================================================================
--- tomcat/trunk/java/org/apache/catalina/tribes/transport/ReceiverBase.java (original)
+++ tomcat/trunk/java/org/apache/catalina/tribes/transport/ReceiverBase.java Wed Jun 29 00:06:20 2011
@@ -227,7 +227,11 @@ public abstract class ReceiverBase imple
                     throw x;
                 }
                 portstart++;
-                try {Thread.sleep(25);}catch( InterruptedException ti){Thread.interrupted();}
+                try {
+                    Thread.sleep(25);
+                } catch (InterruptedException ti) {
+                    Thread.currentThread().interrupt();
+                }
                 retries = bind(socket,portstart,retries);
             }
         }
@@ -258,7 +262,11 @@ public abstract class ReceiverBase imple
                     throw x;
                 }
                 portstart++;
-                try {Thread.sleep(25);}catch( InterruptedException ti){Thread.interrupted();}
+                try {
+                    Thread.sleep(25);
+                } catch (InterruptedException ti) {
+                    Thread.currentThread().interrupt();
+                }
                 retries = bindUdp(socket,portstart,retries);
             }
         }

Modified: tomcat/trunk/java/org/apache/catalina/tribes/transport/bio/util/SingleRemoveSynchronizedAddLock.java
URL: http://svn.apache.org/viewvc/tomcat/trunk/java/org/apache/catalina/tribes/transport/bio/util/SingleRemoveSynchronizedAddLock.java?rev=1140915&r1=1140914&r2=1140915&view=diff
==============================================================================
--- tomcat/trunk/java/org/apache/catalina/tribes/transport/bio/util/SingleRemoveSynchronizedAddLock.java (original)
+++ tomcat/trunk/java/org/apache/catalina/tribes/transport/bio/util/SingleRemoveSynchronizedAddLock.java Wed Jun 29 00:06:20 2011
@@ -184,7 +184,7 @@ public class SingleRemoveSynchronizedAdd
                 try {
                     wait(addWaitTimeout);
                 } catch ( InterruptedException e ) {
-                    Thread.interrupted();
+                    Thread.currentThread().interrupt();
                 }
             } while ( addLocked || removeLocked );
         }
@@ -206,7 +206,7 @@ public class SingleRemoveSynchronizedAdd
                 try {
                     wait(removeWaitTimeout);
                 } catch ( InterruptedException e ) {
-                    Thread.interrupted();
+                    Thread.currentThread().interrupt();
                 }
             } while ( ( addLocked || ! dataAvailable ) && removeEnabled );
             remover=null;



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