tursom/memgraph
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

React to PR comments

Browse Source
This commit is contained in:
gvolfing 2024-02-22 13:04:13 +01:00
parent 11279c4c74
commit 8aed5821f2
1 changed files with 5 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
src/storage/v2/inmemory/edge_type_index.cpp
View File

@ -168,12 +168,11 @@ void InMemoryEdgeTypeIndex::RemoveObsoleteEntries(uint64_t oldest_active_start_t
continue;
}
const bool edge_deleted = !std::ranges::all_of(it->from_vertex->out_edges, [&](const auto &edge) {
auto *to_vertex = std::get<InMemoryEdgeTypeIndex::kVertexPos>(edge);
return to_vertex != it->to_vertex;
});
if (next_it != edges_acc.end() || it->from_vertex->deleted || it->to_vertex->deleted || edge_deleted) {
if (next_it != edges_acc.end() || it->from_vertex->deleted || it->to_vertex->deleted ||
!std::ranges::all_of(it->from_vertex->out_edges, [&](const auto &edge) {
auto *to_vertex = std::get<InMemoryEdgeTypeIndex::kVertexPos>(edge);
return to_vertex != it->to_vertex;
})) {
edges_acc.remove(*it);
}