noah/ag_gen
1
0
Fork 0
forked from UTulsa-Research/ag_gen
Code Issues 3 Pull Requests Projects Releases Wiki Activity

Updating to non-blocking recvs

Browse Source
This commit is contained in:
Noah L. Schrick 2022-01-30 20:00:33 -06:00
parent bf397e3996
commit 7b35242546
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/ag_gen/ag_gen.cpp
View File

@ -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<Factbase> factbases_dump;
std::vector<Edge> 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);