Lines Matching refs:opt
47 try(final DBOptions opt = DBOptions.getDBOptionsFromProps(properties)) { in getDBOptionsFromProps() argument
48 assertThat(opt).isNotNull(); in getDBOptionsFromProps()
49 assertThat(String.valueOf(opt.allowMmapReads())). in getDBOptionsFromProps()
51 assertThat(String.valueOf(opt.bytesPerSync())). in getDBOptionsFromProps()
62 try(final DBOptions opt = DBOptions.getDBOptionsFromProps(properties)) { in failDBOptionsFromPropsWithIllegalValue() argument
63 assertThat(opt).isNull(); in failDBOptionsFromPropsWithIllegalValue()
69 try(final DBOptions opt = DBOptions.getDBOptionsFromProps(null)) { in failDBOptionsFromPropsWithNullValue() argument
76 try(final DBOptions opt = DBOptions.getDBOptionsFromProps( in failDBOptionsFromPropsWithEmptyProps() argument
84 try (final DBOptions opt = new DBOptions()) { in linkageOfPrepMethods() argument
85 opt.optimizeForSmallDb(); in linkageOfPrepMethods()
91 try (final DBOptions opt = new DBOptions(); in env() argument
93 opt.setEnv(env); in env()
94 assertThat(opt.getEnv()).isSameAs(env); in env()
100 try(final DBOptions opt = new DBOptions()) { in setIncreaseParallelism() argument
102 opt.setIncreaseParallelism(threads); in setIncreaseParallelism()
108 try(final DBOptions opt = new DBOptions()) { in createIfMissing() argument
110 opt.setCreateIfMissing(boolValue); in createIfMissing()
111 assertThat(opt.createIfMissing()).isEqualTo(boolValue); in createIfMissing()
117 try(final DBOptions opt = new DBOptions()) { in createMissingColumnFamilies() argument
119 opt.setCreateMissingColumnFamilies(boolValue); in createMissingColumnFamilies()
120 assertThat(opt.createMissingColumnFamilies()).isEqualTo(boolValue); in createMissingColumnFamilies()
126 try(final DBOptions opt = new DBOptions()) { in errorIfExists() argument
128 opt.setErrorIfExists(boolValue); in errorIfExists()
129 assertThat(opt.errorIfExists()).isEqualTo(boolValue); in errorIfExists()
135 try(final DBOptions opt = new DBOptions()) { in paranoidChecks() argument
137 opt.setParanoidChecks(boolValue); in paranoidChecks()
138 assertThat(opt.paranoidChecks()).isEqualTo(boolValue); in paranoidChecks()
144 try(final DBOptions opt = new DBOptions()) { in maxTotalWalSize() argument
146 opt.setMaxTotalWalSize(longValue); in maxTotalWalSize()
147 assertThat(opt.maxTotalWalSize()).isEqualTo(longValue); in maxTotalWalSize()
153 try(final DBOptions opt = new DBOptions()) { in maxOpenFiles() argument
155 opt.setMaxOpenFiles(intValue); in maxOpenFiles()
156 assertThat(opt.maxOpenFiles()).isEqualTo(intValue); in maxOpenFiles()
162 try(final DBOptions opt = new DBOptions()) { in maxFileOpeningThreads() argument
164 opt.setMaxFileOpeningThreads(intValue); in maxFileOpeningThreads()
165 assertThat(opt.maxFileOpeningThreads()).isEqualTo(intValue); in maxFileOpeningThreads()
171 try(final DBOptions opt = new DBOptions()) { in useFsync() argument
173 opt.setUseFsync(boolValue); in useFsync()
174 assertThat(opt.useFsync()).isEqualTo(boolValue); in useFsync()
185 try(final DBOptions opt = new DBOptions()) { in dbPaths() argument
186 assertThat(opt.dbPaths()).isEqualTo(Collections.emptyList()); in dbPaths()
188 opt.setDbPaths(dbPaths); in dbPaths()
190 assertThat(opt.dbPaths()).isEqualTo(dbPaths); in dbPaths()
196 try(final DBOptions opt = new DBOptions()) { in dbLogDir() argument
198 opt.setDbLogDir(str); in dbLogDir()
199 assertThat(opt.dbLogDir()).isEqualTo(str); in dbLogDir()
205 try(final DBOptions opt = new DBOptions()) { in walDir() argument
207 opt.setWalDir(str); in walDir()
208 assertThat(opt.walDir()).isEqualTo(str); in walDir()
214 try(final DBOptions opt = new DBOptions()) { in deleteObsoleteFilesPeriodMicros() argument
216 opt.setDeleteObsoleteFilesPeriodMicros(longValue); in deleteObsoleteFilesPeriodMicros()
217 assertThat(opt.deleteObsoleteFilesPeriodMicros()).isEqualTo(longValue); in deleteObsoleteFilesPeriodMicros()
224 try (final DBOptions opt = new DBOptions()) { in baseBackgroundCompactions() argument
226 opt.setBaseBackgroundCompactions(intValue); in baseBackgroundCompactions()
227 assertThat(opt.baseBackgroundCompactions()). in baseBackgroundCompactions()
235 try(final DBOptions opt = new DBOptions()) { in maxBackgroundCompactions() argument
237 opt.setMaxBackgroundCompactions(intValue); in maxBackgroundCompactions()
238 assertThat(opt.maxBackgroundCompactions()).isEqualTo(intValue); in maxBackgroundCompactions()
244 try (final DBOptions opt = new DBOptions()) { in maxSubcompactions() argument
246 opt.setMaxSubcompactions(intValue); in maxSubcompactions()
247 assertThat(opt.maxSubcompactions()). in maxSubcompactions()
255 try(final DBOptions opt = new DBOptions()) { in maxBackgroundFlushes() argument
257 opt.setMaxBackgroundFlushes(intValue); in maxBackgroundFlushes()
258 assertThat(opt.maxBackgroundFlushes()).isEqualTo(intValue); in maxBackgroundFlushes()
264 try (final DBOptions opt = new DBOptions()) { in maxBackgroundJobs() argument
266 opt.setMaxBackgroundJobs(intValue); in maxBackgroundJobs()
267 assertThat(opt.maxBackgroundJobs()).isEqualTo(intValue); in maxBackgroundJobs()
273 try(final DBOptions opt = new DBOptions()) { in maxLogFileSize() argument
275 opt.setMaxLogFileSize(longValue); in maxLogFileSize()
276 assertThat(opt.maxLogFileSize()).isEqualTo(longValue); in maxLogFileSize()
282 try(final DBOptions opt = new DBOptions()) { in logFileTimeToRoll() argument
284 opt.setLogFileTimeToRoll(longValue); in logFileTimeToRoll()
285 assertThat(opt.logFileTimeToRoll()).isEqualTo(longValue); in logFileTimeToRoll()
291 try(final DBOptions opt = new DBOptions()) { in keepLogFileNum() argument
293 opt.setKeepLogFileNum(longValue); in keepLogFileNum()
294 assertThat(opt.keepLogFileNum()).isEqualTo(longValue); in keepLogFileNum()
300 try(final DBOptions opt = new DBOptions()) { in recycleLogFileNum() argument
302 opt.setRecycleLogFileNum(longValue); in recycleLogFileNum()
303 assertThat(opt.recycleLogFileNum()).isEqualTo(longValue); in recycleLogFileNum()
309 try(final DBOptions opt = new DBOptions()) { in maxManifestFileSize() argument
311 opt.setMaxManifestFileSize(longValue); in maxManifestFileSize()
312 assertThat(opt.maxManifestFileSize()).isEqualTo(longValue); in maxManifestFileSize()
318 try(final DBOptions opt = new DBOptions()) { in tableCacheNumshardbits() argument
320 opt.setTableCacheNumshardbits(intValue); in tableCacheNumshardbits()
321 assertThat(opt.tableCacheNumshardbits()).isEqualTo(intValue); in tableCacheNumshardbits()
327 try(final DBOptions opt = new DBOptions()) { in walSizeLimitMB() argument
329 opt.setWalSizeLimitMB(longValue); in walSizeLimitMB()
330 assertThat(opt.walSizeLimitMB()).isEqualTo(longValue); in walSizeLimitMB()
336 try(final DBOptions opt = new DBOptions()) { in walTtlSeconds() argument
338 opt.setWalTtlSeconds(longValue); in walTtlSeconds()
339 assertThat(opt.walTtlSeconds()).isEqualTo(longValue); in walTtlSeconds()
345 try(final DBOptions opt = new DBOptions()) { in manifestPreallocationSize() argument
347 opt.setManifestPreallocationSize(longValue); in manifestPreallocationSize()
348 assertThat(opt.manifestPreallocationSize()).isEqualTo(longValue); in manifestPreallocationSize()
354 try(final DBOptions opt = new DBOptions()) { in useDirectReads() argument
356 opt.setUseDirectReads(boolValue); in useDirectReads()
357 assertThat(opt.useDirectReads()).isEqualTo(boolValue); in useDirectReads()
363 try(final DBOptions opt = new DBOptions()) { in useDirectIoForFlushAndCompaction() argument
365 opt.setUseDirectIoForFlushAndCompaction(boolValue); in useDirectIoForFlushAndCompaction()
366 assertThat(opt.useDirectIoForFlushAndCompaction()).isEqualTo(boolValue); in useDirectIoForFlushAndCompaction()
372 try(final DBOptions opt = new DBOptions()) { in allowFAllocate() argument
374 opt.setAllowFAllocate(boolValue); in allowFAllocate()
375 assertThat(opt.allowFAllocate()).isEqualTo(boolValue); in allowFAllocate()
381 try(final DBOptions opt = new DBOptions()) { in allowMmapReads() argument
383 opt.setAllowMmapReads(boolValue); in allowMmapReads()
384 assertThat(opt.allowMmapReads()).isEqualTo(boolValue); in allowMmapReads()
390 try(final DBOptions opt = new DBOptions()) { in allowMmapWrites() argument
392 opt.setAllowMmapWrites(boolValue); in allowMmapWrites()
393 assertThat(opt.allowMmapWrites()).isEqualTo(boolValue); in allowMmapWrites()
399 try(final DBOptions opt = new DBOptions()) { in isFdCloseOnExec() argument
401 opt.setIsFdCloseOnExec(boolValue); in isFdCloseOnExec()
402 assertThat(opt.isFdCloseOnExec()).isEqualTo(boolValue); in isFdCloseOnExec()
408 try(final DBOptions opt = new DBOptions()) { in statsDumpPeriodSec() argument
410 opt.setStatsDumpPeriodSec(intValue); in statsDumpPeriodSec()
411 assertThat(opt.statsDumpPeriodSec()).isEqualTo(intValue); in statsDumpPeriodSec()
417 try (final DBOptions opt = new DBOptions()) { in statsPersistPeriodSec() argument
419 opt.setStatsPersistPeriodSec(intValue); in statsPersistPeriodSec()
420 assertThat(opt.statsPersistPeriodSec()).isEqualTo(intValue); in statsPersistPeriodSec()
426 try (final DBOptions opt = new DBOptions()) { in statsHistoryBufferSize() argument
428 opt.setStatsHistoryBufferSize(longValue); in statsHistoryBufferSize()
429 assertThat(opt.statsHistoryBufferSize()).isEqualTo(longValue); in statsHistoryBufferSize()
435 try(final DBOptions opt = new DBOptions()) { in adviseRandomOnOpen() argument
437 opt.setAdviseRandomOnOpen(boolValue); in adviseRandomOnOpen()
438 assertThat(opt.adviseRandomOnOpen()).isEqualTo(boolValue); in adviseRandomOnOpen()
444 try(final DBOptions opt = new DBOptions()) { in dbWriteBufferSize() argument
446 opt.setDbWriteBufferSize(longValue); in dbWriteBufferSize()
447 assertThat(opt.dbWriteBufferSize()).isEqualTo(longValue); in dbWriteBufferSize()
453 try (final DBOptions opt = new DBOptions(); in setWriteBufferManager() argument
456 opt.setWriteBufferManager(writeBufferManager); in setWriteBufferManager()
457 assertThat(opt.writeBufferManager()).isEqualTo(writeBufferManager); in setWriteBufferManager()
463 try (final DBOptions opt = new DBOptions(); in setWriteBufferManagerWithZeroBufferSize() argument
466 opt.setWriteBufferManager(writeBufferManager); in setWriteBufferManagerWithZeroBufferSize()
467 assertThat(opt.writeBufferManager()).isEqualTo(writeBufferManager); in setWriteBufferManagerWithZeroBufferSize()
473 try(final DBOptions opt = new DBOptions()) { in accessHintOnCompactionStart() argument
475 opt.setAccessHintOnCompactionStart(accessHint); in accessHintOnCompactionStart()
476 assertThat(opt.accessHintOnCompactionStart()).isEqualTo(accessHint); in accessHintOnCompactionStart()
482 try(final DBOptions opt = new DBOptions()) { in newTableReaderForCompactionInputs() argument
484 opt.setNewTableReaderForCompactionInputs(boolValue); in newTableReaderForCompactionInputs()
485 assertThat(opt.newTableReaderForCompactionInputs()).isEqualTo(boolValue); in newTableReaderForCompactionInputs()
491 try(final DBOptions opt = new DBOptions()) { in compactionReadaheadSize() argument
493 opt.setCompactionReadaheadSize(longValue); in compactionReadaheadSize()
494 assertThat(opt.compactionReadaheadSize()).isEqualTo(longValue); in compactionReadaheadSize()
500 try(final DBOptions opt = new DBOptions()) { in randomAccessMaxBufferSize() argument
502 opt.setRandomAccessMaxBufferSize(longValue); in randomAccessMaxBufferSize()
503 assertThat(opt.randomAccessMaxBufferSize()).isEqualTo(longValue); in randomAccessMaxBufferSize()
509 try(final DBOptions opt = new DBOptions()) { in writableFileMaxBufferSize() argument
511 opt.setWritableFileMaxBufferSize(longValue); in writableFileMaxBufferSize()
512 assertThat(opt.writableFileMaxBufferSize()).isEqualTo(longValue); in writableFileMaxBufferSize()
518 try(final DBOptions opt = new DBOptions()) { in useAdaptiveMutex() argument
520 opt.setUseAdaptiveMutex(boolValue); in useAdaptiveMutex()
521 assertThat(opt.useAdaptiveMutex()).isEqualTo(boolValue); in useAdaptiveMutex()
527 try(final DBOptions opt = new DBOptions()) { in bytesPerSync() argument
529 opt.setBytesPerSync(longValue); in bytesPerSync()
530 assertThat(opt.bytesPerSync()).isEqualTo(longValue); in bytesPerSync()
536 try(final DBOptions opt = new DBOptions()) { in walBytesPerSync() argument
538 opt.setWalBytesPerSync(longValue); in walBytesPerSync()
539 assertThat(opt.walBytesPerSync()).isEqualTo(longValue); in walBytesPerSync()
545 try (final DBOptions opt = new DBOptions()) { in strictBytesPerSync() argument
546 assertThat(opt.strictBytesPerSync()).isFalse(); in strictBytesPerSync()
547 opt.setStrictBytesPerSync(true); in strictBytesPerSync()
548 assertThat(opt.strictBytesPerSync()).isTrue(); in strictBytesPerSync()
554 try (final DBOptions opt = new DBOptions()) { in enableThreadTracking() argument
556 opt.setEnableThreadTracking(boolValue); in enableThreadTracking()
557 assertThat(opt.enableThreadTracking()).isEqualTo(boolValue); in enableThreadTracking()
563 try(final DBOptions opt = new DBOptions()) { in delayedWriteRate() argument
565 opt.setDelayedWriteRate(longValue); in delayedWriteRate()
566 assertThat(opt.delayedWriteRate()).isEqualTo(longValue); in delayedWriteRate()
572 try(final DBOptions opt = new DBOptions()) { in enablePipelinedWrite() argument
573 assertThat(opt.enablePipelinedWrite()).isFalse(); in enablePipelinedWrite()
574 opt.setEnablePipelinedWrite(true); in enablePipelinedWrite()
575 assertThat(opt.enablePipelinedWrite()).isTrue(); in enablePipelinedWrite()
581 try(final DBOptions opt = new DBOptions()) { in unordredWrite() argument
582 assertThat(opt.unorderedWrite()).isFalse(); in unordredWrite()
583 opt.setUnorderedWrite(true); in unordredWrite()
584 assertThat(opt.unorderedWrite()).isTrue(); in unordredWrite()
590 try (final DBOptions opt = new DBOptions()) { in allowConcurrentMemtableWrite() argument
592 opt.setAllowConcurrentMemtableWrite(boolValue); in allowConcurrentMemtableWrite()
593 assertThat(opt.allowConcurrentMemtableWrite()).isEqualTo(boolValue); in allowConcurrentMemtableWrite()
599 try (final DBOptions opt = new DBOptions()) { in enableWriteThreadAdaptiveYield() argument
601 opt.setEnableWriteThreadAdaptiveYield(boolValue); in enableWriteThreadAdaptiveYield()
602 assertThat(opt.enableWriteThreadAdaptiveYield()).isEqualTo(boolValue); in enableWriteThreadAdaptiveYield()
608 try (final DBOptions opt = new DBOptions()) { in writeThreadMaxYieldUsec() argument
610 opt.setWriteThreadMaxYieldUsec(longValue); in writeThreadMaxYieldUsec()
611 assertThat(opt.writeThreadMaxYieldUsec()).isEqualTo(longValue); in writeThreadMaxYieldUsec()
617 try (final DBOptions opt = new DBOptions()) { in writeThreadSlowYieldUsec() argument
619 opt.setWriteThreadSlowYieldUsec(longValue); in writeThreadSlowYieldUsec()
620 assertThat(opt.writeThreadSlowYieldUsec()).isEqualTo(longValue); in writeThreadSlowYieldUsec()
626 try (final DBOptions opt = new DBOptions()) { in skipStatsUpdateOnDbOpen() argument
628 opt.setSkipStatsUpdateOnDbOpen(boolValue); in skipStatsUpdateOnDbOpen()
629 assertThat(opt.skipStatsUpdateOnDbOpen()).isEqualTo(boolValue); in skipStatsUpdateOnDbOpen()
635 try (final DBOptions opt = new DBOptions()) { in walRecoveryMode() argument
637 opt.setWalRecoveryMode(walRecoveryMode); in walRecoveryMode()
638 assertThat(opt.walRecoveryMode()).isEqualTo(walRecoveryMode); in walRecoveryMode()
645 try (final DBOptions opt = new DBOptions()) { in allow2pc() argument
647 opt.setAllow2pc(boolValue); in allow2pc()
648 assertThat(opt.allow2pc()).isEqualTo(boolValue); in allow2pc()
654 try (final DBOptions opt = new DBOptions()) { in rowCache() argument
655 assertThat(opt.rowCache()).isNull(); in rowCache()
658 opt.setRowCache(lruCache); in rowCache()
659 assertThat(opt.rowCache()).isEqualTo(lruCache); in rowCache()
663 opt.setRowCache(clockCache); in rowCache()
664 assertThat(opt.rowCache()).isEqualTo(clockCache); in rowCache()
671 try (final DBOptions opt = new DBOptions()) { in walFilter() argument
672 assertThat(opt.walFilter()).isNull(); in walFilter()
695 opt.setWalFilter(walFilter); in walFilter()
696 assertThat(opt.walFilter()).isEqualTo(walFilter); in walFilter()
703 try (final DBOptions opt = new DBOptions()) { in failIfOptionsFileError() argument
705 opt.setFailIfOptionsFileError(boolValue); in failIfOptionsFileError()
706 assertThat(opt.failIfOptionsFileError()).isEqualTo(boolValue); in failIfOptionsFileError()
712 try (final DBOptions opt = new DBOptions()) { in dumpMallocStats() argument
714 opt.setDumpMallocStats(boolValue); in dumpMallocStats()
715 assertThat(opt.dumpMallocStats()).isEqualTo(boolValue); in dumpMallocStats()
721 try (final DBOptions opt = new DBOptions()) { in avoidFlushDuringRecovery() argument
723 opt.setAvoidFlushDuringRecovery(boolValue); in avoidFlushDuringRecovery()
724 assertThat(opt.avoidFlushDuringRecovery()).isEqualTo(boolValue); in avoidFlushDuringRecovery()
730 try (final DBOptions opt = new DBOptions()) { in avoidFlushDuringShutdown() argument
732 opt.setAvoidFlushDuringShutdown(boolValue); in avoidFlushDuringShutdown()
733 assertThat(opt.avoidFlushDuringShutdown()).isEqualTo(boolValue); in avoidFlushDuringShutdown()
739 try (final DBOptions opt = new DBOptions()) { in allowIngestBehind() argument
740 assertThat(opt.allowIngestBehind()).isFalse(); in allowIngestBehind()
741 opt.setAllowIngestBehind(true); in allowIngestBehind()
742 assertThat(opt.allowIngestBehind()).isTrue(); in allowIngestBehind()
748 try (final DBOptions opt = new DBOptions()) { in preserveDeletes() argument
749 assertThat(opt.preserveDeletes()).isFalse(); in preserveDeletes()
750 opt.setPreserveDeletes(true); in preserveDeletes()
751 assertThat(opt.preserveDeletes()).isTrue(); in preserveDeletes()
757 try (final DBOptions opt = new DBOptions()) { in twoWriteQueues() argument
758 assertThat(opt.twoWriteQueues()).isFalse(); in twoWriteQueues()
759 opt.setTwoWriteQueues(true); in twoWriteQueues()
760 assertThat(opt.twoWriteQueues()).isTrue(); in twoWriteQueues()
766 try (final DBOptions opt = new DBOptions()) { in manualWalFlush() argument
767 assertThat(opt.manualWalFlush()).isFalse(); in manualWalFlush()
768 opt.setManualWalFlush(true); in manualWalFlush()
769 assertThat(opt.manualWalFlush()).isTrue(); in manualWalFlush()
775 try (final DBOptions opt = new DBOptions()) { in atomicFlush() argument
776 assertThat(opt.atomicFlush()).isFalse(); in atomicFlush()
777 opt.setAtomicFlush(true); in atomicFlush()
778 assertThat(opt.atomicFlush()).isTrue(); in atomicFlush()