Author: clebert.suconic(a)jboss.com
Date: 2010-09-30 18:56:46 -0400 (Thu, 30 Sep 2010)
New Revision: 9740
Modified:
branches/Branch_New_Paging/src/main/org/hornetq/core/paging/cursor/impl/PageCursorProviderImpl.java
branches/Branch_New_Paging/tests/src/org/hornetq/tests/integration/paging/PageCacheTest.java
Log:
small tweak
Modified:
branches/Branch_New_Paging/src/main/org/hornetq/core/paging/cursor/impl/PageCursorProviderImpl.java
===================================================================
---
branches/Branch_New_Paging/src/main/org/hornetq/core/paging/cursor/impl/PageCursorProviderImpl.java 2010-09-30
22:31:47 UTC (rev 9739)
+++
branches/Branch_New_Paging/src/main/org/hornetq/core/paging/cursor/impl/PageCursorProviderImpl.java 2010-09-30
22:56:46 UTC (rev 9740)
@@ -136,6 +136,11 @@
return cache;
}
+
+ public int getCacheSize()
+ {
+ return softCache.size();
+ }
// Package protected ---------------------------------------------
Modified:
branches/Branch_New_Paging/tests/src/org/hornetq/tests/integration/paging/PageCacheTest.java
===================================================================
---
branches/Branch_New_Paging/tests/src/org/hornetq/tests/integration/paging/PageCacheTest.java 2010-09-30
22:31:47 UTC (rev 9739)
+++
branches/Branch_New_Paging/tests/src/org/hornetq/tests/integration/paging/PageCacheTest.java 2010-09-30
22:56:46 UTC (rev 9740)
@@ -65,7 +65,7 @@
StorageManager storageManager = server.getStorageManager();
- final int NUM_MESSAGES = 1000;
+ final int NUM_MESSAGES = 300;
pageStore.startPaging();
@@ -92,9 +92,13 @@
System.out.println("Page " + i + " had " +
cache.getNumberOfMessages() + " messages");
}
-
- System.out.println("Go check!");
- Thread.sleep(50000);
+
+ assertTrue(cursorProvider.getCacheSize() < numberOfPages);
+
+ System.out.println("Cache size = " + cursorProvider.getCacheSize());
+ assertEquals(numberOfPages, pageStore.getNumberOfPages());
+
+
}
// Package protected ---------------------------------------------