Browse Source

mpi: in struct _starpu_mpi_req, rename field needs_unpacking in user_datatype

Nathalie Furmento 12 years ago
parent
commit
8b2f1d8696
2 changed files with 6 additions and 6 deletions
  1. 5 5
      mpi/src/starpu_mpi.c
  2. 1 1
      mpi/src/starpu_mpi_private.h

+ 5 - 5
mpi/src/starpu_mpi.c

@@ -149,8 +149,8 @@ static void _starpu_mpi_isend_size_callback(void *arg)
 
 static void _starpu_mpi_isend_size_func(struct _starpu_mpi_req *req)
 {
-	req->needs_unpacking = starpu_mpi_handle_to_datatype(req->data_handle, &req->datatype);
-	if (!req->needs_unpacking)
+	req->user_datatype = starpu_mpi_handle_to_datatype(req->data_handle, &req->datatype);
+	if (!req->user_datatype)
 	{
 		req->count = 1;
 		req->ptr = starpu_handle_get_local_ptr(req->data_handle);
@@ -263,8 +263,8 @@ static void _starpu_mpi_irecv_size_func(struct _starpu_mpi_req *req)
 {
 	_STARPU_MPI_LOG_IN();
 
-	req->needs_unpacking = starpu_mpi_handle_to_datatype(req->data_handle, &req->datatype);
-	if (!req->needs_unpacking)
+	req->user_datatype = starpu_mpi_handle_to_datatype(req->data_handle, &req->datatype);
+	if (!req->user_datatype)
 	{
 		req->count = 1;
 		req->ptr = starpu_handle_get_local_ptr(req->data_handle);
@@ -573,7 +573,7 @@ static void _starpu_mpi_handle_request_termination(struct _starpu_mpi_req *req)
 	_STARPU_MPI_DEBUG("complete MPI (%s %d) data %p req %p - tag %d\n", _starpu_mpi_request_type(req->request_type), req->srcdst, req->data_handle, &req->request, req->mpi_tag);
 	if (req->request_type == RECV_REQ || req->request_type == SEND_REQ)
 	{
-		if (req->needs_unpacking)
+		if (req->user_datatype)
 		{
 			if (req->request_type == RECV_REQ)
 				// req->ptr is freed by starpu_handle_unpack_data

+ 1 - 1
mpi/src/starpu_mpi_private.h

@@ -77,7 +77,7 @@ LIST_TYPE(_starpu_mpi_req,
 	MPI_Datatype datatype;
 	void *ptr;
 	size_t count;
-	int needs_unpacking;
+	int user_datatype;
 
 	/* who are we talking to ? */
 	int srcdst;