Home
last modified time | relevance | path

Searched refs:b1 (Results 1 – 9 of 9) sorted by relevance

/rocksdb-6.9/java/src/test/java/org/rocksdb/
DWriteBatchTest.java122 try (final WriteBatch b1 = new WriteBatch(); in testAppendOperation() argument
126 WriteBatchTestInternalHelper.append(b1, b2); in testAppendOperation()
127 assertThat(getContents(b1).length).isEqualTo(0); in testAppendOperation()
128 assertThat(b1.count()).isEqualTo(0); in testAppendOperation()
130 WriteBatchTestInternalHelper.append(b1, b2); in testAppendOperation()
133 assertThat(b1.count()).isEqualTo(1); in testAppendOperation()
136 WriteBatchTestInternalHelper.append(b1, b2); in testAppendOperation()
139 .equals(new String(getContents(b1), UTF_8))); in testAppendOperation()
140 assertThat(b1.count()).isEqualTo(2); in testAppendOperation()
142 WriteBatchTestInternalHelper.append(b1, b2); in testAppendOperation()
[all …]
DColumnFamilyTest.java662 final byte[] b1 = new byte[]{(byte) 0x01}; in testByteCreateFolumnFamily()
667 cf2 = db.createColumnFamily(new ColumnFamilyDescriptor(b1)); in testByteCreateFolumnFamily()
670 assertThat(families).contains("default".getBytes(), b0, b1); in testByteCreateFolumnFamily()
695 final byte[] b1 = new byte[]{0, 1}; in testCFNamesWithZeroBytes()
697 cf2 = db.createColumnFamily(new ColumnFamilyDescriptor(b1)); in testCFNamesWithZeroBytes()
700 assertThat(families).contains("default".getBytes(), b0, b1); in testCFNamesWithZeroBytes()
/rocksdb-6.9/db/
Dwrite_batch_test.cc171 WriteBatch b1, b2; in TEST_F() local
176 PrintContents(&b1)); in TEST_F()
177 ASSERT_EQ(0u, b1.Count()); in TEST_F()
181 PrintContents(&b1)); in TEST_F()
182 ASSERT_EQ(1u, b1.Count()); in TEST_F()
188 PrintContents(&b1)); in TEST_F()
189 ASSERT_EQ(2u, b1.Count()); in TEST_F()
196 PrintContents(&b1)); in TEST_F()
197 ASSERT_EQ(4u, b1.Count()); in TEST_F()
211 PrintContents(&b1)); in TEST_F()
[all …]
Dcomparator_db_test.cc238 Slice b1 = Slice(b.data() + 2, size_b1); in Compare() local
242 if (a1 != b1) { in Compare()
243 return a1.compare(b1); in Compare()
/rocksdb-6.9/tools/block_cache_analyzer/
Dblock_cache_pysim.py1370 self.b1 = Deque() # B1: ghost entries recently evicted from the T1 cache
1379 self.b1.appendleft(old)
1386 self.b1.appendleft(old)
1407 if key in self.b1:
1408 self.p = min(self.c, self.p + max(len(self.b2) / len(self.b1), 1))
1410 self.b1.remove(key)
1417 self.p = max(0, self.p - max(len(self.b1) / len(self.b2), 1))
1425 while len(self.t1) + len(self.b1) >= self.c and self.b1:
1426 self.b1.pop()
1428 total = len(self.t1) + len(self.b1) + len(self.t2) + len(self.b2)
/rocksdb-6.9/third-party/folly/folly/synchronization/
DAtomicUtil-inl.h36 auto mask = Integer{0b1} << static_cast<Integer>(bit); in atomic_fetch_set_default()
46 auto mask = Integer{0b1} << static_cast<Integer>(bit); in atomic_fetch_reset_default()
DDistributedMutex-inl.h45 constexpr auto kLocked = std::uintptr_t{0b1};
77 constexpr auto kWaiting = std::uint32_t{0b1};
728 assert(!(mask & 0b1));
1171 assert(!(address & 0b1));
1638 if (!(previous & 0b1)) {
/rocksdb-6.9/utilities/transactions/
Dwrite_prepared_transaction_test.cc416 SequenceNumber& version, size_t a1, size_t a2, size_t b1, size_t b2) { in SnapshotConcurrentAccessTestInternal() argument
428 {"WritePreparedTxnDB::UpdateSnapshots:p:" + std::to_string(b1), in SnapshotConcurrentAccessTestInternal()
431 "WritePreparedTxnDB::UpdateSnapshots:s:" + std::to_string(b1)}, in SnapshotConcurrentAccessTestInternal()
457 {"WritePreparedTxnDB::CheckAgainstSnapshots:p:" + std::to_string(b1), in SnapshotConcurrentAccessTestInternal()
460 "WritePreparedTxnDB::CheckAgainstSnapshots:s:" + std::to_string(b1)}, in SnapshotConcurrentAccessTestInternal()
1240 for (size_t b1 = 1; b1 <= b_range; b1++) { in TEST_P() local
1241 for (size_t b2 = b1 + 1; b2 <= b_range; b2++) { in TEST_P()
1244 a1, a2, b1, b2); in TEST_P()
/rocksdb-6.9/utilities/blob_db/
Dblob_db_impl.cc762 bool b1 = (*finditr)->expiration_range_.first > expiration; in FindBlobFileLocked() local
764 return (b1 || b2) ? nullptr : (*finditr); in FindBlobFileLocked()