Home
last modified time | relevance | path

Searched refs:path (Results 1 – 25 of 131) sorted by relevance

123456

/rocksdb-6.9/tools/
Ddb_sanity_test.cc87 explicit SanityTestBasic(const std::string& path) : SanityTest(path) {} in SanityTestBasic() argument
99 : SanityTest(path) { in SanityTestSpecialComparator()
129 : SanityTest(path) { in SanityTestZlibCompression()
142 : SanityTest(path) { in SanityTestZlibCompressionVersion2()
162 : SanityTest(path) { in SanityTestLZ4Compression()
175 : SanityTest(path) { in SanityTestLZ4HCCompression()
188 : SanityTest(path) { in SanityTestZSTDCompression()
202 : SanityTest(path) { in SanityTestPlainTableFactory()
218 explicit SanityTestBloomFilter(const std::string& path) : SanityTest(path) { in SanityTestBloomFilter() argument
290 if (path.back() != '/') { in main()
[all …]
Dldb_test.py7 import os.path
50 return "--db=%s" % os.path.join(self.TMP_DIR, dbName)
260 dumpFilePath = os.path.join(self.TMP_DIR, "dump1")
269 dumpFilePath = os.path.join(self.TMP_DIR, "dump2")
278 dumpFilePath = os.path.join(self.TMP_DIR, "dump3")
394 dbPath = os.path.join(self.TMP_DIR, self.DB_NAME)
418 dbPath = os.path.join(self.TMP_DIR, self.DB_NAME)
442 dbPath = os.path.join(self.TMP_DIR, self.DB_NAME)
479 dbPath = os.path.join(self.TMP_DIR, self.DB_NAME)
499 dbPath = os.path.join(self.TMP_DIR, self.DB_NAME)
[all …]
/rocksdb-6.9/tools/advisor/test/
Dtest_rule_parser.py44 this_path = os.path.abspath(os.path.dirname(__file__))
45 ini_path = os.path.join(this_path, 'input_files/triggered_rules.ini')
50 log_path = os.path.join(this_path, 'input_files/LOG-0')
51 options_path = os.path.join(this_path, 'input_files/OPTIONS-000005')
101 this_path = os.path.abspath(os.path.dirname(__file__))
102 ini_path = os.path.join(this_path, 'input_files/test_rules.ini')
107 log_path = os.path.join(this_path, 'input_files/LOG-1')
108 options_path = os.path.join(this_path, 'input_files/OPTIONS-000005')
163 this_path = os.path.abspath(os.path.dirname(__file__))
164 ini_path = os.path.join(this_path, 'input_files/rules_err1.ini')
[all …]
Dtest_db_options_parser.py15 self.this_path = os.path.abspath(os.path.dirname(__file__))
16 self.og_options = os.path.join(
25 self.generated_options = os.path.join(
28 if os.path.isfile(self.generated_options):
153 self.assertFalse(os.path.isfile(self.generated_options))
155 self.assertTrue(os.path.isfile(self.generated_options))
Dtest_db_bench_runner.py22 this_path = os.path.abspath(os.path.dirname(__file__))
23 options_path = os.path.join(this_path, 'input_files/OPTIONS-000005')
113 this_path = os.path.abspath(os.path.dirname(__file__))
114 options_path = os.path.join(this_path, 'input_files/OPTIONS-000005')
/rocksdb-6.9/java/src/main/java/org/rocksdb/
DDbPath.java14 final Path path; field in DbPath
17 public DbPath(final Path path, final long targetSize) { in DbPath() argument
18 this.path = path; in DbPath()
38 return path != null ? path.equals(dbPath.path) : dbPath.path == null; in equals()
43 int result = path != null ? path.hashCode() : 0; in hashCode()
DTransactionDB.java44 final TransactionDBOptions transactionDbOptions, final String path) in open() argument
47 transactionDbOptions.nativeHandle_, path)); in open()
76 final String path, in open() argument
91 transactionDbOptions.nativeHandle_, path, cfNames, cfOptionHandles); in open()
351 final DeadlockInfo[] path; field in TransactionDB.DeadlockPath
354 public DeadlockPath(final DeadlockInfo[] path, final boolean limitExceeded) { in DeadlockPath() argument
355 this.path = path; in DeadlockPath()
360 return path.length == 0 && !limitExceeded; in isEmpty()
380 final long transactionDbOptionsHandle, final String path) in open() argument
383 final long transactionDbOptionsHandle, final String path, in open() argument
DSstFileMetaData.java13 private final String path; field in SstFileMetaData
41 final String path, in SstFileMetaData() argument
52 this.path = path; in SstFileMetaData()
78 public String path() { in path() method in SstFileMetaData
79 return path; in path()
DBackupableDBOptions.java33 public BackupableDBOptions(final String path) { in BackupableDBOptions() argument
34 super(newBackupableDBOptions(ensureWritableFile(path))); in BackupableDBOptions()
37 private static String ensureWritableFile(final String path) { in ensureWritableFile() argument
38 final File backupPath = path == null ? null : new File(path); in ensureWritableFile()
43 return path; in ensureWritableFile()
437 private native static long newBackupableDBOptions(final String path); in newBackupableDBOptions() argument
DOptimisticTransactionDB.java39 final String path) throws RocksDBException { in open() argument
41 options.nativeHandle_, path)); in open()
66 final String path, in open() argument
80 final long[] handles = open(dbOptions.nativeHandle_, path, cfNames, in open()
209 final String path) throws RocksDBException; in open() argument
210 protected static native long[] open(final long handle, final String path, in open() argument
DRocksDB.java105 for (final String path : paths) { in loadLibrary()
117 for (final String path : paths) { in loadLibrary()
119 System.load(path + "/" + in loadLibrary()
170 return open(options, path); in open()
202 public static RocksDB open(final String path, in open() argument
323 return openReadOnly(options, path); in openReadOnly()
489 final String path) throws RocksDBException { in listColumnFamilies() argument
491 path)); in listColumnFamilies()
4189 destroyDB(path, options.nativeHandle_); in destroyDB()
4233 final String path) throws RocksDBException; in open() argument
[all …]
DPersistentCache.java14 public PersistentCache(final Env env, final String path, final long size, in PersistentCache() argument
17 super(newPersistentCache(env.nativeHandle_, path, size, in PersistentCache()
22 final String path, final long size, final long loggerHandle, in newPersistentCache() argument
/rocksdb-6.9/env/
Denv_chroot.cc44 for (auto& path : paths) { in RegisterDbPaths() local
57 for (auto& path : paths) { in UnregisterDbPaths() local
256 *path = buf; in GetTestDirectory()
259 CreateDir(*path); in GetTestDirectory()
286 if (path.empty() || path[0] != '/') { in EncodePath()
290 res.second = chroot_dir_ + path; in EncodePath()
316 const std::string& path) { in EncodePathWithNewBasename() argument
317 if (path.empty() || path[0] != '/') { in EncodePathWithNewBasename()
321 size_t final_idx = path.find_last_not_of('/'); in EncodePathWithNewBasename()
324 return EncodePath(path); in EncodePathWithNewBasename()
[all …]
/rocksdb-6.9/file/
Dfilename.cc36 size_t src_len = path.size(); in GetInfoLogPrefix()
39 if ((path[i] >= 'a' && path[i] <= 'z') || in GetInfoLogPrefix()
40 (path[i] >= '0' && path[i] <= '9') || in GetInfoLogPrefix()
41 (path[i] >= 'A' && path[i] <= 'Z') || in GetInfoLogPrefix()
42 path[i] == '-' || in GetInfoLogPrefix()
43 path[i] == '.' || in GetInfoLogPrefix()
44 path[i] == '_'){ in GetInfoLogPrefix()
133 std::string path; in TableFileName() local
135 path = db_paths.back().path; in TableFileName()
137 path = db_paths[path_id].path; in TableFileName()
[all …]
/rocksdb-6.9/build_tools/
Damalgamate.py31 from os import path
40 samedir = path.join(path.dirname(abs_path), name)
41 if path.exists(samedir):
44 include_path = path.join(include_path, name)
45 if path.exists(include_path):
100 include_paths = list(map(path.abspath, args.include_paths or []))
101 public_include_paths = list(map(path.abspath, args.public_include_paths or []))
102 excluded.update(map(path.abspath, args.excluded or []))
104 abs_path = path.abspath(filename)
Dprecommit_checker.py58 def shell(self, cmd, path=os.getcwd()): argument
59 if path:
60 os.chdir(path)
63 self.log.log("%s> %s" % (path, cmd))
64 status = subprocess.call("cd %s; %s" % (path, cmd), shell=True,
70 def GetOutput(self, cmd, path=os.getcwd()): argument
71 if path:
72 os.chdir(path)
75 self.log.log("%s> %s" % (path, cmd))
/rocksdb-6.9/db/
Ddb_universal_compaction_test.cc29 const std::string& path) : DBTestBase(path) {} in DBTestUniversalCompactionBase() argument
1270 env_->GetChildren(options.db_paths[1].path, &filenames); in TEST_P()
1275 env_->DeleteDir(options.db_paths[1].path); in TEST_P()
1289 ASSERT_EQ(1, GetSstFileCount(options.db_paths[2].path)); in TEST_P()
1293 ASSERT_EQ(1, GetSstFileCount(options.db_paths[2].path)); in TEST_P()
1298 ASSERT_EQ(1, GetSstFileCount(options.db_paths[2].path)); in TEST_P()
1299 ASSERT_EQ(1, GetSstFileCount(options.db_paths[1].path)); in TEST_P()
1304 ASSERT_EQ(1, GetSstFileCount(options.db_paths[2].path)); in TEST_P()
1305 ASSERT_EQ(1, GetSstFileCount(options.db_paths[1].path)); in TEST_P()
1310 ASSERT_EQ(1, GetSstFileCount(options.db_paths[3].path)); in TEST_P()
[all …]
Dwal_manager_test.cc124 std::string path = dbname_ + "/000001.log"; in TEST_F() local
126 ASSERT_OK(env_->NewWritableFile(path, &file, EnvOptions())); in TEST_F()
129 ASSERT_OK(wal_manager_->TEST_ReadFirstLine(path, 1 /* number */, &s)); in TEST_F()
137 NewLegacyWritableFileWrapper(std::move(file)), path, EnvOptions())); in TEST_F()
182 Env* env, const std::string& path, const FileType expected_file_type) { in ListSpecificFiles() argument
185 env->GetChildren(path, &files); in ListSpecificFiles()
Ddb_info_dumper.cc76 if (dbname.compare(db_path.path) != 0) { in DumpDBFileSummary()
77 if (!env->GetChildren(db_path.path, &files).ok()) { in DumpDBFileSummary()
80 db_path.path.c_str()); in DumpDBFileSummary()
94 db_path.path.c_str(), file_num, file_info.c_str()); in DumpDBFileSummary()
/rocksdb-6.9/db/db_impl/
Ddb_impl_files.cc114 paths.insert(immutable_db_options_.db_paths[path_id].path); in FindObsoleteFiles()
125 auto& path = cfd->ioptions()->cf_paths[path_id].path; in FindObsoleteFiles() local
127 if (paths.find(path) == paths.end()) { in FindObsoleteFiles()
128 paths.insert(path); in FindObsoleteFiles()
133 for (auto& path : paths) { in FindObsoleteFiles() local
137 env_->GetChildren(path, &files); // Ignore errors in FindObsoleteFiles()
323 MakeTableFileName(file.metadata->fd.GetNumber()), file.path); in PurgeObsoleteFiles()
673 paths.push_back(db_path.path); in CleanupFilesAfterRecovery()
677 paths.push_back(cf_path.path); in CleanupFilesAfterRecovery()
687 for (const auto& path : paths) { in CleanupFilesAfterRecovery() local
[all …]
/rocksdb-6.9/buckifier/
Dbuckify_rocksdb.py66 cc_files.append(os.path.join(root, filename))
68 cc_files.append(os.path.join(root, filename))
216 script_dir = os.path.dirname(sys.argv[0])
217 script_dir = os.path.abspath(script_dir)
218 rocksdb_path = os.path.abspath(
219 os.path.join(script_dir, "../"))
Dtargets_builder.py28 def __init__(self, path): argument
29 self.path = path
30 self.targets_file = open(path, 'w')
/rocksdb-6.9/java/jmh/src/main/java/org/rocksdb/util/
DFileUtils.java34 public static void delete(final Path path) throws IOException { in delete() argument
35 if (!Files.isDirectory(path)) { in delete()
36 Files.deleteIfExists(path); in delete()
38 Files.walkFileTree(path, DELETE_DIR_VISITOR); in delete()
/rocksdb-6.9/java/crossbuild/
DVagrantfile11 linux32.vm.provision :shell, path: "build-linux-centos.sh"
16 linux64.vm.provision :shell, path: "build-linux-centos.sh"
22 musl32.vm.provision :shell, path: "build-linux-alpine.sh"
32 musl64.vm.provision :shell, path: "build-linux-alpine.sh"
/rocksdb-6.9/port/win/
Dport_win.cc208 int truncate(const char* path, int64_t length) { in truncate() argument
209 if (path == nullptr) { in truncate()
213 return ROCKSDB_NAMESPACE::port::Truncate(path, length); in truncate()
216 int Truncate(std::string path, int64_t len) { in Truncate() argument
224 RX_CreateFile(RX_FN(path).c_str(), GENERIC_READ | GENERIC_WRITE, in Truncate()

123456