svn commit: r761850 - /wicket/sandbox/knopp/experimental/wicket-ng/src/test/java/org/apache/wicket/page/persistent/disk/DiskDataStoreTest.java

[knopp]

Author: knopp
Date: Sat Apr  4 01:06:52 2009
New Revision: 761850

URL: http://svn.apache.org/viewvc?rev=761850&view=rev
Log: (empty)

Modified:
    
wicket/sandbox/knopp/experimental/wicket-ng/src/test/java/org/apache/wicket/page/persistent/disk/DiskDataStoreTest.java

Modified: 
wicket/sandbox/knopp/experimental/wicket-ng/src/test/java/org/apache/wicket/page/persistent/disk/DiskDataStoreTest.java
URL: 
http://svn.apache.org/viewvc/wicket/sandbox/knopp/experimental/wicket-ng/src/test/java/org/apache/wicket/page/persistent/disk/DiskDataStoreTest.java?rev=761850&r1=761849&r2=761850&view=diff
==============================================================================
--- 
wicket/sandbox/knopp/experimental/wicket-ng/src/test/java/org/apache/wicket/page/persistent/disk/DiskDataStoreTest.java
 (original)
+++ 
wicket/sandbox/knopp/experimental/wicket-ng/src/test/java/org/apache/wicket/page/persistent/disk/DiskDataStoreTest.java
 Sat Apr  4 01:06:52 2009
@@ -32,6 +32,7 @@
        private static final int FILES_COUNT = 1000;
        private static final int SLEEP_MAX = 10;
        private static final int THREAD_COUNT = 20;
+       private static final int READ_MODULO = 100;
        
        private static class File
        {
@@ -146,7 +147,11 @@
                                {                                       
                                        byte data[] = file.generateData();
                                        
dataStore.storeData(file.getSessionId(), file.getId(), data);
-                                       filesToRead1.add(file);
+                                       
+                                       if (saveCount.get() % READ_MODULO == 0)
+                                       {
+                                               filesToRead1.add(file);
+                                       }
                                        saveCount.incrementAndGet();
                                        bytesWritten.addAndGet(data.length);
                                }
@@ -170,7 +175,7 @@
                public void run()
                {
                        File file;
-                       while ((file = filesToRead1.poll()) != null || 
!saveDone.get() || read1Count.get() < FILES_COUNT)
+                       while ((file = filesToRead1.poll()) != null || 
!saveDone.get())
                        {
                                if (file != null)
                                {
@@ -204,7 +209,7 @@
                public void run()
                {
                        File file;
-                       while ((file = filesToRead2.poll()) != null || 
!read1Done.get() || read2Count.get() < FILES_COUNT)
+                       while ((file = filesToRead2.poll()) != null || 
!read1Done.get())
                        {
                                if (file != null)
                                {
@@ -267,7 +272,7 @@
                
                System.out.println("Took: " + duration + " ms");
                System.out.println("Save: " + saveCount.intValue() + " files, " 
+ bytesWritten.get() +" bytes");
-               System.out.println("Read: " + bytesRead.get() + " bytes");
+               System.out.println("Read: " + (read1Count.get() + 
read2Count.get()) + " files, " + bytesRead.get() + " bytes");
                
                assertEquals(0, failures.get());