Lines Matching refs:s
529 auto s = backup_engine->Initialize(); in Open() local
530 if (!s.ok()) { in Open()
532 return s; in Open()
608 auto s = backup_env_->CreateDirIfMissing(d.first); in Initialize() local
609 if (s.ok()) { in Initialize()
610 s = backup_env_->NewDirectory(d.first, d.second); in Initialize()
612 if (!s.ok()) { in Initialize()
613 return s; in Initialize()
620 auto s = backup_env_->GetChildren(GetBackupMetaDir(), &backup_meta_files); in Initialize() local
621 if (s.IsNotFound()) { in Initialize()
623 } else if (!s.ok()) { in Initialize()
624 return s; in Initialize()
638 auto s = backup_env_->DeleteFile(GetBackupMetaDir() + "/" + file); in Initialize() local
641 file.c_str(), s.ToString().c_str()); in Initialize()
661 auto s = PurgeOldBackups(0); in Initialize() local
662 if (s.ok()) { in Initialize()
663 s = GarbageCollect(); in Initialize()
665 if (!s.ok()) { in Initialize()
666 return s; in Initialize()
692 Status s = backup_iter->second->LoadFromFile(options_.backup_dir, in Initialize() local
694 if (s.IsCorruption()) { in Initialize()
696 backup_iter->first, s.ToString().c_str()); in Initialize()
699 std::make_pair(s, std::move(backup_iter->second)))); in Initialize()
700 } else if (!s.ok()) { in Initialize()
704 return s; in Initialize()
797 Status s = backup_env_->FileExists(private_dir); in CreateNewBackupWithMetadata() local
798 if (s.ok()) { in CreateNewBackupWithMetadata()
806 s = GarbageCollect(); in CreateNewBackupWithMetadata()
807 } else if (s.IsNotFound()) { in CreateNewBackupWithMetadata()
809 s = Status::OK(); in CreateNewBackupWithMetadata()
827 if (s.ok()) { in CreateNewBackupWithMetadata()
828 s = backup_env_->CreateDir(private_dir); in CreateNewBackupWithMetadata()
845 if (s.ok()) { in CreateNewBackupWithMetadata()
850 s = checkpoint.CreateCustomCheckpoint( in CreateNewBackupWithMetadata()
911 if (s.ok()) { in CreateNewBackupWithMetadata()
932 s = item_status; in CreateNewBackupWithMetadata()
941 if (s.ok()) { in CreateNewBackupWithMetadata()
943 s = new_backup->StoreToFile(options_.sync); in CreateNewBackupWithMetadata()
945 if (s.ok() && options_.sync) { in CreateNewBackupWithMetadata()
951 s = backup_private_directory->Fsync(); in CreateNewBackupWithMetadata()
953 if (s.ok() && private_directory_ != nullptr) { in CreateNewBackupWithMetadata()
954 s = private_directory_->Fsync(); in CreateNewBackupWithMetadata()
956 if (s.ok() && meta_directory_ != nullptr) { in CreateNewBackupWithMetadata()
957 s = meta_directory_->Fsync(); in CreateNewBackupWithMetadata()
959 if (s.ok() && shared_directory_ != nullptr) { in CreateNewBackupWithMetadata()
960 s = shared_directory_->Fsync(); in CreateNewBackupWithMetadata()
962 if (s.ok() && backup_directory_ != nullptr) { in CreateNewBackupWithMetadata()
963 s = backup_directory_->Fsync(); in CreateNewBackupWithMetadata()
967 if (s.ok()) { in CreateNewBackupWithMetadata()
970 if (!s.ok()) { in CreateNewBackupWithMetadata()
974 s.ToString().c_str()); in CreateNewBackupWithMetadata()
980 return s; in CreateNewBackupWithMetadata()
1001 return s; in CreateNewBackupWithMetadata()
1020 auto s = DeleteBackupInternal(backup_id); in PurgeOldBackups() local
1021 if (!s.ok()) { in PurgeOldBackups()
1022 overall_status = s; in PurgeOldBackups()
1028 auto s = GarbageCollect(); in PurgeOldBackups() local
1029 if (!s.ok() && overall_status.ok()) { in PurgeOldBackups()
1030 overall_status = s; in PurgeOldBackups()
1061 auto s = backup->second->Delete(); in DeleteBackupInternal() local
1062 if (!s.ok()) { in DeleteBackupInternal()
1063 return s; in DeleteBackupInternal()
1071 auto s = corrupt->second.second->Delete(); in DeleteBackupInternal() local
1072 if (!s.ok()) { in DeleteBackupInternal()
1073 return s; in DeleteBackupInternal()
1084 Status s = backup_env_->DeleteFile(GetAbsolutePath(itr.first)); in DeleteBackupInternal() local
1086 s.ToString().c_str()); in DeleteBackupInternal()
1088 if (!s.ok()) { in DeleteBackupInternal()
1101 Status s = backup_env_->DeleteDir(GetAbsolutePath(private_dir)); in DeleteBackupInternal() local
1103 private_dir.c_str(), s.ToString().c_str()); in DeleteBackupInternal()
1104 if (!s.ok()) { in DeleteBackupInternal()
1174 Status s = in RestoreDBFromBackup() local
1176 if (!s.ok()) { in RestoreDBFromBackup()
1179 return s; in RestoreDBFromBackup()
1193 Status s; in RestoreDBFromBackup() local
1244 s = item_status; in RestoreDBFromBackup()
1247 s = Status::Corruption("Checksum check failed"); in RestoreDBFromBackup()
1253 s.ToString().c_str()); in RestoreDBFromBackup()
1254 return s; in RestoreDBFromBackup()
1301 Status s; in CopyOrCreateFile() local
1319 s = dst_env->NewWritableFile(dst, &dst_file, dst_env_options); in CopyOrCreateFile()
1320 if (s.ok() && !src.empty()) { in CopyOrCreateFile()
1321 s = src_env->NewSequentialFile(src, &src_file, src_env_options); in CopyOrCreateFile()
1323 if (!s.ok()) { in CopyOrCreateFile()
1324 return s; in CopyOrCreateFile()
1347 s = src_reader->Read(buffer_to_read, &data, buf.get()); in CopyOrCreateFile()
1354 if (!s.ok()) { in CopyOrCreateFile()
1355 return s; in CopyOrCreateFile()
1365 s = dest_writer->Append(data); in CopyOrCreateFile()
1375 } while (s.ok() && contents.empty() && data.size() > 0 && size_limit > 0); in CopyOrCreateFile()
1377 if (s.ok() && sync) { in CopyOrCreateFile()
1378 s = dest_writer->Sync(false); in CopyOrCreateFile()
1380 if (s.ok()) { in CopyOrCreateFile()
1381 s = dest_writer->Close(); in CopyOrCreateFile()
1383 return s; in CopyOrCreateFile()
1400 Status s; in AddBackupFileWorkItem() local
1405 s = CalculateChecksum(src_dir + fname, db_env_, src_env_options, size_limit, in AddBackupFileWorkItem()
1407 if (!s.ok()) { in AddBackupFileWorkItem()
1408 return s; in AddBackupFileWorkItem()
1453 assert(s.IsIOError()); in AddBackupFileWorkItem()
1481 s = CalculateChecksum(src_dir + fname, db_env_, src_env_options, in AddBackupFileWorkItem()
1506 result.status = s; in AddBackupFileWorkItem()
1511 return s; in AddBackupFileWorkItem()
1524 Status s = src_env->NewSequentialFile(src, &src_file, src_env_options); in CalculateChecksum() local
1525 if (!s.ok()) { in CalculateChecksum()
1526 return s; in CalculateChecksum()
1540 s = src_reader->Read(buffer_to_read, &data, buf.get()); in CalculateChecksum()
1542 if (!s.ok()) { in CalculateChecksum()
1543 return s; in CalculateChecksum()
1550 return s; in CalculateChecksum()
1611 auto s = backup_env_->FileExists(shared_path); in GarbageCollect() local
1612 if (s.ok()) { in GarbageCollect()
1613 s = backup_env_->GetChildren(shared_path, &shared_children); in GarbageCollect()
1614 } else if (s.IsNotFound()) { in GarbageCollect()
1615 s = Status::OK(); in GarbageCollect()
1617 if (!s.ok()) { in GarbageCollect()
1618 overall_status = s; in GarbageCollect()
1639 Status s = backup_env_->DeleteFile(GetAbsolutePath(rel_fname)); in GarbageCollect() local
1641 rel_fname.c_str(), s.ToString().c_str()); in GarbageCollect()
1643 if (!s.ok()) { in GarbageCollect()
1654 auto s = backup_env_->GetChildren(GetAbsolutePath(GetPrivateDirRel()), in GarbageCollect() local
1656 if (!s.ok()) { in GarbageCollect()
1657 overall_status = s; in GarbageCollect()
1684 Status s = backup_env_->DeleteFile(full_private_path + subchild); in GarbageCollect() local
1687 s.ToString().c_str()); in GarbageCollect()
1688 if (!s.ok()) { in GarbageCollect()
1694 Status s = backup_env_->DeleteDir(full_private_path); in GarbageCollect() local
1696 full_private_path.c_str(), s.ToString().c_str()); in GarbageCollect()
1697 if (!s.ok()) { in GarbageCollect()
1737 Status s; in Delete() local
1744 s = env_->FileExists(meta_filename_); in Delete()
1745 if (s.ok()) { in Delete()
1746 s = env_->DeleteFile(meta_filename_); in Delete()
1747 } else if (s.IsNotFound()) { in Delete()
1748 s = Status::OK(); // nothing to delete in Delete()
1752 return s; in Delete()
1769 Status s; in LoadFromFile() local
1771 s = env_->NewSequentialFile(meta_filename_, &backup_meta_file, EnvOptions()); in LoadFromFile()
1772 if (!s.ok()) { in LoadFromFile()
1773 return s; in LoadFromFile()
1781 s = backup_meta_reader->Read(max_backup_meta_file_size_, &data, buf.get()); in LoadFromFile()
1783 if (!s.ok() || data.size() == max_backup_meta_file_size_) { in LoadFromFile()
1784 return s.ok() ? Status::Corruption("File size too big") : s; in LoadFromFile()
1813 for (uint32_t i = 0; s.ok() && i < num_files; ++i) { in LoadFromFile()
1852 if (s.ok() && data.size() > 0) { in LoadFromFile()
1854 s = Status::Corruption("Tailing data in backup meta file in " + in LoadFromFile()
1858 if (s.ok()) { in LoadFromFile()
1861 s = AddFile(file_info); in LoadFromFile()
1862 if (!s.ok()) { in LoadFromFile()
1868 return s; in LoadFromFile()
1872 Status s; in StoreToFile() local
1877 s = env_->NewWritableFile(meta_tmp_filename_, &backup_meta_file, env_options); in StoreToFile()
1878 if (!s.ok()) { in StoreToFile()
1879 return s; in StoreToFile()
1941 s = backup_meta_file->Append(Slice(buf.get(), len)); in StoreToFile()
1942 if (s.ok() && sync) { in StoreToFile()
1943 s = backup_meta_file->Sync(); in StoreToFile()
1945 if (s.ok()) { in StoreToFile()
1946 s = backup_meta_file->Close(); in StoreToFile()
1948 if (s.ok()) { in StoreToFile()
1949 s = env_->RenameFile(meta_tmp_filename_, meta_filename_); in StoreToFile()
1951 return s; in StoreToFile()
2005 auto s = backup_engine->Initialize(); in Open() local
2006 if (!s.ok()) { in Open()
2008 return s; in Open()