ports/openmpi
ports/openmpi
1
1
Форкнуть 0
Код Релизы Активность

Passing NULL to pthread_exit() is verbotten.

Просмотр исходного кода 
This commit was SVN r15661.
Этот коммит содержится в:
Jeff Squyres 2007-07-27 01:06:36 +00:00
родитель 0b6d77f247
Коммит cae00d1854
1 изменённых файлов: 10 добавлений и 6 удалений
Показать статистику Скачать Patch файл Скачать Diff файл Показать все файлы Свернуть все файлы

16
ompi/mca/btl/openib/btl_openib_async.c
Просмотреть файл

@ -1,5 +1,6 @@
/*
* Copyright (c) 2007 Mellanox Technologies. All rights reserved.
* Copyright (c) 2007 Cisco, Inc. All rights reserved.
* $COPYRIGHT$
*
* Additional copyrights may follow
@ -33,6 +34,8 @@ struct mca_btl_openib_async_poll {
};
typedef struct mca_btl_openib_async_poll mca_btl_openib_async_poll;
static int return_status = OMPI_ERROR;
static int btl_openib_async_poll_init(struct mca_btl_openib_async_poll *hcas_poll);
static int btl_openib_async_commandh(struct mca_btl_openib_async_poll *hcas_poll);
static int btl_openib_async_hcah(struct mca_btl_openib_async_poll *hcas_poll, int index);
@ -170,7 +173,8 @@ static int btl_openib_async_commandh(struct mca_btl_openib_async_poll *hcas_poll
/* Got 0 - command to close the thread */
BTL_VERBOSE(("Async event thread exit"));
free(hcas_poll->async_pollfd);
pthread_exit(NULL);
return_status = OMPI_SUCCESS;
pthread_exit(&return_status);
}
return OMPI_SUCCESS;
}
@ -258,7 +262,7 @@ void* btl_openib_async_thread(void * async)
if (OMPI_SUCCESS != btl_openib_async_poll_init(&hcas_poll)) {
BTL_ERROR(("Fatal error, stoping asyn event thread"));
pthread_exit(NULL);
pthread_exit(&return_status);
}
while(1) {
@ -266,7 +270,7 @@ void* btl_openib_async_thread(void * async)
if (rc < 0) {
if (errno != EINTR) {
BTL_ERROR(("Poll failed.Fatal error, stoping asyn event thread"));
pthread_exit(NULL);
pthread_exit(&return_status);
} else {
/* EINTR - we got interupt */
continue;
@ -285,7 +289,7 @@ void* btl_openib_async_thread(void * async)
free(hcas_poll.async_pollfd);
BTL_ERROR(("Failed to process async thread process."
"Fatal error, stoping asyn event thread"));
pthread_exit(NULL);
pthread_exit(&return_status);
}
} else {
/* We get hca event */
@ -293,7 +297,7 @@ void* btl_openib_async_thread(void * async)
free(hcas_poll.async_pollfd);
BTL_ERROR(("Failed to process async thread process."
"Fatal error, stoping asyn event thread"));
pthread_exit(NULL);
pthread_exit(&return_status);
}
}
break;
@ -304,7 +308,7 @@ void* btl_openib_async_thread(void * async)
"Fatal error, stoping asyn event thread"
,hcas_poll.async_pollfd[i].revents));
free(hcas_poll.async_pollfd);
pthread_exit(NULL);
pthread_exit(&return_status);
}
}
}