Lines Matching refs:db_
46 Status s = db_->GetEnv()->FileExists(full_private_path); in CleanStagingDirectory()
52 db_->GetEnv()->GetChildren(full_private_path, &subchildren); in CleanStagingDirectory()
55 s = db_->GetEnv()->DeleteFile(subchild_path); in CleanStagingDirectory()
60 s = db_->GetEnv()->DeleteDir(full_private_path); in CleanStagingDirectory()
75 DBOptions db_options = db_->GetDBOptions(); in CreateCheckpoint()
77 Status s = db_->GetEnv()->FileExists(checkpoint_dir); in CreateCheckpoint()
107 s = db_->GetEnv()->CreateDir(full_private_path); in CreateCheckpoint()
110 db_->DisableFileDeletions(); in CreateCheckpoint()
116 return db_->GetFileSystem()->LinkFile(src_dirname + fname, in CreateCheckpoint()
123 return CopyFile(db_->GetFileSystem(), src_dirname + fname, in CreateCheckpoint()
129 return CreateFile(db_->GetFileSystem(), full_private_path + fname, in CreateCheckpoint()
134 db_->EnableFileDeletions(false); in CreateCheckpoint()
139 s = db_->GetEnv()->RenameFile(full_private_path, checkpoint_dir); in CreateCheckpoint()
143 db_->GetEnv()->NewDirectory(checkpoint_dir, &checkpoint_directory); in CreateCheckpoint()
183 *sequence_number = db_->GetLatestSequenceNumber(); in CreateCustomCheckpoint()
194 s = db_->GetSortedWalFiles(live_wal_files); in CreateCustomCheckpoint()
215 s = db_->GetLiveFiles(live_files, &manifest_file_size, flush_memtable); in CreateCustomCheckpoint()
220 if (!db_->GetIntProperty(DB::Properties::kMinLogNumberToKeep, in CreateCustomCheckpoint()
241 s = db_->GetLiveFiles(live_files, &manifest_file_size, flush_memtable); in CreateCustomCheckpoint()
246 db_->FlushWAL(false /* sync */); in CreateCustomCheckpoint()
250 s = db_->GetSortedWalFiles(live_wal_files); in CreateCustomCheckpoint()
288 s = link_file_cb(db_->GetName(), src_fname, type); in CreateCustomCheckpoint()
295 s = copy_file_cb(db_->GetName(), src_fname, in CreateCustomCheckpoint()
345 const auto db_options = db_->GetDBOptions(); in ExportColumnFamily()
349 auto s = db_->GetEnv()->FileExists(export_dir); in ExportColumnFamily()
368 s = db_->GetEnv()->CreateDir(tmp_export_dir); in ExportColumnFamily()
371 s = db_->Flush(ROCKSDB_NAMESPACE::FlushOptions(), handle); in ExportColumnFamily()
377 s = db_->DisableFileDeletions(); in ExportColumnFamily()
379 db_->GetColumnFamilyMetaData(handle, &db_metadata); in ExportColumnFamily()
386 return db_->GetEnv()->LinkFile(src_dirname + fname, in ExportColumnFamily()
392 return CopyFile(db_->GetFileSystem(), src_dirname + fname, in ExportColumnFamily()
396 const auto enable_status = db_->EnableFileDeletions(false /*force*/); in ExportColumnFamily()
406 s = db_->GetEnv()->RenameFile(tmp_export_dir, export_dir); in ExportColumnFamily()
413 s = db_->GetEnv()->NewDirectory(export_dir, &dir_ptr); in ExportColumnFamily()
451 db_->GetEnv()->GetChildren(cleanup_dir, &subchildren); in ExportColumnFamily()
454 const auto status = db_->GetEnv()->DeleteFile(subchild_path); in ExportColumnFamily()
460 const auto status = db_->GetEnv()->DeleteDir(cleanup_dir); in ExportColumnFamily()
499 s = link_file_cb(db_->GetName(), src_fname); in ExportFilesInMetaData()
507 s = copy_file_cb(db_->GetName(), src_fname); in ExportFilesInMetaData()