[jboss-cvs] JBoss Messaging SVN: r4710 - in trunk/src/main/org/jboss/messaging/core: asyncio/impl and 1 other directories.

[jboss-cvs-commits at lists.jboss.org]

Author: clebert.suconic at jboss.com
Date: 2008-07-22 16:34:57 -0400 (Tue, 22 Jul 2008)
New Revision: 4710

Modified:
   trunk/src/main/org/jboss/messaging/core/asyncio/AsynchronousFile.java
   trunk/src/main/org/jboss/messaging/core/asyncio/impl/AsynchronousFileImpl.java
   trunk/src/main/org/jboss/messaging/core/journal/impl/AIOSequentialFile.java
   trunk/src/main/org/jboss/messaging/core/journal/impl/JournalImpl.java
Log:
Small tweaks

Modified: trunk/src/main/org/jboss/messaging/core/asyncio/AsynchronousFile.java
===================================================================
--- trunk/src/main/org/jboss/messaging/core/asyncio/AsynchronousFile.java	2008-07-22 15:52:58 UTC (rev 4709)
+++ trunk/src/main/org/jboss/messaging/core/asyncio/AsynchronousFile.java	2008-07-22 20:34:57 UTC (rev 4710)
@@ -58,4 +58,6 @@
 	
 	int getBlockSize();
 	
+	String getFileName();
+	
 }

Modified: trunk/src/main/org/jboss/messaging/core/asyncio/impl/AsynchronousFileImpl.java
===================================================================
--- trunk/src/main/org/jboss/messaging/core/asyncio/impl/AsynchronousFileImpl.java	2008-07-22 15:52:58 UTC (rev 4709)
+++ trunk/src/main/org/jboss/messaging/core/asyncio/impl/AsynchronousFileImpl.java	2008-07-22 20:34:57 UTC (rev 4710)
@@ -232,6 +232,11 @@
 		return 512;
 	}
 	
+	public String getFileName()
+	{
+	   return fileName;
+	}
+	
 	// Private
 	// ---------------------------------------------------------------------------------
 	

Modified: trunk/src/main/org/jboss/messaging/core/journal/impl/AIOSequentialFile.java
===================================================================
--- trunk/src/main/org/jboss/messaging/core/journal/impl/AIOSequentialFile.java	2008-07-22 15:52:58 UTC (rev 4709)
+++ trunk/src/main/org/jboss/messaging/core/journal/impl/AIOSequentialFile.java	2008-07-22 20:34:57 UTC (rev 4710)
@@ -310,6 +310,8 @@
 			
 			this.errorMessage = errorMessage;
 			
+			log.warn("Error Message " + errorMessage);
+			
 			latch.countDown();			
 		}
 		

Modified: trunk/src/main/org/jboss/messaging/core/journal/impl/JournalImpl.java
===================================================================
--- trunk/src/main/org/jboss/messaging/core/journal/impl/JournalImpl.java	2008-07-22 15:52:58 UTC (rev 4709)
+++ trunk/src/main/org/jboss/messaging/core/journal/impl/JournalImpl.java	2008-07-22 20:34:57 UTC (rev 4710)
@@ -801,7 +801,7 @@
             
             if (checkSize != variableSize + recordSize)
             {
-               log.warn("Record at position " + pos + " is corrupted and it is being ignored");
+               log.warn("Record at position " + pos + " file:" + file.getFile().getFileName() + " is corrupted and it is being ignored");
                bb.position(pos + SIZE_BYTE);
                continue;
             }