Lines Matching refs:number

39 Status WalManager::DeleteFile(const std::string& fname, uint64_t number) {  in DeleteFile()  argument
43 read_first_record_cache_.erase(number); in DeleteFile()
176 uint64_t number; in PurgeObsoleteWALFiles() local
178 if (ParseFileName(f, &number, &type) && type == kLogFile) { in PurgeObsoleteWALFiles()
198 read_first_record_cache_.erase(number); in PurgeObsoleteWALFiles()
226 read_first_record_cache_.erase(number); in PurgeObsoleteWALFiles()
271 void WalManager::ArchiveWALFile(const std::string& fname, uint64_t number) { in ArchiveWALFile() argument
272 auto archived_log_name = ArchivedLogFileName(db_options_.wal_dir, number); in ArchiveWALFile()
293 uint64_t number; in GetSortedWalsOfType() local
295 if (ParseFileName(f, &number, &type) && type == kLogFile) { in GetSortedWalsOfType()
297 Status s = ReadFirstRecord(log_type, number, &sequence); in GetSortedWalsOfType()
313 s = env_->GetFileSize(LogFileName(path, number), &size_bytes); in GetSortedWalsOfType()
316 std::string archived_file = ArchivedLogFileName(path, number); in GetSortedWalsOfType()
331 new LogFileImpl(number, log_type, sequence, size_bytes))); in GetSortedWalsOfType()
371 const uint64_t number, in ReadFirstRecord() argument
382 auto itr = read_first_record_cache_.find(number); in ReadFirstRecord()
390 std::string fname = LogFileName(db_options_.wal_dir, number); in ReadFirstRecord()
391 s = ReadFirstLine(fname, number, sequence); in ReadFirstRecord()
401 ArchivedLogFileName(db_options_.wal_dir, number); in ReadFirstRecord()
402 s = ReadFirstLine(archived_file, number, sequence); in ReadFirstRecord()
413 read_first_record_cache_.insert({number, *sequence}); in ReadFirstRecord()
418 Status WalManager::GetLiveWalFile(uint64_t number, in GetLiveWalFile() argument
424 if (!number) { in GetLiveWalFile()
431 s = env_->GetFileSize(LogFileName(db_options_.wal_dir, number), &size_bytes); in GetLiveWalFile()
437 log_file->reset(new LogFileImpl(number, kAliveLogFile, in GetLiveWalFile()
447 const uint64_t number, in ReadFirstLine() argument
485 true /*checksum*/, number); in ReadFirstLine()