http://git-wip-us.apache.org/repos/asf/nifi-minifi-cpp/blob/d3a13a49/thirdparty/rocksdb/java/src/test/java/org/rocksdb/OptionsTest.java ---------------------------------------------------------------------- diff --git a/thirdparty/rocksdb/java/src/test/java/org/rocksdb/OptionsTest.java b/thirdparty/rocksdb/java/src/test/java/org/rocksdb/OptionsTest.java deleted file mode 100644 index 6afcab3..0000000 --- a/thirdparty/rocksdb/java/src/test/java/org/rocksdb/OptionsTest.java +++ /dev/null @@ -1,1095 +0,0 @@ -// Copyright (c) 2011-present, Facebook, Inc. All rights reserved. -// This source code is licensed under both the GPLv2 (found in the -// COPYING file in the root directory) and Apache 2.0 License -// (found in the LICENSE.Apache file in the root directory). - -package org.rocksdb; - -import java.nio.file.Paths; -import java.util.ArrayList; -import java.util.Collections; -import java.util.List; -import java.util.Random; - -import org.junit.ClassRule; -import org.junit.Test; - -import static org.assertj.core.api.Assertions.assertThat; - - -public class OptionsTest { - - @ClassRule - public static final RocksMemoryResource rocksMemoryResource = - new RocksMemoryResource(); - - public static final Random rand = PlatformRandomHelper. - getPlatformSpecificRandomFactory(); - - @Test - public void setIncreaseParallelism() { - try (final Options opt = new Options()) { - final int threads = Runtime.getRuntime().availableProcessors() * 2; - opt.setIncreaseParallelism(threads); - } - } - - @Test - public void writeBufferSize() throws RocksDBException { - try (final Options opt = new Options()) { - final long longValue = rand.nextLong(); - opt.setWriteBufferSize(longValue); - assertThat(opt.writeBufferSize()).isEqualTo(longValue); - } - } - - @Test - public void maxWriteBufferNumber() { - try (final Options opt = new Options()) { - final int intValue = rand.nextInt(); - opt.setMaxWriteBufferNumber(intValue); - assertThat(opt.maxWriteBufferNumber()).isEqualTo(intValue); - } - } - - @Test - public void minWriteBufferNumberToMerge() { - try (final Options opt = new Options()) { - final int intValue = rand.nextInt(); - opt.setMinWriteBufferNumberToMerge(intValue); - assertThat(opt.minWriteBufferNumberToMerge()).isEqualTo(intValue); - } - } - - @Test - public void numLevels() { - try (final Options opt = new Options()) { - final int intValue = rand.nextInt(); - opt.setNumLevels(intValue); - assertThat(opt.numLevels()).isEqualTo(intValue); - } - } - - @Test - public void levelZeroFileNumCompactionTrigger() { - try (final Options opt = new Options()) { - final int intValue = rand.nextInt(); - opt.setLevelZeroFileNumCompactionTrigger(intValue); - assertThat(opt.levelZeroFileNumCompactionTrigger()).isEqualTo(intValue); - } - } - - @Test - public void levelZeroSlowdownWritesTrigger() { - try (final Options opt = new Options()) { - final int intValue = rand.nextInt(); - opt.setLevelZeroSlowdownWritesTrigger(intValue); - assertThat(opt.levelZeroSlowdownWritesTrigger()).isEqualTo(intValue); - } - } - - @Test - public void levelZeroStopWritesTrigger() { - try (final Options opt = new Options()) { - final int intValue = rand.nextInt(); - opt.setLevelZeroStopWritesTrigger(intValue); - assertThat(opt.levelZeroStopWritesTrigger()).isEqualTo(intValue); - } - } - - @Test - public void targetFileSizeBase() { - try (final Options opt = new Options()) { - final long longValue = rand.nextLong(); - opt.setTargetFileSizeBase(longValue); - assertThat(opt.targetFileSizeBase()).isEqualTo(longValue); - } - } - - @Test - public void targetFileSizeMultiplier() { - try (final Options opt = new Options()) { - final int intValue = rand.nextInt(); - opt.setTargetFileSizeMultiplier(intValue); - assertThat(opt.targetFileSizeMultiplier()).isEqualTo(intValue); - } - } - - @Test - public void maxBytesForLevelBase() { - try (final Options opt = new Options()) { - final long longValue = rand.nextLong(); - opt.setMaxBytesForLevelBase(longValue); - assertThat(opt.maxBytesForLevelBase()).isEqualTo(longValue); - } - } - - @Test - public void levelCompactionDynamicLevelBytes() { - try (final Options opt = new Options()) { - final boolean boolValue = rand.nextBoolean(); - opt.setLevelCompactionDynamicLevelBytes(boolValue); - assertThat(opt.levelCompactionDynamicLevelBytes()) - .isEqualTo(boolValue); - } - } - - @Test - public void maxBytesForLevelMultiplier() { - try (final Options opt = new Options()) { - final double doubleValue = rand.nextDouble(); - opt.setMaxBytesForLevelMultiplier(doubleValue); - assertThat(opt.maxBytesForLevelMultiplier()).isEqualTo(doubleValue); - } - } - - @Test - public void maxBytesForLevelMultiplierAdditional() { - try (final Options opt = new Options()) { - final int intValue1 = rand.nextInt(); - final int intValue2 = rand.nextInt(); - final int[] ints = new int[]{intValue1, intValue2}; - opt.setMaxBytesForLevelMultiplierAdditional(ints); - assertThat(opt.maxBytesForLevelMultiplierAdditional()).isEqualTo(ints); - } - } - - @Test - public void maxCompactionBytes() { - try (final Options opt = new Options()) { - final long longValue = rand.nextLong(); - opt.setMaxCompactionBytes(longValue); - assertThat(opt.maxCompactionBytes()).isEqualTo(longValue); - } - } - - @Test - public void softPendingCompactionBytesLimit() { - try (final Options opt = new Options()) { - final long longValue = rand.nextLong(); - opt.setSoftPendingCompactionBytesLimit(longValue); - assertThat(opt.softPendingCompactionBytesLimit()).isEqualTo(longValue); - } - } - - @Test - public void hardPendingCompactionBytesLimit() { - try (final Options opt = new Options()) { - final long longValue = rand.nextLong(); - opt.setHardPendingCompactionBytesLimit(longValue); - assertThat(opt.hardPendingCompactionBytesLimit()).isEqualTo(longValue); - } - } - - @Test - public void level0FileNumCompactionTrigger() { - try (final Options opt = new Options()) { - final int intValue = rand.nextInt(); - opt.setLevel0FileNumCompactionTrigger(intValue); - assertThat(opt.level0FileNumCompactionTrigger()).isEqualTo(intValue); - } - } - - @Test - public void level0SlowdownWritesTrigger() { - try (final Options opt = new Options()) { - final int intValue = rand.nextInt(); - opt.setLevel0SlowdownWritesTrigger(intValue); - assertThat(opt.level0SlowdownWritesTrigger()).isEqualTo(intValue); - } - } - - @Test - public void level0StopWritesTrigger() { - try (final Options opt = new Options()) { - final int intValue = rand.nextInt(); - opt.setLevel0StopWritesTrigger(intValue); - assertThat(opt.level0StopWritesTrigger()).isEqualTo(intValue); - } - } - - @Test - public void arenaBlockSize() throws RocksDBException { - try (final Options opt = new Options()) { - final long longValue = rand.nextLong(); - opt.setArenaBlockSize(longValue); - assertThat(opt.arenaBlockSize()).isEqualTo(longValue); - } - } - - @Test - public void disableAutoCompactions() { - try (final Options opt = new Options()) { - final boolean boolValue = rand.nextBoolean(); - opt.setDisableAutoCompactions(boolValue); - assertThat(opt.disableAutoCompactions()).isEqualTo(boolValue); - } - } - - @Test - public void maxSequentialSkipInIterations() { - try (final Options opt = new Options()) { - final long longValue = rand.nextLong(); - opt.setMaxSequentialSkipInIterations(longValue); - assertThat(opt.maxSequentialSkipInIterations()).isEqualTo(longValue); - } - } - - @Test - public void inplaceUpdateSupport() { - try (final Options opt = new Options()) { - final boolean boolValue = rand.nextBoolean(); - opt.setInplaceUpdateSupport(boolValue); - assertThat(opt.inplaceUpdateSupport()).isEqualTo(boolValue); - } - } - - @Test - public void inplaceUpdateNumLocks() throws RocksDBException { - try (final Options opt = new Options()) { - final long longValue = rand.nextLong(); - opt.setInplaceUpdateNumLocks(longValue); - assertThat(opt.inplaceUpdateNumLocks()).isEqualTo(longValue); - } - } - - @Test - public void memtablePrefixBloomSizeRatio() { - try (final Options opt = new Options()) { - final double doubleValue = rand.nextDouble(); - opt.setMemtablePrefixBloomSizeRatio(doubleValue); - assertThat(opt.memtablePrefixBloomSizeRatio()).isEqualTo(doubleValue); - } - } - - @Test - public void memtableHugePageSize() { - try (final Options opt = new Options()) { - final long longValue = rand.nextLong(); - opt.setMemtableHugePageSize(longValue); - assertThat(opt.memtableHugePageSize()).isEqualTo(longValue); - } - } - - @Test - public void bloomLocality() { - try (final Options opt = new Options()) { - final int intValue = rand.nextInt(); - opt.setBloomLocality(intValue); - assertThat(opt.bloomLocality()).isEqualTo(intValue); - } - } - - @Test - public void maxSuccessiveMerges() throws RocksDBException { - try (final Options opt = new Options()) { - final long longValue = rand.nextLong(); - opt.setMaxSuccessiveMerges(longValue); - assertThat(opt.maxSuccessiveMerges()).isEqualTo(longValue); - } - } - - @Test - public void optimizeFiltersForHits() { - try (final Options opt = new Options()) { - final boolean aBoolean = rand.nextBoolean(); - opt.setOptimizeFiltersForHits(aBoolean); - assertThat(opt.optimizeFiltersForHits()).isEqualTo(aBoolean); - } - } - - @Test - public void createIfMissing() { - try (final Options opt = new Options()) { - final boolean boolValue = rand.nextBoolean(); - opt.setCreateIfMissing(boolValue); - assertThat(opt.createIfMissing()). - isEqualTo(boolValue); - } - } - - @Test - public void createMissingColumnFamilies() { - try (final Options opt = new Options()) { - final boolean boolValue = rand.nextBoolean(); - opt.setCreateMissingColumnFamilies(boolValue); - assertThat(opt.createMissingColumnFamilies()). - isEqualTo(boolValue); - } - } - - @Test - public void errorIfExists() { - try (final Options opt = new Options()) { - final boolean boolValue = rand.nextBoolean(); - opt.setErrorIfExists(boolValue); - assertThat(opt.errorIfExists()).isEqualTo(boolValue); - } - } - - @Test - public void paranoidChecks() { - try (final Options opt = new Options()) { - final boolean boolValue = rand.nextBoolean(); - opt.setParanoidChecks(boolValue); - assertThat(opt.paranoidChecks()). - isEqualTo(boolValue); - } - } - - @Test - public void maxTotalWalSize() { - try (final Options opt = new Options()) { - final long longValue = rand.nextLong(); - opt.setMaxTotalWalSize(longValue); - assertThat(opt.maxTotalWalSize()). - isEqualTo(longValue); - } - } - - @Test - public void maxOpenFiles() { - try (final Options opt = new Options()) { - final int intValue = rand.nextInt(); - opt.setMaxOpenFiles(intValue); - assertThat(opt.maxOpenFiles()).isEqualTo(intValue); - } - } - - @Test - public void maxFileOpeningThreads() { - try (final Options opt = new Options()) { - final int intValue = rand.nextInt(); - opt.setMaxFileOpeningThreads(intValue); - assertThat(opt.maxFileOpeningThreads()).isEqualTo(intValue); - } - } - - @Test - public void useFsync() { - try (final Options opt = new Options()) { - final boolean boolValue = rand.nextBoolean(); - opt.setUseFsync(boolValue); - assertThat(opt.useFsync()).isEqualTo(boolValue); - } - } - - @Test - public void dbPaths() { - final List<DbPath> dbPaths = new ArrayList<>(); - dbPaths.add(new DbPath(Paths.get("/a"), 10)); - dbPaths.add(new DbPath(Paths.get("/b"), 100)); - dbPaths.add(new DbPath(Paths.get("/c"), 1000)); - - try (final Options opt = new Options()) { - assertThat(opt.dbPaths()).isEqualTo(Collections.emptyList()); - - opt.setDbPaths(dbPaths); - - assertThat(opt.dbPaths()).isEqualTo(dbPaths); - } - } - - @Test - public void dbLogDir() { - try (final Options opt = new Options()) { - final String str = "path/to/DbLogDir"; - opt.setDbLogDir(str); - assertThat(opt.dbLogDir()).isEqualTo(str); - } - } - - @Test - public void walDir() { - try (final Options opt = new Options()) { - final String str = "path/to/WalDir"; - opt.setWalDir(str); - assertThat(opt.walDir()).isEqualTo(str); - } - } - - @Test - public void deleteObsoleteFilesPeriodMicros() { - try (final Options opt = new Options()) { - final long longValue = rand.nextLong(); - opt.setDeleteObsoleteFilesPeriodMicros(longValue); - assertThat(opt.deleteObsoleteFilesPeriodMicros()). - isEqualTo(longValue); - } - } - - @Test - public void baseBackgroundCompactions() { - try (final Options opt = new Options()) { - final int intValue = rand.nextInt(); - opt.setBaseBackgroundCompactions(intValue); - assertThat(opt.baseBackgroundCompactions()). - isEqualTo(intValue); - } - } - - @Test - public void maxBackgroundCompactions() { - try (final Options opt = new Options()) { - final int intValue = rand.nextInt(); - opt.setMaxBackgroundCompactions(intValue); - assertThat(opt.maxBackgroundCompactions()). - isEqualTo(intValue); - } - } - - @Test - public void maxSubcompactions() { - try (final Options opt = new Options()) { - final int intValue = rand.nextInt(); - opt.setMaxSubcompactions(intValue); - assertThat(opt.maxSubcompactions()). - isEqualTo(intValue); - } - } - - @Test - public void maxBackgroundFlushes() { - try (final Options opt = new Options()) { - final int intValue = rand.nextInt(); - opt.setMaxBackgroundFlushes(intValue); - assertThat(opt.maxBackgroundFlushes()). - isEqualTo(intValue); - } - } - - @Test - public void maxLogFileSize() throws RocksDBException { - try (final Options opt = new Options()) { - final long longValue = rand.nextLong(); - opt.setMaxLogFileSize(longValue); - assertThat(opt.maxLogFileSize()).isEqualTo(longValue); - } - } - - @Test - public void logFileTimeToRoll() throws RocksDBException { - try (final Options opt = new Options()) { - final long longValue = rand.nextLong(); - opt.setLogFileTimeToRoll(longValue); - assertThat(opt.logFileTimeToRoll()). - isEqualTo(longValue); - } - } - - @Test - public void keepLogFileNum() throws RocksDBException { - try (final Options opt = new Options()) { - final long longValue = rand.nextLong(); - opt.setKeepLogFileNum(longValue); - assertThat(opt.keepLogFileNum()).isEqualTo(longValue); - } - } - - @Test - public void recycleLogFileNum() throws RocksDBException { - try (final Options opt = new Options()) { - final long longValue = rand.nextLong(); - opt.setRecycleLogFileNum(longValue); - assertThat(opt.recycleLogFileNum()).isEqualTo(longValue); - } - } - - @Test - public void maxManifestFileSize() { - try (final Options opt = new Options()) { - final long longValue = rand.nextLong(); - opt.setMaxManifestFileSize(longValue); - assertThat(opt.maxManifestFileSize()). - isEqualTo(longValue); - } - } - - @Test - public void tableCacheNumshardbits() { - try (final Options opt = new Options()) { - final int intValue = rand.nextInt(); - opt.setTableCacheNumshardbits(intValue); - assertThat(opt.tableCacheNumshardbits()). - isEqualTo(intValue); - } - } - - @Test - public void walSizeLimitMB() { - try (final Options opt = new Options()) { - final long longValue = rand.nextLong(); - opt.setWalSizeLimitMB(longValue); - assertThat(opt.walSizeLimitMB()).isEqualTo(longValue); - } - } - - @Test - public void walTtlSeconds() { - try (final Options opt = new Options()) { - final long longValue = rand.nextLong(); - opt.setWalTtlSeconds(longValue); - assertThat(opt.walTtlSeconds()).isEqualTo(longValue); - } - } - - @Test - public void manifestPreallocationSize() throws RocksDBException { - try (final Options opt = new Options()) { - final long longValue = rand.nextLong(); - opt.setManifestPreallocationSize(longValue); - assertThat(opt.manifestPreallocationSize()). - isEqualTo(longValue); - } - } - - @Test - public void useDirectReads() { - try(final Options opt = new Options()) { - final boolean boolValue = rand.nextBoolean(); - opt.setUseDirectReads(boolValue); - assertThat(opt.useDirectReads()).isEqualTo(boolValue); - } - } - - @Test - public void useDirectIoForFlushAndCompaction() { - try(final Options opt = new Options()) { - final boolean boolValue = rand.nextBoolean(); - opt.setUseDirectIoForFlushAndCompaction(boolValue); - assertThat(opt.useDirectIoForFlushAndCompaction()).isEqualTo(boolValue); - } - } - - @Test - public void allowFAllocate() { - try (final Options opt = new Options()) { - final boolean boolValue = rand.nextBoolean(); - opt.setAllowFAllocate(boolValue); - assertThat(opt.allowFAllocate()).isEqualTo(boolValue); - } - } - - @Test - public void allowMmapReads() { - try (final Options opt = new Options()) { - final boolean boolValue = rand.nextBoolean(); - opt.setAllowMmapReads(boolValue); - assertThat(opt.allowMmapReads()).isEqualTo(boolValue); - } - } - - @Test - public void allowMmapWrites() { - try (final Options opt = new Options()) { - final boolean boolValue = rand.nextBoolean(); - opt.setAllowMmapWrites(boolValue); - assertThat(opt.allowMmapWrites()).isEqualTo(boolValue); - } - } - - @Test - public void isFdCloseOnExec() { - try (final Options opt = new Options()) { - final boolean boolValue = rand.nextBoolean(); - opt.setIsFdCloseOnExec(boolValue); - assertThat(opt.isFdCloseOnExec()).isEqualTo(boolValue); - } - } - - @Test - public void statsDumpPeriodSec() { - try (final Options opt = new Options()) { - final int intValue = rand.nextInt(); - opt.setStatsDumpPeriodSec(intValue); - assertThat(opt.statsDumpPeriodSec()).isEqualTo(intValue); - } - } - - @Test - public void adviseRandomOnOpen() { - try (final Options opt = new Options()) { - final boolean boolValue = rand.nextBoolean(); - opt.setAdviseRandomOnOpen(boolValue); - assertThat(opt.adviseRandomOnOpen()).isEqualTo(boolValue); - } - } - - @Test - public void dbWriteBufferSize() { - try (final Options opt = new Options()) { - final long longValue = rand.nextLong(); - opt.setDbWriteBufferSize(longValue); - assertThat(opt.dbWriteBufferSize()).isEqualTo(longValue); - } - } - - @Test - public void accessHintOnCompactionStart() { - try (final Options opt = new Options()) { - final AccessHint accessHint = AccessHint.SEQUENTIAL; - opt.setAccessHintOnCompactionStart(accessHint); - assertThat(opt.accessHintOnCompactionStart()).isEqualTo(accessHint); - } - } - - @Test - public void newTableReaderForCompactionInputs() { - try (final Options opt = new Options()) { - final boolean boolValue = rand.nextBoolean(); - opt.setNewTableReaderForCompactionInputs(boolValue); - assertThat(opt.newTableReaderForCompactionInputs()).isEqualTo(boolValue); - } - } - - @Test - public void compactionReadaheadSize() { - try (final Options opt = new Options()) { - final long longValue = rand.nextLong(); - opt.setCompactionReadaheadSize(longValue); - assertThat(opt.compactionReadaheadSize()).isEqualTo(longValue); - } - } - - @Test - public void randomAccessMaxBufferSize() { - try (final Options opt = new Options()) { - final long longValue = rand.nextLong(); - opt.setRandomAccessMaxBufferSize(longValue); - assertThat(opt.randomAccessMaxBufferSize()).isEqualTo(longValue); - } - } - - @Test - public void writableFileMaxBufferSize() { - try (final Options opt = new Options()) { - final long longValue = rand.nextLong(); - opt.setWritableFileMaxBufferSize(longValue); - assertThat(opt.writableFileMaxBufferSize()).isEqualTo(longValue); - } - } - - @Test - public void useAdaptiveMutex() { - try (final Options opt = new Options()) { - final boolean boolValue = rand.nextBoolean(); - opt.setUseAdaptiveMutex(boolValue); - assertThat(opt.useAdaptiveMutex()).isEqualTo(boolValue); - } - } - - @Test - public void bytesPerSync() { - try (final Options opt = new Options()) { - final long longValue = rand.nextLong(); - opt.setBytesPerSync(longValue); - assertThat(opt.bytesPerSync()).isEqualTo(longValue); - } - } - - @Test - public void walBytesPerSync() { - try (final Options opt = new Options()) { - final long longValue = rand.nextLong(); - opt.setWalBytesPerSync(longValue); - assertThat(opt.walBytesPerSync()).isEqualTo(longValue); - } - } - - @Test - public void enableThreadTracking() { - try (final Options opt = new Options()) { - final boolean boolValue = rand.nextBoolean(); - opt.setEnableThreadTracking(boolValue); - assertThat(opt.enableThreadTracking()).isEqualTo(boolValue); - } - } - - @Test - public void delayedWriteRate() { - try (final Options opt = new Options()) { - final long longValue = rand.nextLong(); - opt.setDelayedWriteRate(longValue); - assertThat(opt.delayedWriteRate()).isEqualTo(longValue); - } - } - - @Test - public void allowConcurrentMemtableWrite() { - try (final Options opt = new Options()) { - final boolean boolValue = rand.nextBoolean(); - opt.setAllowConcurrentMemtableWrite(boolValue); - assertThat(opt.allowConcurrentMemtableWrite()).isEqualTo(boolValue); - } - } - - @Test - public void enableWriteThreadAdaptiveYield() { - try (final Options opt = new Options()) { - final boolean boolValue = rand.nextBoolean(); - opt.setEnableWriteThreadAdaptiveYield(boolValue); - assertThat(opt.enableWriteThreadAdaptiveYield()).isEqualTo(boolValue); - } - } - - @Test - public void writeThreadMaxYieldUsec() { - try (final Options opt = new Options()) { - final long longValue = rand.nextLong(); - opt.setWriteThreadMaxYieldUsec(longValue); - assertThat(opt.writeThreadMaxYieldUsec()).isEqualTo(longValue); - } - } - - @Test - public void writeThreadSlowYieldUsec() { - try (final Options opt = new Options()) { - final long longValue = rand.nextLong(); - opt.setWriteThreadSlowYieldUsec(longValue); - assertThat(opt.writeThreadSlowYieldUsec()).isEqualTo(longValue); - } - } - - @Test - public void skipStatsUpdateOnDbOpen() { - try (final Options opt = new Options()) { - final boolean boolValue = rand.nextBoolean(); - opt.setSkipStatsUpdateOnDbOpen(boolValue); - assertThat(opt.skipStatsUpdateOnDbOpen()).isEqualTo(boolValue); - } - } - - @Test - public void walRecoveryMode() { - try (final Options opt = new Options()) { - for (final WALRecoveryMode walRecoveryMode : WALRecoveryMode.values()) { - opt.setWalRecoveryMode(walRecoveryMode); - assertThat(opt.walRecoveryMode()).isEqualTo(walRecoveryMode); - } - } - } - - @Test - public void allow2pc() { - try (final Options opt = new Options()) { - final boolean boolValue = rand.nextBoolean(); - opt.setAllow2pc(boolValue); - assertThat(opt.allow2pc()).isEqualTo(boolValue); - } - } - - @Test - public void rowCache() { - try (final Options opt = new Options()) { - assertThat(opt.rowCache()).isNull(); - - try(final Cache lruCache = new LRUCache(1000)) { - opt.setRowCache(lruCache); - assertThat(opt.rowCache()).isEqualTo(lruCache); - } - - try(final Cache clockCache = new ClockCache(1000)) { - opt.setRowCache(clockCache); - assertThat(opt.rowCache()).isEqualTo(clockCache); - } - } - } - - @Test - public void failIfOptionsFileError() { - try (final Options opt = new Options()) { - final boolean boolValue = rand.nextBoolean(); - opt.setFailIfOptionsFileError(boolValue); - assertThat(opt.failIfOptionsFileError()).isEqualTo(boolValue); - } - } - - @Test - public void dumpMallocStats() { - try (final Options opt = new Options()) { - final boolean boolValue = rand.nextBoolean(); - opt.setDumpMallocStats(boolValue); - assertThat(opt.dumpMallocStats()).isEqualTo(boolValue); - } - } - - @Test - public void avoidFlushDuringRecovery() { - try (final Options opt = new Options()) { - final boolean boolValue = rand.nextBoolean(); - opt.setAvoidFlushDuringRecovery(boolValue); - assertThat(opt.avoidFlushDuringRecovery()).isEqualTo(boolValue); - } - } - - @Test - public void avoidFlushDuringShutdown() { - try (final Options opt = new Options()) { - final boolean boolValue = rand.nextBoolean(); - opt.setAvoidFlushDuringShutdown(boolValue); - assertThat(opt.avoidFlushDuringShutdown()).isEqualTo(boolValue); - } - } - - @Test - public void env() { - try (final Options options = new Options(); - final Env env = Env.getDefault()) { - options.setEnv(env); - assertThat(options.getEnv()).isSameAs(env); - } - } - - @Test - public void linkageOfPrepMethods() { - try (final Options options = new Options()) { - options.optimizeUniversalStyleCompaction(); - options.optimizeUniversalStyleCompaction(4000); - options.optimizeLevelStyleCompaction(); - options.optimizeLevelStyleCompaction(3000); - options.optimizeForPointLookup(10); - options.optimizeForSmallDb(); - options.prepareForBulkLoad(); - } - } - - @Test - public void compressionTypes() { - try (final Options options = new Options()) { - for (final CompressionType compressionType : - CompressionType.values()) { - options.setCompressionType(compressionType); - assertThat(options.compressionType()). - isEqualTo(compressionType); - assertThat(CompressionType.valueOf("NO_COMPRESSION")). - isEqualTo(CompressionType.NO_COMPRESSION); - } - } - } - - @Test - public void compressionPerLevel() { - try (final Options options = new Options()) { - assertThat(options.compressionPerLevel()).isEmpty(); - List<CompressionType> compressionTypeList = - new ArrayList<>(); - for (int i = 0; i < options.numLevels(); i++) { - compressionTypeList.add(CompressionType.NO_COMPRESSION); - } - options.setCompressionPerLevel(compressionTypeList); - compressionTypeList = options.compressionPerLevel(); - for (final CompressionType compressionType : compressionTypeList) { - assertThat(compressionType).isEqualTo( - CompressionType.NO_COMPRESSION); - } - } - } - - @Test - public void differentCompressionsPerLevel() { - try (final Options options = new Options()) { - options.setNumLevels(3); - - assertThat(options.compressionPerLevel()).isEmpty(); - List<CompressionType> compressionTypeList = new ArrayList<>(); - - compressionTypeList.add(CompressionType.BZLIB2_COMPRESSION); - compressionTypeList.add(CompressionType.SNAPPY_COMPRESSION); - compressionTypeList.add(CompressionType.LZ4_COMPRESSION); - - options.setCompressionPerLevel(compressionTypeList); - compressionTypeList = options.compressionPerLevel(); - - assertThat(compressionTypeList.size()).isEqualTo(3); - assertThat(compressionTypeList). - containsExactly( - CompressionType.BZLIB2_COMPRESSION, - CompressionType.SNAPPY_COMPRESSION, - CompressionType.LZ4_COMPRESSION); - - } - } - - @Test - public void bottommostCompressionType() { - try (final Options options = new Options()) { - assertThat(options.bottommostCompressionType()) - .isEqualTo(CompressionType.DISABLE_COMPRESSION_OPTION); - - for (final CompressionType compressionType : CompressionType.values()) { - options.setBottommostCompressionType(compressionType); - assertThat(options.bottommostCompressionType()) - .isEqualTo(compressionType); - } - } - } - - @Test - public void compressionOptions() { - try (final Options options = new Options(); - final CompressionOptions compressionOptions = new CompressionOptions() - .setMaxDictBytes(123)) { - - options.setCompressionOptions(compressionOptions); - assertThat(options.compressionOptions()) - .isEqualTo(compressionOptions); - assertThat(options.compressionOptions().maxDictBytes()) - .isEqualTo(123); - } - } - - @Test - public void compactionStyles() { - try (final Options options = new Options()) { - for (final CompactionStyle compactionStyle : - CompactionStyle.values()) { - options.setCompactionStyle(compactionStyle); - assertThat(options.compactionStyle()). - isEqualTo(compactionStyle); - assertThat(CompactionStyle.valueOf("FIFO")). - isEqualTo(CompactionStyle.FIFO); - } - } - } - - @Test - public void maxTableFilesSizeFIFO() { - try (final Options opt = new Options()) { - long longValue = rand.nextLong(); - // Size has to be positive - longValue = (longValue < 0) ? -longValue : longValue; - longValue = (longValue == 0) ? longValue + 1 : longValue; - opt.setMaxTableFilesSizeFIFO(longValue); - assertThat(opt.maxTableFilesSizeFIFO()). - isEqualTo(longValue); - } - } - - @Test - public void rateLimiter() { - try (final Options options = new Options(); - final Options anotherOptions = new Options(); - final RateLimiter rateLimiter = - new RateLimiter(1000, 100 * 1000, 1)) { - options.setRateLimiter(rateLimiter); - // Test with parameter initialization - anotherOptions.setRateLimiter( - new RateLimiter(1000)); - } - } - - @Test - public void shouldSetTestPrefixExtractor() { - try (final Options options = new Options()) { - options.useFixedLengthPrefixExtractor(100); - options.useFixedLengthPrefixExtractor(10); - } - } - - @Test - public void shouldSetTestCappedPrefixExtractor() { - try (final Options options = new Options()) { - options.useCappedPrefixExtractor(100); - options.useCappedPrefixExtractor(10); - } - } - - @Test - public void shouldTestMemTableFactoryName() - throws RocksDBException { - try (final Options options = new Options()) { - options.setMemTableConfig(new VectorMemTableConfig()); - assertThat(options.memTableFactoryName()). - isEqualTo("VectorRepFactory"); - options.setMemTableConfig( - new HashLinkedListMemTableConfig()); - assertThat(options.memTableFactoryName()). - isEqualTo("HashLinkedListRepFactory"); - } - } - - @Test - public void statistics() { - try(final Options options = new Options()) { - final Statistics statistics = options.statistics(); - assertThat(statistics).isNull(); - } - - try(final Statistics statistics = new Statistics(); - final Options options = new Options().setStatistics(statistics); - final Statistics stats = options.statistics()) { - assertThat(stats).isNotNull(); - } - } - - @Test - public void maxWriteBufferNumberToMaintain() { - try (final Options options = new Options()) { - int intValue = rand.nextInt(); - // Size has to be positive - intValue = (intValue < 0) ? -intValue : intValue; - intValue = (intValue == 0) ? intValue + 1 : intValue; - options.setMaxWriteBufferNumberToMaintain(intValue); - assertThat(options.maxWriteBufferNumberToMaintain()). - isEqualTo(intValue); - } - } - - @Test - public void compactionPriorities() { - try (final Options options = new Options()) { - for (final CompactionPriority compactionPriority : - CompactionPriority.values()) { - options.setCompactionPriority(compactionPriority); - assertThat(options.compactionPriority()). - isEqualTo(compactionPriority); - } - } - } - - @Test - public void reportBgIoStats() { - try (final Options options = new Options()) { - final boolean booleanValue = true; - options.setReportBgIoStats(booleanValue); - assertThat(options.reportBgIoStats()). - isEqualTo(booleanValue); - } - } - - @Test - public void compactionOptionsUniversal() { - try (final Options options = new Options(); - final CompactionOptionsUniversal optUni = new CompactionOptionsUniversal() - .setCompressionSizePercent(7)) { - options.setCompactionOptionsUniversal(optUni); - assertThat(options.compactionOptionsUniversal()). - isEqualTo(optUni); - assertThat(options.compactionOptionsUniversal().compressionSizePercent()) - .isEqualTo(7); - } - } - - @Test - public void compactionOptionsFIFO() { - try (final Options options = new Options(); - final CompactionOptionsFIFO optFifo = new CompactionOptionsFIFO() - .setMaxTableFilesSize(2000)) { - options.setCompactionOptionsFIFO(optFifo); - assertThat(options.compactionOptionsFIFO()). - isEqualTo(optFifo); - assertThat(options.compactionOptionsFIFO().maxTableFilesSize()) - .isEqualTo(2000); - } - } - - @Test - public void forceConsistencyChecks() { - try (final Options options = new Options()) { - final boolean booleanValue = true; - options.setForceConsistencyChecks(booleanValue); - assertThat(options.forceConsistencyChecks()). - isEqualTo(booleanValue); - } - } -}
http://git-wip-us.apache.org/repos/asf/nifi-minifi-cpp/blob/d3a13a49/thirdparty/rocksdb/java/src/test/java/org/rocksdb/PlainTableConfigTest.java ---------------------------------------------------------------------- diff --git a/thirdparty/rocksdb/java/src/test/java/org/rocksdb/PlainTableConfigTest.java b/thirdparty/rocksdb/java/src/test/java/org/rocksdb/PlainTableConfigTest.java deleted file mode 100644 index dcb6cc3..0000000 --- a/thirdparty/rocksdb/java/src/test/java/org/rocksdb/PlainTableConfigTest.java +++ /dev/null @@ -1,89 +0,0 @@ -// Copyright (c) 2011-present, Facebook, Inc. All rights reserved. -// This source code is licensed under both the GPLv2 (found in the -// COPYING file in the root directory) and Apache 2.0 License -// (found in the LICENSE.Apache file in the root directory). - -package org.rocksdb; - -import org.junit.ClassRule; -import org.junit.Test; - -import static org.assertj.core.api.Assertions.assertThat; - -public class PlainTableConfigTest { - - @ClassRule - public static final RocksMemoryResource rocksMemoryResource = - new RocksMemoryResource(); - - @Test - public void keySize() { - PlainTableConfig plainTableConfig = new PlainTableConfig(); - plainTableConfig.setKeySize(5); - assertThat(plainTableConfig.keySize()). - isEqualTo(5); - } - - @Test - public void bloomBitsPerKey() { - PlainTableConfig plainTableConfig = new PlainTableConfig(); - plainTableConfig.setBloomBitsPerKey(11); - assertThat(plainTableConfig.bloomBitsPerKey()). - isEqualTo(11); - } - - @Test - public void hashTableRatio() { - PlainTableConfig plainTableConfig = new PlainTableConfig(); - plainTableConfig.setHashTableRatio(0.95); - assertThat(plainTableConfig.hashTableRatio()). - isEqualTo(0.95); - } - - @Test - public void indexSparseness() { - PlainTableConfig plainTableConfig = new PlainTableConfig(); - plainTableConfig.setIndexSparseness(18); - assertThat(plainTableConfig.indexSparseness()). - isEqualTo(18); - } - - @Test - public void hugePageTlbSize() { - PlainTableConfig plainTableConfig = new PlainTableConfig(); - plainTableConfig.setHugePageTlbSize(1); - assertThat(plainTableConfig.hugePageTlbSize()). - isEqualTo(1); - } - - @Test - public void encodingType() { - PlainTableConfig plainTableConfig = new PlainTableConfig(); - plainTableConfig.setEncodingType(EncodingType.kPrefix); - assertThat(plainTableConfig.encodingType()).isEqualTo( - EncodingType.kPrefix); - } - - @Test - public void fullScanMode() { - PlainTableConfig plainTableConfig = new PlainTableConfig(); - plainTableConfig.setFullScanMode(true); - assertThat(plainTableConfig.fullScanMode()).isTrue(); } - - @Test - public void storeIndexInFile() { - PlainTableConfig plainTableConfig = new PlainTableConfig(); - plainTableConfig.setStoreIndexInFile(true); - assertThat(plainTableConfig.storeIndexInFile()). - isTrue(); - } - - @Test - public void plainTableConfig() { - try(final Options opt = new Options()) { - final PlainTableConfig plainTableConfig = new PlainTableConfig(); - opt.setTableFormatConfig(plainTableConfig); - assertThat(opt.tableFactoryName()).isEqualTo("PlainTable"); - } - } -} http://git-wip-us.apache.org/repos/asf/nifi-minifi-cpp/blob/d3a13a49/thirdparty/rocksdb/java/src/test/java/org/rocksdb/PlatformRandomHelper.java ---------------------------------------------------------------------- diff --git a/thirdparty/rocksdb/java/src/test/java/org/rocksdb/PlatformRandomHelper.java b/thirdparty/rocksdb/java/src/test/java/org/rocksdb/PlatformRandomHelper.java deleted file mode 100644 index 80ea4d1..0000000 --- a/thirdparty/rocksdb/java/src/test/java/org/rocksdb/PlatformRandomHelper.java +++ /dev/null @@ -1,58 +0,0 @@ -// Copyright (c) 2011-present, Facebook, Inc. All rights reserved. -// This source code is licensed under both the GPLv2 (found in the -// COPYING file in the root directory) and Apache 2.0 License -// (found in the LICENSE.Apache file in the root directory). - -package org.rocksdb; - -import java.util.Random; - -/** - * Helper class to get the appropriate Random class instance dependent - * on the current platform architecture (32bit vs 64bit) - */ -public class PlatformRandomHelper { - /** - * Determine if OS is 32-Bit/64-Bit - * - * @return boolean value indicating if operating system is 64 Bit. - */ - public static boolean isOs64Bit(){ - final boolean is64Bit; - if (System.getProperty("os.name").contains("Windows")) { - is64Bit = (System.getenv("ProgramFiles(x86)") != null); - } else { - is64Bit = (System.getProperty("os.arch").contains("64")); - } - return is64Bit; - } - - /** - * Factory to get a platform specific Random instance - * - * @return {@link java.util.Random} instance. - */ - public static Random getPlatformSpecificRandomFactory(){ - if (isOs64Bit()) { - return new Random(); - } - return new Random32Bit(); - } - - /** - * Random32Bit is a class which overrides {@code nextLong} to - * provide random numbers which fit in size_t. This workaround - * is necessary because there is no unsigned_int < Java 8 - */ - private static class Random32Bit extends Random { - @Override - public long nextLong(){ - return this.nextInt(Integer.MAX_VALUE); - } - } - - /** - * Utility class constructor - */ - private PlatformRandomHelper() { } -} http://git-wip-us.apache.org/repos/asf/nifi-minifi-cpp/blob/d3a13a49/thirdparty/rocksdb/java/src/test/java/org/rocksdb/RateLimiterTest.java ---------------------------------------------------------------------- diff --git a/thirdparty/rocksdb/java/src/test/java/org/rocksdb/RateLimiterTest.java b/thirdparty/rocksdb/java/src/test/java/org/rocksdb/RateLimiterTest.java deleted file mode 100644 index 27567e8..0000000 --- a/thirdparty/rocksdb/java/src/test/java/org/rocksdb/RateLimiterTest.java +++ /dev/null @@ -1,49 +0,0 @@ -// Copyright (c) 2011-present, Facebook, Inc. All rights reserved. -// This source code is licensed under both the GPLv2 (found in the -// COPYING file in the root directory) and Apache 2.0 License -// (found in the LICENSE.Apache file in the root directory). -package org.rocksdb; - -import org.junit.ClassRule; -import org.junit.Test; - -import static org.assertj.core.api.Assertions.assertThat; - -public class RateLimiterTest { - - @ClassRule - public static final RocksMemoryResource rocksMemoryResource = - new RocksMemoryResource(); - - @Test - public void setBytesPerSecond() { - try(final RateLimiter rateLimiter = - new RateLimiter(1000, 100 * 1000, 1)) { - rateLimiter.setBytesPerSecond(2000); - } - } - - @Test - public void getSingleBurstBytes() { - try(final RateLimiter rateLimiter = - new RateLimiter(1000, 100 * 1000, 1)) { - assertThat(rateLimiter.getSingleBurstBytes()).isEqualTo(100); - } - } - - @Test - public void getTotalBytesThrough() { - try(final RateLimiter rateLimiter = - new RateLimiter(1000, 100 * 1000, 1)) { - assertThat(rateLimiter.getTotalBytesThrough()).isEqualTo(0); - } - } - - @Test - public void getTotalRequests() { - try(final RateLimiter rateLimiter = - new RateLimiter(1000, 100 * 1000, 1)) { - assertThat(rateLimiter.getTotalRequests()).isEqualTo(0); - } - } -} http://git-wip-us.apache.org/repos/asf/nifi-minifi-cpp/blob/d3a13a49/thirdparty/rocksdb/java/src/test/java/org/rocksdb/ReadOnlyTest.java ---------------------------------------------------------------------- diff --git a/thirdparty/rocksdb/java/src/test/java/org/rocksdb/ReadOnlyTest.java b/thirdparty/rocksdb/java/src/test/java/org/rocksdb/ReadOnlyTest.java deleted file mode 100644 index 6b4c7b2..0000000 --- a/thirdparty/rocksdb/java/src/test/java/org/rocksdb/ReadOnlyTest.java +++ /dev/null @@ -1,305 +0,0 @@ -// Copyright (c) 2011-present, Facebook, Inc. All rights reserved. -// This source code is licensed under both the GPLv2 (found in the -// COPYING file in the root directory) and Apache 2.0 License -// (found in the LICENSE.Apache file in the root directory). -package org.rocksdb; - -import org.junit.ClassRule; -import org.junit.Rule; -import org.junit.Test; -import org.junit.rules.TemporaryFolder; - -import java.util.ArrayList; -import java.util.Arrays; -import java.util.List; - -import static org.assertj.core.api.Assertions.assertThat; - -public class ReadOnlyTest { - - @ClassRule - public static final RocksMemoryResource rocksMemoryResource = - new RocksMemoryResource(); - - @Rule - public TemporaryFolder dbFolder = new TemporaryFolder(); - - @Test - public void readOnlyOpen() throws RocksDBException { - try (final Options options = new Options() - .setCreateIfMissing(true); - final RocksDB db = RocksDB.open(options, - dbFolder.getRoot().getAbsolutePath())) { - db.put("key".getBytes(), "value".getBytes()); - try (final RocksDB db2 = RocksDB.openReadOnly( - dbFolder.getRoot().getAbsolutePath())) { - assertThat("value"). - isEqualTo(new String(db2.get("key".getBytes()))); - } - } - - try (final ColumnFamilyOptions cfOpts = new ColumnFamilyOptions()) { - final List<ColumnFamilyDescriptor> cfDescriptors = new ArrayList<>(); - cfDescriptors.add(new ColumnFamilyDescriptor( - RocksDB.DEFAULT_COLUMN_FAMILY, cfOpts)); - - final List<ColumnFamilyHandle> columnFamilyHandleList = new ArrayList<>(); - try (final RocksDB db = RocksDB.open(dbFolder.getRoot().getAbsolutePath(), - cfDescriptors, columnFamilyHandleList)) { - try (final ColumnFamilyOptions newCfOpts = new ColumnFamilyOptions(); - final ColumnFamilyOptions newCf2Opts = new ColumnFamilyOptions() - ) { - columnFamilyHandleList.add(db.createColumnFamily( - new ColumnFamilyDescriptor("new_cf".getBytes(), newCfOpts))); - columnFamilyHandleList.add(db.createColumnFamily( - new ColumnFamilyDescriptor("new_cf2".getBytes(), newCf2Opts))); - db.put(columnFamilyHandleList.get(2), "key2".getBytes(), - "value2".getBytes()); - - final List<ColumnFamilyHandle> readOnlyColumnFamilyHandleList = - new ArrayList<>(); - try (final RocksDB db2 = RocksDB.openReadOnly( - dbFolder.getRoot().getAbsolutePath(), cfDescriptors, - readOnlyColumnFamilyHandleList)) { - try (final ColumnFamilyOptions newCfOpts2 = - new ColumnFamilyOptions(); - final ColumnFamilyOptions newCf2Opts2 = - new ColumnFamilyOptions() - ) { - assertThat(db2.get("key2".getBytes())).isNull(); - assertThat(db2.get(readOnlyColumnFamilyHandleList.get(0), - "key2".getBytes())). - isNull(); - cfDescriptors.clear(); - cfDescriptors.add( - new ColumnFamilyDescriptor(RocksDB.DEFAULT_COLUMN_FAMILY, - newCfOpts2)); - cfDescriptors.add(new ColumnFamilyDescriptor("new_cf2".getBytes(), - newCf2Opts2)); - - final List<ColumnFamilyHandle> readOnlyColumnFamilyHandleList2 - = new ArrayList<>(); - try (final RocksDB db3 = RocksDB.openReadOnly( - dbFolder.getRoot().getAbsolutePath(), cfDescriptors, - readOnlyColumnFamilyHandleList2)) { - try { - assertThat(new String(db3.get( - readOnlyColumnFamilyHandleList2.get(1), - "key2".getBytes()))).isEqualTo("value2"); - } finally { - for (final ColumnFamilyHandle columnFamilyHandle : - readOnlyColumnFamilyHandleList2) { - columnFamilyHandle.close(); - } - } - } - } finally { - for (final ColumnFamilyHandle columnFamilyHandle : - readOnlyColumnFamilyHandleList) { - columnFamilyHandle.close(); - } - } - } - } finally { - for (final ColumnFamilyHandle columnFamilyHandle : - columnFamilyHandleList) { - columnFamilyHandle.close(); - } - } - } - } - } - - @Test(expected = RocksDBException.class) - public void failToWriteInReadOnly() throws RocksDBException { - try (final Options options = new Options() - .setCreateIfMissing(true)) { - - try (final RocksDB db = RocksDB.open(options, - dbFolder.getRoot().getAbsolutePath())) { - //no-op - } - } - - try (final ColumnFamilyOptions cfOpts = new ColumnFamilyOptions()) { - final List<ColumnFamilyDescriptor> cfDescriptors = Arrays.asList( - new ColumnFamilyDescriptor(RocksDB.DEFAULT_COLUMN_FAMILY, cfOpts) - ); - - final List<ColumnFamilyHandle> readOnlyColumnFamilyHandleList = - new ArrayList<>(); - try (final RocksDB rDb = RocksDB.openReadOnly( - dbFolder.getRoot().getAbsolutePath(), cfDescriptors, - readOnlyColumnFamilyHandleList)) { - try { - // test that put fails in readonly mode - rDb.put("key".getBytes(), "value".getBytes()); - } finally { - for (final ColumnFamilyHandle columnFamilyHandle : - readOnlyColumnFamilyHandleList) { - columnFamilyHandle.close(); - } - } - } - } - } - - @Test(expected = RocksDBException.class) - public void failToCFWriteInReadOnly() throws RocksDBException { - try (final Options options = new Options().setCreateIfMissing(true); - final RocksDB db = RocksDB.open(options, - dbFolder.getRoot().getAbsolutePath())) { - //no-op - } - - try (final ColumnFamilyOptions cfOpts = new ColumnFamilyOptions()) { - final List<ColumnFamilyDescriptor> cfDescriptors = Arrays.asList( - new ColumnFamilyDescriptor(RocksDB.DEFAULT_COLUMN_FAMILY, cfOpts) - ); - final List<ColumnFamilyHandle> readOnlyColumnFamilyHandleList = - new ArrayList<>(); - try (final RocksDB rDb = RocksDB.openReadOnly( - dbFolder.getRoot().getAbsolutePath(), cfDescriptors, - readOnlyColumnFamilyHandleList)) { - try { - rDb.put(readOnlyColumnFamilyHandleList.get(0), - "key".getBytes(), "value".getBytes()); - } finally { - for (final ColumnFamilyHandle columnFamilyHandle : - readOnlyColumnFamilyHandleList) { - columnFamilyHandle.close(); - } - } - } - } - } - - @Test(expected = RocksDBException.class) - public void failToRemoveInReadOnly() throws RocksDBException { - try (final Options options = new Options().setCreateIfMissing(true); - final RocksDB db = RocksDB.open(options, - dbFolder.getRoot().getAbsolutePath())) { - //no-op - } - - try (final ColumnFamilyOptions cfOpts = new ColumnFamilyOptions()) { - final List<ColumnFamilyDescriptor> cfDescriptors = Arrays.asList( - new ColumnFamilyDescriptor(RocksDB.DEFAULT_COLUMN_FAMILY, cfOpts) - ); - - final List<ColumnFamilyHandle> readOnlyColumnFamilyHandleList = - new ArrayList<>(); - - try (final RocksDB rDb = RocksDB.openReadOnly( - dbFolder.getRoot().getAbsolutePath(), cfDescriptors, - readOnlyColumnFamilyHandleList)) { - try { - rDb.remove("key".getBytes()); - } finally { - for (final ColumnFamilyHandle columnFamilyHandle : - readOnlyColumnFamilyHandleList) { - columnFamilyHandle.close(); - } - } - } - } - } - - @Test(expected = RocksDBException.class) - public void failToCFRemoveInReadOnly() throws RocksDBException { - try (final Options options = new Options().setCreateIfMissing(true); - final RocksDB db = RocksDB.open(options, - dbFolder.getRoot().getAbsolutePath())) { - //no-op - } - - try (final ColumnFamilyOptions cfOpts = new ColumnFamilyOptions()) { - final List<ColumnFamilyDescriptor> cfDescriptors = Arrays.asList( - new ColumnFamilyDescriptor(RocksDB.DEFAULT_COLUMN_FAMILY, cfOpts) - ); - - final List<ColumnFamilyHandle> readOnlyColumnFamilyHandleList = - new ArrayList<>(); - try (final RocksDB rDb = RocksDB.openReadOnly( - dbFolder.getRoot().getAbsolutePath(), cfDescriptors, - readOnlyColumnFamilyHandleList)) { - try { - rDb.remove(readOnlyColumnFamilyHandleList.get(0), - "key".getBytes()); - } finally { - for (final ColumnFamilyHandle columnFamilyHandle : - readOnlyColumnFamilyHandleList) { - columnFamilyHandle.close(); - } - } - } - } - } - - @Test(expected = RocksDBException.class) - public void failToWriteBatchReadOnly() throws RocksDBException { - try (final Options options = new Options().setCreateIfMissing(true); - final RocksDB db = RocksDB.open(options, - dbFolder.getRoot().getAbsolutePath())) { - //no-op - } - - try (final ColumnFamilyOptions cfOpts = new ColumnFamilyOptions()) { - final List<ColumnFamilyDescriptor> cfDescriptors = Arrays.asList( - new ColumnFamilyDescriptor(RocksDB.DEFAULT_COLUMN_FAMILY, cfOpts) - ); - - final List<ColumnFamilyHandle> readOnlyColumnFamilyHandleList = - new ArrayList<>(); - try (final RocksDB rDb = RocksDB.openReadOnly( - dbFolder.getRoot().getAbsolutePath(), cfDescriptors, - readOnlyColumnFamilyHandleList); - final WriteBatch wb = new WriteBatch(); - final WriteOptions wOpts = new WriteOptions()) { - try { - wb.put("key".getBytes(), "value".getBytes()); - rDb.write(wOpts, wb); - } finally { - for (final ColumnFamilyHandle columnFamilyHandle : - readOnlyColumnFamilyHandleList) { - columnFamilyHandle.close(); - } - } - } - } - } - - @Test(expected = RocksDBException.class) - public void failToCFWriteBatchReadOnly() throws RocksDBException { - try (final Options options = new Options().setCreateIfMissing(true); - final RocksDB db = RocksDB.open(options, - dbFolder.getRoot().getAbsolutePath())) { - //no-op - } - - try (final ColumnFamilyOptions cfOpts = new ColumnFamilyOptions()) { - final List<ColumnFamilyDescriptor> cfDescriptors = Arrays.asList( - new ColumnFamilyDescriptor(RocksDB.DEFAULT_COLUMN_FAMILY, cfOpts) - ); - - final List<ColumnFamilyHandle> readOnlyColumnFamilyHandleList = - new ArrayList<>(); - try (final RocksDB rDb = RocksDB.openReadOnly( - dbFolder.getRoot().getAbsolutePath(), cfDescriptors, - readOnlyColumnFamilyHandleList); - final WriteBatch wb = new WriteBatch(); - final WriteOptions wOpts = new WriteOptions()) { - try { - wb.put(readOnlyColumnFamilyHandleList.get(0), "key".getBytes(), - "value".getBytes()); - rDb.write(wOpts, wb); - } finally { - for (final ColumnFamilyHandle columnFamilyHandle : - readOnlyColumnFamilyHandleList) { - columnFamilyHandle.close(); - } - } - } - } - } -} http://git-wip-us.apache.org/repos/asf/nifi-minifi-cpp/blob/d3a13a49/thirdparty/rocksdb/java/src/test/java/org/rocksdb/ReadOptionsTest.java ---------------------------------------------------------------------- diff --git a/thirdparty/rocksdb/java/src/test/java/org/rocksdb/ReadOptionsTest.java b/thirdparty/rocksdb/java/src/test/java/org/rocksdb/ReadOptionsTest.java deleted file mode 100644 index da048c4..0000000 --- a/thirdparty/rocksdb/java/src/test/java/org/rocksdb/ReadOptionsTest.java +++ /dev/null @@ -1,201 +0,0 @@ -// Copyright (c) 2011-present, Facebook, Inc. All rights reserved. -// This source code is licensed under both the GPLv2 (found in the -// COPYING file in the root directory) and Apache 2.0 License -// (found in the LICENSE.Apache file in the root directory). - -package org.rocksdb; - -import java.util.Random; - -import org.junit.ClassRule; -import org.junit.Rule; -import org.junit.Test; -import org.junit.rules.ExpectedException; - -import static org.assertj.core.api.Assertions.assertThat; - -public class ReadOptionsTest { - - @ClassRule - public static final RocksMemoryResource rocksMemoryResource = - new RocksMemoryResource(); - - @Rule - public ExpectedException exception = ExpectedException.none(); - - @Test - public void verifyChecksum() { - try (final ReadOptions opt = new ReadOptions()) { - final Random rand = new Random(); - final boolean boolValue = rand.nextBoolean(); - opt.setVerifyChecksums(boolValue); - assertThat(opt.verifyChecksums()).isEqualTo(boolValue); - } - } - - @Test - public void fillCache() { - try (final ReadOptions opt = new ReadOptions()) { - final Random rand = new Random(); - final boolean boolValue = rand.nextBoolean(); - opt.setFillCache(boolValue); - assertThat(opt.fillCache()).isEqualTo(boolValue); - } - } - - @Test - public void tailing() { - try (final ReadOptions opt = new ReadOptions()) { - final Random rand = new Random(); - final boolean boolValue = rand.nextBoolean(); - opt.setTailing(boolValue); - assertThat(opt.tailing()).isEqualTo(boolValue); - } - } - - @Test - public void snapshot() { - try (final ReadOptions opt = new ReadOptions()) { - opt.setSnapshot(null); - assertThat(opt.snapshot()).isNull(); - } - } - - @Test - public void readTier() { - try (final ReadOptions opt = new ReadOptions()) { - opt.setReadTier(ReadTier.BLOCK_CACHE_TIER); - assertThat(opt.readTier()).isEqualTo(ReadTier.BLOCK_CACHE_TIER); - } - } - - @Test - public void managed() { - try (final ReadOptions opt = new ReadOptions()) { - opt.setManaged(true); - assertThat(opt.managed()).isTrue(); - } - } - - @Test - public void totalOrderSeek() { - try (final ReadOptions opt = new ReadOptions()) { - opt.setTotalOrderSeek(true); - assertThat(opt.totalOrderSeek()).isTrue(); - } - } - - @Test - public void prefixSameAsStart() { - try (final ReadOptions opt = new ReadOptions()) { - opt.setPrefixSameAsStart(true); - assertThat(opt.prefixSameAsStart()).isTrue(); - } - } - - @Test - public void pinData() { - try (final ReadOptions opt = new ReadOptions()) { - opt.setPinData(true); - assertThat(opt.pinData()).isTrue(); - } - } - - @Test - public void backgroundPurgeOnIteratorCleanup() { - try (final ReadOptions opt = new ReadOptions()) { - opt.setBackgroundPurgeOnIteratorCleanup(true); - assertThat(opt.backgroundPurgeOnIteratorCleanup()).isTrue(); - } - } - - @Test - public void readaheadSize() { - try (final ReadOptions opt = new ReadOptions()) { - final Random rand = new Random(); - final long longValue = rand.nextLong(); - opt.setReadaheadSize(longValue); - assertThat(opt.readaheadSize()).isEqualTo(longValue); - } - } - - @Test - public void ignoreRangeDeletions() { - try (final ReadOptions opt = new ReadOptions()) { - opt.setIgnoreRangeDeletions(true); - assertThat(opt.ignoreRangeDeletions()).isTrue(); - } - } - - @Test - public void failSetVerifyChecksumUninitialized() { - try (final ReadOptions readOptions = - setupUninitializedReadOptions(exception)) { - readOptions.setVerifyChecksums(true); - } - } - - @Test - public void failVerifyChecksumUninitialized() { - try (final ReadOptions readOptions = - setupUninitializedReadOptions(exception)) { - readOptions.verifyChecksums(); - } - } - - @Test - public void failSetFillCacheUninitialized() { - try (final ReadOptions readOptions = - setupUninitializedReadOptions(exception)) { - readOptions.setFillCache(true); - } - } - - @Test - public void failFillCacheUninitialized() { - try (final ReadOptions readOptions = - setupUninitializedReadOptions(exception)) { - readOptions.fillCache(); - } - } - - @Test - public void failSetTailingUninitialized() { - try (final ReadOptions readOptions = - setupUninitializedReadOptions(exception)) { - readOptions.setTailing(true); - } - } - - @Test - public void failTailingUninitialized() { - try (final ReadOptions readOptions = - setupUninitializedReadOptions(exception)) { - readOptions.tailing(); - } - } - - @Test - public void failSetSnapshotUninitialized() { - try (final ReadOptions readOptions = - setupUninitializedReadOptions(exception)) { - readOptions.setSnapshot(null); - } - } - - @Test - public void failSnapshotUninitialized() { - try (final ReadOptions readOptions = - setupUninitializedReadOptions(exception)) { - readOptions.snapshot(); - } - } - - private ReadOptions setupUninitializedReadOptions( - ExpectedException exception) { - final ReadOptions readOptions = new ReadOptions(); - readOptions.close(); - exception.expect(AssertionError.class); - return readOptions; - } -} http://git-wip-us.apache.org/repos/asf/nifi-minifi-cpp/blob/d3a13a49/thirdparty/rocksdb/java/src/test/java/org/rocksdb/RocksDBExceptionTest.java ---------------------------------------------------------------------- diff --git a/thirdparty/rocksdb/java/src/test/java/org/rocksdb/RocksDBExceptionTest.java b/thirdparty/rocksdb/java/src/test/java/org/rocksdb/RocksDBExceptionTest.java deleted file mode 100644 index d3bd4ec..0000000 --- a/thirdparty/rocksdb/java/src/test/java/org/rocksdb/RocksDBExceptionTest.java +++ /dev/null @@ -1,115 +0,0 @@ -// Copyright (c) 2011-present, Facebook, Inc. All rights reserved. -// This source code is licensed under both the GPLv2 (found in the -// COPYING file in the root directory) and Apache 2.0 License -// (found in the LICENSE.Apache file in the root directory). - -package org.rocksdb; - -import org.junit.Test; - -import org.rocksdb.Status.Code; -import org.rocksdb.Status.SubCode; -import static org.assertj.core.api.Assertions.assertThat; -import static org.junit.Assert.fail; - -public class RocksDBExceptionTest { - - @Test - public void exception() { - try { - raiseException(); - } catch(final RocksDBException e) { - assertThat(e.getStatus()).isNull(); - assertThat(e.getMessage()).isEqualTo("test message"); - return; - } - fail(); - } - - @Test - public void exceptionWithStatusCode() { - try { - raiseExceptionWithStatusCode(); - } catch(final RocksDBException e) { - assertThat(e.getStatus()).isNotNull(); - assertThat(e.getStatus().getCode()).isEqualTo(Code.NotSupported); - assertThat(e.getStatus().getSubCode()).isEqualTo(SubCode.None); - assertThat(e.getStatus().getState()).isNull(); - assertThat(e.getMessage()).isEqualTo("test message"); - return; - } - fail(); - } - - @Test - public void exceptionNoMsgWithStatusCode() { - try { - raiseExceptionNoMsgWithStatusCode(); - } catch(final RocksDBException e) { - assertThat(e.getStatus()).isNotNull(); - assertThat(e.getStatus().getCode()).isEqualTo(Code.NotSupported); - assertThat(e.getStatus().getSubCode()).isEqualTo(SubCode.None); - assertThat(e.getStatus().getState()).isNull(); - assertThat(e.getMessage()).isEqualTo(Code.NotSupported.name()); - return; - } - fail(); - } - - @Test - public void exceptionWithStatusCodeSubCode() { - try { - raiseExceptionWithStatusCodeSubCode(); - } catch(final RocksDBException e) { - assertThat(e.getStatus()).isNotNull(); - assertThat(e.getStatus().getCode()).isEqualTo(Code.TimedOut); - assertThat(e.getStatus().getSubCode()) - .isEqualTo(Status.SubCode.LockTimeout); - assertThat(e.getStatus().getState()).isNull(); - assertThat(e.getMessage()).isEqualTo("test message"); - return; - } - fail(); - } - - @Test - public void exceptionNoMsgWithStatusCodeSubCode() { - try { - raiseExceptionNoMsgWithStatusCodeSubCode(); - } catch(final RocksDBException e) { - assertThat(e.getStatus()).isNotNull(); - assertThat(e.getStatus().getCode()).isEqualTo(Code.TimedOut); - assertThat(e.getStatus().getSubCode()).isEqualTo(SubCode.LockTimeout); - assertThat(e.getStatus().getState()).isNull(); - assertThat(e.getMessage()).isEqualTo(Code.TimedOut.name() + - "(" + SubCode.LockTimeout.name() + ")"); - return; - } - fail(); - } - - @Test - public void exceptionWithStatusCodeState() { - try { - raiseExceptionWithStatusCodeState(); - } catch(final RocksDBException e) { - assertThat(e.getStatus()).isNotNull(); - assertThat(e.getStatus().getCode()).isEqualTo(Code.NotSupported); - assertThat(e.getStatus().getSubCode()).isEqualTo(SubCode.None); - assertThat(e.getStatus().getState()).isNotNull(); - assertThat(e.getMessage()).isEqualTo("test message"); - return; - } - fail(); - } - - private native void raiseException() throws RocksDBException; - private native void raiseExceptionWithStatusCode() throws RocksDBException; - private native void raiseExceptionNoMsgWithStatusCode() throws RocksDBException; - private native void raiseExceptionWithStatusCodeSubCode() - throws RocksDBException; - private native void raiseExceptionNoMsgWithStatusCodeSubCode() - throws RocksDBException; - private native void raiseExceptionWithStatusCodeState() - throws RocksDBException; -}
