Nothing relevant. Indentation, typos, change PTL to BTL.
This commit was SVN r14727.
Этот коммит содержится в:
родитель
50b26ebb6a
Коммит
b2e805db61
@ -245,13 +245,13 @@ CLEANUP:
|
|||||||
* SM component initialization
|
* SM component initialization
|
||||||
*/
|
*/
|
||||||
mca_btl_base_module_t** mca_btl_sm_component_init(
|
mca_btl_base_module_t** mca_btl_sm_component_init(
|
||||||
int *num_ptls,
|
int *num_btls,
|
||||||
bool enable_progress_threads,
|
bool enable_progress_threads,
|
||||||
bool enable_mpi_threads)
|
bool enable_mpi_threads)
|
||||||
{
|
{
|
||||||
mca_btl_base_module_t **ptls = NULL;
|
mca_btl_base_module_t **btls = NULL;
|
||||||
|
|
||||||
*num_ptls = 0;
|
*num_btls = 0;
|
||||||
|
|
||||||
/* lookup/create shared memory pool only when used */
|
/* lookup/create shared memory pool only when used */
|
||||||
mca_btl_sm_component.sm_mpool = NULL;
|
mca_btl_sm_component.sm_mpool = NULL;
|
||||||
@ -278,25 +278,25 @@ mca_btl_base_module_t** mca_btl_sm_component_init(
|
|||||||
opal_thread_start(&mca_btl_sm_component.sm_fifo_thread);
|
opal_thread_start(&mca_btl_sm_component.sm_fifo_thread);
|
||||||
#endif
|
#endif
|
||||||
|
|
||||||
/* allocate the Shared Memory PTL */
|
/* allocate the Shared Memory BTL */
|
||||||
*num_ptls = 1;
|
*num_btls = 1;
|
||||||
ptls = (mca_btl_base_module_t**)malloc((*num_ptls)*sizeof(mca_btl_base_module_t*));
|
btls = (mca_btl_base_module_t**)malloc((*num_btls)*sizeof(mca_btl_base_module_t*));
|
||||||
if (NULL == ptls) {
|
if (NULL == btls) {
|
||||||
return NULL;
|
return NULL;
|
||||||
}
|
}
|
||||||
|
|
||||||
/* get pointer to the ptls */
|
/* get pointer to the btls */
|
||||||
ptls[0] = (mca_btl_base_module_t *)(&(mca_btl_sm));
|
btls[0] = (mca_btl_base_module_t *)(&(mca_btl_sm));
|
||||||
|
|
||||||
/* initialize some PTL data */
|
/* initialize some PTL data */
|
||||||
/* start with no SM procs */
|
/* start with no SM procs */
|
||||||
mca_btl_sm_component.num_smp_procs = 0;
|
mca_btl_sm_component.num_smp_procs = 0;
|
||||||
mca_btl_sm_component.my_smp_rank = -1; /* not defined */
|
mca_btl_sm_component.my_smp_rank = -1; /* not defined */
|
||||||
|
|
||||||
/* set flag indicating ptl not inited */
|
/* set flag indicating btl not inited */
|
||||||
mca_btl_sm.btl_inited=false;
|
mca_btl_sm.btl_inited=false;
|
||||||
|
|
||||||
return ptls;
|
return btls;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
@ -154,8 +154,8 @@ bool mca_btl_tcp_frag_recv(mca_btl_tcp_frag_t* frag, int sd)
|
|||||||
if( 0 != btl_endpoint->endpoint_cache_length ) {
|
if( 0 != btl_endpoint->endpoint_cache_length ) {
|
||||||
size_t length;
|
size_t length;
|
||||||
/* It's strange at the first look but cnt have to be set to the full amount of data
|
/* It's strange at the first look but cnt have to be set to the full amount of data
|
||||||
* available. After going to advance_iov_position we will use cnt to detect if there
|
* available. After going to advance_iov_position we will use cnt to detect if there
|
||||||
* is still some data pending.
|
* is still some data pending.
|
||||||
*/
|
*/
|
||||||
cnt = length = btl_endpoint->endpoint_cache_length;
|
cnt = length = btl_endpoint->endpoint_cache_length;
|
||||||
for( i = 0; i < frag->iov_cnt; i++ ) {
|
for( i = 0; i < frag->iov_cnt; i++ ) {
|
||||||
@ -171,9 +171,9 @@ bool mca_btl_tcp_frag_recv(mca_btl_tcp_frag_t* frag, int sd)
|
|||||||
btl_endpoint->endpoint_cache_length -= length;
|
btl_endpoint->endpoint_cache_length -= length;
|
||||||
length = btl_endpoint->endpoint_cache_length;
|
length = btl_endpoint->endpoint_cache_length;
|
||||||
if( 0 == length ) {
|
if( 0 == length ) {
|
||||||
btl_endpoint->endpoint_cache_pos = btl_endpoint->endpoint_cache;
|
btl_endpoint->endpoint_cache_pos = btl_endpoint->endpoint_cache;
|
||||||
break;
|
break;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
goto advance_iov_position;
|
goto advance_iov_position;
|
||||||
}
|
}
|
||||||
|
Загрузка…
x
Ссылка в новой задаче
Block a user