Home
last modified time | relevance | path

Searched refs:f (Results 1 – 25 of 127) sorted by relevance

123456

/rocksdb-6.9/db/
Dfile_indexer_test.cc56 auto* f = new FileMetaData(); in AddFile() local
57 f->smallest = IntKey(smallest); in AddFile()
58 f->largest = IntKey(largest); in AddFile()
59 files[level].push_back(f); in AddFile()
68 for (auto* f : files[i]) { in ClearFiles() local
69 delete f; in ClearFiles()
119 for (uint32_t f = 0; f < 3; ++f) { in TEST_F() local
159 for (uint32_t f = 0; f < 3; ++f) { in TEST_F() local
199 for (uint32_t f = 0; f < 3; ++f) { in TEST_F() local
323 for (uint32_t f = 2; f <= 4; ++f) { in TEST_F() local
[all …]
Dversion_edit.cc197 if (!f.smallest.Valid() || !f.largest.Valid()) { in EncodeTo()
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()
257 if (f.marked_for_compaction) { in EncodeTo()
338 FileMetaData f; in DecodeNewFile4From() local
346 GetInternalKey(input, &f.largest) && in DecodeNewFile4From()
418 f.fd = in DecodeNewFile4From()
432 FileMetaData f; in DecodeFrom() local
740 r.append(f.file_checksum); in DebugString()
[all …]
Dexternal_sst_file_ingestion_job.cc45 if (f.cf_id != in Prepare()
85 if (f.num_entries == 0 && f.num_range_deletions == 0) { in Prepare()
89 if (!f.smallest_internal_key.Valid() || !f.largest_internal_key.Valid()) { in Prepare()
97 f.fd = FileDescriptor(next_file_number++, 0, f.file_size); in Prepare()
98 f.copy_file = false; in Prepare()
133 if (f.copy_file) { in Prepare()
259 f.picked_level, f.fd.GetNumber(), f.fd.GetPathId(), f.fd.GetFileSize(), in Run()
260 f.smallest_internal_key, f.largest_internal_key, f.assigned_seqno, in Run()
286 if (f.copy_file) { in UpdateStats()
304 f.external_file_path.c_str(), f.picked_level, in UpdateStats()
[all …]
Dimport_column_family_job.cc75 for (const auto& f : files_to_import_) { in Prepare() local
76 if (f.num_entries == 0) { in Prepare()
80 if (!f.smallest_internal_key.Valid() || !f.largest_internal_key.Valid()) { in Prepare()
87 for (auto& f : files_to_import_) { in Prepare() local
88 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()
109 f.copy_file = !hardlink_files; in Prepare()
116 if (f.internal_file_path.empty()) { in Prepare()
149 const auto& f = files_to_import_[i]; in Run() local
152 edit_.AddFile(file_metadata.level, f.fd.GetNumber(), f.fd.GetPathId(), in Run()
[all …]
Dversion_set.cc222 prev_file_ = f; in GetNextFile()
231 return f; in GetNextFile()
503 *fd = f; in GetNextFileInLevelWithKeys()
563 return f; in GetNextFile()
749 f->refs--; in ~Version()
2469 if (!f->being_compacted && f->marked_for_compaction) { in ComputeFilesMarkedForCompaction()
2587 f->fd.GetNumber(), f->smallest.DebugString(true).c_str(), in AddFile()
2598 f->refs++; in AddFile()
5249 edit.AddFile(level, f->fd.GetNumber(), f->fd.GetPathId(), in WriteCurrentStateToManifest()
5250 f->fd.GetFileSize(), f->smallest, f->largest, in WriteCurrentStateToManifest()
[all …]
Dfilename_test.cc59 std::string f = cases[i].fname; in TEST_F() local
61 ASSERT_TRUE(ParseFileName(f, &number, &type)) << f; in TEST_F()
63 ASSERT_TRUE(ParseFileName(f, &number, info_log_prefix.prefix, &type)) in TEST_F()
64 << f; in TEST_F()
66 ASSERT_EQ(cases[i].type, type) << f; in TEST_F()
67 ASSERT_EQ(cases[i].number, number) << f; in TEST_F()
103 std::string f = errors[i]; in TEST_F() local
104 ASSERT_TRUE(!ParseFileName(f, &number, &type)) << f; in TEST_F()
Dversion_builder.cc137 void UnrefFile(FileMetaData* f) { in UnrefFile() argument
138 f->refs--; in UnrefFile()
139 if (f->refs <= 0) { in UnrefFile()
140 if (f->table_reader_handle) { in UnrefFile()
143 f->table_reader_handle = nullptr; in UnrefFile()
145 delete f; in UnrefFile()
333 FileMetaData* f = base_files[i]; in CheckConsistencyForDeletes() local
334 if (f->fd.GetNumber() == number) { in CheckConsistencyForDeletes()
464 f->refs = 1; in Apply()
469 levels_[level].added_files[f->fd.GetNumber()] = f; in Apply()
[all …]
/rocksdb-6.9/db/db_impl/
Ddb_impl_experimental.cc42 for (auto f : inputs) { in SuggestCompactRange() local
43 f->marked_for_compaction = true; in SuggestCompactRange()
92 auto f = l0_files[i]; in PromoteL0() local
93 if (f->being_compacted) { in PromoteL0()
126 for (const auto& f : l0_files) { in PromoteL0() local
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()
131 f->marked_for_compaction, f->oldest_blob_file_number, in PromoteL0()
132 f->oldest_ancester_time, f->file_creation_time, in PromoteL0()
[all …]
/rocksdb-6.9/db/compaction/
Dcompaction_picker_universal.cc141 FileMetaData* f; member
200 for (FileMetaData* f : files) { in GetSmallestLargestSeqno()
201 assert(f->fd.smallest_seqno <= f->fd.largest_seqno); in GetSmallestLargestSeqno()
248 next.f = nullptr; in IsInputFilesNonOverlapping()
257 if (next.f) { in IsInputFilesNonOverlapping()
332 ret.emplace_back(0, f, f->fd.GetFileSize(), f->compensated_file_size, in CalculateSortedRuns()
345 if (f->being_compacted) { in CalculateSortedRuns()
483 for (auto f : *c->inputs(0)) { in PickCompaction()
484 assert(f->fd.smallest_seqno <= f->fd.largest_seqno); in PickCompaction()
731 files.push_back(f); in PickCompactionToReduceSortedRuns()
[all …]
Dcompaction_picker_fifo.cc24 for (const auto& f : files) { in GetTotalFilesSize() local
25 total_size += f->fd.file_size; in GetTotalFilesSize()
73 FileMetaData* f = *ritr; in PickTTLCompaction() local
79 total_size -= f->compensated_file_size; in PickTTLCompaction()
80 inputs[0].files.push_back(f); in PickTTLCompaction()
94 for (const auto& f : inputs[0].files) { in PickTTLCompaction() local
98 cf_name.c_str(), f->fd.GetNumber(), in PickTTLCompaction()
99 f->TryGetFileCreationTime()); in PickTTLCompaction()
176 auto f = *ritr; in PickSizeCompaction() local
177 total_size -= f->compensated_file_size; in PickSizeCompaction()
[all …]
Dcompaction_picker.cc177 FileMetaData* f = inputs[i]; in GetRange() local
179 *smallest = f->smallest; in GetRange()
180 *largest = f->largest; in GetRange()
183 *smallest = f->smallest; in GetRange()
186 *largest = f->largest; in GetRange()
611 files.push_back(f); in CompactRange()
863 for (size_t f = 0; f < current_files.size(); ++f) { in SanitizeCompactionInputFilesForAllLevels() local
870 largestkey = current_files[f].largestkey; in SanitizeCompactionInputFilesForAllLevels()
904 for (int f = first_included; f <= last_included; ++f) { in SanitizeCompactionInputFilesForAllLevels() local
905 if (current_files[f].being_compacted) { in SanitizeCompactionInputFilesForAllLevels()
[all …]
Dcompaction.cc87 for (const auto* f : inputs[i].files) { in GetBoundaryKeys() local
93 const Slice& end_user_key = f->largest.user_key(); in GetBoundaryKeys()
134 const auto* f = inputs[i].files[j]; in PopulateWithAtomicBoundaries() local
137 cur_boundary.smallest = &f->smallest; in PopulateWithAtomicBoundaries()
138 cur_boundary.largest = &f->largest; in PopulateWithAtomicBoundaries()
144 cur_boundary.largest = &f->largest; in PopulateWithAtomicBoundaries()
148 cur_boundary.smallest = &f->smallest; in PopulateWithAtomicBoundaries()
149 cur_boundary.largest = &f->largest; in PopulateWithAtomicBoundaries()
371 auto* f = files[level_ptrs->at(lvl)]; in KeyNotExistsBeyondOutputLevel() local
431 for (auto f : input_level.files) { in CalculateTotalInputSize() local
[all …]
/rocksdb-6.9/utilities/
Denv_mirror.cc22 explicit SequentialFileMirror(std::string f) : fname(f) {} in SequentialFileMirror() argument
66 explicit RandomAccessFileMirror(std::string f) : fname(f) {} in RandomAccessFileMirror() argument
102 : WritableFile(options), fname(f) {} in WritableFileMirror()
198 if (f.find("/proc/") == 0) { in NewSequentialFile()
199 return a_->NewSequentialFile(f, r, options); in NewSequentialFile()
215 if (f.find("/proc/") == 0) { in NewRandomAccessFile()
216 return a_->NewRandomAccessFile(f, r, options); in NewRandomAccessFile()
229 Status EnvMirror::NewWritableFile(const std::string& f, in NewWritableFile() argument
232 if (f.find("/proc/") == 0) return a_->NewWritableFile(f, r, options); in NewWritableFile()
234 Status as = a_->NewWritableFile(f, &mf->a_, options); in NewWritableFile()
[all …]
/rocksdb-6.9/CMakeFiles/
DMakefile251 RM = /usr/local/bin/cmake -E rm -f
158 $(MAKE) $(MAKESILENT) -f CMakeFiles/Makefile2 CMakeFiles/build_version.dir/all
184 $(MAKE) $(MAKESILENT) -f CMakeFiles/Makefile2 CMakeFiles/rocksdb.dir/all
210 $(MAKE) $(MAKESILENT) -f CMakeFiles/Makefile2 CMakeFiles/rocksdb-shared.dir/all
236 $(MAKE) $(MAKESILENT) -f CMakeFiles/Makefile2 CMakeFiles/db_bench.dir/all
262 $(MAKE) $(MAKESILENT) -f CMakeFiles/Makefile2 CMakeFiles/cache_bench.dir/all
366 $(MAKE) $(MAKESILENT) -f CMakeFiles/Makefile2 CMakeFiles/filter_bench.dir/all
418 $(MAKE) $(MAKESILENT) -f CMakeFiles/Makefile2 CMakeFiles/core_tools.dir/all
444 $(MAKE) $(MAKESILENT) -f CMakeFiles/Makefile2 CMakeFiles/tools.dir/all
470 $(MAKE) $(MAKESILENT) -f CMakeFiles/Makefile2 tools/CMakeFiles/sst_dump.dir/all
[all …]
/rocksdb-6.9/include/rocksdb/utilities/
Denv_mirror.h46 Status NewSequentialFile(const std::string& f,
49 Status NewRandomAccessFile(const std::string& f,
66 Status FileExists(const std::string& f) override { in FileExists() argument
67 Status as = a_->FileExists(f); in FileExists()
68 Status bs = b_->FileExists(f); in FileExists()
95 Status as = a_->DeleteFile(f); in DeleteFile()
96 Status bs = b_->DeleteFile(f); in DeleteFile()
120 Status as = a_->GetFileSize(f, &asize); in GetFileSize()
121 Status bs = b_->GetFileSize(f, &bsize); in GetFileSize()
161 Status as = a_->LockFile(f, &al); in LockFile()
[all …]
/rocksdb-6.9/env/
Denv_hdfs.cc302 : file_(f), gettid_(gettid) { in HdfsLogger()
396 if (f == nullptr || !f->isValid()) { in NewSequentialFile()
397 delete f; in NewSequentialFile()
401 result->reset(dynamic_cast<SequentialFile*>(f)); in NewSequentialFile()
411 if (f == nullptr || !f->isValid()) { in NewRandomAccessFile()
412 delete f; in NewRandomAccessFile()
427 if (f == nullptr || !f->isValid()) { in NewWritableFile()
428 delete f; in NewWritableFile()
432 result->reset(dynamic_cast<WritableFile*>(f)); in NewWritableFile()
599 if (f == nullptr || !f->isValid()) { in NewLogger()
[all …]
Dcomposite_env_wrapper.h293 Status NewSequentialFile(const std::string& f, in NewSequentialFile() argument
306 Status NewRandomAccessFile(const std::string& f, in NewRandomAccessFile() argument
388 Status FileExists(const std::string& f) override { in FileExists() argument
391 return file_system_->FileExists(f, io_opts, &dbg); in FileExists()
405 Status DeleteFile(const std::string& f) override { in DeleteFile() argument
408 return file_system_->DeleteFile(f, io_opts, &dbg); in DeleteFile()
472 return file_system_->LockFile(f, io_opts, l, &dbg); in LockFile()
505 return env_target_->Schedule(f, a, pri, tag, u);
513 return env_target_->StartThread(f, a); in StartThread()
867 IOStatus NewSequentialFile(const std::string& f, in NewSequentialFile() argument
[all …]
/rocksdb-6.9/file/
Drandom_access_file_reader_test.cc47 std::unique_ptr<FSRandomAccessFile> f; in IsDirectIOSupported() local
48 auto s = fs_->NewRandomAccessFile(Path(".direct"), opt, &f, nullptr); in IsDirectIOSupported()
53 std::unique_ptr<FSWritableFile> f; in Write() local
55 ASSERT_OK(f->Append(content, IOOptions(), nullptr)); in Write()
56 ASSERT_OK(f->Close(IOOptions(), nullptr)); in Write()
62 std::unique_ptr<FSRandomAccessFile> f; in Read() local
63 ASSERT_OK(fs_->NewRandomAccessFile(fpath, opts, &f, nullptr)); in Read()
89 std::string f = "get_alignment"; in GetAlignment() local
90 Write(f, ""); in GetAlignment()
92 Read(f, FileOptions(), &r); in GetAlignment()
[all …]
/rocksdb-6.9/util/
Dfilelock_test.cc72 struct flock f; in CheckFileLock()
73 memset(&f, 0, sizeof(f)); in CheckFileLock()
74 f.l_type = (F_WRLCK); in CheckFileLock()
75 f.l_whence = SEEK_SET; in CheckFileLock()
76 f.l_start = 0; in CheckFileLock()
77 f.l_len = 0; // Lock/unlock entire file in CheckFileLock()
78 int value = fcntl(fd, F_SETLK, &f); in CheckFileLock()
/rocksdb-6.9/build_tools/
Damalgamate.py49 def expand_include(include_path, f, abs_path, source_out, header_out, include_paths, public_include… argument
54 with open(include_path) as f:
56 process_file(f, include_path, source_out, header_out, include_paths, public_include_paths)
59 def process_file(f, abs_path, source_out, header_out, include_paths, public_include_paths): argument
60 for (line, text) in enumerate(f):
71 …expanded = expand_include(include_path, f, abs_path, source_out, header_out, include_paths, public…
81 … expand_include(include_path, f, abs_path, header_out, None, public_include_paths, [])
105 …with open(filename) as f, open(args.source_out, 'w') as source_out, open(args.header_out, 'w') as …
108 process_file(f, abs_path, source_out, header_out, include_paths, public_include_paths)
Dprecommit_checker.py25 self.f = open(self.filename, 'w+', 0)
29 if self.f:
30 self.f.write("%s \n" % line)
36 if self.f:
37 self.f.write("%s \n" % data)
42 if self.f:
43 self.f.write("%s \n" % str)
65 stdout=self.log.f, stderr=self.log.f)
/rocksdb-6.9/port/
Dstack_trace.cc60 auto f = popen(cmd, "r"); in PrintStackTraceLine() local
61 if (f) { in PrintStackTraceLine()
63 while (fgets(line, sizeof(line), f)) { in PrintStackTraceLine()
67 pclose(f); in PrintStackTraceLine()
83 auto f = popen(cmd, "r");
84 if (f) {
86 while (fgets(line, sizeof(line), f)) {
90 pclose(f);
/rocksdb-6.9/hdfs/
Dsetup.sh7 for f in `find /usr/lib/hadoop-hdfs | grep jar`; do export CLASSPATH=$CLASSPATH:$f; done
8 for f in `find /usr/lib/hadoop | grep jar`; do export CLASSPATH=$CLASSPATH:$f; done
9 for f in `find /usr/lib/hadoop/client | grep jar`; do export CLASSPATH=$CLASSPATH:$f; done
/rocksdb-6.9/test_util/
Dfault_injection_test_fs.cc71 std::unique_ptr<FSWritableFile>&& f, in TestFSWritableFile() argument
74 target_(std::move(f)), in TestFSWritableFile()
145 : target_(std::move(f)), file_opened_(true), fs_(fs) { in TestFSRandomRWFile()
292 IOStatus FaultInjectionTestFS::DeleteFile(const std::string& f, in DeleteFile() argument
298 IOStatus io_s = FileSystemWrapper::DeleteFile(f, options, dbg); in DeleteFile()
300 fprintf(stderr, "Cannot delete file %s: %s\n", f.c_str(), in DeleteFile()
304 UntrackFile(f); in DeleteFile()
421 void FaultInjectionTestFS::UntrackFile(const std::string& f) { in UntrackFile() argument
423 auto dir_and_name = TestFSGetDirAndName(f); in UntrackFile()
426 db_file_state_.erase(f); in UntrackFile()
[all …]
Dfault_injection_test_env.cc109 std::unique_ptr<WritableFile>&& f, in TestWritableFile() argument
112 target_(std::move(f)), in TestWritableFile()
167 : target_(std::move(f)), file_opened_(true), env_(env) { in TestRandomRWFile()
303 Status FaultInjectionTestEnv::DeleteFile(const std::string& f) { in DeleteFile() argument
307 Status s = EnvWrapper::DeleteFile(f); in DeleteFile()
309 fprintf(stderr, "Cannot delete file %s: %s\n", f.c_str(), in DeleteFile()
313 UntrackFile(f); in DeleteFile()
429 void FaultInjectionTestEnv::UntrackFile(const std::string& f) { in UntrackFile() argument
431 auto dir_and_name = GetDirAndName(f); in UntrackFile()
434 db_file_state_.erase(f); in UntrackFile()
[all …]

123456