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 470cea0de..c6bc4096a 100644 --- a/src/transaction/insert_transaction.cc +++ b/src/transaction/insert_transaction.cc @@ -198,10 +198,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 { @@ -223,24 +221,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);