Home
last modified time | relevance | path

Searched refs:t (Results 1 – 25 of 136) sorted by relevance

123456

/rocksdb-6.9/utilities/persistent_cache/
Dlrulist.h46 assert(t); in Push()
61 head_ = t; in Push()
82 while (t && t->refs_) { in Pop()
83 t = t->next_; in Pop()
86 if (!t) { in Pop()
95 return t; in Pop()
119 assert(t->prev_ || head_ == t); in UnlinkImpl()
120 assert(t->next_ || tail_ == t); in UnlinkImpl()
123 t->prev_->next_ = t->next_; in UnlinkImpl()
126 t->next_->prev_ = t->prev_; in UnlinkImpl()
[all …]
Dhash_table_evictable.h42 bool Insert(T* t) { in Insert() argument
50 lru.Push(t); in Insert()
62 bool Find(T* t, T** ret) { in Find() argument
83 T* t = nullptr; variable
92 assert(!t->refs_);
98 assert(t == tmp);
102 fn(t);
106 assert(!t);
108 return t;
119 (*fn)(t); in Clear()
[all …]
Dhash_table.h99 bool Insert(const T& t) { in Insert() argument
100 const uint64_t h = Hash()(t); in Insert()
106 return Insert(&bucket, t); in Insert()
115 const uint64_t h = Hash()(t); in Find()
123 if (Find(&bucket, t, ret)) { in Find()
135 bool Erase(const T& t, T* ret) { in Erase() argument
136 const uint64_t h = Hash()(t); in Erase()
150 const uint64_t h = Hash()(t); in GetMutex()
162 (*fn)(t); in Clear()
177 if (Equal()(*it, t)) { in Find()
[all …]
Dpersistent_cache_util.h29 void Push(T&& t) { in Push() argument
32 size_ + t.Size() >= max_size_) { in Push()
37 size_ += t.Size(); in Push()
38 q_.push_back(std::move(t)); in Push()
48 T t = std::move(q_.front()); in Pop() local
49 size_ -= t.Size(); in Pop()
51 return t; in Pop()
/rocksdb-6.9/util/
Dppc-opcode.h16 #define VSX_XX3(t, a, b) (__PPC_XT(t) | __PPC_XA(a) | __PPC_XB(b)) argument
24 #define VPMSUMW(t, a, b) .long PPC_INST_VPMSUMW | VSX_XX3((t), a, b) argument
25 #define VPMSUMD(t, a, b) .long PPC_INST_VPMSUMD | VSX_XX3((t), a, b) argument
26 #define MFVRD(a, t) .long PPC_INST_MFVSRD | VSX_XX1((t) + 32, a, 0) argument
27 #define MTVRD(t, a) .long PPC_INST_MTVSRD | VSX_XX1((t) + 32, a, 0) argument
Ddynamic_bloom_test.cc239 std::function<void(size_t)> adder([&](size_t t) { in TEST_F() argument
243 for (uint64_t i = 1 + t; i <= num_keys; i += num_threads) { in TEST_F()
248 for (size_t t = 0; t < num_threads; ++t) { in TEST_F() local
249 threads.emplace_back(adder, t); in TEST_F()
262 std::function<void(size_t)> hitter([&](size_t t) { in TEST_F() argument
266 for (uint64_t i = 1 + t; i <= num_keys; i += num_threads) { in TEST_F()
272 for (size_t t = 0; t < num_threads; ++t) { in TEST_F() local
273 threads.emplace_back(hitter, t); in TEST_F()
287 std::function<void(size_t)> misser([&](size_t t) { in TEST_F() argument
299 for (size_t t = 0; t < num_threads; ++t) { in TEST_F() local
[all …]
Dthread_local.cc442 for (ThreadData* t = head_.next; t != &head_; t = t->next) { in Scrape() local
443 if (id < t->entries.size()) { in Scrape()
445 t->entries[id].ptr.exchange(replacement, std::memory_order_acquire); in Scrape()
455 for (ThreadData* t = head_.next; t != &head_; t = t->next) { in Fold() local
456 if (id < t->entries.size()) { in Fold()
457 void* ptr = t->entries[id].ptr.load(); in Fold()
507 for (ThreadData* t = head_.next; t != &head_; t = t->next) { in ReclaimId() local
508 if (id < t->entries.size()) { in ReclaimId()
509 void* ptr = t->entries[id].ptr.exchange(nullptr); in ReclaimId()
Dthread_list_test.cc255 for (int t = 0; t < kFlushWriteTasks; ++t) { in TEST_F() local
261 for (int t = 0; t < kCompactionWriteTasks; ++t) { in TEST_F() local
267 for (int t = 0; t < kCompactionReadTasks; ++t) { in TEST_F() local
273 for (int t = 0; t < kCompactionWaitTasks; ++t) { in TEST_F() local
/rocksdb-6.9/third-party/folly/folly/
DConstexprMath.h25 constexpr T constexpr_log2_ceil_(T l2, T t) { in constexpr_log2_ceil_() argument
26 return l2 + T(T(1) << l2 < t ? 1 : 0); in constexpr_log2_ceil_()
30 constexpr T constexpr_square_(T t) { in constexpr_square_() argument
31 return t * t; in constexpr_square_()
36 constexpr T constexpr_log2(T t) { in constexpr_log2() argument
37 return detail::constexpr_log2_(T(0), t); in constexpr_log2()
41 constexpr T constexpr_log2_ceil(T t) { in constexpr_log2_ceil() argument
42 return detail::constexpr_log2_ceil_(constexpr_log2(t), t); in constexpr_log2_ceil()
/rocksdb-6.9/db/
Drepair.cc457 TableInfo t; in ExtractMetaData() local
458 t.meta.fd = table_fds_[i]; in ExtractMetaData()
459 Status status = ScanTable(&t); in ExtractMetaData()
462 db_options_.db_paths, t.meta.fd.GetNumber(), t.meta.fd.GetPathId()); in ExtractMetaData()
464 FormatFileNumber(t.meta.fd.GetNumber(), t.meta.fd.GetPathId(), in ExtractMetaData()
470 tables_.push_back(t); in ExtractMetaData()
475 Status ScanTable(TableInfo* t) { in ScanTable() argument
477 db_options_.db_paths, t->meta.fd.GetNumber(), t->meta.fd.GetPathId()); in ScanTable()
481 t->meta.fd = FileDescriptor(t->meta.fd.GetNumber(), t->meta.fd.GetPathId(), in ScanTable()
490 if (t->column_family_id == in ScanTable()
[all …]
Ddbformat.h81 inline bool IsValueType(ValueType t) { in IsValueType() argument
82 return t <= kTypeMerge || t == kTypeSingleDeletion || t == kTypeBlobIndex; in IsValueType()
87 inline bool IsExtendedValueType(ValueType t) { in IsExtendedValueType() argument
88 return IsValueType(t) || t == kTypeRangeDeletion; in IsExtendedValueType()
109 : user_key(u), sequence(seq), type(t) {} in ParsedInternalKey()
146 ValueType t);
267 SetFrom(ParsedInternalKey(_user_key, s, t)); in Set()
284 AppendInternalKeyFooter(&rep_, s, t); in ConvertFromUserKey()
313 uint64_t newval = (seq << 8) | t; in UpdateInternalKey()
439 void UpdateInternalKey(uint64_t seq, ValueType t) { in UpdateInternalKey() argument
[all …]
Drange_del_aggregator_bench.cc111 PersistentRangeTombstone(const PersistentRangeTombstone& t) { *this = t; } in PersistentRangeTombstone()
113 PersistentRangeTombstone& operator=(const PersistentRangeTombstone& t) { in operator =()
114 start_key = t.start_key; in operator =()
115 end_key = t.end_key; in operator =()
116 tombstone = RangeTombstone(start_key, end_key, t.tombstone.seq_); in operator =()
121 PersistentRangeTombstone(PersistentRangeTombstone&& t) noexcept { *this = t; } in PersistentRangeTombstone()
123 PersistentRangeTombstone& operator=(PersistentRangeTombstone&& t) { in operator =()
124 start_key = std::move(t.start_key); in operator =()
125 end_key = std::move(t.end_key); in operator =()
126 tombstone = RangeTombstone(start_key, end_key, t.tombstone.seq_); in operator =()
Dcomparator_db_test.cc456 Slice t("abcxyz"); in TEST_P() local
461 Slice t("abcxy"); in TEST_P() local
467 Slice t("abc2xyz"); in TEST_P() local
473 Slice t("abcxyz"); in TEST_P() local
478 Slice t("abcxz"); in TEST_P() local
483 Slice t("abcxy"); in TEST_P() local
490 Slice t(t_array); in TEST_P() local
497 Slice t(t_array, 3); in TEST_P() local
504 Slice t(t_array, 4); in TEST_P() local
511 Slice t(t_array, 4); in TEST_P() local
[all …]
Ddb_write_test.cc129 for (auto& t : threads) { in TEST_P() local
130 t.join(); in TEST_P()
292 for (int t = 0; t < 10; t++) { in TEST_P() local
293 … threads[t] = std::thread([t, wal_key_prefix, wal_value, no_wal_key_prefix, no_wal_value, this] { in TEST_P()
298 std::string no_wal_key = no_wal_key_prefix + std::to_string(t) + in TEST_P()
309 for (auto& t: threads) { in TEST_P() local
310 t.join(); in TEST_P()
Ddbformat.cc29 uint64_t PackSequenceAndType(uint64_t seq, ValueType t) { in PackSequenceAndType() argument
31 assert(IsExtendedValueType(t)); in PackSequenceAndType()
32 return (seq << 8) | t; in PackSequenceAndType()
65 void UnPackSequenceAndType(uint64_t packed, uint64_t* seq, ValueType* t) { in UnPackSequenceAndType() argument
67 *t = static_cast<ValueType>(packed & 0xff); in UnPackSequenceAndType()
70 assert(IsExtendedValueType(*t)); in UnPackSequenceAndType()
88 ValueType t) { in AppendInternalKeyFooter() argument
89 PutFixed64(result, PackSequenceAndType(s, t)); in AppendInternalKeyFooter()
Dlog_writer.cc29 char t = static_cast<char>(i); in Writer() local
30 type_crc_[i] = crc32c::Value(&t, 1); in Writer()
117 IOStatus Writer::EmitPhysicalRecord(RecordType t, const char* ptr, size_t n) { in EmitPhysicalRecord() argument
126 buf[6] = static_cast<char>(t); in EmitPhysicalRecord()
128 uint32_t crc = type_crc_[t]; in EmitPhysicalRecord()
129 if (t < kRecyclableFullType) { in EmitPhysicalRecord()
Dtable_cache.cc265 TableReader* t = fd.table_reader; in GetRangeTombstoneIterator() local
267 if (t == nullptr) { in GetRangeTombstoneIterator()
270 t = GetTableReaderFromHandle(handle); in GetRangeTombstoneIterator()
380 TableReader* t = fd.table_reader; in Get() local
383 if (t == nullptr) { in Get()
389 t = GetTableReaderFromHandle(handle); in Get()
397 t->NewRangeTombstoneIterator(options)); in Get()
443 TableReader* t = fd.table_reader; in MultiGet() local
483 if (t == nullptr) { in MultiGet()
490 t = GetTableReaderFromHandle(handle); in MultiGet()
[all …]
/rocksdb-6.9/logging/
Dlog_buffer.cc62 struct tm t; in FlushBufferToLog() local
63 if (localtime_r(&seconds, &t) != nullptr) { in FlushBufferToLog()
66 t.tm_year + 1900, t.tm_mon + 1, t.tm_mday, t.tm_hour, t.tm_min, in FlushBufferToLog()
67 t.tm_sec, static_cast<int>(log->now_tv.tv_usec), log->message); in FlushBufferToLog()
Dposix_logger.h109 struct tm t; in Logv() local
110 localtime_r(&seconds, &t); in Logv()
113 t.tm_year + 1900, in Logv()
114 t.tm_mon + 1, in Logv()
115 t.tm_mday, in Logv()
116 t.tm_hour, in Logv()
117 t.tm_min, in Logv()
118 t.tm_sec, in Logv()
Denv_logger.h105 struct tm t; in Logv() local
106 localtime_r(&seconds, &t); in Logv()
108 t.tm_year + 1900, t.tm_mon + 1, t.tm_mday, t.tm_hour, in Logv()
109 t.tm_min, t.tm_sec, static_cast<int>(now_tv.tv_usec), in Logv()
/rocksdb-6.9/tools/
Ddb_repl_stress.cc47 DataPumpThread* t = reinterpret_cast<DataPumpThread*>(arg); in DataPumpThreadBody() local
48 DB* db = t->db; in DataPumpThreadBody()
51 while (i++ < t->no_records) { in DataPumpThreadBody()
68 ReplicationThread* t = reinterpret_cast<ReplicationThread*>(arg); in ReplicationThreadBody() local
69 DB* db = t->db; in ReplicationThreadBody()
72 while (!t->stop.load(std::memory_order_acquire)) { in ReplicationThreadBody()
76 if (t->stop.load(std::memory_order_acquire)) { in ReplicationThreadBody()
81 for (; iter->Valid(); iter->Next(), t->no_read++, currentSeqNum++) { in ReplicationThreadBody()
/rocksdb-6.9/port/win/
Dwin_logger.cc124 struct tm t; in Logv() local
125 localtime_s(&t, &seconds); in Logv()
127 t.tm_year + 1900, t.tm_mon + 1, t.tm_mday, t.tm_hour, in Logv()
128 t.tm_min, t.tm_sec, static_cast<int>(now_tv.tv_usec), in Logv()
/rocksdb-6.9/utilities/cassandra/
Dserialize.h28 inline void Serialize<int8_t>(int8_t t, std::string* dest) {
29 dest->append(1, static_cast<char>(t & kCharMask));
33 inline void Serialize<int32_t>(int32_t t, std::string* dest) {
36 (t >> (sizeof(int32_t) - 1 - i) * kBitsPerByte) & kCharMask));
41 inline void Serialize<int64_t>(int64_t t, std::string* dest) {
45 (t >> (sizeof(int64_t) - 1 - i) * kBitsPerByte) & kCharMask));
/rocksdb-6.9/monitoring/
Dstatistics_test.cc23 for (uint32_t t = 0; t < Tickers::TICKER_ENUM_MAX; t++) { in TEST_F() local
24 auto pair = TickersNameMap[static_cast<size_t>(t)]; in TEST_F()
25 ASSERT_EQ(pair.first, t) << "Miss match at " << pair.second; in TEST_F()
/rocksdb-6.9/env/
Dmock_env.cc363 struct tm t; in Logv() local
364 memset(&t, 0, sizeof(t)); in Logv()
366 ret = localtime_r(&seconds, &t); in Logv()
369 t.tm_year + 1900, t.tm_mon + 1, t.tm_mday, t.tm_hour, in Logv()
370 t.tm_min, t.tm_sec, static_cast<int>(now_tv.tv_usec)); in Logv()
637 auto t = NormalizePath(dest); in RenameFile() local
643 DeleteFileInternal(t); in RenameFile()
644 file_map_[t] = file_map_[s]; in RenameFile()
651 auto t = NormalizePath(dest); in LinkFile() local
657 DeleteFileInternal(t); in LinkFile()
[all …]

123456