Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

[AMQ-4947] ensure index page file does not skip forcing metadata - size is important to the page file 

(cherry picked from commit 42bf6e9061)
This commit is contained in:
gtully 2017-09-04 16:43:48 +01:00 committed by Timothy Bish
parent d76b615ad0
commit 51b428f49d
2 changed files with 10 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/disk/page/PageFile.java
View File

@ -378,7 +378,7 @@ public class PageFile {
File file = getMainPageFile();
IOHelper.mkdirs(file.getParentFile());
writeFile = new RecoverableRandomAccessFile(file, "rw");
writeFile = new RecoverableRandomAccessFile(file, "rw", false);
readFile = new RecoverableRandomAccessFile(file, "r");
if (readFile.length() > 0) {

14
activemq-kahadb-store/src/main/java/org/apache/activemq/util/RecoverableRandomAccessFile.java
View File

@ -31,17 +31,21 @@ public class RecoverableRandomAccessFile implements java.io.DataOutput, java.io.
RandomAccessFile raf;
File file;
String mode;
final boolean isSkipMetadataUpdate;
public RecoverableRandomAccessFile(File file, String mode) throws FileNotFoundException {
public RecoverableRandomAccessFile(File file, String mode, boolean skipMetadataUpdate) throws FileNotFoundException {
this.file = file;
this.mode = mode;
raf = new RandomAccessFile(file, mode);
isSkipMetadataUpdate = skipMetadataUpdate;
}
public RecoverableRandomAccessFile(File file, String mode) throws FileNotFoundException {
this(file, mode, SKIP_METADATA_UPDATE);
}
public RecoverableRandomAccessFile(String name, String mode) throws FileNotFoundException {
this.file = new File(name);
this.mode = mode;
raf = new RandomAccessFile(file, mode);
this(new File(name), mode);
}
protected RandomAccessFile getRaf() throws IOException {
@ -394,7 +398,7 @@ public class RecoverableRandomAccessFile implements java.io.DataOutput, java.io.
public void sync() throws IOException {
try {
getRaf().getChannel().force(!SKIP_METADATA_UPDATE);;
getRaf().getChannel().force(!isSkipMetadataUpdate);;
} catch (IOException ioe) {
handleException();
throw ioe;