Cleanup a set of warnings reported by Ralph.
Signed-off-by: George Bosilca <bosilca@icl.utk.edu>
Этот коммит содержится в:
родитель
565b516dae
Коммит
50f471e31e
@ -39,7 +39,7 @@
|
|||||||
#include "coll_basic.h"
|
#include "coll_basic.h"
|
||||||
#include "ompi/op/op.h"
|
#include "ompi/op/op.h"
|
||||||
|
|
||||||
#define COMMUTATIVE_LONG_MSG 8 * 1024 * 1024
|
#define COMMUTATIVE_LONG_MSG (8 * 1024 * 1024)
|
||||||
|
|
||||||
/*
|
/*
|
||||||
* reduce_scatter
|
* reduce_scatter
|
||||||
@ -60,7 +60,7 @@
|
|||||||
* usage for the recusive halving is msg_size + 2 * comm_size greater
|
* usage for the recusive halving is msg_size + 2 * comm_size greater
|
||||||
* for the recursive halving, so I've limited where the recursive
|
* for the recursive halving, so I've limited where the recursive
|
||||||
* halving is used to be nice to the app memory wise. There are much
|
* halving is used to be nice to the app memory wise. There are much
|
||||||
* better algorithms for large messages with cummutative operations,
|
* better algorithms for large messages with commutative operations,
|
||||||
* so this should be investigated further.
|
* so this should be investigated further.
|
||||||
*/
|
*/
|
||||||
int
|
int
|
||||||
|
@ -57,7 +57,6 @@ static inline void mca_common_monitoring_coll_check_name(mca_monitoring_coll_dat
|
|||||||
|
|
||||||
static inline void mca_common_monitoring_coll_cache(mca_monitoring_coll_data_t*data)
|
static inline void mca_common_monitoring_coll_cache(mca_monitoring_coll_data_t*data)
|
||||||
{
|
{
|
||||||
int world_rank;
|
|
||||||
if( NULL == data->comm_name && 0 < strlen(data->p_comm->c_name) ) {
|
if( NULL == data->comm_name && 0 < strlen(data->p_comm->c_name) ) {
|
||||||
data->comm_name = strdup(data->p_comm->c_name);
|
data->comm_name = strdup(data->p_comm->c_name);
|
||||||
} else {
|
} else {
|
||||||
@ -70,7 +69,7 @@ static inline void mca_common_monitoring_coll_cache(mca_monitoring_coll_data_t*d
|
|||||||
}
|
}
|
||||||
/* Only list procs if the hashtable is already initialized, ie if the previous call worked */
|
/* Only list procs if the hashtable is already initialized, ie if the previous call worked */
|
||||||
if( (-1 != data->world_rank) && (NULL == data->procs || 0 == strlen(data->procs)) ) {
|
if( (-1 != data->world_rank) && (NULL == data->procs || 0 == strlen(data->procs)) ) {
|
||||||
int i, pos = 0, size, world_size = -1, max_length;
|
int i, pos = 0, size, world_size = -1, max_length, world_rank;
|
||||||
char*tmp_procs;
|
char*tmp_procs;
|
||||||
size = ompi_comm_size(data->p_comm);
|
size = ompi_comm_size(data->p_comm);
|
||||||
world_size = ompi_comm_size((ompi_communicator_t*)&ompi_mpi_comm_world) - 1;
|
world_size = ompi_comm_size((ompi_communicator_t*)&ompi_mpi_comm_world) - 1;
|
||||||
@ -84,7 +83,7 @@ static inline void mca_common_monitoring_coll_cache(mca_monitoring_coll_data_t*d
|
|||||||
tmp_procs[0] = '\0';
|
tmp_procs[0] = '\0';
|
||||||
/* Build procs list */
|
/* Build procs list */
|
||||||
for(i = 0; i < size; ++i) {
|
for(i = 0; i < size; ++i) {
|
||||||
mca_common_monitoring_get_world_rank(i, data->p_comm, &world_rank);
|
if( OPAL_SUCCESS == mca_common_monitoring_get_world_rank(i, data->p_comm, &world_rank) )
|
||||||
pos += sprintf(&tmp_procs[pos], "%d,", world_rank);
|
pos += sprintf(&tmp_procs[pos], "%d,", world_rank);
|
||||||
}
|
}
|
||||||
tmp_procs[pos - 1] = '\0'; /* Remove final coma */
|
tmp_procs[pos - 1] = '\0'; /* Remove final coma */
|
||||||
|
@ -352,6 +352,7 @@ opal_datatype_span( const opal_datatype_t* pData, int64_t count,
|
|||||||
ptrdiff_t extent = (pData->ub - pData->lb);
|
ptrdiff_t extent = (pData->ub - pData->lb);
|
||||||
ptrdiff_t true_extent = (pData->true_ub - pData->true_lb);
|
ptrdiff_t true_extent = (pData->true_ub - pData->true_lb);
|
||||||
if (OPAL_UNLIKELY(0 == pData->size) || (0 == count)) {
|
if (OPAL_UNLIKELY(0 == pData->size) || (0 == count)) {
|
||||||
|
*gap = 0;
|
||||||
return 0;
|
return 0;
|
||||||
}
|
}
|
||||||
*gap = pData->true_lb;
|
*gap = pData->true_lb;
|
||||||
|
@ -872,7 +872,7 @@ static int mca_btl_tcp_component_create_listen(uint16_t af_family)
|
|||||||
int flg = 1;
|
int flg = 1;
|
||||||
if (setsockopt (sd, IPPROTO_IPV6, IPV6_V6ONLY,
|
if (setsockopt (sd, IPPROTO_IPV6, IPV6_V6ONLY,
|
||||||
(char *) &flg, sizeof (flg)) < 0) {
|
(char *) &flg, sizeof (flg)) < 0) {
|
||||||
BTL_ERROR((0, "mca_btl_tcp_create_listen: unable to set IPV6_V6ONLY\n"));
|
BTL_ERROR(("mca_btl_tcp_create_listen: unable to set IPV6_V6ONLY\n"));
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
#endif /* IPV6_V6ONLY */
|
#endif /* IPV6_V6ONLY */
|
||||||
@ -1393,10 +1393,10 @@ static void mca_btl_tcp_component_recv_handler(int sd, short flags, void* user)
|
|||||||
*/
|
*/
|
||||||
if (sizeof(hs_msg) != retval) {
|
if (sizeof(hs_msg) != retval) {
|
||||||
opal_output_verbose(20, opal_btl_base_framework.framework_output,
|
opal_output_verbose(20, opal_btl_base_framework.framework_output,
|
||||||
"server did not receive entire connect ACK "
|
"process did not receive full connect ACK "
|
||||||
"Local_host:%s PID:%d Role:%s String_received:%s Test_fail:%s",
|
"Local_host:%s PID:%d String_received:%s Test_fail:%s",
|
||||||
opal_process_info.nodename,
|
opal_process_info.nodename,
|
||||||
getpid(), "server",
|
getpid(),
|
||||||
(retval > 0) ? hs_msg.magic_id : "<nothing>",
|
(retval > 0) ? hs_msg.magic_id : "<nothing>",
|
||||||
"handshake message length");
|
"handshake message length");
|
||||||
|
|
||||||
@ -1406,10 +1406,10 @@ static void mca_btl_tcp_component_recv_handler(int sd, short flags, void* user)
|
|||||||
}
|
}
|
||||||
if (0 != strncmp(hs_msg.magic_id, mca_btl_tcp_magic_id_string, len)) {
|
if (0 != strncmp(hs_msg.magic_id, mca_btl_tcp_magic_id_string, len)) {
|
||||||
opal_output_verbose(20, opal_btl_base_framework.framework_output,
|
opal_output_verbose(20, opal_btl_base_framework.framework_output,
|
||||||
"server did not receive right magic string. "
|
"process did not receive right magic string. "
|
||||||
"Local_host:%s PID:%d Role:%s String_received:%s Test_fail:%s",
|
"Local_host:%s PID:%d String_received:%s Test_fail:%s",
|
||||||
opal_process_info.nodename,
|
opal_process_info.nodename,
|
||||||
getpid(), "server", hs_msg.magic_id,
|
getpid(), hs_msg.magic_id,
|
||||||
"string value");
|
"string value");
|
||||||
/* The other side probably isn't OMPI, so just hang up */
|
/* The other side probably isn't OMPI, so just hang up */
|
||||||
CLOSE_THE_SOCKET(sd);
|
CLOSE_THE_SOCKET(sd);
|
||||||
|
Загрузка…
x
Ссылка в новой задаче
Block a user