Paritioning Fix for Task 1
This commit is contained in:
parent
63d79e9ce1
commit
4675b362b9
@ -431,7 +431,6 @@ AGGenInstance &AGGen::generate(bool batch_process, int batch_size, int numThrd,
|
|||||||
if(world.rank() == 0)
|
if(world.rank() == 0)
|
||||||
{
|
{
|
||||||
auto current_state = localFrontier.back();
|
auto current_state = localFrontier.back();
|
||||||
auto current_hash = current_state.get_hash(instance.facts);
|
|
||||||
localFrontier.pop_back();
|
localFrontier.pop_back();
|
||||||
for(int l=0; l < alloc; l++){
|
for(int l=0; l < alloc; l++){
|
||||||
world.isend(send_check(world, l), 20, current_state);
|
world.isend(send_check(world, l), 20, current_state);
|
||||||
|
|||||||
@ -74,8 +74,9 @@ void task_one(AGGenInstance &instance, NetworkState ¤t_state,\
|
|||||||
|
|
||||||
//Distribute work to all nodes
|
//Distribute work to all nodes
|
||||||
for (size_t i = 0; i < esize; i++) {//for loop for applicable exploits starts
|
for (size_t i = 0; i < esize; i++) {//for loop for applicable exploits starts
|
||||||
if (i % alloc != send_check(world, world.rank()))
|
if (i % alloc != tcomm.rank())
|
||||||
continue;
|
continue;
|
||||||
|
|
||||||
auto e = exploit_list.at(i);
|
auto e = exploit_list.at(i);
|
||||||
size_t num_params = e.get_num_params();
|
size_t num_params = e.get_num_params();
|
||||||
auto preconds_q = e.precond_list_q();
|
auto preconds_q = e.precond_list_q();
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user