From 7b3524254618a4c05ee1f77b5431c486d9e2403d Mon Sep 17 00:00:00 2001 From: noah Date: Sun, 30 Jan 2022 20:00:33 -0600 Subject: [PATCH] Updating to non-blocking recvs --- src/ag_gen/ag_gen.cpp | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/src/ag_gen/ag_gen.cpp b/src/ag_gen/ag_gen.cpp index 3e007ea..5f4efbb 100755 --- a/src/ag_gen/ag_gen.cpp +++ b/src/ag_gen/ag_gen.cpp @@ -535,8 +535,8 @@ AGGenInstance &AGGen::generate(bool batch_process, int batch_size, int numThrd, NetworkState new_state; Quality fact; - world.irecv(mpi::any_source, 3, fact); - world.irecv(mpi::any_source, 4, new_state); + world.recv(mpi::any_source, 3, fact); + world.recv(mpi::any_source, 4, new_state); instance.facts.hash_table[new_state.compound_assign(fact)]=instance.facts.size(); instance.facts.length++; @@ -573,8 +573,8 @@ AGGenInstance &AGGen::generate(bool batch_process, int batch_size, int numThrd, std::cout << "Node " << world.rank() << " is starting Task 4." << std::endl; std::vector factbases_dump; std::vector edges_dump; - world.irecv(0, 7, factbases_dump); - world.irecv(0, 8, edges_dump); + world.recv(0, 7, factbases_dump); + world.recv(0, 8, edges_dump); instance.factbases = factbases_dump; instance.edges = edges_dump; //task_four(instance);