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 ---------------------------------------------