Searched refs:snapshot_queue (Results 1 – 2 of 2) sorted by relevance
514 while (!thread->snapshot_queue.empty()) { 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()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()[all …]
384 std::queue<std::pair<uint64_t, SnapshotState>> snapshot_queue; member