correctly decrement progress_event if tcp is not being
used so that tcp doesn't impact progress loop This commit was SVN r7078.
Этот коммит содержится в:
родитель
7a4013dcdf
Коммит
d34e299829
@ -123,9 +123,18 @@ int mca_btl_tcp_add_procs(
|
||||
int mca_btl_tcp_del_procs(struct mca_btl_base_module_t* btl,
|
||||
size_t nprocs,
|
||||
struct ompi_proc_t **procs,
|
||||
struct mca_btl_base_endpoint_t ** peers)
|
||||
struct mca_btl_base_endpoint_t ** endpoints)
|
||||
{
|
||||
/* TODO */
|
||||
mca_btl_tcp_module_t* tcp_btl = (mca_btl_tcp_module_t*)btl;
|
||||
size_t i;
|
||||
for(i=0; i<nprocs; i++) {
|
||||
mca_btl_tcp_endpoint_t* tcp_endpoint = endpoints[i];
|
||||
if(tcp_endpoint->endpoint_proc != mca_btl_tcp_proc_local()) {
|
||||
opal_list_remove_item(&tcp_btl->tcp_endpoints, (opal_list_item_t*)tcp_endpoint);
|
||||
OBJ_RELEASE(tcp_endpoint);
|
||||
}
|
||||
opal_progress_event_decrement();
|
||||
}
|
||||
return OMPI_SUCCESS;
|
||||
}
|
||||
|
||||
|
Загрузка…
Ссылка в новой задаче
Block a user