From 7cdc04ddaa877742bf1ea7315f96430f1d9ee065 Mon Sep 17 00:00:00 2001 From: "xiaolei.zl" Date: Mon, 18 May 2026 12:13:21 +0800 Subject: [PATCH] rm dummy method get_vertex_with_retries --- include/neug/transaction/insert_transaction.h | 3 --- src/transaction/insert_transaction.cc | 24 ++----------------- 2 files changed, 2 insertions(+), 25 deletions(-) diff --git a/include/neug/transaction/insert_transaction.h b/include/neug/transaction/insert_transaction.h index c822791bc..ebe21cf52 100644 --- a/include/neug/transaction/insert_transaction.h +++ b/include/neug/transaction/insert_transaction.h @@ -166,9 +166,6 @@ class InsertTransaction { void clear(); - static bool get_vertex_with_retries(PropertyGraph& graph, label_t label, - const Property& oid, vid_t& lid, - timestamp_t timestamp); InArchive arc_; std::vector>> added_vertices_; diff --git a/src/transaction/insert_transaction.cc b/src/transaction/insert_transaction.cc index 6b5d1366b..c6101705d 100644 --- a/src/transaction/insert_transaction.cc +++ b/src/transaction/insert_transaction.cc @@ -196,10 +196,8 @@ void InsertTransaction::IngestWal(PropertyGraph& graph, uint32_t timestamp, InsertEdgeRedo redo; arc >> redo; vid_t src_lid, dst_lid; - CHECK(get_vertex_with_retries(graph, redo.src_label, redo.src, src_lid, - timestamp)); - CHECK(get_vertex_with_retries(graph, redo.dst_label, redo.dst, dst_lid, - timestamp)); + CHECK(graph.get_lid(redo.src_label, redo.src, src_lid, timestamp)); + CHECK(graph.get_lid(redo.dst_label, redo.dst, dst_lid, timestamp)); graph.AddEdge(redo.src_label, src_lid, redo.dst_label, dst_lid, redo.edge_label, redo.properties, timestamp, alloc); } else { @@ -220,24 +218,6 @@ void InsertTransaction::clear() { const Schema& InsertTransaction::schema() const { return graph_.schema(); } -bool InsertTransaction::get_vertex_with_retries(PropertyGraph& graph, - label_t label, - const Property& oid, vid_t& lid, - timestamp_t timestamp) { - if (NEUG_LIKELY(graph.get_lid(label, oid, lid, timestamp))) { - return true; - } - for (int i = 0; i < 10; ++i) { - std::this_thread::sleep_for(std::chrono::microseconds(1000000)); - if (NEUG_LIKELY(graph.get_lid(label, oid, lid, timestamp))) { - return true; - } - } - - LOG(ERROR) << "get_vertex [" << oid.to_string() << "] failed"; - return false; -} - void InsertTransaction::create_id_indexer_if_not_exists(label_t label) { if (label >= added_vertices_.size()) { added_vertices_base_.resize(label + 1, 0);