Home
last modified time | relevance | path

Searched refs:type (Results 1 – 25 of 174) sorted by relevance

1234567

/rocksdb-6.9/tools/
Dtrace_analyzer_tool.cc524 for (int type = 0; type < kTaTypeNum; type++) { in MakeStatistics() local
800 for (int type = 0; type < kTaTypeNum; type++) { in MakeStatisticQPS() local
938 for (int type = 0; type <= kTaTypeNum; type++) { in MakeStatisticQPS() local
988 for (int type = 0; type <= kTaTypeNum; type++) { in MakeStatisticQPS() local
1011 for (int type = 0; type < kTaTypeNum; type++) { in ReProcessing() local
1079 for (int type = 0; type < kTaTypeNum; type++) { in ReProcessing() local
1139 for (int type = 0; type < kTaTypeNum; type++) { in ReProcessing() local
1320 trace_u.type = type; in KeyStatsInsertion()
1454 for (int type = 0; type < kTaTypeNum; type++) { in CloseOutputFiles() local
1762 for (int type = 0; type < kTaTypeNum; type++) { in PrintStatistics() local
[all …]
/rocksdb-6.9/db/
Dfilename_test.cc23 FileType type; in TEST_F() local
35 FileType type; in TEST_F() member
66 ASSERT_EQ(cases[i].type, type) << f; in TEST_F()
126 FileType type; in TEST_F() local
133 ASSERT_EQ(kCurrentFile, type); in TEST_F()
139 ASSERT_EQ(kDBLockFile, type); in TEST_F()
145 ASSERT_EQ(kLogFile, type); in TEST_F()
154 ASSERT_EQ(kTableFile, type); in TEST_F()
160 ASSERT_EQ(kDescriptorFile, type); in TEST_F()
166 ASSERT_EQ(kTempFile, type); in TEST_F()
[all …]
Doptions_file_test.cc30 FileType type; in UpdateOptionsFiles() local
33 if (ParseFileName(filename, &number, &type) && type == kOptionsFile) { in UpdateOptionsFiles()
47 FileType type; in VerifyOptionsFileName() local
49 if (ParseFileName(filename, &number, &type) && type == kOptionsFile) { in VerifyOptionsFileName()
86 FileType type; in TEST_F() local
89 ASSERT_TRUE(ParseFileName(options_file_name, &number, &type, nullptr)); in TEST_F()
90 ASSERT_EQ(type, kOptionsFile); in TEST_F()
95 ASSERT_TRUE(ParseFileName(temp_options_file_name, &number, &type, nullptr)); in TEST_F()
98 ASSERT_EQ(type, kTempFile); in TEST_F()
Ddb_statistics_test.cc21 CompressionType type; in TEST_F() local
24 type = kSnappyCompression; in TEST_F()
27 type = kZlibCompression; in TEST_F()
30 type = kBZip2Compression; in TEST_F()
33 type = kLZ4Compression; in TEST_F()
36 type = kXpressCompression; in TEST_F()
39 type = kZSTD; in TEST_F()
47 options.compression = type; in TEST_F()
Ddbformat.cc61 fkey->type = GetEntryType(ikey.type); in ParseFullKey()
75 PutFixed64(result, PackSequenceAndType(key.sequence, key.type)); in AppendInternalKey()
84 PutFixed64(result, PackSequenceAndType(key.sequence, key.type)); in AppendInternalKeyWithDifferentTimestamp()
95 static_cast<int>(type)); in DebugString()
128 } else if (a.type > b.type) { in Compare()
130 } else if (a.type < b.type) { in Compare()
Dobsolete_files_test.cc73 FileType type; in CheckFileTypeCounts() local
74 if (ParseFileName(file, &number, &type)) { in CheckFileTypeCounts()
75 log_cnt += (type == kLogFile); in CheckFileTypeCounts()
76 sst_cnt += (type == kTableFile); in CheckFileTypeCounts()
77 manifest_cnt += (type == kDescriptorFile); in CheckFileTypeCounts()
185 FileType type; in TEST_F() local
187 if (ParseFileName(file, &file_num, dummy_info_log_name_prefix, &type, in TEST_F()
189 type == kOptionsFile) { in TEST_F()
Ddb_info_dumper.cc27 FileType type = kInfoLogFile; in DumpDBFileSummary() local
42 if (!ParseFileName(file, &number, &type)) { in DumpDBFileSummary()
45 switch (type) { in DumpDBFileSummary()
85 if (ParseFileName(file, &number, &type)) { in DumpDBFileSummary()
86 if (type == kTableFile && ++file_num < 10) { in DumpDBFileSummary()
109 if (ParseFileName(file, &number, &type)) { in DumpDBFileSummary()
110 if (type == kLogFile) { in DumpDBFileSummary()
Dwal_manager.cc177 FileType type; in PurgeObsoleteWALFiles() local
178 if (ParseFileName(f, &number, &type) && type == kLogFile) { in PurgeObsoleteWALFiles()
294 FileType type; in GetSortedWalsOfType() local
295 if (ParseFileName(f, &number, &type) && type == kLogFile) { in GetSortedWalsOfType()
370 Status WalManager::ReadFirstRecord(const WalFileType type, in ReadFirstRecord() argument
374 if (type != kAliveLogFile && type != kArchivedLogFile) { in ReadFirstRecord()
376 ToString(type).c_str()); in ReadFirstRecord()
378 "File Type Not Known " + ToString(type)); in ReadFirstRecord()
389 if (type == kAliveLogFile) { in ReadFirstRecord()
398 if (type == kArchivedLogFile || !s.ok()) { in ReadFirstRecord()
/rocksdb-6.9/util/
Dstatus.cc78 const char* type; in ToString() local
83 type = "NotFound: "; in ToString()
86 type = "Corruption: "; in ToString()
89 type = "Not implemented: "; in ToString()
92 type = "Invalid argument: "; in ToString()
95 type = "IO error: "; in ToString()
98 type = "Merge in progress: "; in ToString()
101 type = "Result incomplete: "; in ToString()
113 type = "Resource busy: "; in ToString()
127 type = tmp; in ToString()
[all …]
Dthread_list_test.cc99 for (int type = 0; type != ThreadStatus::NUM_OP_TYPES; ++type) { in TEST_F() local
100 ASSERT_EQ(global_operation_table[type].type, type); in TEST_F()
101 ASSERT_EQ(global_operation_table[type].name, in TEST_F()
103 ThreadStatus::OperationType(type))); in TEST_F()
106 for (int type = 0; type != ThreadStatus::NUM_STATE_TYPES; ++type) { in TEST_F() local
107 ASSERT_EQ(global_state_table[type].type, type); in TEST_F()
108 ASSERT_EQ(global_state_table[type].name, in TEST_F()
110 ThreadStatus::StateType(type))); in TEST_F()
/rocksdb-6.9/
D.travis.yml75 - if: type = pull_request
78 - if: type = pull_request
82 - if: type = pull_request
86 - if: type = pull_request
89 - if: type = pull_request
93 - if: type = pull_request
97 - if: type = pull_request
100 - if: type = pull_request
104 - if: type = pull_request
108 - if: type = pull_request
[all …]
/rocksdb-6.9/db/compaction/
Dcompaction_iterator.cc188 (ikey_.type == kTypeValue || ikey_.type == kTypeBlobIndex)) { in InvokeFilterIfNeeded()
222 ikey_.type = kTypeDeletion; in InvokeFilterIfNeeded()
268 if (ikey_.type == kTypeDeletion || ikey_.type == kTypeSingleDeletion) { in NextFromInput()
350 assert(ikey_.type == kTypeValue); in NextFromInput()
351 if (ikey_.type != kTypeValue) { in NextFromInput()
354 ikey_.type); in NextFromInput()
435 if (next_ikey.type != kTypeValue && in NextFromInput()
564 } else if (ikey_.type == kTypeMerge) { in NextFromInput()
675 assert(ikey_.type != kTypeDeletion && ikey_.type != kTypeSingleDeletion); in PrepareOutput()
676 if (ikey_.type == kTypeDeletion || ikey_.type == kTypeSingleDeletion) { in PrepareOutput()
[all …]
/rocksdb-6.9/db/db_impl/
Ddb_impl_files.cc140 FileType type; in FindObsoleteFiles() local
261 if (type == kTableFile || type == kLogFile) { in DeleteObsoleteFileImpl()
273 fname.c_str(), type, number, in DeleteObsoleteFileImpl()
280 job_id, fname.c_str(), type, number, in DeleteObsoleteFileImpl()
288 if (type == kTableFile) { in DeleteObsoleteFileImpl()
370 FileType type; in PurgeObsoleteFiles() local
372 type != kOptionsFile) { in PurgeObsoleteFiles()
394 FileType type; in PurgeObsoleteFiles() local
401 switch (type) { in PurgeObsoleteFiles()
465 if (type == kTableFile) { in PurgeObsoleteFiles()
[all …]
/rocksdb-6.9/table/
Dget_context.cc29 replay_log->push_back(type); in appendToReplayLog()
34 (void)type; in appendToReplayLog()
197 assert((state_ != kMerge && parsed_key.type != kTypeMerge) || in SaveValue()
206 appendToReplayLog(replay_log_, parsed_key.type, value); in SaveValue()
215 auto type = parsed_key.type; in SaveValue() local
217 if ((type == kTypeValue || type == kTypeMerge || type == kTypeBlobIndex) && in SaveValue()
220 type = kTypeRangeDeletion; in SaveValue()
222 switch (type) { in SaveValue()
226 if (type == kTypeBlobIndex && is_blob_index_ == nullptr) { in SaveValue()
281 *is_blob_index_ = (type == kTypeBlobIndex); in SaveValue()
[all …]
/rocksdb-6.9/tools/advisor/advisor/
Drule_parser_example.py51 '--rules_spec', required=True, type=str,
55 '--rocksdb_options', required=True, type=str,
59 '--log_files_path_prefix', required=True, type=str,
63 '--stats_dump_period_sec', required=True, type=int,
69 '--ods_client', type=str, help='the ODS client binary'
72 '--ods_entity', type=str,
76 '--ods_key_prefix', type=str,
81 '--ods_tstart', type=int,
85 '--ods_tend', type=int,
Dconfig_optimizer_example.py76 '--rocksdb_options', required=True, type=str,
88 '--base_db_path', required=True, type=str,
92 '--rules_spec', required=True, type=str,
96 '--stats_dump_period_sec', required=True, type=int,
102 '--ods_client', type=str, help='the ODS client binary'
105 '--ods_entity', type=str,
109 '--ods_key_prefix', type=str,
115 '--benchrunner_module', required=True, type=str,
121 '--benchrunner_class', required=True, type=str,
/rocksdb-6.9/trace_replay/
Dtrace_replay.cc38 encoded_trace->push_back(trace.type); in EncodeTrace()
77 trace.type = trace_type; in Write()
89 trace.type = trace_type; in Get()
101 trace.type = trace_type; in IteratorSeek()
113 trace.type = trace_type; in IteratorSeekForPrev()
151 trace.type = kTraceBegin; in WriteHeader()
159 trace.type = kTraceEnd; in WriteFooter()
222 if (trace.type == kTraceWrite) { in Replay()
226 } else if (trace.type == kTraceGet) { in Replay()
373 if (header->type != kTraceBegin) { in ReadHeader()
[all …]
/rocksdb-6.9/utilities/checkpoint/
Dcheckpoint_impl.cc176 FileType type)> in CreateCustomCheckpoint()
262 FileType type; in CreateCustomCheckpoint() local
269 assert(type == kTableFile || type == kDescriptorFile || in CreateCustomCheckpoint()
270 type == kCurrentFile || type == kOptionsFile); in CreateCustomCheckpoint()
272 if (type == kCurrentFile) { in CreateCustomCheckpoint()
278 } else if (type == kDescriptorFile) { in CreateCustomCheckpoint()
287 if ((type == kTableFile) && same_fs) { in CreateCustomCheckpoint()
294 if ((type != kTableFile) || (!same_fs)) { in CreateCustomCheckpoint()
297 type); in CreateCustomCheckpoint()
485 FileType type; in ExportFilesInMetaData() local
[all …]
/rocksdb-6.9/file/
Dfilename.cc265 *type = kIdentityFile; in ParseFileName()
268 *type = kCurrentFile; in ParseFileName()
271 *type = kDBLockFile; in ParseFileName()
277 *type = kInfoLogFile; in ParseFileName()
286 *type = kInfoLogFile; in ParseFileName()
308 *type = kMetaDatabase; in ParseFileName()
350 *type = kLogFile; in ParseFileName()
358 *type = kTableFile; in ParseFileName()
360 *type = kBlobFile; in ParseFileName()
362 *type = kTempFile; in ParseFileName()
[all …]
/rocksdb-6.9/third-party/folly/folly/
DTraits.h41 using _t = typename T::type;
110 using type = T; member
115 using type_t = typename traits_detail::type_t_<T, Ts...>::type;
125 using type = member
126 typename std::remove_cv<typename std::remove_reference<T>::type>::type;
129 using remove_cvref_t = typename remove_cvref<T>::type;
144 : std::conditional<T::value, Conjunction<TList...>, T>::type {};
DUnit.h38 using type = T; member
42 using type = Unit;
45 using lift_unit_t = typename lift_unit<T>::type;
49 using type = T;
53 using type = void;
56 using drop_unit_t = typename drop_unit<T>::type;
/rocksdb-6.9/utilities/write_batch_with_index/
Dwrite_batch_with_index_internal.cc26 WriteType* type, Slice* Key, in GetEntryFromDataOffset() argument
29 if (type == nullptr || Key == nullptr || value == nullptr || in GetEntryFromDataOffset()
51 *type = kPutRecord; in GetEntryFromDataOffset()
55 *type = kDeleteRecord; in GetEntryFromDataOffset()
59 *type = kSingleDeleteRecord; in GetEntryFromDataOffset()
63 *type = kDeleteRangeRecord; in GetEntryFromDataOffset()
67 *type = kMergeRecord; in GetEntryFromDataOffset()
70 *type = kLogDataRecord; in GetEntryFromDataOffset()
79 *type = kXIDRecord; in GetEntryFromDataOffset()
199 switch (entry.type) { in GetFromBatch()
[all …]
/rocksdb-6.9/java/src/main/java/org/rocksdb/
DWBWIRocksIterator.java36 entry.type = WriteType.fromId((byte)ptrs[0]); in entry()
101 WriteType type = null; field in WBWIRocksIterator.WriteEntry
117 public WriteEntry(final WriteType type, final DirectSlice key, in WriteEntry() argument
119 this.type = type; in WriteEntry()
130 return type; in getType()
178 return type.equals(otherWriteEntry.type) in equals()
/rocksdb-6.9/utilities/
Dobject_registry.cc17 const std::string &type, const std::string &name) const { in FindEntry() argument
18 auto entries = entries_.find(type); in FindEntry()
29 void ObjectLibrary::AddEntry(const std::string &type, in AddEntry() argument
31 auto &entries = entries_[type]; in AddEntry()
70 const std::string &type, const std::string &name) const { in FindEntry() argument
72 const auto *entry = iter->get()->FindEntry(type, name); in FindEntry()
/rocksdb-6.9/third-party/folly/folly/container/
DArray.h25 folly::Negation<is_ref_wrapper<typename std::decay<T>::type>>;
29 using type = D;
36 using type = typename std::common_type<TList...>::type;
41 array<typename return_type_helper<D, TList...>::type, sizeof...(TList)>;
47 typename array_detail::return_type_helper<D, TList...>::type;

1234567