mpi/src/starpu_mpi.c: comment out the code in starpu_mpi_recv_XXX functions which automatically sets the tag for the data. it means data without tag when arriving too early will be received as raw memory

mpi/src/starpu_mpi.c

@@ -513,12 +513,12 @@ int starpu_mpi_irecv(starpu_data_handle_t data_handle, starpu_mpi_req *public_re
 	_STARPU_MPI_LOG_IN();
 	STARPU_ASSERT_MSG(public_req, "starpu_mpi_irecv needs a valid starpu_mpi_req");
 
-	// We check if a tag is defined for the data handle, if not,
-	// we define the one given for the communication.
-	// A tag is necessary for the internal mpi engine.
-	int tag = starpu_data_get_tag(data_handle);
-	if (tag == -1)
-		starpu_data_set_tag(data_handle, mpi_tag);
+//	// We check if a tag is defined for the data handle, if not,
+//	// we define the one given for the communication.
+//	// A tag is necessary for the internal mpi engine.
+//	int tag = starpu_data_get_tag(data_handle);
+//	if (tag == -1)
+//		starpu_data_set_tag(data_handle, mpi_tag);
 
 	struct _starpu_mpi_req *req;
 	req = _starpu_mpi_irecv_common(data_handle, source, mpi_tag, comm, 0, NULL, NULL, 1, 0, 0);
@@ -534,12 +534,12 @@ int starpu_mpi_irecv_detached(starpu_data_handle_t data_handle, int source, int
 {
 	_STARPU_MPI_LOG_IN();
 
-	// We check if a tag is defined for the data handle, if not,
-	// we define the one given for the communication.
-	// A tag is necessary for the internal mpi engine.
-	int tag = starpu_data_get_tag(data_handle);
-	if (tag == -1)
-		starpu_data_set_tag(data_handle, mpi_tag);
+//	// We check if a tag is defined for the data handle, if not,
+//	// we define the one given for the communication.
+//	// A tag is necessary for the internal mpi engine.
+//	int tag = starpu_data_get_tag(data_handle);
+//	if (tag == -1)
+//		starpu_data_set_tag(data_handle, mpi_tag);
 
 	_starpu_mpi_irecv_common(data_handle, source, mpi_tag, comm, 1, callback, arg, 1, 0, 0);
 	_STARPU_MPI_LOG_OUT();
@@ -550,12 +550,12 @@ int starpu_mpi_irecv_detached_sequential_consistency(starpu_data_handle_t data_h
 {
 	_STARPU_MPI_LOG_IN();
 
-	// We check if a tag is defined for the data handle, if not,
-	// we define the one given for the communication.
-	// A tag is necessary for the internal mpi engine.
-	int tag = starpu_data_get_tag(data_handle);
-	if (tag == -1)
-		starpu_data_set_tag(data_handle, mpi_tag);
+//	// We check if a tag is defined for the data handle, if not,
+//	// we define the one given for the communication.
+//	// A tag is necessary for the internal mpi engine.
+//	int tag = starpu_data_get_tag(data_handle);
+//	if (tag == -1)
+//		starpu_data_set_tag(data_handle, mpi_tag);
 
 	_starpu_mpi_irecv_common(data_handle, source, mpi_tag, comm, 1, callback, arg, sequential_consistency, 0, 0);
 
@@ -568,12 +568,12 @@ int starpu_mpi_recv(starpu_data_handle_t data_handle, int source, int mpi_tag, M
 	starpu_mpi_req req;
 	_STARPU_MPI_LOG_IN();
 
-	// We check if a tag is defined for the data handle, if not,
-	// we define the one given for the communication.
-	// A tag is necessary for the internal mpi engine.
-	int tag = starpu_data_get_tag(data_handle);
-	if (tag == -1)
-		starpu_data_set_tag(data_handle, mpi_tag);
+//	// We check if a tag is defined for the data handle, if not,
+//	// we define the one given for the communication.
+//	// A tag is necessary for the internal mpi engine.
+//	int tag = starpu_data_get_tag(data_handle);
+//	if (tag == -1)
+//		starpu_data_set_tag(data_handle, mpi_tag);
 
 	starpu_mpi_irecv(data_handle, &req, source, mpi_tag, comm);
 	starpu_mpi_wait(&req, status);