Home
last modified time | relevance | path

Searched refs:target_ (Results 1 – 12 of 12) sorted by relevance

/rocksdb-6.9/include/rocksdb/
Denv.h1242 return target_->CreateDir(d); in CreateDir()
1248 return target_->DeleteDir(d); in DeleteDir()
1402 Env* target_;
1426 SequentialFile* target_;
1432 : target_(target) {} in RandomAccessFileWrapper()
1457 RandomAccessFile* target_;
1482 target_->SetIOPriority(pri); in SetIOPriority()
1527 WritableFile* target_;
1551 RandomRWFile* target_;
1564 Directory* target_;
[all …]
Dfile_system.h1162 target_->SanitizeFileOptions(opts); in SanitizeFileOptions()
1198 std::shared_ptr<FileSystem> target_;
1204 : target_(target) {} in FSSequentialFileWrapper()
1225 FSSequentialFile* target_;
1231 : target_(target) {} in FSRandomAccessFileWrapper()
1259 FSRandomAccessFile* target_;
1286 return target_->Sync(options, dbg); in Sync()
1344 FSWritableFile* target_;
1368 return target_->Sync(options, dbg); in Sync()
1378 FSRandomRWFile* target_;
[all …]
/rocksdb-6.9/env/
Dcomposite_env_wrapper.h27 : target_(std::move(target)) {} in CompositeSequentialFileWrapper()
57 : target_(std::move(target)) {} in CompositeRandomAccessFileWrapper()
111 : target_(std::move(t)) {} in CompositeWritableFileWrapper()
141 return target_->Sync(io_opts, &dbg); in Sync()
214 : target_(std::move(target)) {} in CompositeRandomRWFileWrapper()
259 : target_(std::move(target)) {} in CompositeDirectoryWrapper()
650 : target_(std::move(target)) {} in LegacyRandomAccessFileWrapper()
756 return target_->GetFileSize(); in GetFileSize()
801 : target_(std::move(target)) {} in LegacyRandomRWFileWrapper()
841 : target_(std::move(target)) {} in LegacyDirectoryWrapper()
[all …]
/rocksdb-6.9/test_util/
Dfault_injection_test_fs.cc74 target_(std::move(f)), in TestFSWritableFile()
77 assert(target_ != nullptr); in TestFSWritableFile()
106 io_s = target_->Append(state_.buffer_, options, dbg); in Close()
109 target_->Sync(options, dbg); in Close()
110 io_s = target_->Close(options, dbg); in Close()
136 target_->Sync(options, dbg); in Sync()
146 assert(target_ != nullptr); in TestFSRandomRWFile()
161 return target_->Write(offset, data, options, dbg); in Write()
179 return target_->Close(options, dbg); in Close()
187 return target_->Flush(options, dbg); in Flush()
[all …]
Dfault_injection_test_env.cc112 target_(std::move(f)), in TestWritableFile()
115 assert(target_ != nullptr); in TestWritableFile()
129 Status s = target_->Append(data); in Append()
139 Status s = target_->Close(); in Close()
147 Status s = target_->Flush(); in Flush()
168 assert(target_ != nullptr); in TestRandomRWFile()
181 return target_->Write(offset, data); in Write()
189 return target_->Read(offset, n, result, scratch); in Read()
194 return target_->Close(); in Close()
201 return target_->Flush(); in Flush()
[all …]
Dfault_injection_test_env.h64 return target_->Truncate(size); in Truncate()
72 return target_->PositionedAppend(data, offset); in PositionedAppend()
75 return target_->use_direct_io(); in use_direct_io()
80 std::unique_ptr<WritableFile> target_; variable
100 return target_->GetRequiredBufferAlignment(); in GetRequiredBufferAlignment()
102 bool use_direct_io() const override { return target_->use_direct_io(); }; in use_direct_io()
105 std::unique_ptr<RandomRWFile> target_;
Dfault_injection_test_fs.h71 return target_->Truncate(size, options, dbg); in Truncate()
81 return target_->PositionedAppend(data, offset, options, dbg); in PositionedAppend()
84 return target_->use_direct_io(); in use_direct_io()
89 std::unique_ptr<FSWritableFile> target_; variable
112 return target_->GetRequiredBufferAlignment(); in GetRequiredBufferAlignment()
114 bool use_direct_io() const override { return target_->use_direct_io(); }; in use_direct_io()
117 std::unique_ptr<FSRandomRWFile> target_;
/rocksdb-6.9/table/cuckoo/
Dcuckoo_table_reader.cc227 target_(target) {} in BucketComparator()
230 (first == kInvalidIndex) ? target_.data() : in operator ()()
233 (second == kInvalidIndex) ? target_.data() : in operator ()()
243 const Slice target_; member
/rocksdb-6.9/db/
Ddb_basic_test.cc2065 Handle* handle = target_->Lookup(key, stats); in Lookup()
2075 return target_->Release(handle, force_erase); in Release()
2079 return target_->Value(handle); in Value()
2086 target_->SetCapacity(capacity); in SetCapacity()
2090 target_->SetStrictCapacityLimit(strict_capacity_limit); in SetStrictCapacityLimit()
2094 return target_->HasStrictCapacityLimit(); in HasStrictCapacityLimit()
2098 return target_->GetCapacity(); in GetCapacity()
2104 return target_->GetUsage(handle); in GetUsage()
2108 return target_->GetPinnedUsage(); in GetPinnedUsage()
2119 return target_->EraseUnRefEntries(); in EraseUnRefEntries()
[all …]
Ddb_test_util.h432 : target_(std::move(target)), in NewRandomAccessFile()
438 Status s = target_->Read(offset, n, result, scratch); in NewRandomAccessFile()
444 Status s = target_->Prefetch(offset, n); in NewRandomAccessFile()
450 std::unique_ptr<RandomAccessFile> target_; in NewRandomAccessFile()
474 : target_(std::move(target)), counter_(counter) {} in NewSequentialFile()
477 return target_->Read(n, result, scratch); in NewSequentialFile()
479 virtual Status Skip(uint64_t n) override { return target_->Skip(n); } in NewSequentialFile()
482 std::unique_ptr<SequentialFile> target_; in NewSequentialFile()
/rocksdb-6.9/db/db_impl/
Ddb_secondary_test.cc209 : target_(std::move(target)), files_closed_(counter) {} in NewRandomAccessFile()
215 return target_->Read(offset, n, result, scratch); in NewRandomAccessFile()
219 std::unique_ptr<RandomAccessFile> target_; in NewRandomAccessFile() member in ROCKSDB_NAMESPACE::__anon67a9f6170211::TraceFileEnv::NewRandomAccessFile::TracedRandomAccessFile
/rocksdb-6.9/tools/
Ddb_bench_tool.cc1363 std::unique_ptr<SequentialFile> target_; in NewSequentialFile() member in ROCKSDB_NAMESPACE::__anon8e8b84b20111::ReportFileOpEnv::NewSequentialFile::CountingFile
1369 : target_(std::move(target)), counters_(counters) {} in NewSequentialFile()
1373 Status rv = target_->Read(n, result, scratch); in NewSequentialFile()
1395 std::unique_ptr<RandomAccessFile> target_; in NewRandomAccessFile() member in ROCKSDB_NAMESPACE::__anon8e8b84b20111::ReportFileOpEnv::NewRandomAccessFile::CountingFile
1401 : target_(std::move(target)), counters_(counters) {} in NewRandomAccessFile()
1405 Status rv = target_->Read(offset, n, result, scratch); in NewRandomAccessFile()
1424 std::unique_ptr<WritableFile> target_; in NewWritableFile() member in ROCKSDB_NAMESPACE::__anon8e8b84b20111::ReportFileOpEnv::NewWritableFile::CountingFile
1434 Status rv = target_->Append(data); in NewWritableFile()
1441 Status Close() override { return target_->Close(); } in NewWritableFile()
1442 Status Flush() override { return target_->Flush(); } in NewWritableFile()
[all …]