activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tab...@apache.org
Subject activemq git commit: https://issues.apache.org/jira/browse/AMQ-5578
Date Wed, 02 Mar 2016 22:18:36 GMT
Repository: activemq
Updated Branches:
  refs/heads/master e89b7a57f -> e8f44a29d


https://issues.apache.org/jira/browse/AMQ-5578

Revert to previous behavior of explicit init. 

Project: http://git-wip-us.apache.org/repos/asf/activemq/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/e8f44a29
Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/e8f44a29
Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/e8f44a29

Branch: refs/heads/master
Commit: e8f44a29ddf940a3bd254b10336c8e2c1f318fc7
Parents: e89b7a5
Author: Timothy Bish <tabish121@gmail.com>
Authored: Wed Mar 2 17:18:30 2016 -0500
Committer: Timothy Bish <tabish121@gmail.com>
Committed: Wed Mar 2 17:18:30 2016 -0500

----------------------------------------------------------------------
 .../apache/activemq/store/kahadb/disk/journal/Journal.java    | 7 ++++++-
 1 file changed, 6 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/activemq/blob/e8f44a29/activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/disk/journal/Journal.java
----------------------------------------------------------------------
diff --git a/activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/disk/journal/Journal.java
b/activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/disk/journal/Journal.java
index ba0b9f5..2604e39 100644
--- a/activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/disk/journal/Journal.java
+++ b/activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/disk/journal/Journal.java
@@ -275,7 +275,12 @@ public class Journal {
 
     private void doPreallocationZeros(RecoverableRandomAccessFile file) {
         ByteBuffer buffer = ByteBuffer.allocate(maxFileLength);
-        buffer.limit(maxFileLength);
+        // intentional double initialization due to interaction with the OS level
+        // file allocation mechanics.
+        for (int i = 0; i < maxFileLength; i++) {
+            buffer.put((byte) 0x00);
+        }
+        buffer.flip();
 
         try {
             FileChannel channel = file.getChannel();


Mime
View raw message