- fixed issue w/ module close
This commit was SVN r654.
Этот коммит содержится в:
родитель
086fa5b7cb
Коммит
8947cebc8d
@ -59,6 +59,8 @@ static inline int mca_pml_teg_param_register_int(
|
||||
|
||||
int mca_pml_teg_module_open(void)
|
||||
{
|
||||
STATIC_INIT(mca_pml_teg.teg_recv_requests, &lam_free_list_cls);
|
||||
STATIC_INIT(mca_pml_teg.teg_procs, &lam_list_cls);
|
||||
mca_pml_teg.teg_free_list_num =
|
||||
mca_pml_teg_param_register_int("free_list_num", 256);
|
||||
mca_pml_teg.teg_free_list_max =
|
||||
@ -94,7 +96,6 @@ mca_pml_t* mca_pml_teg_module_init(int* priority,
|
||||
mca_pml_teg.teg_ptls = NULL;
|
||||
mca_pml_teg.teg_num_ptls = 0;
|
||||
|
||||
STATIC_INIT(mca_pml_teg.teg_recv_requests, &lam_free_list_cls);
|
||||
lam_free_list_init_with(
|
||||
&mca_pml_teg.teg_recv_requests,
|
||||
sizeof(mca_ptl_base_recv_request_t),
|
||||
@ -104,7 +105,6 @@ mca_pml_t* mca_pml_teg_module_init(int* priority,
|
||||
mca_pml_teg.teg_free_list_inc,
|
||||
NULL);
|
||||
|
||||
STATIC_INIT(mca_pml_teg.teg_procs, &lam_list_cls);
|
||||
lam_mutex_init(&mca_pml_teg.teg_lock);
|
||||
mca_pml_teg.teg_recv_sequence = 0;
|
||||
return &mca_pml_teg.super;
|
||||
|
@ -102,6 +102,13 @@ static inline int mca_ptl_tcp_param_register_int(
|
||||
|
||||
int mca_ptl_tcp_module_open(void)
|
||||
{
|
||||
lam_mutex_init(&mca_ptl_tcp_module.tcp_lock);
|
||||
STATIC_INIT(mca_ptl_tcp_module.tcp_reactor, &lam_reactor_cls);
|
||||
STATIC_INIT(mca_ptl_tcp_module.tcp_procs, &lam_list_cls);
|
||||
STATIC_INIT(mca_ptl_tcp_module.tcp_send_requests, &lam_free_list_cls);
|
||||
STATIC_INIT(mca_ptl_tcp_module.tcp_send_frags, &lam_free_list_cls);
|
||||
STATIC_INIT(mca_ptl_tcp_module.tcp_recv_frags, &lam_free_list_cls);
|
||||
|
||||
/* register TCP module parameters */
|
||||
mca_ptl_tcp_module.tcp_if_include =
|
||||
mca_ptl_tcp_param_register_string("if_include", "");
|
||||
@ -282,13 +289,8 @@ mca_ptl_t** mca_ptl_tcp_module_init(int *num_ptls,
|
||||
*allow_multi_user_threads = true;
|
||||
*have_hidden_threads = false;
|
||||
|
||||
/* initialize containers */
|
||||
STATIC_INIT(mca_ptl_tcp_module.tcp_reactor, &lam_reactor_cls);
|
||||
STATIC_INIT(mca_ptl_tcp_module.tcp_procs, &lam_list_cls);
|
||||
lam_mutex_init(&mca_ptl_tcp_module.tcp_lock);
|
||||
|
||||
/* initialize free lists */
|
||||
STATIC_INIT(mca_ptl_tcp_module.tcp_send_requests, &lam_free_list_cls);
|
||||
lam_free_list_init_with(&mca_ptl_tcp_module.tcp_send_requests,
|
||||
sizeof(mca_ptl_tcp_send_request_t),
|
||||
&mca_ptl_tcp_send_request_cls,
|
||||
@ -297,7 +299,6 @@ mca_ptl_t** mca_ptl_tcp_module_init(int *num_ptls,
|
||||
mca_ptl_tcp_module.tcp_free_list_inc,
|
||||
NULL); /* use default allocator */
|
||||
|
||||
STATIC_INIT(mca_ptl_tcp_module.tcp_send_frags, &lam_free_list_cls);
|
||||
lam_free_list_init_with(&mca_ptl_tcp_module.tcp_send_frags,
|
||||
sizeof(mca_ptl_tcp_send_frag_t),
|
||||
&mca_ptl_tcp_send_frag_cls,
|
||||
@ -306,7 +307,6 @@ mca_ptl_t** mca_ptl_tcp_module_init(int *num_ptls,
|
||||
mca_ptl_tcp_module.tcp_free_list_inc,
|
||||
NULL); /* use default allocator */
|
||||
|
||||
STATIC_INIT(mca_ptl_tcp_module.tcp_recv_frags, &lam_free_list_cls);
|
||||
lam_free_list_init_with(&mca_ptl_tcp_module.tcp_recv_frags,
|
||||
sizeof(mca_ptl_tcp_recv_frag_t),
|
||||
&mca_ptl_tcp_recv_frag_cls,
|
||||
|
Загрузка…
x
Ссылка в новой задаче
Block a user