Lines Matching refs:snapshot_queue

514       while (!thread->snapshot_queue.empty()) {  in OperateDb()
515         db_->ReleaseSnapshot(thread->snapshot_queue.front().second.snapshot);  in OperateDb()
516         delete thread->snapshot_queue.front().second.key_vec;  in OperateDb()
517         thread->snapshot_queue.pop();  in OperateDb()
750   while (!thread->snapshot_queue.empty()) {  in OperateDb()
751     db_->ReleaseSnapshot(thread->snapshot_queue.front().second.snapshot);  in OperateDb()
752     delete thread->snapshot_queue.front().second.key_vec;  in OperateDb()
753     thread->snapshot_queue.pop();  in OperateDb()
1516   thread->snapshot_queue.emplace(release_at, snap_state);  in TestAcquireSnapshot()
1520   while (!thread->snapshot_queue.empty() &&  in MaybeReleaseSnapshots()
1521          i >= thread->snapshot_queue.front().first) {  in MaybeReleaseSnapshots()
1522     auto snap_state = thread->snapshot_queue.front().second;  in MaybeReleaseSnapshots()
1530     thread->snapshot_queue.pop();  in MaybeReleaseSnapshots()