|
@@ -27,13 +27,13 @@
|
|
|
//#define USE_STARPU_ACTIVITY 1
|
|
//#define USE_STARPU_ACTIVITY 1
|
|
|
|
|
|
|
|
static void submit_mpi_req(void *arg);
|
|
static void submit_mpi_req(void *arg);
|
|
|
-static void handle_request_termination(struct starpu_mpi_req_s *req);
|
|
|
|
|
|
|
+static void handle_request_termination(struct _starpu_mpi_req *req);
|
|
|
|
|
|
|
|
/* The list of requests that have been newly submitted by the application */
|
|
/* The list of requests that have been newly submitted by the application */
|
|
|
-static starpu_mpi_req_list_t new_requests;
|
|
|
|
|
|
|
+static struct _starpu_mpi_req_list *new_requests;
|
|
|
|
|
|
|
|
/* The list of detached requests that have already been submitted to MPI */
|
|
/* The list of detached requests that have already been submitted to MPI */
|
|
|
-static starpu_mpi_req_list_t detached_requests;
|
|
|
|
|
|
|
+static struct _starpu_mpi_req_list *detached_requests;
|
|
|
static pthread_mutex_t detached_requests_mutex;
|
|
static pthread_mutex_t detached_requests_mutex;
|
|
|
|
|
|
|
|
static pthread_cond_t cond;
|
|
static pthread_cond_t cond;
|
|
@@ -45,13 +45,13 @@ static int running = 0;
|
|
|
static pthread_mutex_t mutex_posted_requests;
|
|
static pthread_mutex_t mutex_posted_requests;
|
|
|
static int posted_requests = 0;
|
|
static int posted_requests = 0;
|
|
|
|
|
|
|
|
-#define INC_POSTED_REQUESTS(value) { PTHREAD_MUTEX_LOCK(&mutex_posted_requests); posted_requests += value; PTHREAD_MUTEX_UNLOCK(&mutex_posted_requests); }
|
|
|
|
|
|
|
+#define INC_POSTED_REQUESTS(value) { _STARPU_PTHREAD_MUTEX_LOCK(&mutex_posted_requests); posted_requests += value; _STARPU_PTHREAD_MUTEX_UNLOCK(&mutex_posted_requests); }
|
|
|
|
|
|
|
|
/*
|
|
/*
|
|
|
* Isend
|
|
* Isend
|
|
|
*/
|
|
*/
|
|
|
|
|
|
|
|
-static void starpu_mpi_isend_func(struct starpu_mpi_req_s *req)
|
|
|
|
|
|
|
+static void starpu_mpi_isend_func(struct _starpu_mpi_req *req)
|
|
|
{
|
|
{
|
|
|
_STARPU_MPI_LOG_IN();
|
|
_STARPU_MPI_LOG_IN();
|
|
|
void *ptr = starpu_mpi_handle_to_ptr(req->data_handle);
|
|
void *ptr = starpu_mpi_handle_to_ptr(req->data_handle);
|
|
@@ -66,18 +66,18 @@ static void starpu_mpi_isend_func(struct starpu_mpi_req_s *req)
|
|
|
TRACE_MPI_ISEND(req->srcdst, req->mpi_tag, 0);
|
|
TRACE_MPI_ISEND(req->srcdst, req->mpi_tag, 0);
|
|
|
|
|
|
|
|
/* somebody is perhaps waiting for the MPI request to be posted */
|
|
/* somebody is perhaps waiting for the MPI request to be posted */
|
|
|
- PTHREAD_MUTEX_LOCK(&req->req_mutex);
|
|
|
|
|
|
|
+ _STARPU_PTHREAD_MUTEX_LOCK(&req->req_mutex);
|
|
|
req->submitted = 1;
|
|
req->submitted = 1;
|
|
|
- PTHREAD_COND_BROADCAST(&req->req_cond);
|
|
|
|
|
- PTHREAD_MUTEX_UNLOCK(&req->req_mutex);
|
|
|
|
|
|
|
+ _STARPU_PTHREAD_COND_BROADCAST(&req->req_cond);
|
|
|
|
|
+ _STARPU_PTHREAD_MUTEX_UNLOCK(&req->req_mutex);
|
|
|
_STARPU_MPI_LOG_OUT();
|
|
_STARPU_MPI_LOG_OUT();
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
-static struct starpu_mpi_req_s *_starpu_mpi_isend_common(starpu_data_handle data_handle,
|
|
|
|
|
- int dest, int mpi_tag, MPI_Comm comm,
|
|
|
|
|
- unsigned detached, void (*callback)(void *), void *arg)
|
|
|
|
|
|
|
+static struct _starpu_mpi_req *_starpu_mpi_isend_common(starpu_data_handle_t data_handle,
|
|
|
|
|
+ int dest, int mpi_tag, MPI_Comm comm,
|
|
|
|
|
+ unsigned detached, void (*callback)(void *), void *arg)
|
|
|
{
|
|
{
|
|
|
- struct starpu_mpi_req_s *req = calloc(1, sizeof(struct starpu_mpi_req_s));
|
|
|
|
|
|
|
+ struct _starpu_mpi_req *req = calloc(1, sizeof(struct _starpu_mpi_req));
|
|
|
STARPU_ASSERT(req);
|
|
STARPU_ASSERT(req);
|
|
|
|
|
|
|
|
_STARPU_MPI_LOG_IN();
|
|
_STARPU_MPI_LOG_IN();
|
|
@@ -87,8 +87,8 @@ static struct starpu_mpi_req_s *_starpu_mpi_isend_common(starpu_data_handle data
|
|
|
/* Initialize the request structure */
|
|
/* Initialize the request structure */
|
|
|
req->submitted = 0;
|
|
req->submitted = 0;
|
|
|
req->completed = 0;
|
|
req->completed = 0;
|
|
|
- PTHREAD_MUTEX_INIT(&req->req_mutex, NULL);
|
|
|
|
|
- PTHREAD_COND_INIT(&req->req_cond, NULL);
|
|
|
|
|
|
|
+ _STARPU_PTHREAD_MUTEX_INIT(&req->req_mutex, NULL);
|
|
|
|
|
+ _STARPU_PTHREAD_COND_INIT(&req->req_cond, NULL);
|
|
|
|
|
|
|
|
req->request_type = SEND_REQ;
|
|
req->request_type = SEND_REQ;
|
|
|
|
|
|
|
@@ -111,12 +111,12 @@ static struct starpu_mpi_req_s *_starpu_mpi_isend_common(starpu_data_handle data
|
|
|
return req;
|
|
return req;
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
-int starpu_mpi_isend(starpu_data_handle data_handle, starpu_mpi_req *public_req, int dest, int mpi_tag, MPI_Comm comm)
|
|
|
|
|
|
|
+int starpu_mpi_isend(starpu_data_handle_t data_handle, starpu_mpi_req *public_req, int dest, int mpi_tag, MPI_Comm comm)
|
|
|
{
|
|
{
|
|
|
_STARPU_MPI_LOG_IN();
|
|
_STARPU_MPI_LOG_IN();
|
|
|
STARPU_ASSERT(public_req);
|
|
STARPU_ASSERT(public_req);
|
|
|
|
|
|
|
|
- struct starpu_mpi_req_s *req;
|
|
|
|
|
|
|
+ struct _starpu_mpi_req *req;
|
|
|
req = _starpu_mpi_isend_common(data_handle, dest, mpi_tag, comm, 0, NULL, NULL);
|
|
req = _starpu_mpi_isend_common(data_handle, dest, mpi_tag, comm, 0, NULL, NULL);
|
|
|
|
|
|
|
|
STARPU_ASSERT(req);
|
|
STARPU_ASSERT(req);
|
|
@@ -130,7 +130,7 @@ int starpu_mpi_isend(starpu_data_handle data_handle, starpu_mpi_req *public_req,
|
|
|
* Isend (detached)
|
|
* Isend (detached)
|
|
|
*/
|
|
*/
|
|
|
|
|
|
|
|
-int starpu_mpi_isend_detached(starpu_data_handle data_handle,
|
|
|
|
|
|
|
+int starpu_mpi_isend_detached(starpu_data_handle_t data_handle,
|
|
|
int dest, int mpi_tag, MPI_Comm comm, void (*callback)(void *), void *arg)
|
|
int dest, int mpi_tag, MPI_Comm comm, void (*callback)(void *), void *arg)
|
|
|
{
|
|
{
|
|
|
_STARPU_MPI_LOG_IN();
|
|
_STARPU_MPI_LOG_IN();
|
|
@@ -144,7 +144,7 @@ int starpu_mpi_isend_detached(starpu_data_handle data_handle,
|
|
|
* Irecv
|
|
* Irecv
|
|
|
*/
|
|
*/
|
|
|
|
|
|
|
|
-static void starpu_mpi_irecv_func(struct starpu_mpi_req_s *req)
|
|
|
|
|
|
|
+static void starpu_mpi_irecv_func(struct _starpu_mpi_req *req)
|
|
|
{
|
|
{
|
|
|
_STARPU_MPI_LOG_IN();
|
|
_STARPU_MPI_LOG_IN();
|
|
|
void *ptr = starpu_mpi_handle_to_ptr(req->data_handle);
|
|
void *ptr = starpu_mpi_handle_to_ptr(req->data_handle);
|
|
@@ -158,25 +158,25 @@ static void starpu_mpi_irecv_func(struct starpu_mpi_req_s *req)
|
|
|
STARPU_ASSERT(req->ret == MPI_SUCCESS);
|
|
STARPU_ASSERT(req->ret == MPI_SUCCESS);
|
|
|
|
|
|
|
|
/* somebody is perhaps waiting for the MPI request to be posted */
|
|
/* somebody is perhaps waiting for the MPI request to be posted */
|
|
|
- PTHREAD_MUTEX_LOCK(&req->req_mutex);
|
|
|
|
|
|
|
+ _STARPU_PTHREAD_MUTEX_LOCK(&req->req_mutex);
|
|
|
req->submitted = 1;
|
|
req->submitted = 1;
|
|
|
- PTHREAD_COND_BROADCAST(&req->req_cond);
|
|
|
|
|
- PTHREAD_MUTEX_UNLOCK(&req->req_mutex);
|
|
|
|
|
|
|
+ _STARPU_PTHREAD_COND_BROADCAST(&req->req_cond);
|
|
|
|
|
+ _STARPU_PTHREAD_MUTEX_UNLOCK(&req->req_mutex);
|
|
|
_STARPU_MPI_LOG_OUT();
|
|
_STARPU_MPI_LOG_OUT();
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
-static struct starpu_mpi_req_s *_starpu_mpi_irecv_common(starpu_data_handle data_handle, int source, int mpi_tag, MPI_Comm comm, unsigned detached, void (*callback)(void *), void *arg)
|
|
|
|
|
|
|
+static struct _starpu_mpi_req *_starpu_mpi_irecv_common(starpu_data_handle_t data_handle, int source, int mpi_tag, MPI_Comm comm, unsigned detached, void (*callback)(void *), void *arg)
|
|
|
{
|
|
{
|
|
|
_STARPU_MPI_LOG_IN();
|
|
_STARPU_MPI_LOG_IN();
|
|
|
- struct starpu_mpi_req_s *req = calloc(1, sizeof(struct starpu_mpi_req_s));
|
|
|
|
|
|
|
+ struct _starpu_mpi_req *req = calloc(1, sizeof(struct _starpu_mpi_req));
|
|
|
STARPU_ASSERT(req);
|
|
STARPU_ASSERT(req);
|
|
|
|
|
|
|
|
INC_POSTED_REQUESTS(1);
|
|
INC_POSTED_REQUESTS(1);
|
|
|
|
|
|
|
|
/* Initialize the request structure */
|
|
/* Initialize the request structure */
|
|
|
req->submitted = 0;
|
|
req->submitted = 0;
|
|
|
- PTHREAD_MUTEX_INIT(&req->req_mutex, NULL);
|
|
|
|
|
- PTHREAD_COND_INIT(&req->req_cond, NULL);
|
|
|
|
|
|
|
+ _STARPU_PTHREAD_MUTEX_INIT(&req->req_mutex, NULL);
|
|
|
|
|
+ _STARPU_PTHREAD_COND_INIT(&req->req_cond, NULL);
|
|
|
|
|
|
|
|
req->request_type = RECV_REQ;
|
|
req->request_type = RECV_REQ;
|
|
|
|
|
|
|
@@ -200,12 +200,12 @@ static struct starpu_mpi_req_s *_starpu_mpi_irecv_common(starpu_data_handle data
|
|
|
return req;
|
|
return req;
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
-int starpu_mpi_irecv(starpu_data_handle data_handle, starpu_mpi_req *public_req, int source, int mpi_tag, MPI_Comm comm)
|
|
|
|
|
|
|
+int starpu_mpi_irecv(starpu_data_handle_t data_handle, starpu_mpi_req *public_req, int source, int mpi_tag, MPI_Comm comm)
|
|
|
{
|
|
{
|
|
|
_STARPU_MPI_LOG_IN();
|
|
_STARPU_MPI_LOG_IN();
|
|
|
STARPU_ASSERT(public_req);
|
|
STARPU_ASSERT(public_req);
|
|
|
|
|
|
|
|
- struct starpu_mpi_req_s *req;
|
|
|
|
|
|
|
+ struct _starpu_mpi_req *req;
|
|
|
req = _starpu_mpi_irecv_common(data_handle, source, mpi_tag, comm, 0, NULL, NULL);
|
|
req = _starpu_mpi_irecv_common(data_handle, source, mpi_tag, comm, 0, NULL, NULL);
|
|
|
|
|
|
|
|
STARPU_ASSERT(req);
|
|
STARPU_ASSERT(req);
|
|
@@ -219,7 +219,7 @@ int starpu_mpi_irecv(starpu_data_handle data_handle, starpu_mpi_req *public_req,
|
|
|
* Irecv (detached)
|
|
* Irecv (detached)
|
|
|
*/
|
|
*/
|
|
|
|
|
|
|
|
-int starpu_mpi_irecv_detached(starpu_data_handle data_handle, int source, int mpi_tag, MPI_Comm comm, void (*callback)(void *), void *arg)
|
|
|
|
|
|
|
+int starpu_mpi_irecv_detached(starpu_data_handle_t data_handle, int source, int mpi_tag, MPI_Comm comm, void (*callback)(void *), void *arg)
|
|
|
{
|
|
{
|
|
|
_STARPU_MPI_LOG_IN();
|
|
_STARPU_MPI_LOG_IN();
|
|
|
_starpu_mpi_irecv_common(data_handle, source, mpi_tag, comm, 1, callback, arg);
|
|
_starpu_mpi_irecv_common(data_handle, source, mpi_tag, comm, 1, callback, arg);
|
|
@@ -233,7 +233,7 @@ int starpu_mpi_irecv_detached(starpu_data_handle data_handle, int source, int mp
|
|
|
* Recv
|
|
* Recv
|
|
|
*/
|
|
*/
|
|
|
|
|
|
|
|
-int starpu_mpi_recv(starpu_data_handle data_handle, int source, int mpi_tag, MPI_Comm comm, MPI_Status *status)
|
|
|
|
|
|
|
+int starpu_mpi_recv(starpu_data_handle_t data_handle, int source, int mpi_tag, MPI_Comm comm, MPI_Status *status)
|
|
|
{
|
|
{
|
|
|
starpu_mpi_req req;
|
|
starpu_mpi_req req;
|
|
|
|
|
|
|
@@ -249,7 +249,7 @@ int starpu_mpi_recv(starpu_data_handle data_handle, int source, int mpi_tag, MPI
|
|
|
* Send
|
|
* Send
|
|
|
*/
|
|
*/
|
|
|
|
|
|
|
|
-int starpu_mpi_send(starpu_data_handle data_handle, int dest, int mpi_tag, MPI_Comm comm)
|
|
|
|
|
|
|
+int starpu_mpi_send(starpu_data_handle_t data_handle, int dest, int mpi_tag, MPI_Comm comm)
|
|
|
{
|
|
{
|
|
|
starpu_mpi_req req;
|
|
starpu_mpi_req req;
|
|
|
MPI_Status status;
|
|
MPI_Status status;
|
|
@@ -268,11 +268,11 @@ int starpu_mpi_send(starpu_data_handle data_handle, int dest, int mpi_tag, MPI_C
|
|
|
* Wait
|
|
* Wait
|
|
|
*/
|
|
*/
|
|
|
|
|
|
|
|
-static void starpu_mpi_wait_func(struct starpu_mpi_req_s *waiting_req)
|
|
|
|
|
|
|
+static void starpu_mpi_wait_func(struct _starpu_mpi_req *waiting_req)
|
|
|
{
|
|
{
|
|
|
_STARPU_MPI_LOG_IN();
|
|
_STARPU_MPI_LOG_IN();
|
|
|
/* Which is the mpi request we are waiting for ? */
|
|
/* Which is the mpi request we are waiting for ? */
|
|
|
- struct starpu_mpi_req_s *req = waiting_req->other_request;
|
|
|
|
|
|
|
+ struct _starpu_mpi_req *req = waiting_req->other_request;
|
|
|
|
|
|
|
|
req->ret = MPI_Wait(&req->request, waiting_req->status);
|
|
req->ret = MPI_Wait(&req->request, waiting_req->status);
|
|
|
STARPU_ASSERT(req->ret == MPI_SUCCESS);
|
|
STARPU_ASSERT(req->ret == MPI_SUCCESS);
|
|
@@ -285,22 +285,22 @@ int starpu_mpi_wait(starpu_mpi_req *public_req, MPI_Status *status)
|
|
|
{
|
|
{
|
|
|
_STARPU_MPI_LOG_IN();
|
|
_STARPU_MPI_LOG_IN();
|
|
|
int ret;
|
|
int ret;
|
|
|
- struct starpu_mpi_req_s *waiting_req = calloc(1, sizeof(struct starpu_mpi_req_s));
|
|
|
|
|
|
|
+ struct _starpu_mpi_req *waiting_req = calloc(1, sizeof(struct _starpu_mpi_req));
|
|
|
STARPU_ASSERT(waiting_req);
|
|
STARPU_ASSERT(waiting_req);
|
|
|
- struct starpu_mpi_req_s *req = *public_req;
|
|
|
|
|
|
|
+ struct _starpu_mpi_req *req = *public_req;
|
|
|
|
|
|
|
|
INC_POSTED_REQUESTS(1);
|
|
INC_POSTED_REQUESTS(1);
|
|
|
|
|
|
|
|
/* We cannot try to complete a MPI request that was not actually posted
|
|
/* We cannot try to complete a MPI request that was not actually posted
|
|
|
* to MPI yet. */
|
|
* to MPI yet. */
|
|
|
- PTHREAD_MUTEX_LOCK(&(req->req_mutex));
|
|
|
|
|
|
|
+ _STARPU_PTHREAD_MUTEX_LOCK(&(req->req_mutex));
|
|
|
while (!(req->submitted))
|
|
while (!(req->submitted))
|
|
|
- PTHREAD_COND_WAIT(&(req->req_cond), &(req->req_mutex));
|
|
|
|
|
- PTHREAD_MUTEX_UNLOCK(&(req->req_mutex));
|
|
|
|
|
|
|
+ _STARPU_PTHREAD_COND_WAIT(&(req->req_cond), &(req->req_mutex));
|
|
|
|
|
+ _STARPU_PTHREAD_MUTEX_UNLOCK(&(req->req_mutex));
|
|
|
|
|
|
|
|
/* Initialize the request structure */
|
|
/* Initialize the request structure */
|
|
|
- PTHREAD_MUTEX_INIT(&(waiting_req->req_mutex), NULL);
|
|
|
|
|
- PTHREAD_COND_INIT(&(waiting_req->req_cond), NULL);
|
|
|
|
|
|
|
+ _STARPU_PTHREAD_MUTEX_INIT(&(waiting_req->req_mutex), NULL);
|
|
|
|
|
+ _STARPU_PTHREAD_COND_INIT(&(waiting_req->req_cond), NULL);
|
|
|
waiting_req->status = status;
|
|
waiting_req->status = status;
|
|
|
waiting_req->other_request = req;
|
|
waiting_req->other_request = req;
|
|
|
waiting_req->func = starpu_mpi_wait_func;
|
|
waiting_req->func = starpu_mpi_wait_func;
|
|
@@ -309,10 +309,10 @@ int starpu_mpi_wait(starpu_mpi_req *public_req, MPI_Status *status)
|
|
|
submit_mpi_req(waiting_req);
|
|
submit_mpi_req(waiting_req);
|
|
|
|
|
|
|
|
/* We wait for the MPI request to finish */
|
|
/* We wait for the MPI request to finish */
|
|
|
- PTHREAD_MUTEX_LOCK(&req->req_mutex);
|
|
|
|
|
|
|
+ _STARPU_PTHREAD_MUTEX_LOCK(&req->req_mutex);
|
|
|
while (!req->completed)
|
|
while (!req->completed)
|
|
|
- PTHREAD_COND_WAIT(&req->req_cond, &req->req_mutex);
|
|
|
|
|
- PTHREAD_MUTEX_UNLOCK(&req->req_mutex);
|
|
|
|
|
|
|
+ _STARPU_PTHREAD_COND_WAIT(&req->req_cond, &req->req_mutex);
|
|
|
|
|
+ _STARPU_PTHREAD_MUTEX_UNLOCK(&req->req_mutex);
|
|
|
|
|
|
|
|
ret = req->ret;
|
|
ret = req->ret;
|
|
|
|
|
|
|
@@ -329,11 +329,11 @@ int starpu_mpi_wait(starpu_mpi_req *public_req, MPI_Status *status)
|
|
|
* Test
|
|
* Test
|
|
|
*/
|
|
*/
|
|
|
|
|
|
|
|
-static void starpu_mpi_test_func(struct starpu_mpi_req_s *testing_req)
|
|
|
|
|
|
|
+static void starpu_mpi_test_func(struct _starpu_mpi_req *testing_req)
|
|
|
{
|
|
{
|
|
|
_STARPU_MPI_LOG_IN();
|
|
_STARPU_MPI_LOG_IN();
|
|
|
/* Which is the mpi request we are testing for ? */
|
|
/* Which is the mpi request we are testing for ? */
|
|
|
- struct starpu_mpi_req_s *req = testing_req->other_request;
|
|
|
|
|
|
|
+ struct _starpu_mpi_req *req = testing_req->other_request;
|
|
|
|
|
|
|
|
_STARPU_MPI_DEBUG("Test request %p - mpitag %d - TYPE %s %d\n", &req->request, req->mpi_tag, (req->request_type == RECV_REQ)?"recv : source":"send : dest", req->srcdst);
|
|
_STARPU_MPI_DEBUG("Test request %p - mpitag %d - TYPE %s %d\n", &req->request, req->mpi_tag, (req->request_type == RECV_REQ)?"recv : source":"send : dest", req->srcdst);
|
|
|
req->ret = MPI_Test(&req->request, testing_req->flag, testing_req->status);
|
|
req->ret = MPI_Test(&req->request, testing_req->flag, testing_req->status);
|
|
@@ -345,10 +345,10 @@ static void starpu_mpi_test_func(struct starpu_mpi_req_s *testing_req)
|
|
|
handle_request_termination(req);
|
|
handle_request_termination(req);
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
- PTHREAD_MUTEX_LOCK(&testing_req->req_mutex);
|
|
|
|
|
|
|
+ _STARPU_PTHREAD_MUTEX_LOCK(&testing_req->req_mutex);
|
|
|
testing_req->completed = 1;
|
|
testing_req->completed = 1;
|
|
|
- PTHREAD_COND_SIGNAL(&testing_req->req_cond);
|
|
|
|
|
- PTHREAD_MUTEX_UNLOCK(&testing_req->req_mutex);
|
|
|
|
|
|
|
+ _STARPU_PTHREAD_COND_SIGNAL(&testing_req->req_cond);
|
|
|
|
|
+ _STARPU_PTHREAD_MUTEX_UNLOCK(&testing_req->req_mutex);
|
|
|
_STARPU_MPI_LOG_OUT();
|
|
_STARPU_MPI_LOG_OUT();
|
|
|
}
|
|
}
|
|
|
|
|
|
|
@@ -359,23 +359,23 @@ int starpu_mpi_test(starpu_mpi_req *public_req, int *flag, MPI_Status *status)
|
|
|
|
|
|
|
|
STARPU_ASSERT(public_req);
|
|
STARPU_ASSERT(public_req);
|
|
|
|
|
|
|
|
- struct starpu_mpi_req_s *req = *public_req;
|
|
|
|
|
|
|
+ struct _starpu_mpi_req *req = *public_req;
|
|
|
|
|
|
|
|
STARPU_ASSERT(!req->detached);
|
|
STARPU_ASSERT(!req->detached);
|
|
|
|
|
|
|
|
- PTHREAD_MUTEX_LOCK(&req->req_mutex);
|
|
|
|
|
|
|
+ _STARPU_PTHREAD_MUTEX_LOCK(&req->req_mutex);
|
|
|
unsigned submitted = req->submitted;
|
|
unsigned submitted = req->submitted;
|
|
|
- PTHREAD_MUTEX_UNLOCK(&req->req_mutex);
|
|
|
|
|
|
|
+ _STARPU_PTHREAD_MUTEX_UNLOCK(&req->req_mutex);
|
|
|
|
|
|
|
|
if (submitted)
|
|
if (submitted)
|
|
|
{
|
|
{
|
|
|
- struct starpu_mpi_req_s *testing_req = calloc(1, sizeof(struct starpu_mpi_req_s));
|
|
|
|
|
|
|
+ struct _starpu_mpi_req *testing_req = calloc(1, sizeof(struct _starpu_mpi_req));
|
|
|
STARPU_ASSERT(testing_req);
|
|
STARPU_ASSERT(testing_req);
|
|
|
- // memset(testing_req, 0, sizeof(struct starpu_mpi_req_s));
|
|
|
|
|
|
|
+ // memset(testing_req, 0, sizeof(struct _starpu_mpi_req));
|
|
|
|
|
|
|
|
/* Initialize the request structure */
|
|
/* Initialize the request structure */
|
|
|
- PTHREAD_MUTEX_INIT(&(testing_req->req_mutex), NULL);
|
|
|
|
|
- PTHREAD_COND_INIT(&(testing_req->req_cond), NULL);
|
|
|
|
|
|
|
+ _STARPU_PTHREAD_MUTEX_INIT(&(testing_req->req_mutex), NULL);
|
|
|
|
|
+ _STARPU_PTHREAD_COND_INIT(&(testing_req->req_cond), NULL);
|
|
|
testing_req->flag = flag;
|
|
testing_req->flag = flag;
|
|
|
testing_req->status = status;
|
|
testing_req->status = status;
|
|
|
testing_req->other_request = req;
|
|
testing_req->other_request = req;
|
|
@@ -387,10 +387,10 @@ int starpu_mpi_test(starpu_mpi_req *public_req, int *flag, MPI_Status *status)
|
|
|
submit_mpi_req(testing_req);
|
|
submit_mpi_req(testing_req);
|
|
|
|
|
|
|
|
/* We wait for the test request to finish */
|
|
/* We wait for the test request to finish */
|
|
|
- PTHREAD_MUTEX_LOCK(&(testing_req->req_mutex));
|
|
|
|
|
|
|
+ _STARPU_PTHREAD_MUTEX_LOCK(&(testing_req->req_mutex));
|
|
|
while (!(testing_req->completed))
|
|
while (!(testing_req->completed))
|
|
|
- PTHREAD_COND_WAIT(&(testing_req->req_cond), &(testing_req->req_mutex));
|
|
|
|
|
- PTHREAD_MUTEX_UNLOCK(&(testing_req->req_mutex));
|
|
|
|
|
|
|
+ _STARPU_PTHREAD_COND_WAIT(&(testing_req->req_cond), &(testing_req->req_mutex));
|
|
|
|
|
+ _STARPU_PTHREAD_MUTEX_UNLOCK(&(testing_req->req_mutex));
|
|
|
|
|
|
|
|
ret = testing_req->ret;
|
|
ret = testing_req->ret;
|
|
|
|
|
|
|
@@ -415,7 +415,7 @@ int starpu_mpi_test(starpu_mpi_req *public_req, int *flag, MPI_Status *status)
|
|
|
* Barrier
|
|
* Barrier
|
|
|
*/
|
|
*/
|
|
|
|
|
|
|
|
-static void starpu_mpi_barrier_func(struct starpu_mpi_req_s *barrier_req)
|
|
|
|
|
|
|
+static void starpu_mpi_barrier_func(struct _starpu_mpi_req *barrier_req)
|
|
|
{
|
|
{
|
|
|
_STARPU_MPI_LOG_IN();
|
|
_STARPU_MPI_LOG_IN();
|
|
|
|
|
|
|
@@ -430,12 +430,12 @@ int starpu_mpi_barrier(MPI_Comm comm)
|
|
|
{
|
|
{
|
|
|
_STARPU_MPI_LOG_IN();
|
|
_STARPU_MPI_LOG_IN();
|
|
|
int ret;
|
|
int ret;
|
|
|
- struct starpu_mpi_req_s *barrier_req = calloc(1, sizeof(struct starpu_mpi_req_s));
|
|
|
|
|
|
|
+ struct _starpu_mpi_req *barrier_req = calloc(1, sizeof(struct _starpu_mpi_req));
|
|
|
STARPU_ASSERT(barrier_req);
|
|
STARPU_ASSERT(barrier_req);
|
|
|
|
|
|
|
|
/* Initialize the request structure */
|
|
/* Initialize the request structure */
|
|
|
- PTHREAD_MUTEX_INIT(&(barrier_req->req_mutex), NULL);
|
|
|
|
|
- PTHREAD_COND_INIT(&(barrier_req->req_cond), NULL);
|
|
|
|
|
|
|
+ _STARPU_PTHREAD_MUTEX_INIT(&(barrier_req->req_mutex), NULL);
|
|
|
|
|
+ _STARPU_PTHREAD_COND_INIT(&(barrier_req->req_cond), NULL);
|
|
|
barrier_req->func = starpu_mpi_barrier_func;
|
|
barrier_req->func = starpu_mpi_barrier_func;
|
|
|
barrier_req->request_type = BARRIER_REQ;
|
|
barrier_req->request_type = BARRIER_REQ;
|
|
|
barrier_req->comm = comm;
|
|
barrier_req->comm = comm;
|
|
@@ -444,10 +444,10 @@ int starpu_mpi_barrier(MPI_Comm comm)
|
|
|
submit_mpi_req(barrier_req);
|
|
submit_mpi_req(barrier_req);
|
|
|
|
|
|
|
|
/* We wait for the MPI request to finish */
|
|
/* We wait for the MPI request to finish */
|
|
|
- PTHREAD_MUTEX_LOCK(&barrier_req->req_mutex);
|
|
|
|
|
|
|
+ _STARPU_PTHREAD_MUTEX_LOCK(&barrier_req->req_mutex);
|
|
|
while (!barrier_req->completed)
|
|
while (!barrier_req->completed)
|
|
|
- PTHREAD_COND_WAIT(&barrier_req->req_cond, &barrier_req->req_mutex);
|
|
|
|
|
- PTHREAD_MUTEX_UNLOCK(&barrier_req->req_mutex);
|
|
|
|
|
|
|
+ _STARPU_PTHREAD_COND_WAIT(&barrier_req->req_cond, &barrier_req->req_mutex);
|
|
|
|
|
+ _STARPU_PTHREAD_MUTEX_UNLOCK(&barrier_req->req_mutex);
|
|
|
|
|
|
|
|
ret = barrier_req->ret;
|
|
ret = barrier_req->ret;
|
|
|
|
|
|
|
@@ -475,7 +475,7 @@ static char *starpu_mpi_request_type(unsigned request_type)
|
|
|
}
|
|
}
|
|
|
#endif
|
|
#endif
|
|
|
|
|
|
|
|
-static void handle_request_termination(struct starpu_mpi_req_s *req)
|
|
|
|
|
|
|
+static void handle_request_termination(struct _starpu_mpi_req *req)
|
|
|
{
|
|
{
|
|
|
_STARPU_MPI_LOG_IN();
|
|
_STARPU_MPI_LOG_IN();
|
|
|
|
|
|
|
@@ -497,25 +497,25 @@ static void handle_request_termination(struct starpu_mpi_req_s *req)
|
|
|
|
|
|
|
|
/* tell anyone potentiallly waiting on the request that it is
|
|
/* tell anyone potentiallly waiting on the request that it is
|
|
|
* terminated now */
|
|
* terminated now */
|
|
|
- PTHREAD_MUTEX_LOCK(&req->req_mutex);
|
|
|
|
|
|
|
+ _STARPU_PTHREAD_MUTEX_LOCK(&req->req_mutex);
|
|
|
req->completed = 1;
|
|
req->completed = 1;
|
|
|
- PTHREAD_COND_BROADCAST(&req->req_cond);
|
|
|
|
|
- PTHREAD_MUTEX_UNLOCK(&req->req_mutex);
|
|
|
|
|
|
|
+ _STARPU_PTHREAD_COND_BROADCAST(&req->req_cond);
|
|
|
|
|
+ _STARPU_PTHREAD_MUTEX_UNLOCK(&req->req_mutex);
|
|
|
_STARPU_MPI_LOG_OUT();
|
|
_STARPU_MPI_LOG_OUT();
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
static void submit_mpi_req(void *arg)
|
|
static void submit_mpi_req(void *arg)
|
|
|
{
|
|
{
|
|
|
_STARPU_MPI_LOG_IN();
|
|
_STARPU_MPI_LOG_IN();
|
|
|
- struct starpu_mpi_req_s *req = arg;
|
|
|
|
|
|
|
+ struct _starpu_mpi_req *req = arg;
|
|
|
|
|
|
|
|
INC_POSTED_REQUESTS(-1);
|
|
INC_POSTED_REQUESTS(-1);
|
|
|
|
|
|
|
|
- PTHREAD_MUTEX_LOCK(&mutex);
|
|
|
|
|
- starpu_mpi_req_list_push_front(new_requests, req);
|
|
|
|
|
|
|
+ _STARPU_PTHREAD_MUTEX_LOCK(&mutex);
|
|
|
|
|
+ _starpu_mpi_req_list_push_front(new_requests, req);
|
|
|
_STARPU_MPI_DEBUG("Pushing new request type %d\n", req->request_type);
|
|
_STARPU_MPI_DEBUG("Pushing new request type %d\n", req->request_type);
|
|
|
- PTHREAD_COND_BROADCAST(&cond);
|
|
|
|
|
- PTHREAD_MUTEX_UNLOCK(&mutex);
|
|
|
|
|
|
|
+ _STARPU_PTHREAD_COND_BROADCAST(&cond);
|
|
|
|
|
+ _STARPU_PTHREAD_MUTEX_UNLOCK(&mutex);
|
|
|
_STARPU_MPI_LOG_OUT();
|
|
_STARPU_MPI_LOG_OUT();
|
|
|
}
|
|
}
|
|
|
|
|
|
|
@@ -528,13 +528,13 @@ static unsigned progression_hook_func(void *arg __attribute__((unused)))
|
|
|
{
|
|
{
|
|
|
unsigned may_block = 1;
|
|
unsigned may_block = 1;
|
|
|
|
|
|
|
|
- PTHREAD_MUTEX_LOCK(&mutex);
|
|
|
|
|
- if (!starpu_mpi_req_list_empty(detached_requests))
|
|
|
|
|
|
|
+ _STARPU_PTHREAD_MUTEX_LOCK(&mutex);
|
|
|
|
|
+ if (!_starpu_mpi_req_list_empty(detached_requests))
|
|
|
{
|
|
{
|
|
|
- PTHREAD_COND_SIGNAL(&cond);
|
|
|
|
|
|
|
+ _STARPU_PTHREAD_COND_SIGNAL(&cond);
|
|
|
may_block = 0;
|
|
may_block = 0;
|
|
|
}
|
|
}
|
|
|
- PTHREAD_MUTEX_UNLOCK(&mutex);
|
|
|
|
|
|
|
+ _STARPU_PTHREAD_MUTEX_UNLOCK(&mutex);
|
|
|
|
|
|
|
|
return may_block;
|
|
return may_block;
|
|
|
}
|
|
}
|
|
@@ -549,17 +549,17 @@ static void test_detached_requests(void)
|
|
|
_STARPU_MPI_LOG_IN();
|
|
_STARPU_MPI_LOG_IN();
|
|
|
int flag;
|
|
int flag;
|
|
|
MPI_Status status;
|
|
MPI_Status status;
|
|
|
- struct starpu_mpi_req_s *req, *next_req;
|
|
|
|
|
|
|
+ struct _starpu_mpi_req *req, *next_req;
|
|
|
|
|
|
|
|
- PTHREAD_MUTEX_LOCK(&detached_requests_mutex);
|
|
|
|
|
|
|
+ _STARPU_PTHREAD_MUTEX_LOCK(&detached_requests_mutex);
|
|
|
|
|
|
|
|
- for (req = starpu_mpi_req_list_begin(detached_requests);
|
|
|
|
|
- req != starpu_mpi_req_list_end(detached_requests);
|
|
|
|
|
|
|
+ for (req = _starpu_mpi_req_list_begin(detached_requests);
|
|
|
|
|
+ req != _starpu_mpi_req_list_end(detached_requests);
|
|
|
req = next_req)
|
|
req = next_req)
|
|
|
{
|
|
{
|
|
|
- next_req = starpu_mpi_req_list_next(req);
|
|
|
|
|
|
|
+ next_req = _starpu_mpi_req_list_next(req);
|
|
|
|
|
|
|
|
- PTHREAD_MUTEX_UNLOCK(&detached_requests_mutex);
|
|
|
|
|
|
|
+ _STARPU_PTHREAD_MUTEX_UNLOCK(&detached_requests_mutex);
|
|
|
|
|
|
|
|
//_STARPU_MPI_DEBUG("Test detached request %p - mpitag %d - TYPE %s %d\n", &req->request, req->mpi_tag, (req->request_type == RECV_REQ)?"recv : source":"send : dest", req->srcdst);
|
|
//_STARPU_MPI_DEBUG("Test detached request %p - mpitag %d - TYPE %s %d\n", &req->request, req->mpi_tag, (req->request_type == RECV_REQ)?"recv : source":"send : dest", req->srcdst);
|
|
|
req->ret = MPI_Test(&req->request, &flag, &status);
|
|
req->ret = MPI_Test(&req->request, &flag, &status);
|
|
@@ -570,10 +570,10 @@ static void test_detached_requests(void)
|
|
|
handle_request_termination(req);
|
|
handle_request_termination(req);
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
- PTHREAD_MUTEX_LOCK(&detached_requests_mutex);
|
|
|
|
|
|
|
+ _STARPU_PTHREAD_MUTEX_LOCK(&detached_requests_mutex);
|
|
|
|
|
|
|
|
if (flag)
|
|
if (flag)
|
|
|
- starpu_mpi_req_list_erase(detached_requests, req);
|
|
|
|
|
|
|
+ _starpu_mpi_req_list_erase(detached_requests, req);
|
|
|
|
|
|
|
|
#ifdef STARPU_DEVEL
|
|
#ifdef STARPU_DEVEL
|
|
|
#warning TODO fix memleak
|
|
#warning TODO fix memleak
|
|
@@ -583,11 +583,11 @@ static void test_detached_requests(void)
|
|
|
// free(req);
|
|
// free(req);
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
- PTHREAD_MUTEX_UNLOCK(&detached_requests_mutex);
|
|
|
|
|
|
|
+ _STARPU_PTHREAD_MUTEX_UNLOCK(&detached_requests_mutex);
|
|
|
_STARPU_MPI_LOG_OUT();
|
|
_STARPU_MPI_LOG_OUT();
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
-static void handle_new_request(struct starpu_mpi_req_s *req)
|
|
|
|
|
|
|
+static void handle_new_request(struct _starpu_mpi_req *req)
|
|
|
{
|
|
{
|
|
|
_STARPU_MPI_LOG_IN();
|
|
_STARPU_MPI_LOG_IN();
|
|
|
STARPU_ASSERT(req);
|
|
STARPU_ASSERT(req);
|
|
@@ -598,17 +598,17 @@ static void handle_new_request(struct starpu_mpi_req_s *req)
|
|
|
|
|
|
|
|
if (req->detached)
|
|
if (req->detached)
|
|
|
{
|
|
{
|
|
|
- PTHREAD_MUTEX_LOCK(&mutex);
|
|
|
|
|
- starpu_mpi_req_list_push_front(detached_requests, req);
|
|
|
|
|
- PTHREAD_MUTEX_UNLOCK(&mutex);
|
|
|
|
|
|
|
+ _STARPU_PTHREAD_MUTEX_LOCK(&mutex);
|
|
|
|
|
+ _starpu_mpi_req_list_push_front(detached_requests, req);
|
|
|
|
|
+ _STARPU_PTHREAD_MUTEX_UNLOCK(&mutex);
|
|
|
|
|
|
|
|
starpu_wake_all_blocked_workers();
|
|
starpu_wake_all_blocked_workers();
|
|
|
|
|
|
|
|
/* put the submitted request into the list of pending requests
|
|
/* put the submitted request into the list of pending requests
|
|
|
* so that it can be handled by the progression mechanisms */
|
|
* so that it can be handled by the progression mechanisms */
|
|
|
- PTHREAD_MUTEX_LOCK(&mutex);
|
|
|
|
|
- PTHREAD_COND_SIGNAL(&cond);
|
|
|
|
|
- PTHREAD_MUTEX_UNLOCK(&mutex);
|
|
|
|
|
|
|
+ _STARPU_PTHREAD_MUTEX_LOCK(&mutex);
|
|
|
|
|
+ _STARPU_PTHREAD_COND_SIGNAL(&cond);
|
|
|
|
|
+ _STARPU_PTHREAD_MUTEX_UNLOCK(&mutex);
|
|
|
}
|
|
}
|
|
|
_STARPU_MPI_LOG_OUT();
|
|
_STARPU_MPI_LOG_OUT();
|
|
|
}
|
|
}
|
|
@@ -638,49 +638,49 @@ static void *progress_thread_func(void *arg)
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
/* notify the main thread that the progression thread is ready */
|
|
/* notify the main thread that the progression thread is ready */
|
|
|
- PTHREAD_MUTEX_LOCK(&mutex);
|
|
|
|
|
|
|
+ _STARPU_PTHREAD_MUTEX_LOCK(&mutex);
|
|
|
running = 1;
|
|
running = 1;
|
|
|
- PTHREAD_COND_SIGNAL(&cond);
|
|
|
|
|
- PTHREAD_MUTEX_UNLOCK(&mutex);
|
|
|
|
|
|
|
+ _STARPU_PTHREAD_COND_SIGNAL(&cond);
|
|
|
|
|
+ _STARPU_PTHREAD_MUTEX_UNLOCK(&mutex);
|
|
|
|
|
|
|
|
- PTHREAD_MUTEX_LOCK(&mutex);
|
|
|
|
|
- while (running || posted_requests || !(starpu_mpi_req_list_empty(new_requests)) || !(starpu_mpi_req_list_empty(detached_requests))) {
|
|
|
|
|
|
|
+ _STARPU_PTHREAD_MUTEX_LOCK(&mutex);
|
|
|
|
|
+ while (running || posted_requests || !(_starpu_mpi_req_list_empty(new_requests)) || !(_starpu_mpi_req_list_empty(detached_requests))) {
|
|
|
/* shall we block ? */
|
|
/* shall we block ? */
|
|
|
- unsigned block = starpu_mpi_req_list_empty(new_requests);
|
|
|
|
|
|
|
+ unsigned block = _starpu_mpi_req_list_empty(new_requests);
|
|
|
|
|
|
|
|
#ifndef USE_STARPU_ACTIVITY
|
|
#ifndef USE_STARPU_ACTIVITY
|
|
|
- block = block && starpu_mpi_req_list_empty(detached_requests);
|
|
|
|
|
|
|
+ block = block && _starpu_mpi_req_list_empty(detached_requests);
|
|
|
#endif
|
|
#endif
|
|
|
|
|
|
|
|
if (block)
|
|
if (block)
|
|
|
{
|
|
{
|
|
|
_STARPU_MPI_DEBUG("NO MORE REQUESTS TO HANDLE\n");
|
|
_STARPU_MPI_DEBUG("NO MORE REQUESTS TO HANDLE\n");
|
|
|
- PTHREAD_COND_WAIT(&cond, &mutex);
|
|
|
|
|
|
|
+ _STARPU_PTHREAD_COND_WAIT(&cond, &mutex);
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
/* test whether there are some terminated "detached request" */
|
|
/* test whether there are some terminated "detached request" */
|
|
|
- PTHREAD_MUTEX_UNLOCK(&mutex);
|
|
|
|
|
|
|
+ _STARPU_PTHREAD_MUTEX_UNLOCK(&mutex);
|
|
|
test_detached_requests();
|
|
test_detached_requests();
|
|
|
- PTHREAD_MUTEX_LOCK(&mutex);
|
|
|
|
|
|
|
+ _STARPU_PTHREAD_MUTEX_LOCK(&mutex);
|
|
|
|
|
|
|
|
/* get one request */
|
|
/* get one request */
|
|
|
- struct starpu_mpi_req_s *req;
|
|
|
|
|
- while (!starpu_mpi_req_list_empty(new_requests))
|
|
|
|
|
|
|
+ struct _starpu_mpi_req *req;
|
|
|
|
|
+ while (!_starpu_mpi_req_list_empty(new_requests))
|
|
|
{
|
|
{
|
|
|
- req = starpu_mpi_req_list_pop_back(new_requests);
|
|
|
|
|
|
|
+ req = _starpu_mpi_req_list_pop_back(new_requests);
|
|
|
|
|
|
|
|
/* handling a request is likely to block for a while
|
|
/* handling a request is likely to block for a while
|
|
|
* (on a sync_data_with_mem call), we want to let the
|
|
* (on a sync_data_with_mem call), we want to let the
|
|
|
* application submit requests in the meantime, so we
|
|
* application submit requests in the meantime, so we
|
|
|
* release the lock. */
|
|
* release the lock. */
|
|
|
- PTHREAD_MUTEX_UNLOCK(&mutex);
|
|
|
|
|
|
|
+ _STARPU_PTHREAD_MUTEX_UNLOCK(&mutex);
|
|
|
handle_new_request(req);
|
|
handle_new_request(req);
|
|
|
- PTHREAD_MUTEX_LOCK(&mutex);
|
|
|
|
|
|
|
+ _STARPU_PTHREAD_MUTEX_LOCK(&mutex);
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
- STARPU_ASSERT(starpu_mpi_req_list_empty(detached_requests));
|
|
|
|
|
- STARPU_ASSERT(starpu_mpi_req_list_empty(new_requests));
|
|
|
|
|
|
|
+ STARPU_ASSERT(_starpu_mpi_req_list_empty(detached_requests));
|
|
|
|
|
+ STARPU_ASSERT(_starpu_mpi_req_list_empty(new_requests));
|
|
|
STARPU_ASSERT(posted_requests == 0);
|
|
STARPU_ASSERT(posted_requests == 0);
|
|
|
|
|
|
|
|
if (initialize_mpi) {
|
|
if (initialize_mpi) {
|
|
@@ -688,7 +688,7 @@ static void *progress_thread_func(void *arg)
|
|
|
MPI_Finalize();
|
|
MPI_Finalize();
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
- PTHREAD_MUTEX_UNLOCK(&mutex);
|
|
|
|
|
|
|
+ _STARPU_PTHREAD_MUTEX_UNLOCK(&mutex);
|
|
|
|
|
|
|
|
return NULL;
|
|
return NULL;
|
|
|
}
|
|
}
|
|
@@ -735,21 +735,21 @@ static void _starpu_mpi_add_sync_point_in_fxt(void)
|
|
|
static
|
|
static
|
|
|
int _starpu_mpi_initialize(int initialize_mpi, int *rank, int *world_size)
|
|
int _starpu_mpi_initialize(int initialize_mpi, int *rank, int *world_size)
|
|
|
{
|
|
{
|
|
|
- PTHREAD_MUTEX_INIT(&mutex, NULL);
|
|
|
|
|
- PTHREAD_COND_INIT(&cond, NULL);
|
|
|
|
|
- new_requests = starpu_mpi_req_list_new();
|
|
|
|
|
|
|
+ _STARPU_PTHREAD_MUTEX_INIT(&mutex, NULL);
|
|
|
|
|
+ _STARPU_PTHREAD_COND_INIT(&cond, NULL);
|
|
|
|
|
+ new_requests = _starpu_mpi_req_list_new();
|
|
|
|
|
|
|
|
- PTHREAD_MUTEX_INIT(&detached_requests_mutex, NULL);
|
|
|
|
|
- detached_requests = starpu_mpi_req_list_new();
|
|
|
|
|
|
|
+ _STARPU_PTHREAD_MUTEX_INIT(&detached_requests_mutex, NULL);
|
|
|
|
|
+ detached_requests = _starpu_mpi_req_list_new();
|
|
|
|
|
|
|
|
- PTHREAD_MUTEX_INIT(&mutex_posted_requests, NULL);
|
|
|
|
|
|
|
+ _STARPU_PTHREAD_MUTEX_INIT(&mutex_posted_requests, NULL);
|
|
|
|
|
|
|
|
pthread_create(&progress_thread, NULL, progress_thread_func, (void *)&initialize_mpi);
|
|
pthread_create(&progress_thread, NULL, progress_thread_func, (void *)&initialize_mpi);
|
|
|
|
|
|
|
|
- PTHREAD_MUTEX_LOCK(&mutex);
|
|
|
|
|
|
|
+ _STARPU_PTHREAD_MUTEX_LOCK(&mutex);
|
|
|
while (!running)
|
|
while (!running)
|
|
|
- PTHREAD_COND_WAIT(&cond, &mutex);
|
|
|
|
|
- PTHREAD_MUTEX_UNLOCK(&mutex);
|
|
|
|
|
|
|
+ _STARPU_PTHREAD_COND_WAIT(&cond, &mutex);
|
|
|
|
|
+ _STARPU_PTHREAD_MUTEX_UNLOCK(&mutex);
|
|
|
|
|
|
|
|
if (rank && world_size) {
|
|
if (rank && world_size) {
|
|
|
_STARPU_DEBUG("Calling MPI_Comm_rank\n");
|
|
_STARPU_DEBUG("Calling MPI_Comm_rank\n");
|
|
@@ -788,10 +788,10 @@ int starpu_mpi_shutdown(void)
|
|
|
void *value;
|
|
void *value;
|
|
|
|
|
|
|
|
/* kill the progression thread */
|
|
/* kill the progression thread */
|
|
|
- PTHREAD_MUTEX_LOCK(&mutex);
|
|
|
|
|
|
|
+ _STARPU_PTHREAD_MUTEX_LOCK(&mutex);
|
|
|
running = 0;
|
|
running = 0;
|
|
|
- PTHREAD_COND_BROADCAST(&cond);
|
|
|
|
|
- PTHREAD_MUTEX_UNLOCK(&mutex);
|
|
|
|
|
|
|
+ _STARPU_PTHREAD_COND_BROADCAST(&cond);
|
|
|
|
|
+ _STARPU_PTHREAD_MUTEX_UNLOCK(&mutex);
|
|
|
|
|
|
|
|
pthread_join(progress_thread, &value);
|
|
pthread_join(progress_thread, &value);
|
|
|
|
|
|
|
@@ -800,8 +800,8 @@ int starpu_mpi_shutdown(void)
|
|
|
#endif
|
|
#endif
|
|
|
|
|
|
|
|
/* free the request queues */
|
|
/* free the request queues */
|
|
|
- starpu_mpi_req_list_delete(detached_requests);
|
|
|
|
|
- starpu_mpi_req_list_delete(new_requests);
|
|
|
|
|
|
|
+ _starpu_mpi_req_list_delete(detached_requests);
|
|
|
|
|
+ _starpu_mpi_req_list_delete(new_requests);
|
|
|
|
|
|
|
|
return 0;
|
|
return 0;
|
|
|
}
|
|
}
|