Home
last modified time | relevance | path

Searched refs:soptions (Results 1 – 25 of 28) sorted by relevance

12

/rocksdb-6.9/env/
Denv_test.cc172 EnvOptions soptions; in TEST_F() local
899 soptions.use_direct_reads = soptions.use_direct_writes = direct_io_; in TEST_P()
972 soptions.use_direct_reads = soptions.use_direct_writes = direct_io_; in TEST_P()
1034 soptions.use_direct_reads = soptions.use_direct_writes = direct_io_; in TEST_P()
1074 soptions.use_direct_reads = soptions.use_direct_writes = direct_io_; in TEST_P()
1113 EnvOptions soptions; in TEST_P() local
1114 soptions.use_direct_reads = soptions.use_direct_writes = direct_io_; in TEST_P()
1189 soptions.use_direct_reads = soptions.use_direct_writes = false; in TEST_F()
1286 soptions.use_direct_reads = soptions.use_direct_writes = direct_io_; in TEST_P()
1473 soptions.use_direct_reads = soptions.use_direct_writes = direct_io_; in TEST_P()
[all …]
Dfile_system.cc89 EnvOptions soptions; in WriteStringToFile() local
90 IOStatus s = fs->NewWritableFile(fname, soptions, &file, nullptr); in WriteStringToFile()
106 FileOptions soptions; in ReadFileToString() local
110 fs->NewSequentialFile(fname, soptions, &file, nullptr)); in ReadFileToString()
Dmock_env.h40 const EnvOptions& soptions) override;
44 const EnvOptions& soptions) override;
/rocksdb-6.9/file/
Dfile_util.cc22 const FileOptions soptions; in CopyFile() local
29 s = fs->NewSequentialFile(source, soptions, &srcfile, nullptr); in CopyFile()
34 s = fs->NewWritableFile(destination, soptions, &destfile, nullptr); in CopyFile()
48 new WritableFileWriter(std::move(destfile), destination, soptions)); in CopyFile()
74 const EnvOptions soptions; in CreateFile() local
79 s = fs->NewWritableFile(destination, soptions, &destfile, nullptr); in CreateFile()
84 new WritableFileWriter(std::move(destfile), destination, soptions)); in CreateFile()
/rocksdb-6.9/table/
Dsst_file_reader.cc23 EnvOptions soptions; member
31 soptions(options), in Rep()
48 s = r->options.env->NewRandomAccessFile(file_path, &file, r->soptions); in Open()
56 r->soptions, r->ioptions.internal_comparator); in Open()
/rocksdb-6.9/test_util/
Dfault_injection_test_env.cc225 const EnvOptions& soptions) { in NewWritableFile() argument
237 s = target()->NewWritableFile(fname, result, soptions); in NewWritableFile()
254 const EnvOptions& soptions) { in ReopenWritableFile() argument
258 Status s = target()->ReopenWritableFile(fname, result, soptions); in ReopenWritableFile()
275 const EnvOptions& soptions) { in NewRandomRWFile() argument
279 Status s = target()->NewRandomRWFile(fname, result, soptions); in NewRandomRWFile()
296 const EnvOptions& soptions) { in NewRandomAccessFile() argument
300 return target()->NewRandomAccessFile(fname, result, soptions); in NewRandomAccessFile()
Dfault_injection_test_env.h136 const EnvOptions& soptions) override;
140 const EnvOptions& soptions) override;
144 const EnvOptions& soptions) override;
148 const EnvOptions& soptions) override;
Dtestutil.h70 const EnvOptions& soptions) override { in NewWritableFile() argument
76 return target()->NewWritableFile(fname, result, soptions); in NewWritableFile()
/rocksdb-6.9/db/
Ddb_test_util.h213 const EnvOptions& soptions) override { in NewWritableFile() argument
404 EnvOptions optimized = soptions; in NewWritableFile()
426 const EnvOptions& soptions) override { in NewRandomAccessFile() argument
455 Status s = target()->NewRandomAccessFile(f, r, soptions); in NewRandomAccessFile()
461 if (s.ok() && soptions.compaction_readahead_size > 0) { in NewRandomAccessFile()
462 compaction_readahead_size_ = soptions.compaction_readahead_size; in NewRandomAccessFile()
469 const EnvOptions& soptions) override { in NewSequentialFile() argument
486 Status s = target()->NewSequentialFile(f, r, soptions); in NewSequentialFile()
Dtransaction_log_impl.cc18 const EnvOptions& soptions, const SequenceNumber seq, in TransactionLogIteratorImpl() argument
24 soptions_(soptions), in TransactionLogIteratorImpl()
Dforward_iterator.cc79 read_options_, *(cfd_->soptions()), cfd_->internal_comparator(), in Reset()
651 read_options_, *cfd_->soptions(), cfd_->internal_comparator(), *l0, in RebuildIterators()
727 read_options_, *cfd_->soptions(), cfd_->internal_comparator(), in RenewIterators()
792 read_options_, *cfd_->soptions(), cfd_->internal_comparator(), in ResetIncompleteIterators()
Dtransaction_log_impl.h64 const EnvOptions& soptions, const SequenceNumber seqNum,
Dversion_set.h574 void AddIterators(const ReadOptions&, const FileOptions& soptions,
578 void AddIteratorsForLevel(const ReadOptions&, const FileOptions& soptions,
Ddb_test_util.cc1352 const EnvOptions soptions; in CopyFile() local
1354 ASSERT_OK(env_->NewSequentialFile(source, &srcfile, soptions)); in CopyFile()
1356 ASSERT_OK(env_->NewWritableFile(destination, &destfile, soptions)); in CopyFile()
Dcolumn_family.h327 const FileOptions* soptions() const;
Dcolumn_family_test.cc54 const EnvOptions& soptions) override { in NewWritableFile() argument
56 return EnvWrapper::NewWritableFile(f, r, soptions); in NewWritableFile()
503 const EnvOptions soptions; in CopyFile() local
505 ASSERT_OK(env_->NewSequentialFile(source, &srcfile, soptions)); in CopyFile()
507 ASSERT_OK(env_->NewWritableFile(destination, &destfile, soptions)); in CopyFile()
Ddb_wal_test.cc39 const EnvOptions& soptions) override { in NewSequentialFile() argument
48 return SpecialEnv::NewSequentialFile(f, r, soptions); in NewSequentialFile()
Dversion_set.cc1534 const FileOptions& soptions, in AddIterators() argument
1540 AddIteratorsForLevel(read_options, soptions, merge_iter_builder, level, in AddIterators()
1546 const FileOptions& soptions, in AddIteratorsForLevel() argument
1567 read_options, soptions, cfd_->internal_comparator(), in AddIteratorsForLevel()
1591 cfd_->table_cache(), read_options, soptions, in AddIteratorsForLevel()
4783 FileOptions soptions; in ListColumnFamilies() local
4796 s = fs->NewSequentialFile(manifest_path, soptions, &file, nullptr); in ListColumnFamilies()
/rocksdb-6.9/db/db_impl/
Ddb_impl.cc3456 const FileOptions soptions; in GetDbIdentityFromIdentityFile() local
3533 ImmutableDBOptions soptions(SanitizeOptions(dbname, options)); in DestroyDB() local
3534 Env* env = soptions.env; in DestroyDB()
3536 bool wal_in_db_path = IsWalDirSameAsDBPath(&soptions); in DestroyDB()
3540 soptions.info_log.reset(); in DestroyDB()
3559 del = DeleteDBFile(&soptions, path_to_delete, dbname, in DestroyDB()
3599 if (dbname != soptions.wal_dir) { in DestroyDB()
3601 archivedir = ArchivalDirectory(soptions.wal_dir); in DestroyDB()
3628 DeleteDBFile(&soptions, LogFileName(soptions.wal_dir, number), in DestroyDB()
3636 env->DeleteDir(soptions.wal_dir); in DestroyDB()
[all …]
/rocksdb-6.9/db_stress_tool/
Ddb_stress_shared_state.h109 const EnvOptions soptions; in SharedState() local
111 env->NewWritableFile(FLAGS_expected_values_path, &wfile, soptions); in SharedState()
/rocksdb-6.9/tools/
Dsst_dump_tool_imp.h59 const EnvOptions& soptions,
Dldb_cmd_test.cc121 EnvOptions soptions; in VerifyChecksum() local
124 s = options_.env->NewSequentialFile(file_path, &file_reader, soptions); in VerifyChecksum()
Dldb_cmd.cc1874 EnvOptions soptions; in GetOldNumOfLevels() local
1880 VersionSet versions(db_path_, &db_options, soptions, tc.get(), &wb, &wc, in GetOldNumOfLevels()
1941 EnvOptions soptions; in DoCommand() local
1942 st = VersionSet::ReduceNumberOfLevels(db_path_, &opt, soptions, new_levels_); in DoCommand()
2193 EnvOptions soptions(options); in DumpWalFile() local
2199 status = env->NewSequentialFile(wal_file, &file, soptions); in DumpWalFile()
/rocksdb-6.9/table/block_based/
Ddata_block_hash_index_test.cc550 EnvOptions soptions; in TestBoundary() local
552 soptions.use_mmap_reads = ioptions.allow_mmap_reads; in TestBoundary()
587 TableReaderOptions(ioptions, moptions.prefix_extractor.get(), soptions, in TestBoundary()
/rocksdb-6.9/utilities/blob_db/
Dblob_db_impl.cc2006 const ImmutableDBOptions soptions(SanitizeOptions(dbname, options)); in DestroyBlobDB() local
2007 Env* env = soptions.env; in DestroyBlobDB()
2021 Status del = DeleteDBFile(&soptions, blobdir + "/" + f, blobdir, true, in DestroyBlobDB()

12