Home
last modified time | relevance | path

Searched refs:fd (Results 1 – 25 of 60) sorted by relevance

123

/rocksdb-6.9/env/
Dfs_posix.cc139 fcntl(fd, F_SETFD, fcntl(fd, F_GETFD) | FD_CLOEXEC); in SetFD_CLOEXEC()
148 int fd = -1; in NewSequentialFile() local
166 if (fd < 0) { in NewSequentialFile()
203 int fd; in NewRandomAccessFile() local
221 if (fd < 0) { in NewRandomAccessFile()
271 int fd = -1; in OpenWritableFile() local
376 int fd = -1; in ReuseWritableFile() local
413 close(fd); in ReuseWritableFile()
465 int fd = -1; in NewRandomRWFile() local
534 int fd; in NewDirectory() local
[all …]
Dio_posix.cc83 (void)fd; in Fadvise()
159 int ret = fstatfs(fd, &buf); in IsSyncFileRangeSupported()
214 fd_(fd), in PosixSequentialFile()
332 int result = fstat(fd, &buf); in GetUniqueIdFromFile()
459 if (fd == -1) { in GetLogicalBlockSizeOfDirectory()
460 close(fd); in GetLogicalBlockSizeOfDirectory()
464 close(fd); in GetLogicalBlockSizeOfDirectory()
534 (void)fd; in GetLogicalBlockSizeOfFd()
552 fd_(fd), in PosixRandomAccessFile()
955 fd_(fd), in PosixMmapFile()
[all …]
Dio_posix.h46 static size_t GetUniqueIdFromFile(int fd, char* id, size_t max_size);
47 static size_t GetLogicalBlockSizeOfFd(int fd);
88 size_t GetLogicalBlockSize(const std::string& fname, int fd);
134 PosixSequentialFile(const std::string& fname, FILE* file, int fd,
183 PosixRandomAccessFile(const std::string& fname, int fd,
233 explicit PosixWritableFile(const std::string& fname, int fd,
282 PosixMmapReadableFile(const int fd, const std::string& fname, void* base,
321 PosixMmapFile(const std::string& fname, int fd, size_t page_size,
349 explicit PosixRandomRWFile(const std::string& fname, int fd,
378 explicit PosixDirectory(int fd) : fd_(fd) {} in PosixDirectory() argument
Dio_posix_test.cc19 auto get_fd_block_size = [&](int fd) { in TEST_F() argument
21 return fd; in TEST_F()
88 auto get_fd_block_size = [&](int fd) { in TEST_F() argument
90 return fd; in TEST_F()
/rocksdb-6.9/db/
Dtable_cache.cc94 TableFileName(ioptions_.cf_paths, fd.GetNumber(), fd.GetPathId()); in GetTableReader()
128 uint64_t number = fd.GetNumber(); in EraseHandle()
143 uint64_t number = fd.GetNumber(); in FindTable()
192 auto& fd = file_meta.fd; in NewIterator() local
193 table_reader = fd.table_reader; in NewIterator()
263 const FileDescriptor& fd = file_meta.fd; in GetRangeTombstoneIterator() local
265 TableReader* t = fd.table_reader; in GetRangeTombstoneIterator()
360 auto& fd = file_meta.fd; in Get() local
380 TableReader* t = fd.table_reader; in Get()
441 auto& fd = file_meta.fd; in MultiGet() local
[all …]
Dversion_builder.cc38 if (a->fd.largest_seqno != b->fd.largest_seqno) { in NewestFirstBySeqNo()
39 return a->fd.largest_seqno > b->fd.largest_seqno; in NewestFirstBySeqNo()
41 if (a->fd.smallest_seqno != b->fd.smallest_seqno) { in NewestFirstBySeqNo()
42 return a->fd.smallest_seqno > b->fd.smallest_seqno; in NewestFirstBySeqNo()
45 return a->fd.GetNumber() > b->fd.GetNumber(); in NewestFirstBySeqNo()
56 return (a->fd.GetNumber() < b->fd.GetNumber()); in BySmallestKey()
245 if (f2->fd.smallest_seqno == f2->fd.largest_seqno) { in CheckConsistency()
253 f1->fd.smallest_seqno, f1->fd.largest_seqno, in CheckConsistency()
263 } else if (f1->fd.smallest_seqno <= f2->fd.smallest_seqno) { in CheckConsistency()
267 f1->fd.smallest_seqno, f1->fd.largest_seqno, in CheckConsistency()
[all …]
Dversion_edit.h63 FileDescriptor(const FileDescriptor& fd) { *this = fd; } in FileDescriptor()
66 table_reader = fd.table_reader;
68 file_size = fd.file_size;
70 largest_seqno = fd.largest_seqno;
97 FileDescriptor fd; member
184 fd.smallest_seqno = std::min(fd.smallest_seqno, seqno); in UpdateBoundariesForRange()
185 fd.largest_seqno = std::max(fd.largest_seqno, seqno); in UpdateBoundariesForRange()
216 FileDescriptor fd; member
222 : fd(), in FdWithKeyRange()
230 : fd(_fd), in FdWithKeyRange()
[all …]
Drepair.cc211 bytes += tables_[i].meta.fd.GetFileSize(); in Run()
444 if (meta.fd.GetFileSize() > 0) { in ConvertLogToTable()
445 table_fds_.push_back(meta.fd); in ConvertLogToTable()
458 t.meta.fd = table_fds_[i]; in ExtractMetaData()
462 db_options_.db_paths, t.meta.fd.GetNumber(), t.meta.fd.GetPathId()); in ExtractMetaData()
464 FormatFileNumber(t.meta.fd.GetNumber(), t.meta.fd.GetPathId(), in ExtractMetaData()
477 db_options_.db_paths, t->meta.fd.GetNumber(), t->meta.fd.GetPathId()); in ScanTable()
481 t->meta.fd = FileDescriptor(t->meta.fd.GetNumber(), t->meta.fd.GetPathId(), in ScanTable()
497 t->meta.fd.GetNumber()); in ScanTable()
554 t->meta.fd.GetNumber(), counter, in ScanTable()
[all …]
Dflush_job.cc187 meta_.fd = FileDescriptor(versions_->NewFileNumber(), 0, 0); in PickMemTable()
354 meta_.fd.GetNumber()); in WriteLevel0Table()
403 meta_.fd.GetNumber(), meta_.fd.GetFileSize(), in WriteLevel0Table()
417 if (s.ok() && meta_.fd.GetFileSize() > 0) { in WriteLevel0Table()
423 edit_->AddFile(0 /* level */, meta_.fd.GetNumber(), meta_.fd.GetPathId(), in WriteLevel0Table()
425 meta_.fd.smallest_seqno, meta_.fd.largest_seqno, in WriteLevel0Table()
439 stats.bytes_written = meta_.fd.GetFileSize(); in WriteLevel0Table()
443 meta_.fd.GetFileSize()); in WriteLevel0Table()
455 const uint64_t file_number = meta_.fd.GetNumber(); in GetFlushJobInfo()
462 info->smallest_seqno = meta_.fd.smallest_seqno; in GetFlushJobInfo()
[all …]
Dversion_edit.cc99 fd.smallest_seqno = std::min(fd.smallest_seqno, seqno); in UpdateBoundaries()
100 fd.largest_seqno = std::max(fd.largest_seqno, seqno); in UpdateBoundaries()
202 PutVarint64(dst, f.fd.GetFileSize()); in EncodeTo()
205 PutVarint64Varint64(dst, f.fd.smallest_seqno, f.fd.largest_seqno); in EncodeTo()
252 if (f.fd.GetPathId() != 0) { in EncodeTo()
254 char p = static_cast<char>(f.fd.GetPathId()); in EncodeTo()
418 f.fd = in DecodeNewFile4From()
724 AppendNumberTo(&r, f.fd.GetNumber()); in DebugString()
726 AppendNumberTo(&r, f.fd.GetFileSize()); in DebugString()
824 jw << "FileNumber" << f.fd.GetNumber(); in DebugJSON()
[all …]
Dbuilder.cc95 meta->fd.file_size = 0; in BuildTable()
103 std::string fname = TableFileName(ioptions.cf_paths, meta->fd.GetNumber(), in BuildTable()
104 meta->fd.GetPathId()); in BuildTable()
129 job_id, meta->fd, kInvalidBlobFileNumber, tp, reason, s); in BuildTable()
199 meta->fd.file_size = file_size; in BuildTable()
201 assert(meta->fd.GetFileSize() > 0); in BuildTable()
259 if (!s.ok() || meta->fd.GetFileSize() == 0) { in BuildTable()
263 if (meta->fd.GetFileSize() == 0) { in BuildTable()
269 job_id, meta->fd, meta->oldest_blob_file_number, tp, reason, s); in BuildTable()
Dexternal_sst_file_ingestion_job.cc97 f.fd = FileDescriptor(next_file_number++, 0, f.file_size); in Prepare()
101 TableFileName(cfd_->ioptions()->cf_paths, f.fd.GetNumber(), in Prepare()
102 f.fd.GetPathId()); in Prepare()
145 ingestion_path_ids.insert(f.fd.GetPathId()); in Prepare()
259 f.picked_level, f.fd.GetNumber(), f.fd.GetPathId(), f.fd.GetFileSize(), in Run()
287 stats.bytes_written = f.fd.GetFileSize(); in UpdateStats()
289 stats.bytes_moved = f.fd.GetFileSize(); in UpdateStats()
295 f.fd.GetFileSize()); in UpdateStats()
575 return f1->fd.largest_seqno < f2->fd.largest_seqno; in AssignLevelAndSeqnoForIngestedFile()
577 ->fd.largest_seqno; in AssignLevelAndSeqnoForIngestedFile()
[all …]
Dtable_cache.h126 void EraseHandle(const FileDescriptor& fd, Cache::Handle* handle);
161 const FileDescriptor& fd,
166 const Slice& key, const FileDescriptor& fd, TableReaderCaller caller,
173 const FileDescriptor& fd, TableReaderCaller caller,
198 const FileDescriptor& fd, bool sequential_mode,
209 const FileDescriptor& fd,
Dversion_set.cc503 *fd = f; in GetNextFileInLevelWithKeys()
791 f.fd = files[i]->fd; in DoGenerateLevelFilesBrief()
1361 file_meta->fd.GetNumber(), file_meta->fd.GetPathId()); in GetPropertiesOfTablesInRange()
1441 static_cast<size_t>(file->fd.GetFileSize()), file->fd.smallest_seqno, in GetColumnFamilyMetaData()
2260 level_size += f->fd.GetFileSize(); in EstimateCompactionBytesNeeded()
3154 f->fd.GetNumber(), f->fd.smallest_seqno, sztxt, in LevelFileSummary()
3366 size += file->fd.file_size; in EstimateLiveDataSize()
3408 live->push_back(file->fd); in AddLiveFiles()
5249 edit.AddFile(level, f->fd.GetNumber(), f->fd.GetPathId(), in WriteCurrentStateToManifest()
5251 f->fd.smallest_seqno, f->fd.largest_seqno, in WriteCurrentStateToManifest()
[all …]
Dimport_column_family_job.cc88 f.fd = FileDescriptor(next_file_number++, 0, f.file_size); in Prepare()
92 cfd_->ioptions()->cf_paths, f.fd.GetNumber(), f.fd.GetPathId()); in Prepare()
152 edit_.AddFile(file_metadata.level, f.fd.GetNumber(), f.fd.GetPathId(), in Run()
153 f.fd.GetFileSize(), f.smallest_internal_key, in Run()
Dversion_edit_test.cc95 ASSERT_EQ(3u, new_files[0].second.fd.GetPathId()); in TEST_F()
96 ASSERT_EQ(3u, new_files[1].second.fd.GetPathId()); in TEST_F()
97 ASSERT_EQ(0u, new_files[2].second.fd.GetPathId()); in TEST_F()
98 ASSERT_EQ(0u, new_files[3].second.fd.GetPathId()); in TEST_F()
155 ASSERT_EQ(3u, new_files[0].second.fd.GetPathId()); in TEST_F()
156 ASSERT_EQ(3u, new_files[1].second.fd.GetPathId()); in TEST_F()
Devent_helpers.cc72 const std::string& file_path, int job_id, const FileDescriptor& fd, in LogAndNotifyTableFileCreationFinished() argument
80 << "file_number" << fd.GetNumber() << "file_size" in LogAndNotifyTableFileCreationFinished()
81 << fd.GetFileSize(); in LogAndNotifyTableFileCreationFinished()
150 info.file_size = fd.file_size; in LogAndNotifyTableFileCreationFinished()
/rocksdb-6.9/db/compaction/
Dcompaction_picker_test.cc168 ASSERT_EQ(1U, compaction->input(0, 0)->fd.GetNumber()); in TEST_F()
169 ASSERT_EQ(2U, compaction->input(0, 1)->fd.GetNumber()); in TEST_F()
181 ASSERT_EQ(66U, compaction->input(0, 0)->fd.GetNumber()); in TEST_F()
200 ASSERT_EQ(66U, compaction->input(0, 0)->fd.GetNumber()); in TEST_F()
201 ASSERT_EQ(6U, compaction->input(1, 0)->fd.GetNumber()); in TEST_F()
202 ASSERT_EQ(7U, compaction->input(1, 1)->fd.GetNumber()); in TEST_F()
230 ASSERT_EQ(7U, compaction->input(0, 0)->fd.GetNumber()); in TEST_F()
277 ASSERT_EQ(1U, compaction->input(0, 0)->fd.GetNumber()); in TEST_F()
278 ASSERT_EQ(2U, compaction->input(0, 1)->fd.GetNumber()); in TEST_F()
301 ASSERT_EQ(1U, compaction->input(0, 0)->fd.GetNumber()); in TEST_F()
[all …]
Dcompaction_picker_universal.cc201 assert(f->fd.smallest_seqno <= f->fd.largest_seqno); in GetSmallestLargestSeqno()
204 *smallest_seqno = f->fd.smallest_seqno; in GetSmallestLargestSeqno()
205 *largest_seqno = f->fd.largest_seqno; in GetSmallestLargestSeqno()
208 *smallest_seqno = f->fd.smallest_seqno; in GetSmallestLargestSeqno()
210 if (f->fd.largest_seqno > *largest_seqno) { in GetSmallestLargestSeqno()
211 *largest_seqno = f->fd.largest_seqno; in GetSmallestLargestSeqno()
300 file->fd.GetNumber(), file->fd.GetPathId()); in Dump()
315 file->fd.GetNumber(), sorted_run_count, file->fd.GetFileSize(), in DumpSizeInfo()
342 total_size += f->fd.GetFileSize(); in CalculateSortedRuns()
484 assert(f->fd.smallest_seqno <= f->fd.largest_seqno); in PickCompaction()
[all …]
Dcompaction.cc61 sum += files[i]->fd.GetFileSize(); in TotalFileSize()
324 input(0, 0)->fd.GetPathId() == output_path_id() && in IsTrivialMove()
339 file->fd.GetFileSize() + TotalFileSize(file_grand_parents); in IsTrivialMove()
351 out_edit->DeleteFile(level(which), inputs_[which][i]->fd.GetNumber()); in AddInputDeletions()
432 size += f->fd.GetFileSize(); in CalculateTotalInputSize()
457 AppendHumanBytes(files.at(i)->fd.GetFileSize(), sztxt, 16); in InputSummary()
459 files.at(i)->fd.GetNumber(), sztxt); in InputSummary()
498 preallocation_size += file->fd.GetFileSize(); in OutputFilePreallocationSize()
/rocksdb-6.9/db/db_impl/
Ddb_impl_experimental.cc96 f->fd.GetNumber()); in PromoteL0()
107 prev_f->fd.GetNumber(), f->fd.GetNumber()); in PromoteL0()
127 edit.DeleteFile(0, f->fd.GetNumber()); in PromoteL0()
128 edit.AddFile(target_level, f->fd.GetNumber(), f->fd.GetPathId(), in PromoteL0()
129 f->fd.GetFileSize(), f->smallest, f->largest, in PromoteL0()
130 f->fd.smallest_seqno, f->fd.largest_seqno, in PromoteL0()
Ddb_impl_compaction_flush.cc621 info.largest_seqno = file_meta->fd.largest_seqno; in NotifyOnFlushBegin()
1179 const FileDescriptor& desc = fmd->fd; in NotifyOnCompactionBegin()
1197 const FileDescriptor& desc = meta.fd; in NotifyOnCompactionBegin()
1311 edit.DeleteFile(level, f->fd.GetNumber()); in ReFitLevel()
1312 edit.AddFile(to_level, f->fd.GetNumber(), f->fd.GetPathId(), in ReFitLevel()
1314 f->fd.smallest_seqno, f->fd.largest_seqno, in ReFitLevel()
2732 f->fd.GetPathId(), f->fd.GetFileSize(), f->smallest, in BackgroundCompaction()
2743 c->output_level(), f->fd.GetFileSize()); in BackgroundCompaction()
2745 moved_bytes += f->fd.GetFileSize(); in BackgroundCompaction()
3058 const FileDescriptor& desc = fmd->fd; in BuildCompactionJobInfo()
[all …]
/rocksdb-6.9/tools/block_cache_analyzer/
Dblock_cache_pysim_test.py137 fd=0,
161 fd=0,
185 fd=0,
209 fd=0,
316 fd=0,
366 fd = random.randint(0, nfds)
376 access_record += "{},".format(fd)
443 fd=0,
550 fd=0,
655 fd=0,
/rocksdb-6.9/util/
Dfilelock_test.cc65 int fd = open(file_.c_str(), O_RDWR | O_CREAT, 0644); in CheckFileLock()
66 if (fd < 0) { in CheckFileLock()
78 int value = fcntl(fd, F_SETLK, &f); in CheckFileLock()
88 close(fd); // lock is released for child process in CheckFileLock()
/rocksdb-6.9/file/
Dsst_file_manager_impl.cc97 size_added_by_compaction += filemeta->fd.GetFileSize(); in OnCompactionCompletion()
105 new_file.second.fd.GetNumber(), in OnCompactionCompletion()
106 new_file.second.fd.GetPathId()); in OnCompactionCompletion()
168 size_added_by_compaction += filemeta->fd.GetFileSize(); in EnoughRoomForCompaction()
188 TableFileName(cfd->ioptions()->cf_paths, inputs[0][0]->fd.GetNumber(), in EnoughRoomForCompaction()
189 inputs[0][0]->fd.GetPathId()); in EnoughRoomForCompaction()

123