ports/openmpi
ports/openmpi
1
1
Форкнуть 0
Код Релизы Активность

print "flush error" only once.

Просмотр исходного кода 
This commit was SVN r10672.
Этот коммит содержится в:
Gleb Natapov 2006-07-06 08:03:01 +00:00
родитель 9b0807e547
Коммит e05ec69dc4
1 изменённых файлов: 7 добавлений и 3 удалений
Показать статистику Скачать Patch файл Скачать Diff файл Показать все файлы Свернуть все файлы

4
ompi/mca/btl/openib/btl_openib_component.c
Просмотреть файл

@ -949,6 +949,7 @@ int mca_btl_openib_component_progress()
} }
else if(1 == ne) { else if(1 == ne) {
if(wc.status != IBV_WC_SUCCESS) { if(wc.status != IBV_WC_SUCCESS) {
static int flush_err_printed = 0;
ompi_proc_t* remote_proc = NULL; ompi_proc_t* remote_proc = NULL;
frag = (mca_btl_openib_frag_t*) (unsigned long) wc.wr_id; frag = (mca_btl_openib_frag_t*) (unsigned long) wc.wr_id;
if(frag) { if(frag) {
@ -959,6 +960,7 @@ int mca_btl_openib_component_progress()
remote_proc = endpoint->endpoint_proc->proc_ompi; remote_proc = endpoint->endpoint_proc->proc_ompi;
} }
} }
if(wc.status != IBV_WC_WR_FLUSH_ERR || !flush_err_printed++)
BTL_PEER_ERROR(remote_proc, ("error polling HP CQ with status %s status number %d for wr_id %llu opcode %d", BTL_PEER_ERROR(remote_proc, ("error polling HP CQ with status %s status number %d for wr_id %llu opcode %d",
mca_btl_openib_component_status_to_string(wc.status), mca_btl_openib_component_status_to_string(wc.status),
wc.status, wc.wr_id, wc.opcode)); wc.status, wc.wr_id, wc.opcode));
@ -1051,6 +1053,7 @@ int mca_btl_openib_component_progress()
} }
else if(1 == ne) { else if(1 == ne) {
if(wc.status != IBV_WC_SUCCESS) { if(wc.status != IBV_WC_SUCCESS) {
static int flush_err_printed = 0;
ompi_proc_t* remote_proc = NULL; ompi_proc_t* remote_proc = NULL;
frag = (mca_btl_openib_frag_t*) (unsigned long) wc.wr_id; frag = (mca_btl_openib_frag_t*) (unsigned long) wc.wr_id;
if(frag) { if(frag) {
@ -1061,6 +1064,7 @@ int mca_btl_openib_component_progress()
remote_proc = endpoint->endpoint_proc->proc_ompi; remote_proc = endpoint->endpoint_proc->proc_ompi;
} }
} }
if(wc.status != IBV_WC_WR_FLUSH_ERR || !flush_err_printed++)
BTL_PEER_ERROR(remote_proc, ("error polling LP CQ with status %s status number %d for wr_id %llu opcode %d", BTL_PEER_ERROR(remote_proc, ("error polling LP CQ with status %s status number %d for wr_id %llu opcode %d",
mca_btl_openib_component_status_to_string(wc.status), mca_btl_openib_component_status_to_string(wc.status),
wc.status, wc.wr_id, wc.opcode)); wc.status, wc.wr_id, wc.opcode));