Lines Matching refs:rep
125 struct rocksdb_t { DB* rep; }; member
126 struct rocksdb_backup_engine_t { BackupEngine* rep; }; member
127 struct rocksdb_backup_engine_info_t { std::vector<BackupInfo> rep; }; member
128 struct rocksdb_restore_options_t { RestoreOptions rep; }; member
129 struct rocksdb_iterator_t { Iterator* rep; }; member
130 struct rocksdb_writebatch_t { WriteBatch rep; }; member
131 struct rocksdb_writebatch_wi_t { WriteBatchWithIndex* rep; }; member
132 struct rocksdb_snapshot_t { const Snapshot* rep; }; member
133 struct rocksdb_flushoptions_t { FlushOptions rep; }; member
134 struct rocksdb_fifo_compaction_options_t { CompactionOptionsFIFO rep; }; member
136 ReadOptions rep; member
141 struct rocksdb_writeoptions_t { WriteOptions rep; }; member
142 struct rocksdb_options_t { Options rep; }; member
144 CompactRangeOptions rep; member
146 struct rocksdb_block_based_table_options_t { BlockBasedTableOptions rep; }; member
147 struct rocksdb_cuckoo_table_options_t { CuckooTableOptions rep; }; member
148 struct rocksdb_seqfile_t { SequentialFile* rep; }; member
149 struct rocksdb_randomfile_t { RandomAccessFile* rep; }; member
150 struct rocksdb_writablefile_t { WritableFile* rep; }; member
151 struct rocksdb_wal_iterator_t { TransactionLogIterator* rep; }; member
152 struct rocksdb_wal_readoptions_t { TransactionLogIterator::ReadOptions rep; }; member
153 struct rocksdb_filelock_t { FileLock* rep; }; member
155 std::shared_ptr<Logger> rep; member
158 std::shared_ptr<Cache> rep; member
160 struct rocksdb_livefiles_t { std::vector<LiveFileMetaData> rep; }; member
161 struct rocksdb_column_family_handle_t { ColumnFamilyHandle* rep; }; member
162 struct rocksdb_envoptions_t { EnvOptions rep; }; member
163 struct rocksdb_ingestexternalfileoptions_t { IngestExternalFileOptions rep; }; member
164 struct rocksdb_sstfilewriter_t { SstFileWriter* rep; }; member
166 std::shared_ptr<RateLimiter> rep; member
168 struct rocksdb_perfcontext_t { PerfContext* rep; }; member
170 PinnableSlice rep; member
173 TransactionDBOptions rep; member
176 TransactionDB* rep; member
179 TransactionOptions rep; member
182 Transaction* rep; member
185 Checkpoint* rep; member
188 OptimisticTransactionDB* rep; member
191 OptimisticTransactionOptions rep; member
195 CompactionFilter::Context rep; member
248 ccontext.rep = context; in CreateCompactionFilter()
412 DbPath rep; member
416 Env* rep; member
455 ROCKSDB_NAMESPACE::CompactionOptionsUniversal* rep; member
484 if (SaveError(errptr, DB::Open(options->rep, std::string(name), &db))) { in rocksdb_open()
488 result->rep = db; in rocksdb_open()
499 options->rep, std::string(name), &db, ttl))) { in rocksdb_open_with_ttl()
503 result->rep = db; in rocksdb_open_with_ttl()
513 …if (SaveError(errptr, DB::OpenForReadOnly(options->rep, std::string(name), &db, error_if_log_file_… in rocksdb_open_for_read_only()
517 result->rep = db; in rocksdb_open_for_read_only()
527 DB::OpenAsSecondary(options->rep, std::string(name), in rocksdb_open_as_secondary()
532 result->rep = db; in rocksdb_open_as_secondary()
539 if (SaveError(errptr, BackupEngine::Open(options->rep.env, in rocksdb_backup_engine_open()
543 options->rep.info_log.get()), in rocksdb_backup_engine_open()
548 result->rep = be; in rocksdb_backup_engine_open()
555 SaveError(errptr, be->rep->CreateNewBackup(db->rep)); in rocksdb_backup_engine_create_new_backup()
562 SaveError(errptr, be->rep->CreateNewBackup(db->rep, flush_before_backup)); in rocksdb_backup_engine_create_new_backup_flush()
568 SaveError(errptr, be->rep->PurgeOldBackups(num_backups_to_keep)); in rocksdb_backup_engine_purge_old_backups()
581 opt->rep.keep_log_files = v; in rocksdb_restore_options_set_keep_log_files()
587 SaveError(errptr, be->rep->VerifyBackup(static_cast<BackupID>(backup_id))); in rocksdb_backup_engine_verify_backup()
593 SaveError(errptr, be->rep->RestoreDBFromLatestBackup(std::string(db_dir), in rocksdb_backup_engine_restore_db_from_latest_backup()
595 restore_options->rep)); in rocksdb_backup_engine_restore_db_from_latest_backup()
601 be->rep->GetBackupInfo(&result->rep); in rocksdb_backup_engine_get_backup_info()
606 return static_cast<int>(info->rep.size()); in rocksdb_backup_engine_info_count()
611 return info->rep[index].timestamp; in rocksdb_backup_engine_info_timestamp()
616 return info->rep[index].backup_id; in rocksdb_backup_engine_info_backup_id()
621 return info->rep[index].size; in rocksdb_backup_engine_info_size()
626 return info->rep[index].number_files; in rocksdb_backup_engine_info_number_files()
635 delete be->rep; in rocksdb_backup_engine_close()
642 if (SaveError(errptr, Checkpoint::Create(db->rep, &checkpoint))) { in rocksdb_checkpoint_object_create()
646 result->rep = checkpoint; in rocksdb_checkpoint_object_create()
653 SaveError(errptr, checkpoint->rep->CreateCheckpoint( in rocksdb_checkpoint_create()
658 delete checkpoint->rep; in rocksdb_checkpoint_object_destroy()
663 delete db->rep; in rocksdb_close()
668 opt->rep.merge_operator = in rocksdb_options_set_uint64add_merge_operator()
681 ColumnFamilyOptions(column_family_options[i]->rep))); in rocksdb_open_column_families()
686 if (SaveError(errptr, DB::Open(DBOptions(db_options->rep), in rocksdb_open_column_families()
693 c_handle->rep = handles[i]; in rocksdb_open_column_families()
697 result->rep = db; in rocksdb_open_column_families()
711 ColumnFamilyOptions(column_family_options[i]->rep))); in rocksdb_open_for_read_only_column_families()
716 if (SaveError(errptr, DB::OpenForReadOnly(DBOptions(db_options->rep), in rocksdb_open_for_read_only_column_families()
723 c_handle->rep = handles[i]; in rocksdb_open_for_read_only_column_families()
727 result->rep = db; in rocksdb_open_for_read_only_column_families()
741 ColumnFamilyOptions(column_family_options[i]->rep)); in rocksdb_open_as_secondary_column_families()
745 if (SaveError(errptr, DB::OpenAsSecondary(DBOptions(db_options->rep), in rocksdb_open_as_secondary_column_families()
754 c_handle->rep = handles[i]; in rocksdb_open_as_secondary_column_families()
758 result->rep = db; in rocksdb_open_as_secondary_column_families()
769 DB::ListColumnFamilies(DBOptions(options->rep), in rocksdb_list_column_families()
794 db->rep->CreateColumnFamily(ColumnFamilyOptions(column_family_options->rep), in rocksdb_create_column_family()
795 std::string(column_family_name), &(handle->rep))); in rocksdb_create_column_family()
803 SaveError(errptr, db->rep->DropColumnFamily(handle->rep)); in rocksdb_drop_column_family()
807 delete handle->rep; in rocksdb_column_family_handle_destroy()
818 db->rep->Put(options->rep, Slice(key, keylen), Slice(val, vallen))); in rocksdb_put()
829 db->rep->Put(options->rep, column_family->rep, in rocksdb_put_cf()
838 SaveError(errptr, db->rep->Delete(options->rep, Slice(key, keylen))); in rocksdb_delete()
847 SaveError(errptr, db->rep->Delete(options->rep, column_family->rep, in rocksdb_delete_cf()
857 SaveError(errptr, db->rep->DeleteRange(options->rep, column_family->rep, in rocksdb_delete_range_cf()
869 db->rep->Merge(options->rep, Slice(key, keylen), Slice(val, vallen))); in rocksdb_merge()
880 db->rep->Merge(options->rep, column_family->rep, in rocksdb_merge_cf()
889 SaveError(errptr, db->rep->Write(options->rep, &batch->rep)); in rocksdb_write()
900 Status s = db->rep->Get(options->rep, Slice(key, keylen), &tmp); in rocksdb_get()
922 Status s = db->rep->Get(options->rep, column_family->rep, in rocksdb_get_cf()
948 std::vector<Status> statuses = db->rep->MultiGet(options->rep, keys, &values); in rocksdb_multi_get()
978 cfs[i] = column_families[i]->rep; in rocksdb_multi_get_cf()
981 std::vector<Status> statuses = db->rep->MultiGet(options->rep, cfs, keys, &values); in rocksdb_multi_get_cf()
1003 result->rep = db->rep->NewIterator(options->rep); in rocksdb_create_iterator()
1014 ro = options->rep; in rocksdb_get_updates_since()
1016 if (SaveError(errptr, db->rep->GetUpdatesSince(seq_number, &iter, ro))) { in rocksdb_get_updates_since()
1020 result->rep = iter.release(); in rocksdb_get_updates_since()
1025 iter->rep->Next(); in rocksdb_wal_iter_next()
1029 return iter->rep->Valid(); in rocksdb_wal_iter_valid()
1033 SaveError(errptr, iter->rep->status()); in rocksdb_wal_iter_status()
1037 delete iter->rep; in rocksdb_wal_iter_destroy()
1043 BatchResult wal_batch = iter->rep->GetBatch(); in rocksdb_wal_iter_get_batch()
1044 result->rep = std::move(*wal_batch.writeBatchPtr); in rocksdb_wal_iter_get_batch()
1052 return db->rep->GetLatestSequenceNumber(); in rocksdb_get_latest_sequence_number()
1060 result->rep = db->rep->NewIterator(options->rep, column_family->rep); in rocksdb_create_iterator_cf()
1073 column_families_vec.push_back(column_families[i]->rep); in rocksdb_create_iterators()
1077 Status status = db->rep->NewIterators(opts->rep, column_families_vec, &res); in rocksdb_create_iterators()
1085 iterators[i]->rep = res[i]; in rocksdb_create_iterators()
1092 result->rep = db->rep->GetSnapshot(); in rocksdb_create_snapshot()
1099 db->rep->ReleaseSnapshot(snapshot->rep); in rocksdb_release_snapshot()
1107 if (db->rep->GetProperty(Slice(propname), &tmp)) { in rocksdb_property_value()
1119 if (db->rep->GetIntProperty(Slice(propname), out_val)) { in rocksdb_property_int()
1131 if (db->rep->GetIntProperty(column_family->rep, Slice(propname), out_val)) { in rocksdb_property_int_cf()
1143 if (db->rep->GetProperty(column_family->rep, Slice(propname), &tmp)) { in rocksdb_property_value_cf()
1162 db->rep->GetApproximateSizes(ranges, num_ranges, sizes); in rocksdb_approximate_sizes()
1178 db->rep->GetApproximateSizes(column_family->rep, ranges, num_ranges, sizes); in rocksdb_approximate_sizes_cf()
1185 db->rep->DeleteFile(name); in rocksdb_delete_file()
1191 db->rep->GetLiveFilesMetaData(&result->rep); in rocksdb_livefiles()
1200 db->rep->CompactRange( in rocksdb_compact_range()
1213 db->rep->CompactRange( in rocksdb_compact_range_cf()
1214 CompactRangeOptions(), column_family->rep, in rocksdb_compact_range_cf()
1224 db->rep->CompactRange( in rocksdb_compact_range_opt()
1225 opt->rep, in rocksdb_compact_range_opt()
1237 db->rep->CompactRange( in rocksdb_compact_range_cf_opt()
1238 opt->rep, column_family->rep, in rocksdb_compact_range_cf_opt()
1248 SaveError(errptr, db->rep->Flush(options->rep)); in rocksdb_flush()
1256 SaveError(errptr, db->rep->Flush(options->rep, column_family->rep)); in rocksdb_flush_cf()
1262 SaveError(errptr, db->rep->DisableFileDeletions()); in rocksdb_disable_file_deletions()
1269 SaveError(errptr, db->rep->EnableFileDeletions(force)); in rocksdb_enable_file_deletions()
1276 SaveError(errptr, DestroyDB(name, options->rep)); in rocksdb_destroy_db()
1283 SaveError(errptr, RepairDB(name, options->rep)); in rocksdb_repair_db()
1287 delete iter->rep; in rocksdb_iter_destroy()
1292 return iter->rep->Valid(); in rocksdb_iter_valid()
1296 iter->rep->SeekToFirst(); in rocksdb_iter_seek_to_first()
1300 iter->rep->SeekToLast(); in rocksdb_iter_seek_to_last()
1304 iter->rep->Seek(Slice(k, klen)); in rocksdb_iter_seek()
1309 iter->rep->SeekForPrev(Slice(k, klen)); in rocksdb_iter_seek_for_prev()
1313 iter->rep->Next(); in rocksdb_iter_next()
1317 iter->rep->Prev(); in rocksdb_iter_prev()
1321 Slice s = iter->rep->key(); in rocksdb_iter_key()
1327 Slice s = iter->rep->value(); in rocksdb_iter_value()
1333 SaveError(errptr, iter->rep->status()); in rocksdb_iter_get_error()
1340 rocksdb_writebatch_t* rocksdb_writebatch_create_from(const char* rep, in rocksdb_writebatch_create_from() argument
1343 b->rep = WriteBatch(std::string(rep, size)); in rocksdb_writebatch_create_from()
1352 b->rep.Clear(); in rocksdb_writebatch_clear()
1356 return b->rep.Count(); in rocksdb_writebatch_count()
1363 b->rep.Put(Slice(key, klen), Slice(val, vlen)); in rocksdb_writebatch_put()
1371 b->rep.Put(column_family->rep, Slice(key, klen), Slice(val, vlen)); in rocksdb_writebatch_put_cf()
1388 b->rep.Put(SliceParts(key_slices.data(), num_keys), in rocksdb_writebatch_putv()
1407 b->rep.Put(column_family->rep, SliceParts(key_slices.data(), num_keys), in rocksdb_writebatch_putv_cf()
1415 b->rep.Merge(Slice(key, klen), Slice(val, vlen)); in rocksdb_writebatch_merge()
1423 b->rep.Merge(column_family->rep, Slice(key, klen), Slice(val, vlen)); in rocksdb_writebatch_merge_cf()
1440 b->rep.Merge(SliceParts(key_slices.data(), num_keys), in rocksdb_writebatch_mergev()
1459 b->rep.Merge(column_family->rep, SliceParts(key_slices.data(), num_keys), in rocksdb_writebatch_mergev_cf()
1466 b->rep.Delete(Slice(key, klen)); in rocksdb_writebatch_delete()
1473 b->rep.Delete(column_family->rep, Slice(key, klen)); in rocksdb_writebatch_delete_cf()
1484 b->rep.Delete(SliceParts(key_slices.data(), num_keys)); in rocksdb_writebatch_deletev()
1496 b->rep.Delete(column_family->rep, SliceParts(key_slices.data(), num_keys)); in rocksdb_writebatch_deletev_cf()
1503 b->rep.DeleteRange(Slice(start_key, start_key_len), in rocksdb_writebatch_delete_range()
1511 b->rep.DeleteRange(column_family->rep, Slice(start_key, start_key_len), in rocksdb_writebatch_delete_range_cf()
1526 b->rep.DeleteRange(SliceParts(start_key_slices.data(), num_keys), in rocksdb_writebatch_delete_rangev()
1541 b->rep.DeleteRange(column_family->rep, in rocksdb_writebatch_delete_rangev_cf()
1549 b->rep.PutLogData(Slice(blob, len)); in rocksdb_writebatch_put_log_data()
1574 b->rep.Iterate(&handler); in rocksdb_writebatch_iterate()
1578 *size = b->rep.GetDataSize(); in rocksdb_writebatch_data()
1579 return b->rep.Data().c_str(); in rocksdb_writebatch_data()
1583 b->rep.SetSavePoint(); in rocksdb_writebatch_set_save_point()
1588 SaveError(errptr, b->rep.RollbackToSavePoint()); in rocksdb_writebatch_rollback_to_save_point()
1592 SaveError(errptr, b->rep.PopSavePoint()); in rocksdb_writebatch_pop_save_point()
1597 b->rep = new WriteBatchWithIndex(BytewiseComparator(), reserved_bytes, overwrite_key); in rocksdb_writebatch_wi_create()
1602 if (b->rep) { in rocksdb_writebatch_wi_destroy()
1603 delete b->rep; in rocksdb_writebatch_wi_destroy()
1609 b->rep->Clear(); in rocksdb_writebatch_wi_clear()
1613 return b->rep->GetWriteBatch()->Count(); in rocksdb_writebatch_wi_count()
1620 b->rep->Put(Slice(key, klen), Slice(val, vlen)); in rocksdb_writebatch_wi_put()
1628 b->rep->Put(column_family->rep, Slice(key, klen), Slice(val, vlen)); in rocksdb_writebatch_wi_put_cf()
1645 b->rep->Put(SliceParts(key_slices.data(), num_keys), in rocksdb_writebatch_wi_putv()
1664 b->rep->Put(column_family->rep, SliceParts(key_slices.data(), num_keys), in rocksdb_writebatch_wi_putv_cf()
1672 b->rep->Merge(Slice(key, klen), Slice(val, vlen)); in rocksdb_writebatch_wi_merge()
1680 b->rep->Merge(column_family->rep, Slice(key, klen), Slice(val, vlen)); in rocksdb_writebatch_wi_merge_cf()
1697 b->rep->Merge(SliceParts(key_slices.data(), num_keys), in rocksdb_writebatch_wi_mergev()
1716 b->rep->Merge(column_family->rep, SliceParts(key_slices.data(), num_keys), in rocksdb_writebatch_wi_mergev_cf()
1723 b->rep->Delete(Slice(key, klen)); in rocksdb_writebatch_wi_delete()
1730 b->rep->Delete(column_family->rep, Slice(key, klen)); in rocksdb_writebatch_wi_delete_cf()
1741 b->rep->Delete(SliceParts(key_slices.data(), num_keys)); in rocksdb_writebatch_wi_deletev()
1753 b->rep->Delete(column_family->rep, SliceParts(key_slices.data(), num_keys)); in rocksdb_writebatch_wi_deletev_cf()
1760 b->rep->DeleteRange(Slice(start_key, start_key_len), in rocksdb_writebatch_wi_delete_range()
1768 b->rep->DeleteRange(column_family->rep, Slice(start_key, start_key_len), in rocksdb_writebatch_wi_delete_range_cf()
1783 b->rep->DeleteRange(SliceParts(start_key_slices.data(), num_keys), in rocksdb_writebatch_wi_delete_rangev()
1798 b->rep->DeleteRange(column_family->rep, in rocksdb_writebatch_wi_delete_rangev_cf()
1806 b->rep->PutLogData(Slice(blob, len)); in rocksdb_writebatch_wi_put_log_data()
1818 b->rep->GetWriteBatch()->Iterate(&handler); in rocksdb_writebatch_wi_iterate()
1822 WriteBatch* wb = b->rep->GetWriteBatch(); in rocksdb_writebatch_wi_data()
1828 b->rep->SetSavePoint(); in rocksdb_writebatch_wi_set_save_point()
1833 SaveError(errptr, b->rep->RollbackToSavePoint()); in rocksdb_writebatch_wi_rollback_to_save_point()
1840 result->rep = wbwi->rep->NewIteratorWithBase(base_iterator->rep); in rocksdb_writebatch_wi_create_iterator_with_base()
1849 result->rep = in rocksdb_writebatch_wi_create_iterator_with_base_cf()
1850 wbwi->rep->NewIteratorWithBase(column_family->rep, base_iterator->rep); in rocksdb_writebatch_wi_create_iterator_with_base_cf()
1863 Status s = wbwi->rep->GetFromBatch(options->rep, Slice(key, keylen), &tmp); in rocksdb_writebatch_wi_get_from_batch()
1885 Status s = wbwi->rep->GetFromBatch(column_family->rep, options->rep, in rocksdb_writebatch_wi_get_from_batch_cf()
1908 Status s = wbwi->rep->GetFromBatchAndDB(db->rep, options->rep, Slice(key, keylen), &tmp); in rocksdb_writebatch_wi_get_from_batch_and_db()
1931 Status s = wbwi->rep->GetFromBatchAndDB(db->rep, options->rep, column_family->rep, in rocksdb_writebatch_wi_get_from_batch_and_db_cf()
1950 WriteBatch* wb = wbwi->rep->GetWriteBatch(); in rocksdb_write_writebatch_wi()
1951 SaveError(errptr, db->rep->Write(options->rep, wb)); in rocksdb_write_writebatch_wi()
1966 options->rep.block_size = block_size; in rocksdb_block_based_options_set_block_size()
1971 options->rep.block_size_deviation = block_size_deviation; in rocksdb_block_based_options_set_block_size_deviation()
1976 options->rep.block_restart_interval = block_restart_interval; in rocksdb_block_based_options_set_block_restart_interval()
1981 options->rep.index_block_restart_interval = index_block_restart_interval; in rocksdb_block_based_options_set_index_block_restart_interval()
1986 options->rep.metadata_block_size = metadata_block_size; in rocksdb_block_based_options_set_metadata_block_size()
1991 options->rep.partition_filters = partition_filters; in rocksdb_block_based_options_set_partition_filters()
1996 options->rep.use_delta_encoding = use_delta_encoding; in rocksdb_block_based_options_set_use_delta_encoding()
2002 options->rep.filter_policy.reset(filter_policy); in rocksdb_block_based_options_set_filter_policy()
2008 options->rep.no_block_cache = no_block_cache; in rocksdb_block_based_options_set_no_block_cache()
2015 options->rep.block_cache = block_cache->rep; in rocksdb_block_based_options_set_block_cache()
2023 options->rep.block_cache_compressed = block_cache_compressed->rep; in rocksdb_block_based_options_set_block_cache_compressed()
2029 options->rep.whole_key_filtering = v; in rocksdb_block_based_options_set_whole_key_filtering()
2034 options->rep.format_version = v; in rocksdb_block_based_options_set_format_version()
2039 options->rep.index_type = static_cast<BlockBasedTableOptions::IndexType>(v); in rocksdb_block_based_options_set_index_type()
2044 options->rep.data_block_index_type = in rocksdb_block_based_options_set_data_block_index_type()
2050 options->rep.data_block_hash_table_util_ratio = v; in rocksdb_block_based_options_set_data_block_hash_ratio()
2055 options->rep.hash_index_allow_collision = v; in rocksdb_block_based_options_set_hash_index_allow_collision()
2060 options->rep.cache_index_and_filter_blocks = v; in rocksdb_block_based_options_set_cache_index_and_filter_blocks()
2065 options->rep.cache_index_and_filter_blocks_with_high_priority = v; in rocksdb_block_based_options_set_cache_index_and_filter_blocks_with_high_priority()
2070 options->rep.pin_l0_filter_and_index_blocks_in_cache = v; in rocksdb_block_based_options_set_pin_l0_filter_and_index_blocks_in_cache()
2075 options->rep.pin_top_level_index_and_filter = v; in rocksdb_block_based_options_set_pin_top_level_index_and_filter()
2082 opt->rep.table_factory.reset( in rocksdb_options_set_block_based_table_factory()
2083 ROCKSDB_NAMESPACE::NewBlockBasedTableFactory(table_options->rep)); in rocksdb_options_set_block_based_table_factory()
2099 options->rep.hash_table_ratio = v; in rocksdb_cuckoo_options_set_hash_ratio()
2104 options->rep.max_search_depth = v; in rocksdb_cuckoo_options_set_max_search_depth()
2109 options->rep.cuckoo_block_size = v; in rocksdb_cuckoo_options_set_cuckoo_block_size()
2114 options->rep.identity_as_first_hash = v; in rocksdb_cuckoo_options_set_identity_as_first_hash()
2119 options->rep.use_module_hash = v; in rocksdb_cuckoo_options_set_use_module_hash()
2126 opt->rep.table_factory.reset( in rocksdb_options_set_cuckoo_table_factory()
2127 ROCKSDB_NAMESPACE::NewCuckooTableFactory(table_options->rep)); in rocksdb_options_set_cuckoo_table_factory()
2137 db->rep->SetOptions(options_map)); in rocksdb_set_options()
2146 db->rep->SetOptions(handle->rep, options_map)); in rocksdb_set_options_cf()
2159 opt->rep.IncreaseParallelism(total_threads); in rocksdb_options_increase_parallelism()
2164 opt->rep.OptimizeForPointLookup(block_cache_size_mb); in rocksdb_options_optimize_for_point_lookup()
2169 opt->rep.OptimizeLevelStyleCompaction(memtable_memory_budget); in rocksdb_options_optimize_level_style_compaction()
2174 opt->rep.OptimizeUniversalStyleCompaction(memtable_memory_budget); in rocksdb_options_optimize_universal_style_compaction()
2179 opt->rep.allow_ingest_behind = v; in rocksdb_options_set_allow_ingest_behind()
2185 opt->rep.compaction_filter = filter; in rocksdb_options_set_compaction_filter()
2190 opt->rep.compaction_filter_factory = in rocksdb_options_set_compaction_filter_factory()
2196 opt->rep.compaction_readahead_size = s; in rocksdb_options_compaction_readahead_size()
2202 opt->rep.comparator = cmp; in rocksdb_options_set_comparator()
2208 opt->rep.merge_operator = std::shared_ptr<MergeOperator>(merge_operator); in rocksdb_options_set_merge_operator()
2214 opt->rep.create_if_missing = v; in rocksdb_options_set_create_if_missing()
2219 opt->rep.create_missing_column_families = v; in rocksdb_options_set_create_missing_column_families()
2224 opt->rep.error_if_exists = v; in rocksdb_options_set_error_if_exists()
2229 opt->rep.paranoid_checks = v; in rocksdb_options_set_paranoid_checks()
2237 db_paths[i] = dbpath_values[i]->rep; in rocksdb_options_set_db_paths()
2239 opt->rep.db_paths = db_paths; in rocksdb_options_set_db_paths()
2243 opt->rep.env = (env ? env->rep : nullptr); in rocksdb_options_set_env()
2248 opt->rep.info_log = l->rep; in rocksdb_options_set_info_log()
2254 opt->rep.info_log_level = static_cast<InfoLogLevel>(v); in rocksdb_options_set_info_log_level()
2259 opt->rep.db_write_buffer_size = s; in rocksdb_options_set_db_write_buffer_size()
2263 opt->rep.write_buffer_size = s; in rocksdb_options_set_write_buffer_size()
2267 opt->rep.max_open_files = n; in rocksdb_options_set_max_open_files()
2271 opt->rep.max_file_opening_threads = n; in rocksdb_options_set_max_file_opening_threads()
2275 opt->rep.max_total_wal_size = n; in rocksdb_options_set_max_total_wal_size()
2280 opt->rep.target_file_size_base = n; in rocksdb_options_set_target_file_size_base()
2285 opt->rep.target_file_size_multiplier = n; in rocksdb_options_set_target_file_size_multiplier()
2290 opt->rep.max_bytes_for_level_base = n; in rocksdb_options_set_max_bytes_for_level_base()
2295 opt->rep.level_compaction_dynamic_level_bytes = v; in rocksdb_options_set_level_compaction_dynamic_level_bytes()
2300 opt->rep.max_bytes_for_level_multiplier = n; in rocksdb_options_set_max_bytes_for_level_multiplier()
2305 opt->rep.max_compaction_bytes = n; in rocksdb_options_set_max_compaction_bytes()
2310 opt->rep.max_bytes_for_level_multiplier_additional.resize(num_levels); in rocksdb_options_set_max_bytes_for_level_multiplier_additional()
2312 opt->rep.max_bytes_for_level_multiplier_additional[i] = level_values[i]; in rocksdb_options_set_max_bytes_for_level_multiplier_additional()
2317 opt->rep.statistics = ROCKSDB_NAMESPACE::CreateDBStatistics(); in rocksdb_options_enable_statistics()
2322 opt->rep.skip_stats_update_on_db_open = val; in rocksdb_options_set_skip_stats_update_on_db_open()
2327 opt->rep.skip_checking_sst_file_sizes_on_db_open = val; in rocksdb_options_set_skip_checking_sst_file_sizes_on_db_open()
2331 opt->rep.num_levels = n; in rocksdb_options_set_num_levels()
2336 opt->rep.level0_file_num_compaction_trigger = n; in rocksdb_options_set_level0_file_num_compaction_trigger()
2341 opt->rep.level0_slowdown_writes_trigger = n; in rocksdb_options_set_level0_slowdown_writes_trigger()
2346 opt->rep.level0_stop_writes_trigger = n; in rocksdb_options_set_level0_stop_writes_trigger()
2353 opt->rep.wal_recovery_mode = static_cast<WALRecoveryMode>(mode); in rocksdb_options_set_wal_recovery_mode()
2357 opt->rep.compression = static_cast<CompressionType>(t); in rocksdb_options_set_compression()
2363 opt->rep.compression_per_level.resize(num_levels); in rocksdb_options_set_compression_per_level()
2365 opt->rep.compression_per_level[i] = in rocksdb_options_set_compression_per_level()
2375 opt->rep.bottommost_compression_opts.window_bits = w_bits; in rocksdb_options_set_bottommost_compression_options()
2376 opt->rep.bottommost_compression_opts.level = level; in rocksdb_options_set_bottommost_compression_options()
2377 opt->rep.bottommost_compression_opts.strategy = strategy; in rocksdb_options_set_bottommost_compression_options()
2378 opt->rep.bottommost_compression_opts.max_dict_bytes = max_dict_bytes; in rocksdb_options_set_bottommost_compression_options()
2379 opt->rep.bottommost_compression_opts.enabled = enabled; in rocksdb_options_set_bottommost_compression_options()
2385 opt->rep.compression_opts.window_bits = w_bits; in rocksdb_options_set_compression_options()
2386 opt->rep.compression_opts.level = level; in rocksdb_options_set_compression_options()
2387 opt->rep.compression_opts.strategy = strategy; in rocksdb_options_set_compression_options()
2388 opt->rep.compression_opts.max_dict_bytes = max_dict_bytes; in rocksdb_options_set_compression_options()
2393 opt->rep.prefix_extractor.reset(prefix_extractor); in rocksdb_options_set_prefix_extractor()
2398 opt->rep.use_fsync = use_fsync; in rocksdb_options_set_use_fsync()
2403 opt->rep.db_log_dir = db_log_dir; in rocksdb_options_set_db_log_dir()
2408 opt->rep.wal_dir = v; in rocksdb_options_set_wal_dir()
2412 opt->rep.WAL_ttl_seconds = ttl; in rocksdb_options_set_WAL_ttl_seconds()
2417 opt->rep.WAL_size_limit_MB = limit; in rocksdb_options_set_WAL_size_limit_MB()
2422 opt->rep.manifest_preallocation_size = v; in rocksdb_options_set_manifest_preallocation_size()
2431 opt->rep.use_direct_reads = v; in rocksdb_options_set_use_direct_reads()
2436 opt->rep.use_direct_io_for_flush_and_compaction = v; in rocksdb_options_set_use_direct_io_for_flush_and_compaction()
2441 opt->rep.allow_mmap_reads = v; in rocksdb_options_set_allow_mmap_reads()
2446 opt->rep.allow_mmap_writes = v; in rocksdb_options_set_allow_mmap_writes()
2451 opt->rep.is_fd_close_on_exec = v; in rocksdb_options_set_is_fd_close_on_exec()
2456 opt->rep.skip_log_error_on_recovery = v; in rocksdb_options_set_skip_log_error_on_recovery()
2461 opt->rep.stats_dump_period_sec = v; in rocksdb_options_set_stats_dump_period_sec()
2466 opt->rep.advise_random_on_open = v; in rocksdb_options_set_advise_random_on_open()
2473 opt->rep.access_hint_on_compaction_start = in rocksdb_options_set_access_hint_on_compaction_start()
2477 opt->rep.access_hint_on_compaction_start = in rocksdb_options_set_access_hint_on_compaction_start()
2481 opt->rep.access_hint_on_compaction_start = in rocksdb_options_set_access_hint_on_compaction_start()
2485 opt->rep.access_hint_on_compaction_start = in rocksdb_options_set_access_hint_on_compaction_start()
2493 opt->rep.use_adaptive_mutex = v; in rocksdb_options_set_use_adaptive_mutex()
2498 opt->rep.wal_bytes_per_sync = v; in rocksdb_options_set_wal_bytes_per_sync()
2503 opt->rep.bytes_per_sync = v; in rocksdb_options_set_bytes_per_sync()
2508 opt->rep.writable_file_max_buffer_size = static_cast<size_t>(v); in rocksdb_options_set_writable_file_max_buffer_size()
2513 opt->rep.allow_concurrent_memtable_write = v; in rocksdb_options_set_allow_concurrent_memtable_write()
2518 opt->rep.enable_write_thread_adaptive_yield = v; in rocksdb_options_set_enable_write_thread_adaptive_yield()
2523 opt->rep.max_sequential_skip_in_iterations = v; in rocksdb_options_set_max_sequential_skip_in_iterations()
2527 opt->rep.max_write_buffer_number = n; in rocksdb_options_set_max_write_buffer_number()
2531 opt->rep.min_write_buffer_number_to_merge = n; in rocksdb_options_set_min_write_buffer_number_to_merge()
2536 opt->rep.max_write_buffer_number_to_maintain = n; in rocksdb_options_set_max_write_buffer_number_to_maintain()
2541 opt->rep.max_write_buffer_size_to_maintain = n; in rocksdb_options_set_max_write_buffer_size_to_maintain()
2546 opt->rep.enable_pipelined_write = v; in rocksdb_options_set_enable_pipelined_write()
2551 opt->rep.unordered_write = v; in rocksdb_options_set_unordered_write()
2556 opt->rep.max_subcompactions = n; in rocksdb_options_set_max_subcompactions()
2560 opt->rep.max_background_jobs = n; in rocksdb_options_set_max_background_jobs()
2564 opt->rep.max_background_compactions = n; in rocksdb_options_set_max_background_compactions()
2569 opt->rep.base_background_compactions = n; in rocksdb_options_set_base_background_compactions()
2573 opt->rep.max_background_flushes = n; in rocksdb_options_set_max_background_flushes()
2577 opt->rep.max_log_file_size = v; in rocksdb_options_set_max_log_file_size()
2581 opt->rep.log_file_time_to_roll = v; in rocksdb_options_set_log_file_time_to_roll()
2585 opt->rep.keep_log_file_num = v; in rocksdb_options_set_keep_log_file_num()
2590 opt->rep.recycle_log_file_num = v; in rocksdb_options_set_recycle_log_file_num()
2594 opt->rep.soft_rate_limit = v; in rocksdb_options_set_soft_rate_limit()
2598 opt->rep.hard_rate_limit = v; in rocksdb_options_set_hard_rate_limit()
2602 opt->rep.soft_pending_compaction_bytes_limit = v; in rocksdb_options_set_soft_pending_compaction_bytes_limit()
2606 opt->rep.hard_pending_compaction_bytes_limit = v; in rocksdb_options_set_hard_pending_compaction_bytes_limit()
2611 opt->rep.rate_limit_delay_max_milliseconds = v; in rocksdb_options_set_rate_limit_delay_max_milliseconds()
2616 opt->rep.max_manifest_file_size = v; in rocksdb_options_set_max_manifest_file_size()
2621 opt->rep.table_cache_numshardbits = v; in rocksdb_options_set_table_cache_numshardbits()
2631 opt->rep.arena_block_size = v; in rocksdb_options_set_arena_block_size()
2635 opt->rep.disable_auto_compactions = disable; in rocksdb_options_set_disable_auto_compactions()
2639 opt->rep.optimize_filters_for_hits = v; in rocksdb_options_set_optimize_filters_for_hits()
2644 opt->rep.delete_obsolete_files_period_micros = v; in rocksdb_options_set_delete_obsolete_files_period_micros()
2648 opt->rep.PrepareForBulkLoad(); in rocksdb_options_prepare_for_bulk_load()
2652 opt->rep.memtable_factory.reset(new ROCKSDB_NAMESPACE::VectorRepFactory); in rocksdb_options_set_memtable_vector_rep()
2657 opt->rep.memtable_prefix_bloom_size_ratio = v; in rocksdb_options_set_memtable_prefix_bloom_size_ratio()
2662 opt->rep.memtable_huge_page_size = v; in rocksdb_options_set_memtable_huge_page_size()
2671 opt->rep.memtable_factory.reset(factory); in rocksdb_options_set_hash_skip_list_rep()
2676 opt->rep.memtable_factory.reset( in rocksdb_options_set_hash_link_list_rep()
2691 opt->rep.table_factory.reset(factory); in rocksdb_options_set_plain_table_factory()
2696 opt->rep.max_successive_merges = v; in rocksdb_options_set_max_successive_merges()
2701 opt->rep.bloom_locality = v; in rocksdb_options_set_bloom_locality()
2706 opt->rep.inplace_update_support = v; in rocksdb_options_set_inplace_update_support()
2711 opt->rep.inplace_update_num_locks = v; in rocksdb_options_set_inplace_update_num_locks()
2716 opt->rep.report_bg_io_stats = v; in rocksdb_options_set_report_bg_io_stats()
2720 opt->rep.compaction_style = in rocksdb_options_set_compaction_style()
2725 opt->rep.compaction_options_universal = *(uco->rep); in rocksdb_options_set_universal_compaction_options()
2731 opt->rep.compaction_options_fifo = fifo->rep; in rocksdb_options_set_fifo_compaction_options()
2735 ROCKSDB_NAMESPACE::Statistics* statistics = opt->rep.statistics.get(); in rocksdb_options_statistics_get_string()
2744 opt->rep.rate_limiter = limiter->rep; in rocksdb_options_set_ratelimiter()
2750 opt->rep.atomic_flush = atomic_flush; in rocksdb_options_set_atomic_flush()
2758 rate_limiter->rep.reset( in rocksdb_ratelimiter_create()
2770 opt->rep.row_cache = cache->rep; in rocksdb_options_set_row_cache()
2781 context->rep = ROCKSDB_NAMESPACE::get_perf_context(); in rocksdb_perfcontext_create()
2786 context->rep->Reset(); in rocksdb_perfcontext_reset()
2791 return strdup(context->rep->ToString(exclude_zero_counters).c_str()); in rocksdb_perfcontext_report()
2796 PerfContext* rep = context->rep; in rocksdb_perfcontext_metric() local
2799 return rep->user_key_comparison_count; in rocksdb_perfcontext_metric()
2801 return rep->block_cache_hit_count; in rocksdb_perfcontext_metric()
2803 return rep->block_read_count; in rocksdb_perfcontext_metric()
2805 return rep->block_read_byte; in rocksdb_perfcontext_metric()
2807 return rep->block_read_time; in rocksdb_perfcontext_metric()
2809 return rep->block_checksum_time; in rocksdb_perfcontext_metric()
2811 return rep->block_decompress_time; in rocksdb_perfcontext_metric()
2813 return rep->get_read_bytes; in rocksdb_perfcontext_metric()
2815 return rep->multiget_read_bytes; in rocksdb_perfcontext_metric()
2817 return rep->iter_read_bytes; in rocksdb_perfcontext_metric()
2819 return rep->internal_key_skipped_count; in rocksdb_perfcontext_metric()
2821 return rep->internal_delete_skipped_count; in rocksdb_perfcontext_metric()
2823 return rep->internal_recent_skipped_count; in rocksdb_perfcontext_metric()
2825 return rep->internal_merge_count; in rocksdb_perfcontext_metric()
2827 return rep->get_snapshot_time; in rocksdb_perfcontext_metric()
2829 return rep->get_from_memtable_time; in rocksdb_perfcontext_metric()
2831 return rep->get_from_memtable_count; in rocksdb_perfcontext_metric()
2833 return rep->get_post_process_time; in rocksdb_perfcontext_metric()
2835 return rep->get_from_output_files_time; in rocksdb_perfcontext_metric()
2837 return rep->seek_on_memtable_time; in rocksdb_perfcontext_metric()
2839 return rep->seek_on_memtable_count; in rocksdb_perfcontext_metric()
2841 return rep->next_on_memtable_count; in rocksdb_perfcontext_metric()
2843 return rep->prev_on_memtable_count; in rocksdb_perfcontext_metric()
2845 return rep->seek_child_seek_time; in rocksdb_perfcontext_metric()
2847 return rep->seek_child_seek_count; in rocksdb_perfcontext_metric()
2849 return rep->seek_min_heap_time; in rocksdb_perfcontext_metric()
2851 return rep->seek_max_heap_time; in rocksdb_perfcontext_metric()
2853 return rep->seek_internal_seek_time; in rocksdb_perfcontext_metric()
2855 return rep->find_next_user_entry_time; in rocksdb_perfcontext_metric()
2857 return rep->write_wal_time; in rocksdb_perfcontext_metric()
2859 return rep->write_memtable_time; in rocksdb_perfcontext_metric()
2861 return rep->write_delay_time; in rocksdb_perfcontext_metric()
2863 return rep->write_pre_and_post_process_time; in rocksdb_perfcontext_metric()
2865 return rep->db_mutex_lock_nanos; in rocksdb_perfcontext_metric()
2867 return rep->db_condition_wait_nanos; in rocksdb_perfcontext_metric()
2869 return rep->merge_operator_time_nanos; in rocksdb_perfcontext_metric()
2871 return rep->read_index_block_nanos; in rocksdb_perfcontext_metric()
2873 return rep->read_filter_block_nanos; in rocksdb_perfcontext_metric()
2875 return rep->new_table_block_iter_nanos; in rocksdb_perfcontext_metric()
2877 return rep->new_table_iterator_nanos; in rocksdb_perfcontext_metric()
2879 return rep->block_seek_nanos; in rocksdb_perfcontext_metric()
2881 return rep->find_table_nanos; in rocksdb_perfcontext_metric()
2883 return rep->bloom_memtable_hit_count; in rocksdb_perfcontext_metric()
2885 return rep->bloom_memtable_miss_count; in rocksdb_perfcontext_metric()
2887 return rep->bloom_sst_hit_count; in rocksdb_perfcontext_metric()
2889 return rep->bloom_sst_miss_count; in rocksdb_perfcontext_metric()
2891 return rep->key_lock_wait_time; in rocksdb_perfcontext_metric()
2893 return rep->key_lock_wait_count; in rocksdb_perfcontext_metric()
2895 return rep->env_new_sequential_file_nanos; in rocksdb_perfcontext_metric()
2897 return rep->env_new_random_access_file_nanos; in rocksdb_perfcontext_metric()
2899 return rep->env_new_writable_file_nanos; in rocksdb_perfcontext_metric()
2901 return rep->env_reuse_writable_file_nanos; in rocksdb_perfcontext_metric()
2903 return rep->env_new_random_rw_file_nanos; in rocksdb_perfcontext_metric()
2905 return rep->env_new_directory_nanos; in rocksdb_perfcontext_metric()
2907 return rep->env_file_exists_nanos; in rocksdb_perfcontext_metric()
2909 return rep->env_get_children_nanos; in rocksdb_perfcontext_metric()
2911 return rep->env_get_children_file_attributes_nanos; in rocksdb_perfcontext_metric()
2913 return rep->env_delete_file_nanos; in rocksdb_perfcontext_metric()
2915 return rep->env_create_dir_nanos; in rocksdb_perfcontext_metric()
2917 return rep->env_create_dir_if_missing_nanos; in rocksdb_perfcontext_metric()
2919 return rep->env_delete_dir_nanos; in rocksdb_perfcontext_metric()
2921 return rep->env_get_file_size_nanos; in rocksdb_perfcontext_metric()
2923 return rep->env_get_file_modification_time_nanos; in rocksdb_perfcontext_metric()
2925 return rep->env_rename_file_nanos; in rocksdb_perfcontext_metric()
2927 return rep->env_link_file_nanos; in rocksdb_perfcontext_metric()
2929 return rep->env_lock_file_nanos; in rocksdb_perfcontext_metric()
2931 return rep->env_unlock_file_nanos; in rocksdb_perfcontext_metric()
2933 return rep->env_new_logger_nanos; in rocksdb_perfcontext_metric()
2990 return context->rep.is_full_compaction; in rocksdb_compactionfiltercontext_is_full_compaction()
2995 return context->rep.is_manual_compaction; in rocksdb_compactionfiltercontext_is_manual_compaction()
3149 opt->rep.verify_checksums = v; in rocksdb_readoptions_set_verify_checksums()
3154 opt->rep.fill_cache = v; in rocksdb_readoptions_set_fill_cache()
3160 opt->rep.snapshot = (snap ? snap->rep : nullptr); in rocksdb_readoptions_set_snapshot()
3168 opt->rep.iterate_upper_bound = nullptr; in rocksdb_readoptions_set_iterate_upper_bound()
3172 opt->rep.iterate_upper_bound = &opt->upper_bound; in rocksdb_readoptions_set_iterate_upper_bound()
3181 opt->rep.iterate_lower_bound = nullptr; in rocksdb_readoptions_set_iterate_lower_bound()
3184 opt->rep.iterate_lower_bound = &opt->lower_bound; in rocksdb_readoptions_set_iterate_lower_bound()
3190 opt->rep.read_tier = static_cast<ROCKSDB_NAMESPACE::ReadTier>(v); in rocksdb_readoptions_set_read_tier()
3195 opt->rep.tailing = v; in rocksdb_readoptions_set_tailing()
3200 opt->rep.managed = v; in rocksdb_readoptions_set_managed()
3205 opt->rep.readahead_size = v; in rocksdb_readoptions_set_readahead_size()
3210 opt->rep.prefix_same_as_start = v; in rocksdb_readoptions_set_prefix_same_as_start()
3215 opt->rep.pin_data = v; in rocksdb_readoptions_set_pin_data()
3220 opt->rep.total_order_seek = v; in rocksdb_readoptions_set_total_order_seek()
3226 opt->rep.max_skippable_internal_keys = v; in rocksdb_readoptions_set_max_skippable_internal_keys()
3231 opt->rep.background_purge_on_iterator_cleanup = v; in rocksdb_readoptions_set_background_purge_on_iterator_cleanup()
3236 opt->rep.ignore_range_deletions = v; in rocksdb_readoptions_set_ignore_range_deletions()
3249 opt->rep.sync = v; in rocksdb_writeoptions_set_sync()
3253 opt->rep.disableWAL = disable; in rocksdb_writeoptions_disable_WAL()
3259 opt->rep.ignore_missing_column_families = v; in rocksdb_writeoptions_set_ignore_missing_column_families()
3265 opt->rep.no_slowdown = v; in rocksdb_writeoptions_set_no_slowdown()
3271 opt->rep.low_pri = v; in rocksdb_writeoptions_set_low_pri()
3276 opt->rep.memtable_insert_hint_per_batch = v; in rocksdb_writeoptions_set_memtable_insert_hint_per_batch()
3289 opt->rep.bottommost_level_compaction = static_cast<BottommostLevelCompaction>(v); in rocksdb_compactoptions_set_bottommost_level_compaction()
3294 opt->rep.exclusive_manual_compaction = v; in rocksdb_compactoptions_set_exclusive_manual_compaction()
3299 opt->rep.change_level = v; in rocksdb_compactoptions_set_change_level()
3304 opt->rep.target_level = n; in rocksdb_compactoptions_set_target_level()
3317 opt->rep.wait = v; in rocksdb_flushoptions_set_wait()
3322 c->rep = NewLRUCache(capacity); in rocksdb_cache_create_lru()
3331 cache->rep->SetCapacity(capacity); in rocksdb_cache_set_capacity()
3335 return cache->rep->GetUsage(); in rocksdb_cache_get_usage()
3339 return cache->rep->GetPinnedUsage(); in rocksdb_cache_get_pinned_usage()
3344 result->rep.path = std::string(path); in rocksdb_dbpath_create()
3345 result->rep.target_size = target_size; in rocksdb_dbpath_create()
3355 result->rep = Env::Default(); in rocksdb_create_default_env()
3362 result->rep = ROCKSDB_NAMESPACE::NewMemEnv(Env::Default()); in rocksdb_create_mem_env()
3368 env->rep->SetBackgroundThreads(n); in rocksdb_env_set_background_threads()
3372 env->rep->SetBackgroundThreads(n, Env::HIGH); in rocksdb_env_set_high_priority_background_threads()
3376 env->rep->WaitForJoin(); in rocksdb_env_join_all_threads()
3380 env->rep->LowerThreadPoolIOPriority(); in rocksdb_env_lower_thread_pool_io_priority()
3384 env->rep->LowerThreadPoolIOPriority(Env::HIGH); in rocksdb_env_lower_high_priority_thread_pool_io_priority()
3388 env->rep->LowerThreadPoolCPUPriority(); in rocksdb_env_lower_thread_pool_cpu_priority()
3392 env->rep->LowerThreadPoolCPUPriority(Env::HIGH); in rocksdb_env_lower_high_priority_thread_pool_cpu_priority()
3396 if (!env->is_default) delete env->rep; in rocksdb_env_destroy()
3410 writer->rep = new SstFileWriter(env->rep, io_options->rep); in rocksdb_sstfilewriter_create()
3418 writer->rep = new SstFileWriter(env->rep, io_options->rep); in rocksdb_sstfilewriter_create_with_comparator()
3424 SaveError(errptr, writer->rep->Open(std::string(name))); in rocksdb_sstfilewriter_open()
3430 SaveError(errptr, writer->rep->Put(Slice(key, keylen), Slice(val, vallen))); in rocksdb_sstfilewriter_add()
3436 SaveError(errptr, writer->rep->Put(Slice(key, keylen), Slice(val, vallen))); in rocksdb_sstfilewriter_put()
3443 SaveError(errptr, writer->rep->Merge(Slice(key, keylen), Slice(val, vallen))); in rocksdb_sstfilewriter_merge()
3449 SaveError(errptr, writer->rep->Delete(Slice(key, keylen))); in rocksdb_sstfilewriter_delete()
3454 SaveError(errptr, writer->rep->Finish(nullptr)); in rocksdb_sstfilewriter_finish()
3459 *file_size = writer->rep->FileSize(); in rocksdb_sstfilewriter_file_size()
3463 delete writer->rep; in rocksdb_sstfilewriter_destroy()
3476 opt->rep.move_files = move_files; in rocksdb_ingestexternalfileoptions_set_move_files()
3482 opt->rep.snapshot_consistency = snapshot_consistency; in rocksdb_ingestexternalfileoptions_set_snapshot_consistency()
3488 opt->rep.allow_global_seqno = allow_global_seqno; in rocksdb_ingestexternalfileoptions_set_allow_global_seqno()
3494 opt->rep.allow_blocking_flush = allow_blocking_flush; in rocksdb_ingestexternalfileoptions_set_allow_blocking_flush()
3500 opt->rep.ingest_behind = ingest_behind; in rocksdb_ingestexternalfileoptions_set_ingest_behind()
3515 SaveError(errptr, db->rep->IngestExternalFile(files, opt->rep)); in rocksdb_ingest_external_file()
3526 SaveError(errptr, db->rep->IngestExternalFile(handle->rep, files, opt->rep)); in rocksdb_ingest_external_file_cf()
3530 SaveError(errptr, db->rep->TryCatchUpWithPrimary()); in rocksdb_try_catch_up_with_primary()
3593 result->rep = new ROCKSDB_NAMESPACE::CompactionOptionsUniversal; in rocksdb_universal_compaction_options_create()
3599 uco->rep->size_ratio = ratio; in rocksdb_universal_compaction_options_set_size_ratio()
3604 uco->rep->min_merge_width = w; in rocksdb_universal_compaction_options_set_min_merge_width()
3609 uco->rep->max_merge_width = w; in rocksdb_universal_compaction_options_set_max_merge_width()
3614 uco->rep->max_size_amplification_percent = p; in rocksdb_universal_compaction_options_set_max_size_amplification_percent()
3619 uco->rep->compression_size_percent = p; in rocksdb_universal_compaction_options_set_compression_size_percent()
3624 uco->rep->stop_style = in rocksdb_universal_compaction_options_set_stop_style()
3630 delete uco->rep; in rocksdb_universal_compaction_options_destroy()
3636 result->rep = CompactionOptionsFIFO(); in rocksdb_fifo_compaction_options_create()
3642 fifo_opts->rep.max_table_files_size = size; in rocksdb_fifo_compaction_options_set_max_table_files_size()
3652 assert(level <= opt->rep.num_levels); in rocksdb_options_set_min_level_to_compress()
3653 opt->rep.compression_per_level.resize(opt->rep.num_levels); in rocksdb_options_set_min_level_to_compress()
3655 opt->rep.compression_per_level[i] = ROCKSDB_NAMESPACE::kNoCompression; in rocksdb_options_set_min_level_to_compress()
3657 for (int i = level; i < opt->rep.num_levels; i++) { in rocksdb_options_set_min_level_to_compress()
3658 opt->rep.compression_per_level[i] = opt->rep.compression; in rocksdb_options_set_min_level_to_compress()
3665 return static_cast<int>(lf->rep.size()); in rocksdb_livefiles_count()
3671 return lf->rep[index].name.c_str(); in rocksdb_livefiles_name()
3677 return lf->rep[index].level; in rocksdb_livefiles_level()
3683 return lf->rep[index].size; in rocksdb_livefiles_size()
3690 *size = lf->rep[index].smallestkey.size(); in rocksdb_livefiles_smallestkey()
3691 return lf->rep[index].smallestkey.data(); in rocksdb_livefiles_smallestkey()
3698 *size = lf->rep[index].largestkey.size(); in rocksdb_livefiles_largestkey()
3699 return lf->rep[index].largestkey.data(); in rocksdb_livefiles_largestkey()
3705 return lf->rep[index].num_entries; in rocksdb_livefiles_entries()
3711 return lf->rep[index].num_deletions; in rocksdb_livefiles_deletions()
3724 GetOptionsFromString(base_options->rep, std::string(opts_str), in rocksdb_get_options_from_string()
3725 &new_options->rep)); in rocksdb_get_options_from_string()
3735 db->rep, db->rep->DefaultColumnFamily(), in rocksdb_delete_file_in_range()
3748 db->rep, column_family->rep, in rocksdb_delete_file_in_range_cf()
3763 opt->rep.max_num_locks = max_num_locks; in rocksdb_transactiondb_options_set_max_num_locks()
3768 opt->rep.num_stripes = num_stripes; in rocksdb_transactiondb_options_set_num_stripes()
3773 opt->rep.transaction_lock_timeout = txn_lock_timeout; in rocksdb_transactiondb_options_set_transaction_lock_timeout()
3778 opt->rep.default_lock_timeout = default_lock_timeout; in rocksdb_transactiondb_options_set_default_lock_timeout()
3791 opt->rep.set_snapshot = v; in rocksdb_transaction_options_set_set_snapshot()
3796 opt->rep.deadlock_detect = v; in rocksdb_transaction_options_set_deadlock_detect()
3801 opt->rep.lock_timeout = lock_timeout; in rocksdb_transaction_options_set_lock_timeout()
3806 opt->rep.expiration = expiration; in rocksdb_transaction_options_set_expiration()
3811 opt->rep.deadlock_detect_depth = depth; in rocksdb_transaction_options_set_deadlock_detect_depth()
3816 opt->rep.max_write_batch_size = size; in rocksdb_transaction_options_set_max_write_batch_size()
3831 opt->rep.set_snapshot = v; in rocksdb_optimistictransaction_options_set_set_snapshot()
3839 SaveError(errptr, txn_db->rep->CreateColumnFamily( in rocksdb_transactiondb_create_column_family()
3840 ColumnFamilyOptions(column_family_options->rep), in rocksdb_transactiondb_create_column_family()
3841 std::string(column_family_name), &(handle->rep))); in rocksdb_transactiondb_create_column_family()
3850 if (SaveError(errptr, TransactionDB::Open(options->rep, txn_db_options->rep, in rocksdb_transactiondb_open()
3855 result->rep = txn_db; in rocksdb_transactiondb_open()
3869 ColumnFamilyOptions(column_family_options[i]->rep))); in rocksdb_transactiondb_open_column_families()
3874 if (SaveError(errptr, TransactionDB::Open(options->rep, txn_db_options->rep, in rocksdb_transactiondb_open_column_families()
3883 c_handle->rep = handles[i]; in rocksdb_transactiondb_open_column_families()
3887 result->rep = txn_db; in rocksdb_transactiondb_open_column_families()
3894 result->rep = txn_db->rep->GetSnapshot(); in rocksdb_transactiondb_create_snapshot()
3900 txn_db->rep->ReleaseSnapshot(snapshot->rep); in rocksdb_transactiondb_release_snapshot()
3911 result->rep = txn_db->rep->BeginTransaction(write_options->rep, in rocksdb_transaction_begin()
3912 txn_options->rep, nullptr); in rocksdb_transaction_begin()
3915 old_txn->rep = txn_db->rep->BeginTransaction(write_options->rep, in rocksdb_transaction_begin()
3916 txn_options->rep, old_txn->rep); in rocksdb_transaction_begin()
3921 SaveError(errptr, txn->rep->Commit()); in rocksdb_transaction_commit()
3925 SaveError(errptr, txn->rep->Rollback()); in rocksdb_transaction_rollback()
3929 txn->rep->SetSavePoint(); in rocksdb_transaction_set_savepoint()
3933 SaveError(errptr, txn->rep->RollbackToSavePoint()); in rocksdb_transaction_rollback_to_savepoint()
3937 delete txn->rep; in rocksdb_transaction_destroy()
3944 result->rep = txn->rep->GetSnapshot(); in rocksdb_transaction_get_snapshot()
3955 Status s = txn->rep->Get(options->rep, Slice(key, klen), &tmp); in rocksdb_transaction_get()
3976 txn->rep->Get(options->rep, column_family->rep, Slice(key, klen), &tmp); in rocksdb_transaction_get_cf()
3998 txn->rep->GetForUpdate(options->rep, Slice(key, klen), &tmp, exclusive); in rocksdb_transaction_get_for_update()
4017 Status s = txn->rep->GetForUpdate(options->rep, column_family->rep, in rocksdb_transaction_get_for_update_cf()
4040 Status s = txn_db->rep->Get(options->rep, Slice(key, klen), &tmp); in rocksdb_transactiondb_get()
4059 Status s = txn_db->rep->Get(options->rep, column_family->rep, in rocksdb_transactiondb_get_cf()
4077 SaveError(errptr, txn->rep->Put(Slice(key, klen), Slice(val, vlen))); in rocksdb_transaction_put()
4084 SaveError(errptr, txn->rep->Put(column_family->rep, Slice(key, klen), in rocksdb_transaction_put_cf()
4094 txn_db->rep->Put(options->rep, Slice(key, klen), Slice(val, vlen))); in rocksdb_transactiondb_put()
4103 SaveError(errptr, txn_db->rep->Put(options->rep, column_family->rep, in rocksdb_transactiondb_put_cf()
4113 SaveError(errptr, db->rep->Write(options->rep, &batch->rep)); in rocksdb_transactiondb_write()
4120 SaveError(errptr, txn->rep->Merge(Slice(key, klen), Slice(val, vlen))); in rocksdb_transaction_merge()
4127 SaveError(errptr, txn->rep->Merge(column_family->rep, Slice(key, klen), in rocksdb_transaction_merge_cf()
4136 SaveError(errptr, txn_db->rep->Merge(options->rep, Slice(key, klen), in rocksdb_transactiondb_merge()
4144 SaveError(errptr, txn_db->rep->Merge(options->rep, column_family->rep, in rocksdb_transactiondb_merge_cf()
4151 SaveError(errptr, txn->rep->Delete(Slice(key, klen))); in rocksdb_transaction_delete()
4157 SaveError(errptr, txn->rep->Delete(column_family->rep, Slice(key, klen))); in rocksdb_transaction_delete_cf()
4164 SaveError(errptr, txn_db->rep->Delete(options->rep, Slice(key, klen))); in rocksdb_transactiondb_delete()
4171 SaveError(errptr, txn_db->rep->Delete(options->rep, column_family->rep, in rocksdb_transactiondb_delete_cf()
4179 result->rep = txn->rep->GetIterator(options->rep); in rocksdb_transaction_create_iterator()
4188 result->rep = txn->rep->GetIterator(options->rep, column_family->rep); in rocksdb_transaction_create_iterator_cf()
4196 result->rep = txn_db->rep->NewIterator(options->rep); in rocksdb_transactiondb_create_iterator()
4204 result->rep = txn_db->rep->NewIterator(options->rep, column_family->rep); in rocksdb_transactiondb_create_iterator_cf()
4209 delete txn_db->rep; in rocksdb_transactiondb_close()
4216 if (SaveError(errptr, Checkpoint::Create(txn_db->rep, &checkpoint))) { in rocksdb_transactiondb_checkpoint_object_create()
4220 result->rep = checkpoint; in rocksdb_transactiondb_checkpoint_object_create()
4228 options->rep, std::string(name), &otxn_db))) { in rocksdb_optimistictransactiondb_open()
4233 result->rep = otxn_db; in rocksdb_optimistictransactiondb_open()
4247 ColumnFamilyOptions(column_family_options[i]->rep))); in rocksdb_optimistictransactiondb_open_column_families()
4253 DBOptions(db_options->rep), std::string(name), in rocksdb_optimistictransactiondb_open_column_families()
4261 c_handle->rep = handles[i]; in rocksdb_optimistictransactiondb_open_column_families()
4266 result->rep = otxn_db; in rocksdb_optimistictransactiondb_open_column_families()
4272 DB* base_db = otxn_db->rep->GetBaseDB(); in rocksdb_optimistictransactiondb_get_base_db()
4276 result->rep = base_db; in rocksdb_optimistictransactiondb_get_base_db()
4294 result->rep = otxn_db->rep->BeginTransaction(write_options->rep, in rocksdb_optimistictransaction_begin()
4295 otxn_options->rep, nullptr); in rocksdb_optimistictransaction_begin()
4298 old_txn->rep = otxn_db->rep->BeginTransaction( in rocksdb_optimistictransaction_begin()
4299 write_options->rep, otxn_options->rep, old_txn->rep); in rocksdb_optimistictransaction_begin()
4305 delete otxn_db->rep; in rocksdb_optimistictransactiondb_close()
4315 Status s = db->rep->Get(options->rep, db->rep->DefaultColumnFamily(), in rocksdb_get_pinned()
4316 Slice(key, keylen), &v->rep); in rocksdb_get_pinned()
4332 Status s = db->rep->Get(options->rep, column_family->rep, Slice(key, keylen), in rocksdb_get_pinned_cf()
4333 &v->rep); in rocksdb_get_pinned_cf()
4353 *vlen = v->rep.size(); in rocksdb_pinnableslice_value()
4354 return v->rep.data(); in rocksdb_pinnableslice_value()
4400 dbs.push_back(db->rep); in rocksdb_approximate_memory_usage_create()
4405 cache_set.insert(const_cast<const Cache*>(cache->rep.get())); in rocksdb_approximate_memory_usage_create()