Lines Matching refs:dbfull
98 ASSERT_OK(dbfull()->SetDBOptions(new_options)); in TEST_F()
99 ASSERT_EQ(new_options, GetMutableDBOptionsMap(dbfull()->GetDBOptions())); in TEST_F()
113 ASSERT_OK(dbfull()->SetOptions(handles_[0], options_default)); in TEST_F()
114 ASSERT_OK(dbfull()->SetOptions(handles_[1], options_foo)); in TEST_F()
116 GetMutableCFOptionsMap(dbfull()->GetOptions(handles_[0]))); in TEST_F()
118 GetMutableCFOptionsMap(dbfull()->GetOptions(handles_[1]))); in TEST_F()
136 ASSERT_EQ(options.bytes_per_sync, dbfull()->GetDBOptions().bytes_per_sync); in TEST_F()
146 ASSERT_OK(dbfull()->CompactRange(CompactRangeOptions(), nullptr, nullptr)); in TEST_F()
154 ASSERT_OK(dbfull()->SetDBOptions({{"bytes_per_sync", "8388608"}})); in TEST_F()
155 ASSERT_EQ(8388608, dbfull()->GetDBOptions().bytes_per_sync); in TEST_F()
162 ASSERT_OK(dbfull()->CompactRange(CompactRangeOptions(), nullptr, nullptr)); in TEST_F()
181 ASSERT_EQ(512, dbfull()->GetDBOptions().wal_bytes_per_sync); in TEST_F()
196 ASSERT_OK(dbfull()->SetDBOptions({{"wal_bytes_per_sync", "5242880"}})); in TEST_F()
197 ASSERT_EQ(5242880, dbfull()->GetDBOptions().wal_bytes_per_sync); in TEST_F()
218 dbfull()->GetDBOptions().writable_file_max_buffer_size); in TEST_F()
238 dbfull()->TEST_WaitForCompact(); in TEST_F()
243 dbfull()->SetDBOptions({{"writable_file_max_buffer_size", "524288"}})); in TEST_F()
249 dbfull()->GetDBOptions().writable_file_max_buffer_size); in TEST_F()
256 dbfull()->TEST_WaitForCompact(); in TEST_F()
264 ASSERT_OK(dbfull()->SetOptions(rand_opts)); in TEST_F()
299 dbfull()->TEST_WaitForFlushMemTable(); in TEST_F()
321 dbfull()->TEST_WaitForCompact(); in TEST_F()
322 ASSERT_FALSE(dbfull()->TEST_write_controler().IsStopped()); in TEST_F()
323 ASSERT_FALSE(dbfull()->TEST_write_controler().NeedsDelay()); in TEST_F()
338 dbfull()->SetOptions({{"disable_auto_compactions", "false"}})); in TEST_F()
341 ASSERT_OK(dbfull()->EnableAutoCompaction( in TEST_F()
342 {dbfull()->DefaultColumnFamily()})); in TEST_F()
351 ASSERT_TRUE(dbfull()->TEST_write_controler().IsStopped()); in TEST_F()
354 ASSERT_FALSE(dbfull()->TEST_write_controler().IsStopped()); in TEST_F()
355 ASSERT_TRUE(dbfull()->TEST_write_controler().NeedsDelay()); in TEST_F()
358 ASSERT_TRUE(dbfull()->TEST_write_controler().IsStopped()); in TEST_F()
361 ASSERT_FALSE(dbfull()->TEST_write_controler().IsStopped()); in TEST_F()
362 ASSERT_TRUE(dbfull()->TEST_write_controler().NeedsDelay()); in TEST_F()
368 dbfull()->TEST_WaitForCompact(); in TEST_F()
369 ASSERT_FALSE(dbfull()->TEST_write_controler().IsStopped()); in TEST_F()
370 ASSERT_FALSE(dbfull()->TEST_write_controler().NeedsDelay()); in TEST_F()
389 dbfull()->SetOptions({{"level0_file_num_compaction_trigger", "3"}})); in TEST_F()
390 dbfull()->TEST_WaitForCompact(); in TEST_F()
400 ASSERT_EQ(1, dbfull()->TEST_BGCompactionsAllowed()); in TEST_F()
401 ASSERT_OK(dbfull()->SetDBOptions({{"max_background_compactions", "3"}})); in TEST_F()
402 ASSERT_EQ(1, dbfull()->TEST_BGCompactionsAllowed()); in TEST_F()
403 auto stop_token = dbfull()->TEST_write_controler().GetStopToken(); in TEST_F()
404 ASSERT_EQ(3, dbfull()->TEST_BGCompactionsAllowed()); in TEST_F()
417 ASSERT_OK(dbfull()->SetDBOptions( in TEST_F()
424 ASSERT_EQ(expected_max_flushes, dbfull()->TEST_BGFlushesAllowed()); in TEST_F()
425 ASSERT_EQ(1, dbfull()->TEST_BGCompactionsAllowed()); in TEST_F()
427 auto stop_token = dbfull()->TEST_write_controler().GetStopToken(); in TEST_F()
431 ASSERT_EQ(expected_max_flushes, dbfull()->TEST_BGFlushesAllowed()); in TEST_F()
432 ASSERT_EQ(expected_max_compactions, dbfull()->TEST_BGCompactionsAllowed()); in TEST_F()
458 ASSERT_OK(dbfull()->SetDBOptions({{"avoid_flush_during_shutdown", "true"}})); in TEST_F()
470 ASSERT_EQ(2 * 1024U * 1024U, dbfull()->TEST_write_controler().max_delayed_write_rate()); in TEST_F()
472 ASSERT_OK(dbfull()->SetDBOptions({{"delayed_write_rate", "20000"}})); in TEST_F()
473 ASSERT_EQ(20000, dbfull()->TEST_write_controler().max_delayed_write_rate()); in TEST_F()
496 ASSERT_OK(dbfull()->SetDBOptions({{"max_total_wal_size", "10"}})); in TEST_F()
499 dbfull()->TEST_WaitForFlushMemTable(handles_[cf]); in TEST_F()
510 ASSERT_EQ(5u, dbfull()->GetDBOptions().stats_dump_period_sec); in TEST_F()
515 dbfull()->SetDBOptions({{"stats_dump_period_sec", ToString(num)}})); in TEST_F()
516 ASSERT_EQ(num, dbfull()->GetDBOptions().stats_dump_period_sec); in TEST_F()
527 ASSERT_EQ(5u, dbfull()->GetDBOptions().stats_persist_period_sec); in TEST_F()
529 ASSERT_OK(dbfull()->SetDBOptions({{"stats_persist_period_sec", "12345"}})); in TEST_F()
530 ASSERT_EQ(12345u, dbfull()->GetDBOptions().stats_persist_period_sec); in TEST_F()
531 ASSERT_NOK(dbfull()->SetDBOptions({{"stats_persist_period_sec", "abcde"}})); in TEST_F()
532 ASSERT_EQ(12345u, dbfull()->GetDBOptions().stats_persist_period_sec); in TEST_F()
535 static void assert_candidate_files_empty(DBImpl* dbfull, const bool empty) { in assert_candidate_files_empty() argument
536 dbfull->TEST_LockMutex(); in assert_candidate_files_empty()
538 dbfull->FindObsoleteFiles(&job_context, false); in assert_candidate_files_empty()
540 dbfull->TEST_UnlockMutex(); in assert_candidate_files_empty()
544 dbfull->PurgeObsoleteFiles(job_context); in assert_candidate_files_empty()
558 assert_candidate_files_empty(dbfull(), true); in TEST_F()
561 dbfull()->SetDBOptions({{"delete_obsolete_files_period_micros", "0"}})); in TEST_F()
565 assert_candidate_files_empty(dbfull(), false); in TEST_F()
568 dbfull()->SetDBOptions({{"delete_obsolete_files_period_micros", "20"}})); in TEST_F()
570 assert_candidate_files_empty(dbfull(), true); in TEST_F()
573 assert_candidate_files_empty(dbfull(), true); in TEST_F()
576 assert_candidate_files_empty(dbfull(), false); in TEST_F()
589 Cache* tc = dbfull()->TEST_table_cache(); in TEST_F()
591 ASSERT_EQ(-1, dbfull()->GetDBOptions().max_open_files); in TEST_F()
593 ASSERT_OK(dbfull()->SetDBOptions({{"max_open_files", "1024"}})); in TEST_F()
594 ASSERT_EQ(1024, dbfull()->GetDBOptions().max_open_files); in TEST_F()
604 ASSERT_EQ(16 * 1024 * 1024, dbfull()->GetDBOptions().delayed_write_rate); in TEST_F()
608 ASSERT_EQ(31 * 1024 * 1024, dbfull()->GetDBOptions().delayed_write_rate); in TEST_F()
618 ASSERT_EQ(0, dbfull()->GetOptions().ttl); in TEST_F()
619 ASSERT_EQ(0, dbfull()->GetOptions().periodic_compaction_seconds); in TEST_F()
624 ASSERT_EQ(0, dbfull()->GetOptions().ttl); in TEST_F()
625 ASSERT_EQ(100, dbfull()->GetOptions().periodic_compaction_seconds); in TEST_F()
630 ASSERT_EQ(100, dbfull()->GetOptions().ttl); in TEST_F()
631 ASSERT_EQ(100, dbfull()->GetOptions().periodic_compaction_seconds); in TEST_F()
636 ASSERT_EQ(100, dbfull()->GetOptions().ttl); in TEST_F()
637 ASSERT_EQ(100, dbfull()->GetOptions().periodic_compaction_seconds); in TEST_F()
643 ASSERT_EQ(30 * 24 * 60 * 60, dbfull()->GetOptions().ttl); in TEST_F()
648 ASSERT_EQ(0, dbfull()->GetOptions().ttl); in TEST_F()
652 ASSERT_EQ(100, dbfull()->GetOptions().ttl); in TEST_F()
660 ASSERT_EQ(30 * 24 * 60 * 60, dbfull()->GetOptions().ttl); in TEST_F()
664 ASSERT_EQ(100, dbfull()->GetOptions().ttl); in TEST_F()
668 ASSERT_EQ(100 * 24 * 60 * 60, dbfull()->GetOptions().ttl); in TEST_F()
673 ASSERT_EQ(200, dbfull()->GetOptions().ttl); in TEST_F()
678 ASSERT_EQ(300, dbfull()->GetOptions().ttl); in TEST_F()
705 ASSERT_OK(dbfull()->TEST_WaitForCompact()); in TEST_F()
712 ASSERT_EQ(dbfull()->GetOptions().ttl, 3600); in TEST_F()
713 dbfull()->CompactRange(CompactRangeOptions(), nullptr, nullptr); in TEST_F()
717 ASSERT_OK(dbfull()->SetOptions({{"ttl", "60"}})); in TEST_F()
718 ASSERT_EQ(dbfull()->GetOptions().ttl, 60); in TEST_F()
719 dbfull()->CompactRange(CompactRangeOptions(), nullptr, nullptr); in TEST_F()
720 ASSERT_OK(dbfull()->TEST_WaitForCompact()); in TEST_F()
736 ASSERT_OK(dbfull()->TEST_WaitForCompact()); in TEST_F()
740 ASSERT_EQ(dbfull()->GetOptions().compaction_options_fifo.max_table_files_size, in TEST_F()
742 dbfull()->CompactRange(CompactRangeOptions(), nullptr, nullptr); in TEST_F()
746 ASSERT_OK(dbfull()->SetOptions( in TEST_F()
748 ASSERT_EQ(dbfull()->GetOptions().compaction_options_fifo.max_table_files_size, in TEST_F()
750 dbfull()->CompactRange(CompactRangeOptions(), nullptr, nullptr); in TEST_F()
751 ASSERT_OK(dbfull()->TEST_WaitForCompact()); in TEST_F()
768 ASSERT_OK(dbfull()->TEST_WaitForCompact()); in TEST_F()
773 ASSERT_EQ(dbfull()->GetOptions().compaction_options_fifo.allow_compaction, in TEST_F()
775 dbfull()->CompactRange(CompactRangeOptions(), nullptr, nullptr); in TEST_F()
779 ASSERT_OK(dbfull()->SetOptions( in TEST_F()
781 ASSERT_EQ(dbfull()->GetOptions().compaction_options_fifo.allow_compaction, in TEST_F()
783 dbfull()->CompactRange(CompactRangeOptions(), nullptr, nullptr); in TEST_F()
784 ASSERT_OK(dbfull()->TEST_WaitForCompact()); in TEST_F()
800 ASSERT_EQ(0, dbfull()->GetDBOptions().compaction_readahead_size); in TEST_F()
801 ASSERT_OK(dbfull()->SetDBOptions({{"compaction_readahead_size", "256"}})); in TEST_F()
802 ASSERT_EQ(256, dbfull()->GetDBOptions().compaction_readahead_size); in TEST_F()
811 dbfull()->TEST_WaitForCompact(); in TEST_F()
832 ASSERT_OK(dbfull()->TEST_WaitForCompact()); in TEST_F()
839 ASSERT_OK(dbfull()->SetOptions( in TEST_F()
843 ASSERT_EQ(dbfull()->GetOptions().compaction_options_fifo.allow_compaction, in TEST_F()
845 ASSERT_EQ(dbfull()->GetOptions().compaction_options_fifo.max_table_files_size, in TEST_F()
847 ASSERT_EQ(dbfull()->GetOptions().ttl, 60); in TEST_F()
851 ASSERT_OK(dbfull()->SetOptions( in TEST_F()
855 ASSERT_EQ(dbfull()->GetOptions().compaction_options_fifo.allow_compaction, in TEST_F()
857 ASSERT_EQ(dbfull()->GetOptions().compaction_options_fifo.max_table_files_size, in TEST_F()
859 ASSERT_EQ(dbfull()->GetOptions().ttl, 191); in TEST_F()