1
1

Remove mca_pml_ob1_send_fin_btl function.

This commit was SVN r14784.
Этот коммит содержится в:
Gleb Natapov 2007-05-28 06:51:12 +00:00
родитель f5078db0db
Коммит 06bf5d74e7
2 изменённых файлов: 6 добавлений и 18 удалений

Просмотреть файл

@ -249,7 +249,7 @@ static void mca_pml_ob1_fin_completion(
MCA_PML_OB1_PROGRESS_PENDING(bml_btl); MCA_PML_OB1_PROGRESS_PENDING(bml_btl);
} }
int mca_pml_ob1_send_fin_btl( int mca_pml_ob1_send_fin(
ompi_proc_t* proc, ompi_proc_t* proc,
mca_bml_base_btl_t* bml_btl, mca_bml_base_btl_t* bml_btl,
void *hdr_des, void *hdr_des,
@ -262,6 +262,7 @@ int mca_pml_ob1_send_fin_btl(
MCA_PML_OB1_DES_ALLOC(bml_btl, fin, order, sizeof(mca_pml_ob1_fin_hdr_t)); MCA_PML_OB1_DES_ALLOC(bml_btl, fin, order, sizeof(mca_pml_ob1_fin_hdr_t));
if(NULL == fin) { if(NULL == fin) {
MCA_PML_OB1_ADD_FIN_TO_PENDING(proc, hdr_des, bml_btl, order);
return OMPI_ERR_OUT_OF_RESOURCE; return OMPI_ERR_OUT_OF_RESOURCE;
} }
fin->des_flags |= MCA_BTL_DES_FLAGS_PRIORITY; fin->des_flags |= MCA_BTL_DES_FLAGS_PRIORITY;
@ -295,6 +296,7 @@ int mca_pml_ob1_send_fin_btl(
MCA_BTL_TAG_PML MCA_BTL_TAG_PML
); );
if(OMPI_SUCCESS != rc) { if(OMPI_SUCCESS != rc) {
MCA_PML_OB1_ADD_FIN_TO_PENDING(proc, hdr_des, bml_btl, order);
MCA_BML_BASE_BTL_DES_RETURN(bml_btl, fin); MCA_BML_BASE_BTL_DES_RETURN(bml_btl, fin);
return OMPI_ERR_OUT_OF_RESOURCE; return OMPI_ERR_OUT_OF_RESOURCE;
} }
@ -348,15 +350,12 @@ void mca_pml_ob1_process_pending_packets(mca_bml_base_btl_t* bml_btl)
} }
break; break;
case MCA_PML_OB1_HDR_TYPE_FIN: case MCA_PML_OB1_HDR_TYPE_FIN:
rc = mca_pml_ob1_send_fin_btl(pckt->proc, send_dst, rc = mca_pml_ob1_send_fin(pckt->proc, send_dst,
pckt->hdr.hdr_fin.hdr_des.pval, pckt->hdr.hdr_fin.hdr_des.pval,
pckt->order); pckt->order);
MCA_PML_OB1_PCKT_PENDING_RETURN(pckt); MCA_PML_OB1_PCKT_PENDING_RETURN(pckt);
if(OMPI_ERR_OUT_OF_RESOURCE == rc) { if(OMPI_ERR_OUT_OF_RESOURCE == rc)
MCA_PML_OB1_ADD_FIN_TO_PENDING(pckt->proc,
pckt->hdr.hdr_fin.hdr_des.pval, pckt->bml_btl, pckt->order);
return; return;
}
break; break;
default: default:
opal_output(0, "[%s:%d] wrong header type\n", opal_output(0, "[%s:%d] wrong header type\n",

Просмотреть файл

@ -283,20 +283,9 @@ do { \
} while(0) } while(0)
int mca_pml_ob1_send_fin_btl(ompi_proc_t* proc, mca_bml_base_btl_t* bml_btl, int mca_pml_ob1_send_fin(ompi_proc_t* proc, mca_bml_base_btl_t* bml_btl,
void *hdr_des, uint8_t order); void *hdr_des, uint8_t order);
static inline int mca_pml_ob1_send_fin(ompi_proc_t* proc,
mca_bml_base_btl_t* bml_btl, void *hdr_des, uint8_t order)
{
if(mca_pml_ob1_send_fin_btl(proc, bml_btl, hdr_des, order) == OMPI_SUCCESS)
return OMPI_SUCCESS;
MCA_PML_OB1_ADD_FIN_TO_PENDING(proc, hdr_des, bml_btl, order);
return OMPI_ERR_OUT_OF_RESOURCE;
}
/* This function tries to resend FIN/ACK packets from pckt_pending queue. /* This function tries to resend FIN/ACK packets from pckt_pending queue.
* Packets are added to the queue when sending of FIN or ACK is failed due to * Packets are added to the queue when sending of FIN or ACK is failed due to
* resource unavailability. bml_btl passed to the function doesn't represents * resource unavailability. bml_btl passed to the function doesn't represents