| /leveldb-1.20/include/leveldb/ |
| H A D | env.h | 299 return target_->NewSequentialFile(f, r); in NewSequentialFile()
302 return target_->NewRandomAccessFile(f, r); in NewRandomAccessFile()
305 return target_->NewWritableFile(f, r); in NewWritableFile()
308 return target_->NewAppendableFile(f, r); in NewAppendableFile()
310 bool FileExists(const std::string& f) { return target_->FileExists(f); } in FileExists() argument
314 Status DeleteFile(const std::string& f) { return target_->DeleteFile(f); } in DeleteFile() argument
318 return target_->GetFileSize(f, s); in GetFileSize()
324 return target_->LockFile(f, l); in LockFile()
327 void Schedule(void (*f)(void*), void* a) { in Schedule()
328 return target_->Schedule(f, a); in Schedule()
[all …]
|
| /leveldb-1.20/db/ |
| H A D | version_edit.cc | 78 const FileMetaData& f = new_files_[i].second; in EncodeTo() local
81 PutVarint64(dst, f.number); in EncodeTo()
82 PutVarint64(dst, f.file_size); in EncodeTo()
118 FileMetaData f; in DecodeFrom() local
185 GetVarint64(&input, &f.number) && in DecodeFrom()
186 GetVarint64(&input, &f.file_size) && in DecodeFrom()
188 GetInternalKey(&input, &f.largest)) { in DecodeFrom()
254 AppendNumberTo(&r, f.number); in DebugString()
256 AppendNumberTo(&r, f.file_size); in DebugString()
258 r.append(f.smallest.DebugString()); in DebugString()
[all …]
|
| H A D | filename_test.cc | 40 std::string f = cases[i].fname; in TEST() local
41 ASSERT_TRUE(ParseFileName(f, &number, &type)) << f; in TEST()
42 ASSERT_EQ(cases[i].type, type) << f; in TEST()
43 ASSERT_EQ(cases[i].number, number) << f; in TEST()
72 std::string f = errors[i]; in TEST() local
73 ASSERT_TRUE(!ParseFileName(f, &number, &type)) << f; in TEST()
|
| H A D | version_set.cc | 78 f->refs--; in ~Version()
80 delete f; in ~Version()
408 s = vset_->table_cache_->Get(options, f->number, f->file_size, in Get()
433 if (f != NULL) { in UpdateStats()
655 f->refs--; in ~Builder()
657 delete f; in ~Builder()
687 f->refs = 1; in Apply()
702 f->allowed_seeks = (f->file_size / 16384); in Apply()
703 if (f->allowed_seeks < 100) f->allowed_seeks = 100; in Apply()
769 f->refs++; in MaybeAddFile()
[all …]
|
| H A D | version_edit.h | 66 FileMetaData f; in AddFile() local
67 f.number = file; in AddFile()
68 f.file_size = file_size; in AddFile()
69 f.smallest = smallest; in AddFile()
70 f.largest = largest; in AddFile()
71 new_files_.push_back(std::make_pair(level, f)); in AddFile()
|
| H A D | version_set_test.cc | 28 FileMetaData* f = new FileMetaData; in Add() local
29 f->number = files_.size() + 1; in Add()
30 f->smallest = InternalKey(smallest, smallest_seq, kTypeValue); in Add()
31 f->largest = InternalKey(largest, largest_seq, kTypeValue); in Add()
32 files_.push_back(f); in Add()
|
| H A D | fault_injection_test.cc | 110 WritableFile* f,
135 virtual Status DeleteFile(const std::string& f);
144 void UntrackFile(const std::string& f);
160 WritableFile* f, in TestWritableFile() argument
163 target_(f), in TestWritableFile()
166 assert(f != NULL); in TestWritableFile()
291 void FaultInjectionTestEnv::UntrackFile(const std::string& f) { in UntrackFile() argument
293 db_file_state_.erase(f); in UntrackFile()
294 new_files_since_last_dir_sync_.erase(f); in UntrackFile()
298 Status s = EnvWrapper::DeleteFile(f); in DeleteFile()
[all …]
|
| H A D | dbformat.cc | 117 bool InternalFilterPolicy::KeyMayMatch(const Slice& key, const Slice& f) const { in KeyMayMatch()
118 return user_policy_->KeyMayMatch(ExtractUserKey(key), f); in KeyMayMatch()
|
| H A D | db_impl.cc | 720 FileMetaData* f = c->input(0, 0); in BackgroundCompaction() local
721 c->edit()->DeleteFile(c->level(), f->number); in BackgroundCompaction()
722 c->edit()->AddFile(c->level() + 1, f->number, f->file_size, in BackgroundCompaction()
723 f->smallest, f->largest); in BackgroundCompaction()
730 static_cast<unsigned long long>(f->number), in BackgroundCompaction()
732 static_cast<unsigned long long>(f->file_size), in BackgroundCompaction()
|
| H A D | db_test.cc | 91 Status NewWritableFile(const std::string& f, WritableFile** r) { in NewWritableFile() argument
152 Status s = target()->NewWritableFile(f, r); in NewWritableFile()
154 if (strstr(f.c_str(), ".ldb") != NULL || in NewWritableFile()
155 strstr(f.c_str(), ".log") != NULL) { in NewWritableFile()
157 } else if (strstr(f.c_str(), "MANIFEST") != NULL) { in NewWritableFile()
164 Status NewRandomAccessFile(const std::string& f, RandomAccessFile** r) { in NewRandomAccessFile() argument
181 Status s = target()->NewRandomAccessFile(f, r); in NewRandomAccessFile()
404 int f = NumTableFilesAtLevel(level); in FilesPerLevel() local
406 snprintf(buf, sizeof(buf), "%s%d", (level ? "," : ""), f); in FilesPerLevel()
408 if (f > 0) { in FilesPerLevel()
|
| /leveldb-1.20/util/ |
| H A D | env_posix.cc | 257 basename = f; in SyncDirIfManifest()
259 dir = std::string(f, sep - f); in SyncDirIfManifest()
293 struct flock f; in LockOrUnlock() local
294 memset(&f, 0, sizeof(f)); in LockOrUnlock()
296 f.l_whence = SEEK_SET; in LockOrUnlock()
297 f.l_start = 0; in LockOrUnlock()
299 return fcntl(fd, F_SETLK, &f); in LockOrUnlock()
338 if (f == NULL) { in NewSequentialFile()
379 if (f == NULL) { in NewWritableFile()
392 if (f == NULL) { in NewAppendableFile()
[all …]
|
| H A D | env_posix_test.cc | 34 FILE* f = fopen(test_file.c_str(), "w"); in TEST() local
35 ASSERT_TRUE(f != NULL); in TEST()
37 fputs(kFileData, f); in TEST()
38 fclose(f); in TEST()
|
| H A D | posix_logger.h | 24 PosixLogger(FILE* f, uint64_t (*gettid)()) : file_(f), gettid_(gettid) { } in PosixLogger() argument
|
| H A D | testharness.h | 50 Tester(const char* f, int l) in Tester() argument
51 : ok_(true), fname_(f), line_(l) { in Tester()
|
| /leveldb-1.20/table/ |
| H A D | table_builder.cc | 47 Rep(const Options& opt, WritableFile* f) in Rep()
50 file(f), in Rep()
|