You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by cl...@apache.org on 2017/02/03 16:58:05 UTC
activemq-artemis git commit: ARTEMIS-937 no sync on AIO shouldn't use
O_DIRECT
Repository: activemq-artemis
Updated Branches:
refs/heads/master 1ac635499 -> c60c92697
ARTEMIS-937 no sync on AIO shouldn't use O_DIRECT
Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/c60c9269
Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/c60c9269
Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/c60c9269
Branch: refs/heads/master
Commit: c60c92697f782209875f21fad8b4fdecc3fdcd12
Parents: 1ac6354
Author: Clebert Suconic <cl...@apache.org>
Authored: Fri Feb 3 11:39:32 2017 -0500
Committer: Clebert Suconic <cl...@apache.org>
Committed: Fri Feb 3 11:47:28 2017 -0500
----------------------------------------------------------------------
.../org/apache/activemq/artemis/core/io/aio/AIOSequentialFile.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/c60c9269/artemis-journal/src/main/java/org/apache/activemq/artemis/core/io/aio/AIOSequentialFile.java
----------------------------------------------------------------------
diff --git a/artemis-journal/src/main/java/org/apache/activemq/artemis/core/io/aio/AIOSequentialFile.java b/artemis-journal/src/main/java/org/apache/activemq/artemis/core/io/aio/AIOSequentialFile.java
index 21f5e0d..f641aec 100644
--- a/artemis-journal/src/main/java/org/apache/activemq/artemis/core/io/aio/AIOSequentialFile.java
+++ b/artemis-journal/src/main/java/org/apache/activemq/artemis/core/io/aio/AIOSequentialFile.java
@@ -130,7 +130,7 @@ public class AIOSequentialFile extends AbstractSequentialFile {
opened = true;
try {
- aioFile = aioFactory.libaioContext.openFile(getFile(), true);
+ aioFile = aioFactory.libaioContext.openFile(getFile(), factory.isDatasync());
} catch (IOException e) {
factory.onIOError(e, e.getMessage(), this);
throw new ActiveMQNativeIOError(e.getMessage(), e);