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

check retry counts on NAK retrans as well as timeouts

Просмотр исходного кода 
This commit was SVN r9342.
Этот коммит содержится в:
Galen Shipman 2006-03-20 22:11:23 +00:00
родитель 7ce7baff15
Коммит fc42320ea6
2 изменённых файлов: 7 добавлений и 3 удалений
Показать статистику Скачать Patch файл Скачать Diff файл Показать все файлы Свернуть все файлы

6
ompi/mca/pml/dr/pml_dr_sendreq.h
Просмотреть файл

@ -351,6 +351,12 @@ do { \
#define MCA_PML_DR_SEND_REQUEST_RETRY(sendreq, vfrag) \
do { \
mca_bml_base_btl_t* bml_btl = sendreq->descriptor->des_context; \
vfrag->vf_retry_cnt ++; \
if(vfrag->vf_retry_cnt > mca_pml_dr.timer_wdog_max_count) { \
opal_output(0, "%s:%d,%s retry count exceeded! FATAL", __FILE__, __LINE__, __func__); \
orte_errmgr.abort(); \
} \
\
opal_output(0, "%s:%d:%s, retransmitting\n", __FILE__, __LINE__, __func__); \
assert(sendreq->descriptor->des_src != NULL); \
vfrag->vf_idx = 1; \

4
ompi/mca/pml/dr/pml_dr_vfrag.c
Просмотреть файл

@ -69,9 +69,8 @@ void mca_pml_dr_vfrag_wdog_timeout(int fd, short event, void* data)
mca_pml_dr_vfrag_t* vfrag = (mca_pml_dr_vfrag_t*) data;
mca_pml_dr_send_request_t* sendreq = vfrag->vf_send.pval;
OPAL_THREAD_LOCK(&ompi_request_lock);
vfrag->vf_retry_cnt++;
if(vfrag->vf_retry_cnt > mca_pml_dr.timer_wdog_max_count) {
opal_output(0, "wdog retry count exceeded! %s:%d FATAL", __FILE__, __LINE__);
opal_output(0, "%s:%d:%s, wdog retry count exceeded! FATAL", __FILE__, __LINE__, __func__);
orte_errmgr.abort();
}
vfrag->vf_idx = 1;
@ -90,7 +89,6 @@ void mca_pml_dr_vfrag_ack_timeout(int fd, short event, void* data) {
mca_pml_dr_vfrag_t* vfrag = (mca_pml_dr_vfrag_t*) data;
mca_pml_dr_send_request_t* sendreq = vfrag->vf_send.pval;
OPAL_THREAD_LOCK(&ompi_request_lock);
vfrag->vf_retry_cnt++;
if(vfrag->vf_retry_cnt > mca_pml_dr.timer_ack_max_count) {
opal_output(0, "%s:%d: maximum ack retry count exceeded: FATAL", __FILE__, __LINE__);
orte_errmgr.abort();