| /rocksdb-6.9/util/ |
| D | dynamic_bloom.h | 100 AddHash(hash, [](std::atomic<uint64_t>* ptr, uint64_t mask) { in AddHash()
101 ptr->store(ptr->load(std::memory_order_relaxed) | mask, in AddHash()
107 AddHash(hash, [](std::atomic<uint64_t>* ptr, uint64_t mask) { in AddHashConcurrently()
113 if ((mask & ptr->load(std::memory_order_relaxed)) != mask) { in AddHashConcurrently()
114 ptr->fetch_or(mask, std::memory_order_relaxed); in AddHashConcurrently()
184 uint64_t mask = in DoubleProbe() local
188 return (val & mask) == mask; in DoubleProbe()
189 } else if ((val & mask) != mask) { in DoubleProbe()
204 uint64_t mask = in AddHash() local
206 or_func(&data_[a ^ i], mask); in AddHash()
|
| /rocksdb-6.9/utilities/cassandra/ |
| D | format.cc | 23 ColumnBase::ColumnBase(int8_t mask, int8_t index) in ColumnBase() argument
24 : mask_(mask), index_(index) {} in ColumnBase()
46 if ((mask & ColumnTypeMask::DELETION_MASK) != 0) { in Deserialize()
56 int8_t mask, in Column() argument
61 ) : ColumnBase(mask, index), timestamp_(timestamp), in Column()
83 offset += sizeof(mask); in Deserialize()
97 int8_t mask, in ExpiringColumn() argument
144 offset += sizeof(mask); in Deserialize()
157 mask, index, timestamp, value_size, value, ttl); in Deserialize()
161 int8_t mask, in Tombstone() argument
[all …]
|
| D | test_utils.cc | 17 std::shared_ptr<ColumnBase> CreateTestColumn(int8_t mask, in CreateTestColumn() argument
20 if ((mask & ColumnTypeMask::DELETION_MASK) != 0) { in CreateTestColumn()
22 new Tombstone(mask, index, ToSeconds(timestamp), timestamp)); in CreateTestColumn()
23 } else if ((mask & ColumnTypeMask::EXPIRATION_MASK) != 0) { in CreateTestColumn()
25 mask, index, timestamp, sizeof(kExpiringData), kExpiringData, kTtl)); in CreateTestColumn()
28 new Column(mask, index, timestamp, sizeof(kData), kData)); in CreateTestColumn()
32 std::tuple<int8_t, int8_t, int64_t> CreateTestColumnSpec(int8_t mask, in CreateTestColumnSpec() argument
35 return std::make_tuple(mask, index, timestamp); in CreateTestColumnSpec()
|
| D | cassandra_format_test.cc | 20 int8_t mask = 0; in TEST() local
23 Column c = Column(mask, index, timestamp, sizeof(data), data); in TEST()
36 EXPECT_EQ(Deserialize<int8_t>(dest.c_str(), offset), mask); in TEST()
71 int8_t mask = ColumnTypeMask::EXPIRATION_MASK; in TEST() local
75 ExpiringColumn c = ExpiringColumn(mask, index, timestamp, in TEST()
89 EXPECT_EQ(Deserialize<int8_t>(dest.c_str(), offset), mask); in TEST()
140 int8_t mask = ColumnTypeMask::DELETION_MASK; in TEST() local
144 Tombstone c = Tombstone(mask, index, local_deletion_time, in TEST()
158 EXPECT_EQ(Deserialize<int8_t>(dest.c_str(), offset), mask); in TEST()
|
| D | format.h | 77 ColumnBase(int8_t mask, int8_t index);
95 Column(int8_t mask, int8_t index, int64_t timestamp,
112 Tombstone(int8_t mask, int8_t index,
129 ExpiringColumn(int8_t mask, int8_t index, int64_t timestamp,
|
| D | test_utils.h | 22 std::shared_ptr<ColumnBase> CreateTestColumn(int8_t mask,
26 std::tuple<int8_t, int8_t, int64_t> CreateTestColumnSpec(int8_t mask,
|
| /rocksdb-6.9/third-party/folly/folly/synchronization/ |
| D | AtomicUtil-inl.h | 36 auto mask = Integer{0b1} << static_cast<Integer>(bit); in atomic_fetch_set_default()
37 return (atomic.fetch_or(mask, order) & mask); in atomic_fetch_set_default()
46 auto mask = Integer{0b1} << static_cast<Integer>(bit); in atomic_fetch_reset_default()
47 return (atomic.fetch_and(~mask, order) & mask); in atomic_fetch_reset_default()
|
| D | DistributedMutex-inl.h | 725 auto mask = std::numeric_limits<std::uintptr_t>::max();
726 mask >>= 1;
727 mask <<= 1;
728 assert(!(mask & 0b1));
730 return folly::bit_cast<Type*>(from & mask);
|
| /rocksdb-6.9/third-party/folly/folly/detail/ |
| D | Futex.cpp | 159 parkingLot.unpark(addr, [&](const uint32_t& mask) { in emulatedFutexWake() argument
160 if ((mask & waitMask) == 0) { in emulatedFutexWake()
|
| /rocksdb-6.9/third-party/gtest-1.8.1/fused-src/gtest/ |
| D | gtest-all.cc | 3303 const UInt32 mask = (1 << 10) - 1; in CreateCodePointFromUtf16SurrogatePair() local
3305 (((first & mask) << 10) | (second & mask)) + 0x10000 : in CreateCodePointFromUtf16SurrogatePair()
|