Apache/activemq-artemis
1
0
Fork 0
mirror of https://github.com/apache/activemq-artemis.git synced 2025-02-21 01:15:50 +00:00
Code Issues Packages Projects Releases Wiki Activity

This closes #2740

Browse Source
This commit is contained in:
2019-07-15 23:53:48 +01:00
commit 072e9b467a
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) {