Apache/activemq-artemis
1
0
Fork 0
mirror of https://github.com/apache/activemq-artemis.git synced 2025-03-05 08:50:13 +00:00
Code Issues Packages Projects Releases Wiki Activity

ARTEMIS-2483 Sync calculation should use the block size

Browse Source
This commit is contained in:
Clebert Suconic 2019-09-10 16:15:55 -04:00
parent 485043cf0b
commit a2dd5ae590
1 changed files with 4 additions and 1 deletions

5
artemis-cli/src/main/java/org/apache/activemq/artemis/cli/commands/util/SyncCalculation.java

@ -77,7 +77,10 @@ public class SyncCalculation {
int maxAIO, int maxAIO,
JournalType journalType) throws Exception { JournalType journalType) throws Exception {
SequentialFileFactory factory = newFactory(datafolder, fsync, journalType, blockSize * blocks, maxAIO); SequentialFileFactory factory = newFactory(datafolder, fsync, journalType, blockSize * blocks, maxAIO);
final boolean asyncWrites = journalType == JournalType.ASYNCIO && !syncWrites;
if (factory instanceof AIOSequentialFileFactory) {
factory.setAlignment(blockSize);
}
//the write latencies could be taken only when writes are effectively synchronous //the write latencies could be taken only when writes are effectively synchronous
if (journalType == JournalType.ASYNCIO && syncWrites) { if (journalType == JournalType.ASYNCIO && syncWrites) {