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

ARTEMIS-2414 Sync before closing file in case data loss

This commit is contained in:
yang wei 2019-07-05 11:32:40 +08:00 committed by
parent 1eaf12b8e1
commit dd62be1602
2 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
artemis-journal/src/main/java/org/apache/activemq/artemis/core/io/mapped/MappedSequentialFile.java
View File

@ -361,6 +361,8 @@ final class MappedSequentialFile implements SequentialFile {
@Override
public void close(boolean waitOnSync) {
if (this.mappedFile != null) {
if (factory.isDatasync())
this.mappedFile.force();
this.mappedFile.close();
this.mappedFile = null;
}

2
artemis-journal/src/main/java/org/apache/activemq/artemis/core/io/nio/NIOSequentialFile.java
View File

@ -135,6 +135,8 @@ public class NIOSequentialFile extends AbstractSequentialFile {
try {
if (channel != null) {
if (factory.isDatasync())
channel.force(false);
channel.close();
}
} catch (ClosedChannelException e) {