| /rocksdb-6.9/tools/advisor/advisor/ |
| D | rule_parser.py | 15 def __init__(self, name): argument
16 self.name = name
28 def __init__(self, name): argument
29 super().__init__(name)
227 def __init__(self, name): argument
228 super().__init__(name)
267 sugg_string = "Suggestion: " + self.name
282 def __init__(self, name): argument
283 super().__init__(name)
333 log_cond_str = "LogCondition: " + self.name
[all …]
|
| /rocksdb-6.9/java/src/main/java/org/rocksdb/util/ |
| D | Environment.java | 73 public static String getSharedLibraryName(final String name) { in getSharedLibraryName() argument
74 return name + "jni"; in getSharedLibraryName()
77 public static String getSharedLibraryFileName(final String name) { in getSharedLibraryFileName() argument
103 public static String getJniLibraryName(final String name) { in getJniLibraryName() argument
109 return String.format("%sjni-linux%s", name, ARCH); in getJniLibraryName()
114 return String.format("%sjni-osx", name); in getJniLibraryName()
118 return String.format("%sjni-aix64", name); in getJniLibraryName()
121 return String.format("%sjni-solaris%s", name, arch); in getJniLibraryName()
123 return String.format("%sjni-win64", name); in getJniLibraryName()
131 public static String getJniLibraryFileName(final String name) { in getJniLibraryFileName() argument
[all …]
|
| /rocksdb-6.9/utilities/ |
| D | merge_operators.h | 31 const std::string& name) { in CreateFromStringId() argument
32 if (name == "put") { in CreateFromStringId()
34 } else if (name == "put_v1") { in CreateFromStringId()
36 } else if ( name == "uint64add") { in CreateFromStringId()
38 } else if (name == "stringappend") { in CreateFromStringId()
40 } else if (name == "stringappendtest") { in CreateFromStringId()
42 } else if (name == "max") { in CreateFromStringId()
44 } else if (name == "bytesxor") { in CreateFromStringId()
46 } else if (name == "sortlist") { in CreateFromStringId()
|
| D | object_registry.cc | 17 const std::string &type, const std::string &name) const { in FindEntry()
21 if (entry->matches(name)) { in FindEntry()
70 const std::string &type, const std::string &name) const { in FindEntry()
72 const auto *entry = iter->get()->FindEntry(type, name); in FindEntry()
|
| /rocksdb-6.9/java/rocksjni/ |
| D | thread_status.cc | 22 auto name = ROCKSDB_NAMESPACE::ThreadStatus::GetThreadTypeName( in Java_org_rocksdb_ThreadStatus_getThreadTypeName() local
24 return ROCKSDB_NAMESPACE::JniUtil::toJavaString(env, &name, true); in Java_org_rocksdb_ThreadStatus_getThreadTypeName()
34 auto name = ROCKSDB_NAMESPACE::ThreadStatus::GetOperationName( in Java_org_rocksdb_ThreadStatus_getOperationName() local
37 return ROCKSDB_NAMESPACE::JniUtil::toJavaString(env, &name, true); in Java_org_rocksdb_ThreadStatus_getOperationName()
59 auto name = ROCKSDB_NAMESPACE::ThreadStatus::GetOperationStageName( in Java_org_rocksdb_ThreadStatus_getOperationStageName() local
62 return ROCKSDB_NAMESPACE::JniUtil::toJavaString(env, &name, true); in Java_org_rocksdb_ThreadStatus_getOperationStageName()
72 auto name = ROCKSDB_NAMESPACE::ThreadStatus::GetOperationPropertyName( in Java_org_rocksdb_ThreadStatus_getOperationPropertyName() local
76 return ROCKSDB_NAMESPACE::JniUtil::toJavaString(env, &name, true); in Java_org_rocksdb_ThreadStatus_getOperationPropertyName()
122 auto name = ROCKSDB_NAMESPACE::ThreadStatus::GetStateName( in Java_org_rocksdb_ThreadStatus_getStateName() local
124 return ROCKSDB_NAMESPACE::JniUtil::toJavaString(env, &name, true); in Java_org_rocksdb_ThreadStatus_getStateName()
|
| /rocksdb-6.9/java/src/main/java/org/rocksdb/ |
| D | ColumnFamilyMetaData.java | 17 private final byte[] name; field in ColumnFamilyMetaData
26 final byte[] name, in ColumnFamilyMetaData() argument
30 this.name = name; in ColumnFamilyMetaData()
58 public byte[] name() { in name() method in ColumnFamilyMetaData
59 return name; in name()
|
| D | AbstractMutableOptions.java | 88 keys[i] = option.getKey().name(); in build()
110 throw new NoSuchElementException(key.name() + " has not been set"); in getDouble()
129 throw new NoSuchElementException(key.name() + " has not been set"); in getLong()
148 throw new NoSuchElementException(key.name() + " has not been set"); in getInt()
167 throw new NoSuchElementException(key.name() + " has not been set"); in getBoolean()
186 throw new NoSuchElementException(key.name() + " has not been set"); in getIntArray()
206 throw new NoSuchElementException(key.name() + " has not been set"); in getEnum()
210 throw new NoSuchElementException(key.name() + " is not of Enum type"); in getEnum()
|
| /rocksdb-6.9/monitoring/ |
| D | thread_status_impl.cc | 37 return global_operation_table[OP_UNKNOWN].name; in GetOperationName()
39 return global_operation_table[op_type].name; in GetOperationName()
45 return global_op_stage_table[STAGE_UNKNOWN].name; in GetOperationStageName()
47 return global_op_stage_table[stage].name; in GetOperationStageName()
53 return global_state_table[STATE_UNKNOWN].name; in GetStateName()
55 return global_state_table[state_type].name; in GetStateName()
76 return compaction_operation_properties[i].name; in GetOperationPropertyName()
81 return flush_operation_properties[i].name; in GetOperationPropertyName()
|
| /rocksdb-6.9/test_util/ |
| D | testharness.cc | 33 std::string PerThreadDBPath(std::string dir, std::string name) { in PerThreadDBPath() argument
35 return dir + "/" + name + "_" + std::to_string(tid); in PerThreadDBPath()
38 std::string PerThreadDBPath(std::string name) { in PerThreadDBPath() argument
39 return PerThreadDBPath(test::TmpDir(), name); in PerThreadDBPath()
42 std::string PerThreadDBPath(Env* env, std::string name) { in PerThreadDBPath() argument
43 return PerThreadDBPath(test::TmpDir(env), name); in PerThreadDBPath()
|
| /rocksdb-6.9/port/win/ |
| D | env_win.cc | 495 if (!DirExists(name)) { in NewDirectory()
497 "open folder: " + name, ERROR_DIRECTORY); in NewDirectory()
506 RX_FN(name).c_str(), 0, in NewDirectory()
626 if (DirExists(name)) { in CreateDirIfMissing()
1012 if (!::GetComputerNameA(name, &nSize)) { in GetHostName()
1016 name[nSize] = 0; in GetHostName()
1365 return winenv_io_.NewDirectory(name, result); in NewDirectory()
1378 return winenv_io_.CreateDir(name); in CreateDir()
1382 return winenv_io_.CreateDirIfMissing(name); in CreateDirIfMissing()
1386 return winenv_io_.DeleteDir(name); in DeleteDir()
[all …]
|
| D | env_win.h | 118 virtual Status NewDirectory(const std::string& name,
126 virtual Status CreateDir(const std::string& name);
128 virtual Status CreateDirIfMissing(const std::string& name);
130 virtual Status DeleteDir(const std::string& name);
162 virtual Status GetHostName(char* name, uint64_t len);
250 Status NewDirectory(const std::string& name,
258 Status CreateDir(const std::string& name) override;
260 Status CreateDirIfMissing(const std::string& name) override;
262 Status DeleteDir(const std::string& name) override;
294 Status GetHostName(char* name, uint64_t len) override;
|
| /rocksdb-6.9/include/rocksdb/utilities/ |
| D | object_registry.h | 32 Entry(const std::string& name) : name_(std::move(name)) {} in Entry() argument
48 FactoryEntry(const std::string& name, FactoryFunc<T> f) in FactoryEntry() argument
49 : Entry(name), pattern_(std::move(name)), factory_(std::move(f)) {} in FactoryEntry()
67 const std::string& name) const;
197 const std::string& name) const;
|
| /rocksdb-6.9/file/ |
| D | filename.cc | 67 static std::string MakeFileName(const std::string& name, uint64_t number, in MakeFileName() argument
69 return name + "/" + MakeFileName(number, suffix); in MakeFileName()
72 std::string LogFileName(const std::string& name, uint64_t number) { in LogFileName() argument
74 return MakeFileName(name, number, "log"); in LogFileName()
97 std::string ArchivedLogFileName(const std::string& name, uint64_t number) { in ArchivedLogFileName() argument
99 return MakeFileName(name + "/" + ARCHIVAL_DIR, number, "log"); in ArchivedLogFileName()
119 uint64_t TableFileNameToNumber(const std::string& name) { in TableFileNameToNumber() argument
122 int pos = static_cast<int>(name.find_last_of('.')); in TableFileNameToNumber()
123 while (--pos >= 0 && name[pos] >= '0' && name[pos] <= '9') { in TableFileNameToNumber()
124 number += (name[pos] - '0') * base; in TableFileNameToNumber()
|
| /rocksdb-6.9/tools/ |
| D | db_bench_tool.cc | 889 char name[100]; in ColumnFamilyName() local
890 snprintf(name, sizeof(name), "column_family_name_%06zu", i); in ColumnFamilyName()
891 return std::string(name); in ColumnFamilyName()
2172 name, num_runs, static_cast<int>(CalcAvg(throughput_ops_)), name, in Report()
2861 std::string name; in Run() local
2891 if (!name.empty() && *name.rbegin() == ']') { in Run()
2899 name.resize(it); in Run()
3040 name.c_str()); in Run()
3053 name.c_str()); in Run()
3394 merge_stats.Report(name); in RunBenchmark()
[all …]
|
| /rocksdb-6.9/buckifier/ |
| D | targets_builder.py | 40 def add_library(self, name, srcs, deps=None, headers=None): argument
46 name=name,
53 def add_binary(self, name, srcs, deps=None): argument
55 name,
|
| /rocksdb-6.9/port/ |
| D | stack_trace.cc | 37 static char name[1024]; in GetExecutableName() local
41 auto read = readlink(link, name, sizeof(name) - 1); in GetExecutableName()
45 name[read] = 0; in GetExecutableName()
46 return name; in GetExecutableName()
|
| /rocksdb-6.9/options/ |
| D | options_helper.cc | 938 name); in ParseCompressionOptions()
945 name); in ParseCompressionOptions()
951 name); in ParseCompressionOptions()
998 if (name == "block_based_table_factory") { in ParseColumnFamilyOption()
1030 } else if (name == "memtable") { in ParseColumnFamilyOption()
1045 } else if (name == "compression_opts") { in ParseColumnFamilyOption()
1052 if (name == kNameComparator) { in ParseColumnFamilyOption()
1060 } else if (name == kNameMergeOperator) { in ParseColumnFamilyOption()
1110 auto iter = type_info.find(name); in SerializeSingleStructOption()
1188 Status ParseDBOption(const std::string& name, in ParseDBOption() argument
[all …]
|
| /rocksdb-6.9/include/rocksdb/ |
| D | metadata.h | 23 ColumnFamilyMetaData() : size(0), file_count(0), name("") {} in ColumnFamilyMetaData()
26 : size(_size), name(_name), levels(_levels) {} in ColumnFamilyMetaData()
34 std::string name; member
77 name(_file_name), in SstFileMetaData()
97 std::string name; member
|
| /rocksdb-6.9/env/ |
| D | env_hdfs.cc | 449 Status HdfsEnv::NewDirectory(const std::string& name, in NewDirectory() argument
451 int value = hdfsExists(fileSys_, name.c_str()); in NewDirectory()
459 ToString(value) + " on path " + name + in NewDirectory()
522 Status HdfsEnv::CreateDir(const std::string& name) { in CreateDir() argument
523 if (hdfsCreateDirectory(fileSys_, name.c_str()) == 0) { in CreateDir()
526 return IOError(name, errno); in CreateDir()
529 Status HdfsEnv::CreateDirIfMissing(const std::string& name) { in CreateDirIfMissing() argument
530 const int value = hdfsExists(fileSys_, name.c_str()); in CreateDirIfMissing()
536 return CreateDir(name); in CreateDirIfMissing()
544 Status HdfsEnv::DeleteDir(const std::string& name) { in DeleteDir() argument
[all …]
|
| D | env_posix.cc | 105 PosixDynamicLibrary(const std::string& name, void* handle) in PosixDynamicLibrary() argument
106 : name_(name), handle_(handle) {} in PosixDynamicLibrary()
168 Status LoadLibrary(const std::string& name, const std::string& path, in LoadLibrary() argument
172 if (name.empty()) { in LoadLibrary()
175 result->reset(new PosixDynamicLibrary(name, hndl)); in LoadLibrary()
179 std::string library_name = name; in LoadLibrary()
211 IOErrorMsg("Failed to open shared library: xs", name), dlerror()); in LoadLibrary()
297 Status GetHostName(char* name, uint64_t len) override { in GetHostName() argument
298 int ret = gethostname(name, static_cast<size_t>(len)); in GetHostName()
303 return IOError("GetHostName", name, errno); in GetHostName()
|
| D | fs_posix.cc | 538 fd = open(name.c_str(), flags); in NewDirectory()
541 return IOError("While open directory", name, errno); in NewDirectory()
633 IOStatus CreateDir(const std::string& name, const IOOptions& /*opts*/, in CreateDir() argument
636 if (mkdir(name.c_str(), 0755) != 0) { in CreateDir()
637 result = IOError("While mkdir", name, errno); in CreateDir()
642 IOStatus CreateDirIfMissing(const std::string& name, in CreateDirIfMissing() argument
646 if (mkdir(name.c_str(), 0755) != 0) { in CreateDirIfMissing()
648 result = IOError("While mkdir if missing", name, errno); in CreateDirIfMissing()
649 } else if (!DirExists(name)) { // Check that name is actually a in CreateDirIfMissing()
662 if (rmdir(name.c_str()) != 0) { in DeleteDir()
[all …]
|
| /rocksdb-6.9/util/ |
| D | thread_operation.h | 27 const std::string name; member
46 const std::string name; member
79 const std::string name; member
94 std::string name; member
|
| D | concurrent_task_limiter_impl.cc | 16 const std::string& name, int32_t max_outstanding_task) in ConcurrentTaskLimiterImpl() argument
17 : name_(name), in ConcurrentTaskLimiterImpl()
58 const std::string& name, int32_t limit) { in NewConcurrentTaskLimiter() argument
59 return new ConcurrentTaskLimiterImpl(name, limit); in NewConcurrentTaskLimiter()
|
| /rocksdb-6.9/memtable/ |
| D | memtablerep_bench.cc | 621 ROCKSDB_NAMESPACE::Slice name; in main() local
623 name = benchmarks; in main()
626 name = ROCKSDB_NAMESPACE::Slice(benchmarks, sep - benchmarks); in main()
630 if (name == ROCKSDB_NAMESPACE::Slice("fillseq")) { in main()
636 } else if (name == ROCKSDB_NAMESPACE::Slice("fillrandom")) { in main()
642 } else if (name == ROCKSDB_NAMESPACE::Slice("readrandom")) { in main()
647 } else if (name == ROCKSDB_NAMESPACE::Slice("readseq")) { in main()
652 } else if (name == ROCKSDB_NAMESPACE::Slice("readwrite")) { in main()
659 } else if (name == ROCKSDB_NAMESPACE::Slice("seqreadwrite")) { in main()
667 std::cout << "WARNING: skipping unknown benchmark '" << name.ToString() in main()
[all …]
|
| /rocksdb-6.9/db/ |
| D | job_context.h | 62 const std::string& name, const ImmutableCFOptions* ioptions) { in PushWriteStallNotification()
65 notif.write_stall_info.cf_name = name; in PushWriteStallNotification()
73 (void)name; in PushWriteStallNotification()
125 CandidateFileInfo(std::string name, std::string path) in CandidateFileInfo()
126 : file_name(std::move(name)), file_path(std::move(path)) {} in CandidateFileInfo()
|