More object fixes
This commit was SVN r682.
Этот коммит содержится в:
родитель
6453116b31
Коммит
7812efa3ce
@ -116,12 +116,11 @@ int mca_pml_teg_add_procs(lam_proc_t** procs, size_t nprocs)
|
|||||||
if(proc_pml == 0) {
|
if(proc_pml == 0) {
|
||||||
|
|
||||||
/* allocate pml specific proc data */
|
/* allocate pml specific proc data */
|
||||||
proc_pml = malloc(sizeof(mca_pml_proc_t));
|
proc_pml = OBJ_NEW(mca_pml_teg_proc_t);
|
||||||
if (NULL == proc_pml) {
|
if (NULL == proc_pml) {
|
||||||
lam_output(0, "mca_pml_teg_add_procs: unable to allocate resources");
|
lam_output(0, "mca_pml_teg_add_procs: unable to allocate resources");
|
||||||
return LAM_ERR_OUT_OF_RESOURCE;
|
return LAM_ERR_OUT_OF_RESOURCE;
|
||||||
}
|
}
|
||||||
mca_pml_teg_proc_init(proc_pml);
|
|
||||||
|
|
||||||
/* preallocate space in array for max number of ptls */
|
/* preallocate space in array for max number of ptls */
|
||||||
mca_ptl_array_reserve(&proc_pml->proc_ptl_first, mca_pml_teg.teg_num_ptls);
|
mca_ptl_array_reserve(&proc_pml->proc_ptl_first, mca_pml_teg.teg_num_ptls);
|
||||||
@ -256,7 +255,7 @@ int mca_pml_teg_del_procs(lam_proc_t** procs, size_t nprocs)
|
|||||||
return LAM_SUCCESS;
|
return LAM_SUCCESS;
|
||||||
}
|
}
|
||||||
|
|
||||||
int mca_pml_teg_module_destruct(void)
|
int mca_pml_teg_module_fini(void)
|
||||||
{
|
{
|
||||||
/* FIX */
|
/* FIX */
|
||||||
return LAM_SUCCESS;
|
return LAM_SUCCESS;
|
||||||
|
@ -11,8 +11,6 @@
|
|||||||
#include "mpi/proc/proc.h"
|
#include "mpi/proc/proc.h"
|
||||||
#include "pml_ptl_array.h"
|
#include "pml_ptl_array.h"
|
||||||
|
|
||||||
extern lam_class_info_t mca_pml_teg_proc_t_class_info;
|
|
||||||
|
|
||||||
/*
|
/*
|
||||||
* Structure associated w/ lam_proc_t that contains data specific
|
* Structure associated w/ lam_proc_t that contains data specific
|
||||||
* to the PML. Note that this name is not PML specific.
|
* to the PML. Note that this name is not PML specific.
|
||||||
@ -28,6 +26,10 @@ struct mca_pml_proc_t {
|
|||||||
typedef struct mca_pml_proc_t mca_pml_proc_t;
|
typedef struct mca_pml_proc_t mca_pml_proc_t;
|
||||||
|
|
||||||
|
|
||||||
|
extern lam_class_info_t mca_pml_teg_proc_t_class_info;
|
||||||
|
typedef struct mca_pml_proc_t mca_pml_teg_proc_t;
|
||||||
|
|
||||||
|
|
||||||
void mca_pml_teg_proc_construct(mca_pml_proc_t*);
|
void mca_pml_teg_proc_construct(mca_pml_proc_t*);
|
||||||
void mca_pml_teg_proc_destruct(mca_pml_proc_t*);
|
void mca_pml_teg_proc_destruct(mca_pml_proc_t*);
|
||||||
|
|
||||||
|
@ -101,6 +101,8 @@ int lam_mpi_init(int argc, char **argv, int requested, int *provided)
|
|||||||
/* Setup MPI_COMM_SELF */
|
/* Setup MPI_COMM_SELF */
|
||||||
|
|
||||||
lam_comm_init(MPI_COMM_SELF);
|
lam_comm_init(MPI_COMM_SELF);
|
||||||
|
#else
|
||||||
|
lam_comm_link_function();
|
||||||
#endif
|
#endif
|
||||||
|
|
||||||
/* All done */
|
/* All done */
|
||||||
|
Загрузка…
x
Ссылка в новой задаче
Block a user