Remove unnecessary FileDescriptor sync

PiperOrigin-RevId: 255380796
This commit is contained in:
olly 2019-06-27 13:26:47 +01:00 committed by Oliver Woodman
parent 2a366e76b7
commit 1d36edc214
2 changed files with 1 additions and 31 deletions

View file

@ -49,7 +49,6 @@ public final class CacheDataSink implements DataSink {
private final long fragmentSize;
private final int bufferSize;
private boolean syncFileDescriptor;
private DataSpec dataSpec;
private long dataSpecFragmentSize;
private File file;
@ -108,18 +107,6 @@ public final class CacheDataSink implements DataSink {
this.cache = Assertions.checkNotNull(cache);
this.fragmentSize = fragmentSize == C.LENGTH_UNSET ? Long.MAX_VALUE : fragmentSize;
this.bufferSize = bufferSize;
syncFileDescriptor = true;
}
/**
* Sets whether file descriptors are synced when closing output streams.
*
* <p>This method is experimental, and will be renamed or removed in a future release.
*
* @param syncFileDescriptor Whether file descriptors are synced when closing output streams.
*/
public void experimental_setSyncFileDescriptor(boolean syncFileDescriptor) {
this.syncFileDescriptor = syncFileDescriptor;
}
@Override
@ -207,9 +194,6 @@ public final class CacheDataSink implements DataSink {
boolean success = false;
try {
outputStream.flush();
if (syncFileDescriptor) {
underlyingFileOutputStream.getFD().sync();
}
success = true;
} finally {
Util.closeQuietly(outputStream);

View file

@ -26,8 +26,6 @@ public final class CacheDataSinkFactory implements DataSink.Factory {
private final long fragmentSize;
private final int bufferSize;
private boolean syncFileDescriptor;
/** @see CacheDataSink#CacheDataSink(Cache, long) */
public CacheDataSinkFactory(Cache cache, long fragmentSize) {
this(cache, fragmentSize, CacheDataSink.DEFAULT_BUFFER_SIZE);
@ -40,20 +38,8 @@ public final class CacheDataSinkFactory implements DataSink.Factory {
this.bufferSize = bufferSize;
}
/**
* See {@link CacheDataSink#experimental_setSyncFileDescriptor(boolean)}.
*
* <p>This method is experimental, and will be renamed or removed in a future release.
*/
public CacheDataSinkFactory experimental_setSyncFileDescriptor(boolean syncFileDescriptor) {
this.syncFileDescriptor = syncFileDescriptor;
return this;
}
@Override
public DataSink createDataSink() {
CacheDataSink dataSink = new CacheDataSink(cache, fragmentSize, bufferSize);
dataSink.experimental_setSyncFileDescriptor(syncFileDescriptor);
return dataSink;
return new CacheDataSink(cache, fragmentSize, bufferSize);
}
}