[infinispan-commits] Infinispan SVN: r230 - trunk/core/src/main/java/org/infinispan/container.

[infinispan-commits at lists.jboss.org]

Author: manik.surtani at jboss.com
Date: 2009-05-07 12:35:12 -0400 (Thu, 07 May 2009)
New Revision: 230

Modified:
   trunk/core/src/main/java/org/infinispan/container/FIFODataContainer.java
Log:
Temporarily remove backing off in loop

Modified: trunk/core/src/main/java/org/infinispan/container/FIFODataContainer.java
===================================================================
--- trunk/core/src/main/java/org/infinispan/container/FIFODataContainer.java	2009-05-07 15:46:28 UTC (rev 229)
+++ trunk/core/src/main/java/org/infinispan/container/FIFODataContainer.java	2009-05-07 16:35:12 UTC (rev 230)
@@ -7,7 +7,6 @@
 import java.util.Iterator;
 import java.util.Set;
 import java.util.concurrent.atomic.AtomicReferenceFieldUpdater;
-import java.util.concurrent.locks.LockSupport;
 import java.util.concurrent.locks.ReentrantLock;
 
 /**
@@ -226,18 +225,18 @@
     */
    protected final void linkAtEnd(LinkedEntry entry) {
       LinkedEntry prev = tail.p;
-      long backOffNanos = 100000; // start at 0.1 millis
+//      long backOffNanos = 100000; // start at 0.1 millis
       for (; ;) {
          entry.p = prev;
          entry.n = tail;
          if (prev.casNext(tail, entry)) break;
          prev = correctPrev(prev, tail);
 
-         LockSupport.parkNanos(backOffNanos);
-         backOffNanos <<= 1;
+//         LockSupport.parkNanos(backOffNanos);
+//         backOffNanos <<= 1;
       }
 
-      backOffNanos = 100000; // start at 0.1 millis
+//      backOffNanos = 100000; // start at 0.1 millis
       for (; ;) {
          LinkedEntry l1 = tail.p;
          if (isMarkedForRemoval(l1) || entry.n != tail) break;
@@ -245,8 +244,8 @@
             if (isMarkedForRemoval(entry.p)) entry = correctPrev(entry, tail);
             break;
          }
-         LockSupport.parkNanos(backOffNanos);
-         backOffNanos <<= 1;
+//         LockSupport.parkNanos(backOffNanos);
+//         backOffNanos <<= 1;
       }
    }
 
@@ -303,7 +302,7 @@
     */
    protected final LinkedEntry correctPrev(LinkedEntry suggestedPreviousEntry, LinkedEntry currentEntry) {
       LinkedEntry lastLink = null, link1, prev2;
-      long backOffNanos = 100000; // start at 0.1 millis
+//      long backOffNanos = 100000; // start at 0.1 millis
       while (true) {
          link1 = currentEntry.p;
          if (isMarkedForRemoval(link1)) break;
@@ -331,8 +330,8 @@
             if (isMarkedForRemoval(suggestedPreviousEntry.p)) continue;
             break;
          }
-         LockSupport.parkNanos(backOffNanos);
-         backOffNanos <<= 1;
+//         LockSupport.parkNanos(backOffNanos);
+//         backOffNanos <<= 1;
       }
       return suggestedPreviousEntry;
    }