big-data/hadoop
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

HDDS-1621. writeData in ChunkUtils should not use AsynchronousFileChannel. Contributed by Supratim Deka (#917)

Browse Source
This commit is contained in:
supratimdeka 2019-06-06 18:53:37 +05:30 committed by bshashikant
parent 829848ba2e
commit 9fded678ff
1 changed files with 12 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/keyvalue/helpers/ChunkUtils.java
View File

@ -43,6 +43,7 @@
import java.io.IOException;
import java.nio.ByteBuffer;
import java.nio.channels.AsynchronousFileChannel;
import java.nio.channels.FileChannel;
import java.nio.channels.FileLock;
import java.nio.file.StandardOpenOption;
import java.security.NoSuchAlgorithmException;
@ -84,23 +85,20 @@ public static void writeData(File chunkFile, ChunkInfo chunkInfo,
throw new StorageContainerException(err, INVALID_WRITE_SIZE);
}
AsynchronousFileChannel file = null;
FileChannel file = null;
FileLock lock = null;
try {
long writeTimeStart = Time.monotonicNow();
file = sync ?
AsynchronousFileChannel.open(chunkFile.toPath(),
StandardOpenOption.CREATE,
StandardOpenOption.WRITE,
StandardOpenOption.SPARSE,
StandardOpenOption.SYNC) :
AsynchronousFileChannel.open(chunkFile.toPath(),
// skip SYNC and DSYNC to reduce contention on file.lock
file = FileChannel.open(chunkFile.toPath(),
StandardOpenOption.CREATE,
StandardOpenOption.WRITE,
StandardOpenOption.SPARSE);
lock = file.lock().get();
int size = file.write(data, chunkInfo.getOffset()).get();
lock = file.lock();
int size = file.write(data, chunkInfo.getOffset());
// Increment volumeIO stats here.
volumeIOStats.incWriteTime(Time.monotonicNow() - writeTimeStart);
volumeIOStats.incWriteOpCount();
@ -128,6 +126,10 @@ public static void writeData(File chunkFile, ChunkInfo chunkInfo,
}
if (file != null) {
try {
if (sync) {
// ensure data and metadata is persisted. Outside the lock
file.force(true);
}
file.close();
} catch (IOException e) {
throw new StorageContainerException("Error closing chunk file",