Home
last modified time | relevance | path

Searched refs:expected (Results 1 – 25 of 63) sorted by relevance

123

/rocksdb-6.9/third-party/folly/folly/synchronization/
DAtomicNotification-inl.h43 std::uint32_t expected) { in atomic_wait_impl() argument
44 futexWait(atomic, expected); in atomic_wait_impl()
49 void atomic_wait_impl(const Atom<Integer, Args...>* atomic, Integer expected) { in atomic_wait_impl() argument
52 atomic, -1, [&] { return atomic->load() == expected; }, [] {}); in atomic_wait_impl()
62 std::uint32_t expected, in atomic_wait_until_impl() argument
64 return toCvStatus(futexWaitUntil(atomic, expected, deadline)); in atomic_wait_until_impl()
75 Integer expected, in atomic_wait_until_impl() argument
115 void atomic_wait(const std::atomic<Integer>* atomic, Integer expected) { in atomic_wait() argument
116 detail::atomic_notification::atomic_wait_impl(atomic, expected); in atomic_wait()
122 Integer expected, in atomic_wait_until() argument
[all …]
DDistributedMutex-inl.h788 std::uintptr_t expected,
795 expected_{expected},
1227 auto expected = address;
1230 expected = kLocked;
1247 /* expected */ expected,
1502 auto expected = proxy.expected_;
1505 expected,
1518 if (expected == (proxy.expected_ | kTimedWaiter)) {
1584 if (wake(Publish, *next, expected, sleepers, i)) {
1676 return Proxy{next, expected, timedWaiter};
[all …]
DBaton.h273 uint32_t expected = INIT; in tryWaitSlow() local
275 expected, in tryWaitSlow()
280 assert(expected == EARLY_DELIVERY); in tryWaitSlow()
DAtomicNotification.h38 void atomic_wait(const std::atomic<Integer>* atomic, Integer expected);
42 Integer expected,
/rocksdb-6.9/third-party/folly/folly/detail/
DFutex-inl.h51 uint32_t expected,
62 uint32_t expected,
71 uint32_t expected, in futexWaitImpl() argument
74 return futexWaitImpl(futex, expected, nullptr, &deadline, waitMask); in futexWaitImpl()
81 uint32_t expected, in futexWaitImpl() argument
84 return futexWaitImpl(futex, expected, &deadline, nullptr, waitMask); in futexWaitImpl()
89 futexWait(const Futex* futex, uint32_t expected, uint32_t waitMask) { in futexWait() argument
90 auto rv = futexWaitImpl(futex, expected, nullptr, nullptr, waitMask); in futexWait()
103 uint32_t expected, in futexWaitUntil() argument
112 ? futexWaitImpl(futex, expected, nullptr, nullptr, waitMask) in futexWaitUntil()
[all …]
DFutex.cpp93 uint32_t expected, in nativeFutexWaitImpl() argument
118 expected, /* val */ in nativeFutexWaitImpl()
175 uint32_t expected, in emulatedFutexWaitImpl() argument
188 [&] { return *futex == expected; }, in emulatedFutexWaitImpl()
195 [&] { return *futex == expected; }, in emulatedFutexWaitImpl()
200 futex, waitMask, [&] { return *futex == expected; }, [] {}); in emulatedFutexWaitImpl()
239 uint32_t expected, in futexWaitImpl() argument
245 futex, expected, absSystemTime, absSteadyTime, waitMask); in futexWaitImpl()
248 futex, expected, absSystemTime, absSteadyTime, waitMask); in futexWaitImpl()
254 uint32_t expected, in futexWaitImpl() argument
[all …]
DFutex.h47 futexWait(const Futex* futex, uint32_t expected, uint32_t waitMask = -1);
62 uint32_t expected,
/rocksdb-6.9/util/
Dcrc32c_test.cc106 for (auto expected : expectedResults) { in TEST() local
107 uint32_t result = Value(buffer + expected.offset, expected.length); in TEST()
108 EXPECT_EQ(~expected.crc32c, result); in TEST()
112 for (auto expected : expectedResults) { in TEST() local
113 size_t partialLength = expected.length / 2; in TEST()
114 uint32_t partialChecksum = Value(buffer + expected.offset, partialLength); in TEST()
116 buffer + expected.offset + partialLength, in TEST()
117 expected.length - partialLength); in TEST()
118 EXPECT_EQ(~expected.crc32c, result); in TEST()
Dthread_local_test.cc521 void* expected = reinterpret_cast<void*>(1); in TEST_F() local
523 ASSERT_TRUE(tls.CompareAndSwap(reinterpret_cast<void*>(2), expected)); in TEST_F()
524 expected = reinterpret_cast<void*>(100); in TEST_F()
526 ASSERT_TRUE(!tls.CompareAndSwap(reinterpret_cast<void*>(2), expected)); in TEST_F()
527 ASSERT_EQ(expected, reinterpret_cast<void*>(2)); in TEST_F()
529 expected = reinterpret_cast<void*>(2); in TEST_F()
530 ASSERT_TRUE(tls.CompareAndSwap(reinterpret_cast<void*>(3), expected)); in TEST_F()
Dthread_local.cc72 bool CompareAndSwap(uint32_t id, void* ptr, void*& expected);
428 void*& expected) { in CompareAndSwap() argument
436 expected, ptr, std::memory_order_release, std::memory_order_relaxed); in CompareAndSwap()
542 bool ThreadLocalPtr::CompareAndSwap(void* ptr, void*& expected) { in CompareAndSwap() argument
543 return Instance()->CompareAndSwap(id_, ptr, expected); in CompareAndSwap()
Dcompression_context_cache.cc43 void* expected = &uncomp_cached_data_; in GetUncompressData() local
44 if (zstd_uncomp_sentinel_.compare_exchange_strong(expected, in GetUncompressData()
/rocksdb-6.9/third-party/folly/folly/synchronization/test/
DDistributedMutexTest.cpp145 ++expected; in combineNThreads()
193 auto&& expected = std::uint64_t{0}; in combineWithLockNThreads()
197 ++expected; in combineWithLockNThreads()
210 EXPECT_EQ(expected, current + 1); in combineWithLockNThreads()
213 EXPECT_EQ(expected, total.load()); in combineWithLockNThreads()
252 ++expected; in combineWithTryLockNThreads()
268 EXPECT_EQ(expected, total.load()); in combineWithTryLockNThreads()
324 ++expected; in combineWithLockTryAndTimedNThreads()
347 EXPECT_EQ(expected, current[1]); in combineWithLockTryAndTimedNThreads()
354 EXPECT_EQ(expected, total.load()); in combineWithLockTryAndTimedNThreads()
[all …]
/rocksdb-6.9/java/src/test/java/org/rocksdb/
DWriteBatchWithIndexTest.java199 final WBWIRocksIterator.WriteEntry[] expected = { in iterator() local
227 expected[testOffset].getKey().data().mark(); in iterator()
237 assertThat(it.entry()).isEqualTo(expected[i++]); in iterator()
241 i = expected.length - 1; in iterator()
259 final WBWIRocksIterator.WriteEntry expected = in zeroByteTests() local
267 assertThat(actual.equals(expected)).isTrue(); in zeroByteTests()
359 @Test(expected = RocksDBException.class)
366 @Test(expected = RocksDBException.class)
403 @Test(expected = RocksDBException.class)
410 @Test(expected = RocksDBException.class)
[all …]
DReadOnlyTest.java113 @Test(expected = RocksDBException.class)
147 @Test(expected = RocksDBException.class)
177 @Test(expected = RocksDBException.class)
208 @Test(expected = RocksDBException.class)
239 @Test(expected = RocksDBException.class)
272 @Test(expected = RocksDBException.class)
DCheckPointTest.java60 @Test(expected = IllegalArgumentException.class)
67 @Test(expected = IllegalStateException.class)
76 @Test(expected = RocksDBException.class)
DHdfsEnvTest.java25 @Test(expected = RocksDBException.class)
33 @Test(expected = RocksDBException.class)
/rocksdb-6.9/db/
Ddb_range_del_test.cc493 expected.clear(); in TEST_F()
522 PutFixed64(&expected, 1); in TEST_F()
612 int expected = kRangeEnd; in TEST_F() local
621 ++expected; in TEST_F()
626 ASSERT_EQ(kNum, expected); in TEST_F()
707 expected.clear(); in TEST_F()
763 int expected = 0; in TEST_F() local
767 expected = kNum / 2; in TEST_F()
769 ++expected; in TEST_F()
798 int expected = 0; in TEST_F() local
[all …]
Dc_test.c81 if (expected == NULL && v == NULL) { in CheckEqual()
83 } else if (expected != NULL && v != NULL && n == strlen(expected) && in CheckEqual()
90 (expected ? expected : "(null)"), in CheckEqual()
105 const char* expected, in CheckValue() argument
117 const char* expected) { in CheckGet() argument
123 CheckEqual(expected, val, val_len); in CheckGet()
132 const char* expected) { in CheckGetCF() argument
138 CheckEqual(expected, val, val_len); in CheckGetCF()
151 CheckEqual(expected, val, val_len); in CheckPinGet()
375 const char* expected) { in CheckTxnGet() argument
[all …]
Dmemtable_list.h315 auto expected = false; in MarkTrimHistoryNeeded() local
317 expected, true, std::memory_order_relaxed, std::memory_order_relaxed); in MarkTrimHistoryNeeded()
321 auto expected = true; in ResetTrimHistoryNeeded() local
323 expected, false, std::memory_order_relaxed, std::memory_order_relaxed); in ResetTrimHistoryNeeded()
Dwrite_thread.cc648 Writer* expected = last_writer; in ExitAsBatchGroupLeader() local
649 bool has_dummy = newest_writer_.compare_exchange_strong(expected, &dummy); in ExitAsBatchGroupLeader()
653 next_leader = FindNextLeader(expected, last_writer); in ExitAsBatchGroupLeader()
674 expected = &dummy; in ExitAsBatchGroupLeader()
676 !newest_writer_.compare_exchange_strong(expected, nullptr); in ExitAsBatchGroupLeader()
678 next_leader = FindNextLeader(expected, &dummy); in ExitAsBatchGroupLeader()
/rocksdb-6.9/table/block_based/
Dreader_common.cc22 uint32_t expected) { in VerifyChecksum() argument
29 expected = crc32c::Unmask(expected); in VerifyChecksum()
42 if (s.ok() && actual != expected) { in VerifyChecksum()
/rocksdb-6.9/utilities/transactions/
Dpessimistic_transaction.cc147 TransactionState expected = STARTED; in CommitBatch() local
148 can_commit = std::atomic_compare_exchange_strong(&txn_state_, &expected, in CommitBatch()
189 TransactionState expected = STARTED; in Prepare() local
190 can_prepare = std::atomic_compare_exchange_strong(&txn_state_, &expected, in Prepare()
278 TransactionState expected = STARTED; in Commit() local
280 &txn_state_, &expected, AWAITING_COMMIT); in Commit()
691 TransactionState expected = STARTED; in TryStealingLocks() local
692 return std::atomic_compare_exchange_strong(&txn_state_, &expected, in TryStealingLocks()
/rocksdb-6.9/memory/
Darena_test.cc24 bool CheckMemoryAllocated(size_t allocated, size_t expected) { in CheckMemoryAllocated() argument
28 size_t max_expected = expected + expected / 10; in CheckMemoryAllocated()
29 return allocated >= expected && allocated <= max_expected; in CheckMemoryAllocated()
Djemalloc_nodump_allocator.cc179 extent_alloc_t* expected = nullptr; in NewJemallocNodumpAllocator() local
182 expected, original_alloc); in NewJemallocNodumpAllocator()
183 if (!success && original_alloc != expected) { in NewJemallocNodumpAllocator()
/rocksdb-6.9/tools/
Ddb_crashtest.py440 expected = False
443 expected = True
447 expected = True
449 if not expected:

123