forgot to add struct prefi .. sorry ... my bad
This commit was SVN r3402.
Этот коммит содержится в:
родитель
18b1157610
Коммит
d8294afea9
@ -76,7 +76,7 @@ mca_oob_tcp_addr_t* mca_oob_tcp_addr_unpack(ompi_buffer_t buffer)
|
|||||||
ompi_unpack(buffer, &addr->addr_name, 1, OMPI_NAME);
|
ompi_unpack(buffer, &addr->addr_name, 1, OMPI_NAME);
|
||||||
ompi_unpack(buffer, &addr->addr_count, 1, OMPI_INT32);
|
ompi_unpack(buffer, &addr->addr_count, 1, OMPI_INT32);
|
||||||
if(addr->addr_count != 0) {
|
if(addr->addr_count != 0) {
|
||||||
addr->addr_inet = (sockaddr_in *)malloc(sizeof(struct sockaddr_in) * addr->addr_count);
|
addr->addr_inet = (struct sockaddr_in *)malloc(sizeof(struct sockaddr_in) * addr->addr_count);
|
||||||
if(NULL == addr->addr_inet) {
|
if(NULL == addr->addr_inet) {
|
||||||
OBJ_RELEASE(addr);
|
OBJ_RELEASE(addr);
|
||||||
return NULL;
|
return NULL;
|
||||||
@ -103,10 +103,10 @@ int mca_oob_tcp_addr_insert(mca_oob_tcp_addr_t* addr, const struct sockaddr_in*
|
|||||||
{
|
{
|
||||||
if(addr->addr_alloc == 0) {
|
if(addr->addr_alloc == 0) {
|
||||||
addr->addr_alloc = 2;
|
addr->addr_alloc = 2;
|
||||||
addr->addr_inet = (sockaddr_in *)malloc(addr->addr_alloc * sizeof(struct sockaddr_in));
|
addr->addr_inet = (struct sockaddr_in *)malloc(addr->addr_alloc * sizeof(struct sockaddr_in));
|
||||||
} else if(addr->addr_count == addr->addr_alloc) {
|
} else if(addr->addr_count == addr->addr_alloc) {
|
||||||
addr->addr_alloc <<= 1;
|
addr->addr_alloc <<= 1;
|
||||||
addr->addr_inet = (sockaddr_in *)realloc(addr->addr_inet, addr->addr_alloc * sizeof(struct sockaddr_in));
|
addr->addr_inet = (struct sockaddr_in *)realloc(addr->addr_inet, addr->addr_alloc * sizeof(struct sockaddr_in));
|
||||||
}
|
}
|
||||||
if(NULL == addr->addr_inet)
|
if(NULL == addr->addr_inet)
|
||||||
return OMPI_ERR_OUT_OF_RESOURCE;
|
return OMPI_ERR_OUT_OF_RESOURCE;
|
||||||
|
@ -191,7 +191,7 @@ int mca_pml_teg_add_procs(ompi_proc_t** procs, size_t nprocs)
|
|||||||
}
|
}
|
||||||
|
|
||||||
/* attempt to add all procs to each ptl */
|
/* attempt to add all procs to each ptl */
|
||||||
ptl_peers = (mca_ptl_base_peer_t **)malloc(nprocs * sizeof(struct mca_ptl_base_peer_t*));
|
ptl_peers = (struct mca_ptl_base_peer_t **)malloc(nprocs * sizeof(struct mca_ptl_base_peer_t*));
|
||||||
for(p_index = 0; p_index < mca_pml_teg.teg_num_ptl_modules; p_index++) {
|
for(p_index = 0; p_index < mca_pml_teg.teg_num_ptl_modules; p_index++) {
|
||||||
mca_ptl_base_module_t* ptl = mca_pml_teg.teg_ptl_modules[p_index];
|
mca_ptl_base_module_t* ptl = mca_pml_teg.teg_ptl_modules[p_index];
|
||||||
|
|
||||||
|
Загрузка…
x
Ссылка в новой задаче
Block a user