[hornetq-commits] JBoss hornetq SVN: r11826 - trunk/hornetq-journal/src/main/java/org/hornetq/core/asyncio/impl.
Author: borges
Date: 2011-12-05 07:43:53 -0500 (Mon, 05 Dec 2011)
New Revision: 11826
Modified:
trunk/hornetq-journal/src/main/java/org/hornetq/core/asyncio/impl/AsynchronousFileImpl.java
Log:
Remove spurious @SuppressWarnings
Modified:
trunk/hornetq-journal/src/main/java/org/hornetq/core/asyncio/impl/AsynchronousFileImpl.java
===================================================================
---
trunk/hornetq-journal/src/main/java/org/hornetq/core/asyncio/impl/AsynchronousFileImpl.java 2011-12-05
12:43:42 UTC (rev 11825)
+++
trunk/hornetq-journal/src/main/java/org/hornetq/core/asyncio/impl/AsynchronousFileImpl.java 2011-12-05
12:43:53 UTC (rev 11826)
@@ -34,9 +34,9 @@
import org.hornetq.utils.ReusableLatch;
/**
- *
+ *
* AsynchronousFile implementation
- *
+ *
* @author clebert.suconic(a)jboss.com
* Warning: Case you refactor the name or the package of this class
* You need to make sure you also rename the C++ native calls
@@ -62,7 +62,7 @@
* This is accessed from a single thread (the Poller Thread) */
private long nextReadSequence = 0;
- /**
+ /**
* AIO can't guarantee ordering over callbacks.
* We use thie PriorityQueue to hold values until they are in order
*/
@@ -161,7 +161,7 @@
private Semaphore maxIOSemaphore;
private BufferCallback bufferCallback;
-
+
/** A callback for IO errors when they happen */
private final IOExceptionListener ioExceptionListener;
@@ -282,8 +282,8 @@
writeLock.unlock();
}
}
-
-
+
+
public void writeInternal(long positionToWrite, long size, ByteBuffer bytes) throws
HornetQException
{
try
@@ -426,7 +426,7 @@
}
/**
- * This needs to be synchronized because of
+ * This needs to be synchronized because of
* http://bugs.sun.com/view_bug.do?bug_id=6791815
*
http://mail.openjdk.java.net/pipermail/hotspot-runtime-dev/2009-January/0...
*/
@@ -470,8 +470,6 @@
// Private
---------------------------------------------------------------------------
- /** */
- @SuppressWarnings("unused")
private void callbackDone(final AIOCallback callback, final long sequence, final
ByteBuffer buffer)
{
maxIOSemaphore.release();
@@ -540,7 +538,7 @@
final String errorMessage)
{
AsynchronousFileImpl.log.warn("CallbackError: " + errorMessage);
-
+
fireExceptionListener(errorCode, errorMessage);
maxIOSemaphore.release();
@@ -648,7 +646,7 @@
// completely done, or we might get beautiful GPFs
pollerLatch.await();
}
-
+
public static FileLock lock(int handle)
{
if (flock(handle))
@@ -662,13 +660,13 @@
}
// Native
----------------------------------------------------------------------------
-
-
+
+
// Functions used for locking files .....
public static native int openFile(String fileName);
-
+
public static native void closeFile(int handle);
-
+
private static native boolean flock(int handle);
// Functions used for locking files ^^^^^^^^