Browse Source

bidouille

Romain LION 5 years ago
parent
commit
8246d72dea

+ 1 - 0
mpi/src/mpi_failure_tolerance/starpu_mpi_checkpoint.c

@@ -158,6 +158,7 @@ int starpu_mpi_submit_checkpoint_template(starpu_mpi_checkpoint_template_t cp_te
 	int current_instance;
 
 	current_instance = increment_current_instance();
+	STARPU_ASSERT(current_instance<4);
 	_starpu_mpi_checkpoint_post_cp_discard_recv(cp_template);
 	_starpu_mpi_checkpoint_template_create_instance_tracker(cp_template, cp_template->cp_id, cp_template->checkpoint_domain, current_instance);
 	//TODO check what happens when all the ack msg are received when we arrrive here.

+ 1 - 0
mpi/src/mpi_failure_tolerance/starpu_mpi_checkpoint.h

@@ -31,6 +31,7 @@ extern int _my_rank;
 struct _starpu_mpi_cp_ack_msg
 {
 	int checkpoint_id;
+	int klm;
 	int checkpoint_instance;
 };