Lines Matching refs:snap_state
263 ThreadState::SnapshotState& snap_state) { in AssertSame() argument
265 if (cf->GetName() != snap_state.cf_at_name) { in AssertSame()
269 ropt.snapshot = snap_state.snapshot; in AssertSame()
270 PinnableSlice exp_v(&snap_state.value); in AssertSame()
273 s = db->Get(ropt, cf, snap_state.key, &v); in AssertSame()
277 if (snap_state.status != s) { in AssertSame()
280 ToString(Hash(snap_state.key.c_str(), snap_state.key.size(), 0)) + in AssertSame()
281 " in cf " + cf->GetName() + ": (" + snap_state.status.ToString() + in AssertSame()
291 if (snap_state.key_vec != nullptr) { in AssertSame()
304 if (!std::equal(snap_state.key_vec->begin(), snap_state.key_vec->end(), in AssertSame()
1498 ThreadState::SnapshotState snap_state = { in TestAcquireSnapshot() local
1516 thread->snapshot_queue.emplace(release_at, snap_state); in TestAcquireSnapshot()
1522 auto snap_state = thread->snapshot_queue.front().second; in MaybeReleaseSnapshots() local
1523 assert(snap_state.snapshot); in MaybeReleaseSnapshots()
1527 Status s = AssertSame(db_, column_families_[snap_state.cf_at], snap_state); in MaybeReleaseSnapshots()
1528 db_->ReleaseSnapshot(snap_state.snapshot); in MaybeReleaseSnapshots()
1529 delete snap_state.key_vec; in MaybeReleaseSnapshots()