[HORNETQ-1479] JournalImpl.load() fails if there are truncated files

BZ-1229434

(cherry picked from commit c95eea5)

Squashed with:

HORNETQ-1479 / BZ-1229434 - JournalImpl.load() fails if there are truncated files

- truncated files are deleted to avoid potential problems

(cherry picked from commit 87b8a4c)

hornetq-journal/src/main/java/org/hornetq/core/journal/impl/JournalImpl.java

@@ -375,18 +375,25 @@ public List<JournalFile> orderFiles() throws Exception
       {
          SequentialFile file = fileFactory.createSequentialFile(fileName, filesRepository.getMaxAIO());
 
-         file.open(1, false);
-
-         try
+         if (file.size() >= SIZE_HEADER)
          {
+            file.open(1, false);
 
-            JournalFileImpl jrnFile = readFileHeader(file);
+            try
+            {
+               JournalFileImpl jrnFile = readFileHeader(file);
 
-            orderedFiles.add(jrnFile);
+               orderedFiles.add(jrnFile);
+            }
+            finally
+            {
+               file.close();
+            }
          }
-         finally
+         else
          {
-            file.close();
+            HornetQJournalLogger.LOGGER.deletingTooShortFile(fileName);
+            file.delete();
          }
       }
 

hornetq-journal/src/main/java/org/hornetq/journal/HornetQJournalLogger.java

@@ -281,4 +281,8 @@ public interface HornetQJournalLogger extends BasicLogger
    @Message(id = 144006, value = "IOError code {0}, {1}", format = Message.Format.MESSAGE_FORMAT)
    void ioError(final int errorCode, final String errorMessage);
 
+   @LogMessage(level = Logger.Level.WARN)
+   @Message(id = 144007, value = "Deleting journal file {0}: file is shorter then minimum header size.", format = Message.Format.MESSAGE_FORMAT)
+   void deletingTooShortFile(String fileName);
+
 }

tests/unit-tests/src/test/java/org/hornetq/tests/unit/core/journal/impl/JournalImplTestUnit.java

@@ -13,6 +13,7 @@
 
 package org.hornetq.tests.unit.core.journal.impl;
 
+import java.io.File;
 import java.nio.ByteBuffer;
 import java.util.List;
 
@@ -3225,6 +3226,26 @@ public void testAddTexThenUpdate() throws Exception
 
    }
 
+   @Test
+   public void testLoadTruncatedFile() throws Exception
+   {
+      setup(2, 2 * 1024, true);
+      createJournal();
+      startJournal();
+
+      String testDir = getTestDir();
+      new File(testDir + File.separator + filePrefix + "-1." + fileExtension).createNewFile();
+
+      try
+      {
+         load();
+      }
+      catch (Exception e)
+      {
+         Assert.fail("Unexpected exception: " + e.toString());
+      }
+   }
+
    protected abstract int getAlignment();
 
 }