Lines Matching refs:s
40 auto s = env_->DeleteFile(db_options_.wal_dir + "/" + fname); in DeleteFile() local
41 if (s.ok()) { in DeleteFile()
45 return s; in DeleteFile()
52 Status s; in GetSortedWalFiles() local
55 s = GetSortedWalsOfType(db_options_.wal_dir, logs, kAliveLogFile); in GetSortedWalFiles()
56 if (!s.ok()) { in GetSortedWalFiles()
57 return s; in GetSortedWalFiles()
71 s = GetSortedWalsOfType(archivedir, files, kArchivedLogFile); in GetSortedWalFiles()
72 if (!s.ok()) { in GetSortedWalFiles()
73 return s; in GetSortedWalFiles()
76 assert(s.IsIOError()); in GetSortedWalFiles()
77 return s; in GetSortedWalFiles()
101 return s; in GetSortedWalFiles()
113 Status s = GetSortedWalFiles(*wal_files); in GetUpdatesSince() local
114 if (!s.ok()) { in GetUpdatesSince()
115 return s; in GetUpdatesSince()
118 s = RetainProbableWalFiles(*wal_files, seq); in GetUpdatesSince()
119 if (!s.ok()) { in GetUpdatesSince()
120 return s; in GetUpdatesSince()
144 Status s = env_->GetCurrentTime(¤t_time); in PurgeObsoleteWALFiles() local
145 if (!s.ok()) { in PurgeObsoleteWALFiles()
147 s.ToString().c_str()); in PurgeObsoleteWALFiles()
164 s = env_->GetChildren(archival_dir, &files); in PurgeObsoleteWALFiles()
165 if (!s.ok()) { in PurgeObsoleteWALFiles()
167 s.ToString().c_str()); in PurgeObsoleteWALFiles()
182 s = env_->GetFileModificationTime(file_path, &file_m_time); in PurgeObsoleteWALFiles()
183 if (!s.ok()) { in PurgeObsoleteWALFiles()
186 s.ToString().c_str()); in PurgeObsoleteWALFiles()
190 s = DeleteDBFile(&db_options_, file_path, archival_dir, false, in PurgeObsoleteWALFiles()
192 if (!s.ok()) { in PurgeObsoleteWALFiles()
194 file_path.c_str(), s.ToString().c_str()); in PurgeObsoleteWALFiles()
206 s = env_->GetFileSize(file_path, &file_size); in PurgeObsoleteWALFiles()
207 if (!s.ok()) { in PurgeObsoleteWALFiles()
210 s.ToString().c_str()); in PurgeObsoleteWALFiles()
217 s = DeleteDBFile(&db_options_, file_path, archival_dir, false, in PurgeObsoleteWALFiles()
219 if (!s.ok()) { in PurgeObsoleteWALFiles()
222 s.ToString().c_str()); in PurgeObsoleteWALFiles()
257 s = DeleteDBFile(&db_options_, db_options_.wal_dir + "/" + file_path, in PurgeObsoleteWALFiles()
260 if (!s.ok()) { in PurgeObsoleteWALFiles()
262 file_path.c_str(), s.ToString().c_str()); in PurgeObsoleteWALFiles()
275 Status s = env_->RenameFile(fname, archived_log_name); in ArchiveWALFile() local
280 s.ToString().c_str()); in ArchiveWALFile()
297 Status s = ReadFirstRecord(log_type, number, &sequence); in GetSortedWalsOfType() local
298 if (!s.ok()) { in GetSortedWalsOfType()
299 return s; in GetSortedWalsOfType()
313 s = env_->GetFileSize(LogFileName(path, number), &size_bytes); in GetSortedWalsOfType()
315 if (!s.ok() && log_type == kAliveLogFile) { in GetSortedWalsOfType()
318 s = env_->GetFileSize(archived_file, &size_bytes); in GetSortedWalsOfType()
319 if (!s.ok() && env_->FileExists(archived_file).IsNotFound()) { in GetSortedWalsOfType()
321 s = Status::OK(); in GetSortedWalsOfType()
326 if (!s.ok()) { in GetSortedWalsOfType()
327 return s; in GetSortedWalsOfType()
388 Status s; in ReadFirstRecord() local
391 s = ReadFirstLine(fname, number, sequence); in ReadFirstRecord()
392 if (!s.ok() && env_->FileExists(fname).ok()) { in ReadFirstRecord()
394 return s; in ReadFirstRecord()
398 if (type == kArchivedLogFile || !s.ok()) { in ReadFirstRecord()
402 s = ReadFirstLine(archived_file, number, sequence); in ReadFirstRecord()
406 if (!s.ok() && env_->FileExists(archived_file).IsNotFound()) { in ReadFirstRecord()
411 if (s.ok() && *sequence != 0) { in ReadFirstRecord()
415 return s; in ReadFirstRecord()
428 Status s; in GetLiveWalFile() local
431 s = env_->GetFileSize(LogFileName(db_options_.wal_dir, number), &size_bytes); in GetLiveWalFile()
433 if (!s.ok()) { in GetLiveWalFile()
434 return s; in GetLiveWalFile()
456 void Corruption(size_t bytes, const Status& s) override { in ReadFirstLine()
459 static_cast<int>(bytes), s.ToString().c_str()); in ReadFirstLine()
462 *this->status = s; in ReadFirstLine()