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

MPI Subgraphing Debug Statements

Browse Source
This commit is contained in:
Noah L. Schrick 2022-02-06 23:17:44 -06:00
parent ea713ea9cb
commit 851b032830
2 changed files with 9 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

BIN
build/ag_gen
View File

Binary file not shown.

12
src/ag_gen/ag_gen.cpp
View File

@ -1508,6 +1508,7 @@ AGGenInstance &AGGen::sg_generate(bool batch_process, int batch_num, int numThrd
if(send_msg == 1){ if(send_msg == 1){
world.isend(0, 2, 1); world.isend(0, 2, 1);
send_msg = 0; send_msg = 0;
std::cout << "Node " << world.rank() << " finished subgraphing work." << std::endl;
if(localFrontier.size() > 0){ if(localFrontier.size() > 0){
world.isend(0, 3, localFrontier); world.isend(0, 3, localFrontier);
} }
@ -1615,9 +1616,7 @@ AGGenInstance &AGGen::sg_generate(bool batch_process, int batch_num, int numThrd
*/ */
} }
if(localFrontier.empty() && finish_count == world.size() -2){ std::cout << "Root received all signals from nodes" << std::endl;
finished_signal = 1;
}
//Receive node frontiers and merge them into root frontier //Receive node frontiers and merge them into root frontier
for(int w = 2; w < world.size(); w++){ for(int w = 2; w < world.size(); w++){
@ -1664,6 +1663,12 @@ AGGenInstance &AGGen::sg_generate(bool batch_process, int batch_num, int numThrd
} }
} }
} }
if(localFrontier.empty() && finish_count == world.size() -2){
finished_signal = 1;
}
} //end world rank 0 } //end world rank 0
} // end main work loop } // end main work loop
@ -1674,6 +1679,7 @@ AGGenInstance &AGGen::sg_generate(bool batch_process, int batch_num, int numThrd
} }
} }
std::cout << "Process " << world.rank() << " is finishing" << std::endl;
world.barrier(); world.barrier();
if(world.rank() == 0){ if(world.rank() == 0){
gettimeofday(&t2,NULL); gettimeofday(&t2,NULL);