mirror of
https://github.com/XRPLF/rippled.git
synced 2025-12-06 17:27:55 +00:00
2885ad9b77
Summary:
Make each set function of Options / WriteOptions return its option instance.
Java developers can now easier specify each option like the following:
options.setCreateIfMissing(true)
.setWriteBufferSize(8 * 1024)
.setMaxWriteBufferNumber(3)
.setDisableSeekCompaction(true)
.setBlockSize(64 * 1024)
.setMaxBackgroundCompactions(10);
Test Plan:
make rocksdbjava
make jtest
Reviewers: haobo, ankgup87, sdong, dhruba
Reviewed By: haobo
CC: leveldb
Differential Revision: https://reviews.facebook.net/D17661
107 lines
3.4 KiB
Java
107 lines
3.4 KiB
Java
// Copyright (c) 2014, Facebook, Inc. All rights reserved.
|
|
// This source code is licensed under the BSD-style license found in the
|
|
// LICENSE file in the root directory of this source tree. An additional grant
|
|
// of patent rights can be found in the PATENTS file in the same directory.
|
|
|
|
package org.rocksdb;
|
|
|
|
/**
|
|
* Options that control write operations.
|
|
*
|
|
* Note that developers should call WriteOptions.dispose() to release the
|
|
* c++ side memory before a WriteOptions instance runs out of scope.
|
|
*/
|
|
public class WriteOptions {
|
|
public WriteOptions() {
|
|
nativeHandle_ = 0;
|
|
newWriteOptions();
|
|
}
|
|
|
|
public synchronized void dispose() {
|
|
if (nativeHandle_ != 0) {
|
|
dispose0(nativeHandle_);
|
|
}
|
|
}
|
|
|
|
/**
|
|
* If true, the write will be flushed from the operating system
|
|
* buffer cache (by calling WritableFile::Sync()) before the write
|
|
* is considered complete. If this flag is true, writes will be
|
|
* slower.
|
|
*
|
|
* If this flag is false, and the machine crashes, some recent
|
|
* writes may be lost. Note that if it is just the process that
|
|
* crashes (i.e., the machine does not reboot), no writes will be
|
|
* lost even if sync==false.
|
|
*
|
|
* In other words, a DB write with sync==false has similar
|
|
* crash semantics as the "write()" system call. A DB write
|
|
* with sync==true has similar crash semantics to a "write()"
|
|
* system call followed by "fdatasync()".
|
|
*
|
|
* Default: false
|
|
*
|
|
* @param flag a boolean flag to indicate whether a write
|
|
* should be synchronized.
|
|
* @return the instance of the current WriteOptions.
|
|
*/
|
|
public WriteOptions setSync(boolean flag) {
|
|
setSync(nativeHandle_, flag);
|
|
return this;
|
|
}
|
|
|
|
/**
|
|
* If true, the write will be flushed from the operating system
|
|
* buffer cache (by calling WritableFile::Sync()) before the write
|
|
* is considered complete. If this flag is true, writes will be
|
|
* slower.
|
|
*
|
|
* If this flag is false, and the machine crashes, some recent
|
|
* writes may be lost. Note that if it is just the process that
|
|
* crashes (i.e., the machine does not reboot), no writes will be
|
|
* lost even if sync==false.
|
|
*
|
|
* In other words, a DB write with sync==false has similar
|
|
* crash semantics as the "write()" system call. A DB write
|
|
* with sync==true has similar crash semantics to a "write()"
|
|
* system call followed by "fdatasync()".
|
|
*/
|
|
public boolean sync() {
|
|
return sync(nativeHandle_);
|
|
}
|
|
|
|
/**
|
|
* If true, writes will not first go to the write ahead log,
|
|
* and the write may got lost after a crash.
|
|
*
|
|
* @param flag a boolean flag to specify whether to disable
|
|
* write-ahead-log on writes.
|
|
* @return the instance of the current WriteOptions.
|
|
*/
|
|
public WriteOptions setDisableWAL(boolean flag) {
|
|
setDisableWAL(nativeHandle_, flag);
|
|
return this;
|
|
}
|
|
|
|
/**
|
|
* If true, writes will not first go to the write ahead log,
|
|
* and the write may got lost after a crash.
|
|
*/
|
|
public boolean disableWAL() {
|
|
return disableWAL(nativeHandle_);
|
|
}
|
|
|
|
@Override protected void finalize() {
|
|
dispose();
|
|
}
|
|
|
|
private native void newWriteOptions();
|
|
private native void setSync(long handle, boolean flag);
|
|
private native boolean sync(long handle);
|
|
private native void setDisableWAL(long handle, boolean flag);
|
|
private native boolean disableWAL(long handle);
|
|
private native void dispose0(long handle);
|
|
|
|
protected long nativeHandle_;
|
|
}
|