Author: clebert.suconic(a)jboss.com Date: 2010-05-17 13:39:52 -0400 (Mon, 17 May 2010) New Revision: 9241 Modified: trunk/tests/src/org/hornetq/tests/unit/core/asyncio/AsynchronousFileTest.java Log: just a cleanup Modified: trunk/tests/src/org/hornetq/tests/unit/core/asyncio/AsynchronousFileTest.java =================================================================== --- trunk/tests/src/org/hornetq/tests/unit/core/asyncio/AsynchronousFileTest.java 2010-05-17 17:27:15 UTC (rev 9240) +++ trunk/tests/src/org/hornetq/tests/unit/core/asyncio/AsynchronousFileTest.java 2010-05-17 17:39:52 UTC (rev 9241) @@ -74,7 +74,8 @@ { super.setUp(); pollerExecutor = Executors.newCachedThreadPool(new HornetQThreadFactory("HornetQ-AIO-poller-pool" + System.identityHashCode(this), - false, this.getClass().getClassLoader())); + false, + this.getClass().getClassLoader())); executor = Executors.newSingleThreadExecutor(); } @@ -100,54 +101,54 @@ } } - + public void testReleaseBuffers() throws Exception { AsynchronousFileImpl controller = new AsynchronousFileImpl(executor, pollerExecutor); controller.open(FILE_NAME, 10000); WeakReference<ByteBuffer> bufferCheck = new WeakReference<ByteBuffer>(controller.getHandler()); - controller.fill(0, 10, 1024, (byte)0); - + controller.fill(0, 10, 1024, (byte)0); + ByteBuffer write = AsynchronousFileImpl.newBuffer(1024); - - for (int i = 0 ; i < 1024; i++) + + for (int i = 0; i < 1024; i++) { - write.put(getSamplebyte(i)); + write.put(UnitTestCase.getSamplebyte(i)); } final CountDownLatch latch = new CountDownLatch(1); - + controller.write(0, 1024, write, new AIOCallback() { - - public void onError(int errorCode, String errorMessage) + + public void onError(final int errorCode, final String errorMessage) { } - + public void done() { latch.countDown(); } }); - - assertTrue(latch.await(10, TimeUnit.SECONDS)); - + + Assert.assertTrue(latch.await(10, TimeUnit.SECONDS)); + WeakReference<ByteBuffer> bufferCheck2 = new WeakReference<ByteBuffer>(write); - + AsynchronousFileImpl.destroyBuffer(write); write = null; - - forceGC(); - - assertNull(bufferCheck2.get()); - + + UnitTestCase.forceGC(); + + Assert.assertNull(bufferCheck2.get()); + controller.close(); controller = null; - - forceGC(); - - assertNull(bufferCheck.get()); + + UnitTestCase.forceGC(); + + Assert.assertNull(bufferCheck.get()); } public void testFileNonExistent() throws Exception @@ -341,7 +342,7 @@ callbackLocal.latch.await(); - assertTrue(callbackLocal.error); + Assert.assertTrue(callbackLocal.error); callbackLocal = new LocalCallback();