Lines Matching refs:s

46   Status s = db_->GetEnv()->FileExists(full_private_path);  in CleanStagingDirectory()  local
47 if (s.IsNotFound()) { in CleanStagingDirectory()
51 full_private_path.c_str(), s.ToString().c_str()); in CleanStagingDirectory()
55 s = db_->GetEnv()->DeleteFile(subchild_path); in CleanStagingDirectory()
57 subchild_path.c_str(), s.ToString().c_str()); in CleanStagingDirectory()
60 s = db_->GetEnv()->DeleteDir(full_private_path); in CleanStagingDirectory()
62 full_private_path.c_str(), s.ToString().c_str()); in CleanStagingDirectory()
77 Status s = db_->GetEnv()->FileExists(checkpoint_dir); in CreateCheckpoint() local
78 if (s.ok()) { in CreateCheckpoint()
80 } else if (!s.IsNotFound()) { in CreateCheckpoint()
81 assert(s.IsIOError()); in CreateCheckpoint()
82 return s; in CreateCheckpoint()
107 s = db_->GetEnv()->CreateDir(full_private_path); in CreateCheckpoint()
109 if (s.ok()) { in CreateCheckpoint()
111 s = CreateCustomCheckpoint( in CreateCheckpoint()
137 if (s.ok()) { in CreateCheckpoint()
139 s = db_->GetEnv()->RenameFile(full_private_path, checkpoint_dir); in CreateCheckpoint()
141 if (s.ok()) { in CreateCheckpoint()
145 s = checkpoint_directory->Fsync(); in CreateCheckpoint()
149 if (s.ok()) { in CreateCheckpoint()
160 s.ToString().c_str()); in CreateCheckpoint()
163 return s; in CreateCheckpoint()
179 Status s; in CreateCustomCheckpoint() local
188 if (s.ok()) { in CreateCustomCheckpoint()
194 s = db_->GetSortedWalFiles(live_wal_files); in CreateCustomCheckpoint()
196 if (!s.ok()) { in CreateCustomCheckpoint()
197 return s; in CreateCustomCheckpoint()
215 s = db_->GetLiveFiles(live_files, &manifest_file_size, flush_memtable); in CreateCustomCheckpoint()
217 if (s.ok() && db_options.allow_2pc) { in CreateCustomCheckpoint()
241 s = db_->GetLiveFiles(live_files, &manifest_file_size, flush_memtable); in CreateCustomCheckpoint()
249 if (s.ok()) { in CreateCustomCheckpoint()
250 s = db_->GetSortedWalFiles(live_wal_files); in CreateCustomCheckpoint()
252 if (!s.ok()) { in CreateCustomCheckpoint()
253 return s; in CreateCustomCheckpoint()
260 for (size_t i = 0; s.ok() && i < live_files.size(); ++i) { in CreateCustomCheckpoint()
265 s = Status::Corruption("Can't parse file name. This is very bad"); in CreateCustomCheckpoint()
288 s = link_file_cb(db_->GetName(), src_fname, type); in CreateCustomCheckpoint()
289 if (s.IsNotSupported()) { in CreateCustomCheckpoint()
291 s = Status::OK(); in CreateCustomCheckpoint()
295 s = copy_file_cb(db_->GetName(), src_fname, in CreateCustomCheckpoint()
300 if (s.ok() && !current_fname.empty() && !manifest_fname.empty()) { in CreateCustomCheckpoint()
309 for (size_t i = 0; s.ok() && i < wal_size; ++i) { in CreateCustomCheckpoint()
315 s = copy_file_cb(db_options.wal_dir, live_wal_files[i]->PathName(), in CreateCustomCheckpoint()
321 s = link_file_cb(db_options.wal_dir, live_wal_files[i]->PathName(), in CreateCustomCheckpoint()
323 if (s.IsNotSupported()) { in CreateCustomCheckpoint()
325 s = Status::OK(); in CreateCustomCheckpoint()
329 s = copy_file_cb(db_options.wal_dir, live_wal_files[i]->PathName(), 0, in CreateCustomCheckpoint()
335 return s; in CreateCustomCheckpoint()
349 auto s = db_->GetEnv()->FileExists(export_dir); in ExportColumnFamily() local
350 if (s.ok()) { in ExportColumnFamily()
352 } else if (!s.IsNotFound()) { in ExportColumnFamily()
353 assert(s.IsIOError()); in ExportColumnFamily()
354 return s; in ExportColumnFamily()
368 s = db_->GetEnv()->CreateDir(tmp_export_dir); in ExportColumnFamily()
370 if (s.ok()) { in ExportColumnFamily()
371 s = db_->Flush(ROCKSDB_NAMESPACE::FlushOptions(), handle); in ExportColumnFamily()
375 if (s.ok()) { in ExportColumnFamily()
377 s = db_->DisableFileDeletions(); in ExportColumnFamily()
378 if (s.ok()) { in ExportColumnFamily()
381 s = ExportFilesInMetaData( in ExportColumnFamily()
397 if (s.ok()) { in ExportColumnFamily()
398 s = enable_status; in ExportColumnFamily()
404 if (s.ok()) { in ExportColumnFamily()
406 s = db_->GetEnv()->RenameFile(tmp_export_dir, export_dir); in ExportColumnFamily()
409 if (s.ok()) { in ExportColumnFamily()
413 s = db_->GetEnv()->NewDirectory(export_dir, &dir_ptr); in ExportColumnFamily()
414 if (s.ok()) { in ExportColumnFamily()
416 s = dir_ptr->Fsync(); in ExportColumnFamily()
420 if (s.ok()) { in ExportColumnFamily()
447 cf_name.c_str(), s.ToString().c_str()); in ExportColumnFamily()
466 return s; in ExportColumnFamily()
477 Status s; in ExportFilesInMetaData() local
488 s = Status::Corruption("Could not parse file name"); in ExportFilesInMetaData()
499 s = link_file_cb(db_->GetName(), src_fname); in ExportFilesInMetaData()
500 if (num_files == 1 && s.IsNotSupported()) { in ExportFilesInMetaData()
503 s = Status::OK(); in ExportFilesInMetaData()
507 s = copy_file_cb(db_->GetName(), src_fname); in ExportFilesInMetaData()
509 if (!s.ok()) { in ExportFilesInMetaData()
517 return s; in ExportFilesInMetaData()